Function onCommand

packages/bot/src/create-bot.ts:516–561

(cmd: IncomingCommand)

        }
      },
      async onCommand(cmd: IncomingCommand) {
        // Dedup guard: drop duplicate deliveries of the same event within the TTL window.
        if (cmd.eventId) {
          const dupKey = `evt:${adapter.platform}:${cmd.eventId}`;
          try {
            if (await backend.dedup.seen(dupKey, cfg.dedupTtl ?? 300_000))
              return;
          } catch (err) {
            console.warn(
              `[bot] dedup check failed for ${adapter.platform}; processing without dedup`,
              err,
            );
          }
        }

        const command = commandHandlers.get(normalizeCommandName(cmd.command));
        if (!command) return; // unregistered command → skip
        const thread = makeThread(
          adapter,
          cmd.replyTarget,
          cmd.conversationKey,
        );
        // Resolve typed options from any structured args the surface supplied
        // (e.g. Discord); text-only surfaces (Slack) leave `options` empty and
        // the handler reads `text`.
        let options: Record<string, unknown> = {};
        if (command.options && cmd.rawOptions) {
          const parsed = await parseToolArgs(command.options, cmd.rawOptions);
          if (parsed.ok) options = parsed.value;
        }
        const ctx: CommandContext<Record<string, unknown>> = {
          thread,
          command: normalizeCommandName(cmd.command),
          text: cmd.text,
          options,
          user: cmd.user,
          platform: cmd.platform,
        };
        const openModal = makeOpenModal(
          adapter,
          cmd.replyTarget,
          cmd.triggerId,
        );
        if (openModal) ctx.openModal = openModal;
        await command.handler(ctx);
      },
      async onThreadStarted(evt: IncomingThreadStart) {
        // The adapter has already applied its static defaults (greeting /
        // prompts) before emitting this, so handlers layer on top and never