[Fix] Discord request_user_input pauses again after user answers

apps/api/src/handlers/discord/callback-actions.ts

@@ -26,6 +26,10 @@ import {
   handleDiscordRoutingCallback,
   parseDiscordRouteCallbackData,
 } from './routing-confirmation.js';
+import {
+  hasPendingDiscordRequestUserInputCallback,
+  tryHandleDiscordRequestUserInputCallback,
+} from './request-user-input.js';
 import type { DiscordChannelContext } from './task-launch.js';
 import {
   discordMetadataForChannel,
@@ -370,6 +374,22 @@ export async function handleDiscordComponentInteraction(input: {
   channel: DiscordChannelContext;
 }): Promise<'handled' | 'unsupported'> {
   const customId = input.interaction.data?.custom_id;
+  if (hasPendingDiscordRequestUserInputCallback(customId)) {
+    const sender = input.interaction.member?.user ?? input.interaction.user;
+    const mappedUserId = sender?.id
+      ? await findDiscordMappedUserId(sender.id)
+      : null;
+    await tryHandleDiscordRequestUserInputCallback({
+      provider: input.provider,
+      applicationId: input.applicationId,
+      channel: input.channel,
+      interaction: input.interaction,
+      interactionDeferred: input.interactionDeferred,
+      customId,
+      userId: mappedUserId,
+    });
+    return 'handled';
+  }
   const cancelRunId = parseCancelCallbackData(customId);
   if (cancelRunId) {
     await handleCancelCallback({ ...input, runId: cancelRunId });

apps/api/src/handlers/discord/index.ts

@@ -37,6 +37,7 @@ import {
   findCommunicationTaskRunBySourceEvent,
 } from '../tasks/communication-task-run-lookup.js';
 import { resumeCommunicationTaskFromSnapshot } from '../tasks/communication-snapshot-resume.js';
+import { tryHandleDiscordRequestUserInputMessage } from './request-user-input.js';
 import {
   attachOutOfBandContextToCommunicationMessage,
   releaseCommunicationOutOfBandClaim,
@@ -519,6 +520,28 @@ async function processDiscordGatewayEvent(event: DiscordGatewayEvent) {
       runId: activeRun.id,
       senderUserId,
     });
+
+    if (message && queuedMessage) {
+      const handledRequestUserInput =
+        await tryHandleDiscordRequestUserInputMessage({
+          provider: resolved.provider,
+          applicationId: resolved.applicationId,
+          channel,
+          activeRun: { id: activeRun.id },
+          userId: senderUserId,
+          text: queuedMessage.text,
+          replyToMessageId: message.id,
+        });
+      if (handledRequestUserInput) {
+        return {
+          ok: true,
+          queued: true,
+          runId: activeRun.id,
+          requestUserInput: true,
+        };
+      }
+    }
+
     // Mirror Slack: rebuild undelivered thread context + latest bot reply into
     // the follow-up prompt so agents keep full Discord conversation context.
     let continuationClaim: {