diff --git a/src/auto-reply/reply/agent-runner-payloads.ts b/src/auto-reply/reply/agent-runner-payloads.ts index b611344b93f..ac688407b0b 100644 --- a/src/auto-reply/reply/agent-runner-payloads.ts +++ b/src/auto-reply/reply/agent-runner-payloads.ts @@ -359,11 +359,9 @@ export async function buildReplyPayloads(params: { }) : contentSuppressedPayloads; const replyPayloads: ReplyPayload[] = []; - if (!messagingToolPayloadDedupe.suppressReplies) { - for (const payload of filteredPayloads) { - if (isRenderablePayload(payload)) { - replyPayloads.push(payload); - } + for (const payload of filteredPayloads) { + if (isRenderablePayload(payload)) { + replyPayloads.push(payload); } } diff --git a/src/auto-reply/reply/queue/drain.ts b/src/auto-reply/reply/queue/drain.ts index 2bc1dc72f65..9c15e8d2601 100644 --- a/src/auto-reply/reply/queue/drain.ts +++ b/src/auto-reply/reply/queue/drain.ts @@ -51,9 +51,15 @@ type OriginRoutingMetadata = Pick< function resolveOriginRoutingMetadata(items: FollowupRun[]): OriginRoutingMetadata { const metadata: OriginRoutingMetadata = {}; for (const item of items) { - metadata.originatingChannel ??= item.originatingChannel; - metadata.originatingTo ??= item.originatingTo; - metadata.originatingAccountId ??= item.originatingAccountId; + if (!metadata.originatingChannel && item.originatingChannel) { + metadata.originatingChannel = item.originatingChannel; + } + if (!metadata.originatingTo && item.originatingTo) { + metadata.originatingTo = item.originatingTo; + } + if (!metadata.originatingAccountId && item.originatingAccountId) { + metadata.originatingAccountId = item.originatingAccountId; + } // Support both number (Telegram topic) and string (Slack thread_ts) thread IDs. if ( metadata.originatingThreadId == null &&