import { hasReplyPayloadContent } from "../../interactive/payload.js";

import { normalizeOptionalString } from "../../shared/string-coerce.js";

import { stripHeartbeatToken } from "../heartbeat.js";

import { copyReplyPayloadMetadata } from "../reply-payload.js";

import {

HEARTBEAT_TOKEN,

isSilentReplyPayloadText,

return null;

}

let enrichedPayload: ReplyPayload = { ...payload, text };

let enrichedPayload: ReplyPayload = copyReplyPayloadMetadata(payload, { ...payload, text });

if (applyChannelTransforms && opts.transformReplyPayload) {

const transformedPayload = opts.transformReplyPayload(enrichedPayload);

if (transformedPayload === null) {

return null;

}

enrichedPayload = transformedPayload ?? enrichedPayload;

enrichedPayload = transformedPayload

? copyReplyPayloadMetadata(enrichedPayload, transformedPayload)

: enrichedPayload;

text = enrichedPayload.text;

}

text = `${effectivePrefix} ${text}`;

}

enrichedPayload = { ...enrichedPayload, text };

enrichedPayload = copyReplyPayloadMetadata(enrichedPayload, { ...enrichedPayload, text });

return enrichedPayload;

}

import { afterEach, describe, expect, it, vi } from "vitest";

import { getReplyPayloadMetadata, setReplyPayloadMetadata } from "../reply-payload.js";

import { SILENT_REPLY_TOKEN } from "../tokens.js";

import { parseAudioTag } from "./audio-tags.js";

import { createBlockReplyCoalescer } from "./block-reply-coalescer.js";

// Keep channelData-only payloads so channel-specific replies survive normalization.

describe("normalizeReplyPayload", () => {

it("preserves reply payload metadata across normalization clones", () => {

const payload = setReplyPayloadMetadata(

{

text: " Visible reply ",

},

{

sourceReplyTranscriptMirror: {

sessionKey: "main",

text: " Visible reply ",

idempotencyKey: "run-1:source-reply",

},

},

);

const normalized = normalizeReplyPayload(payload);

const reply = expectNormalizedReply(normalized);

expect(reply).not.toBe(payload);

expect(getReplyPayloadMetadata(reply)?.sourceReplyTranscriptMirror).toEqual({

sessionKey: "main",

text: " Visible reply ",

idempotencyKey: "run-1:source-reply",

});

});

it("keeps channelData-only replies", () => {

const payload = {

channelData: {