Function submitReplyText

apps/web/components/codex-sessions-shell.tsx:984–1044

(rawText: string)

  }

  async function submitReplyText(rawText: string) {
    if (sendingReply) {
      return;
    }
    const text = rawText.trim();
    if (!text) {
      return;
    }

    const timestamp = new Date().toISOString();
    const userMessageId = createLocalMessageId('local-user');
    const assistantDraftId = createLocalMessageId('local-assistant');
    const optimisticUserMessage: WebCodexThreadMessage = {
      id: userMessageId,
      role: 'user',
      source: 'local',
      text,
      timestamp,
    };

    setThreadMessages((current) => [
      ...current.filter((message) => message.source !== 'stream'),
      optimisticUserMessage,
      buildStreamAssistantMessage(assistantDraftId, timestamp, '', '', 'queued'),
    ]);
    setComposerText('');
    setSendingReply(true);
    setReplyError(null);
    requestAnimationFrame(() => {
      composerInputRef.current?.focus();
    });

    try {
      const response = await fetch(`/api/codex-threads/${encodeURIComponent(threadId)}/reply`, {
        method: 'POST',
        headers: { 'Content-Type': 'application/json' },
        body: JSON.stringify({ text }),
      });
      const payload = await response.json().catch(() => null) as ThreadReplyResponse | null;
      if (!response.ok || !payload?.ok) {
        const errorMessage = (payload?.error && String(payload.error).trim()) || '发送失败';
        replaceStreamFailureMessage(assistantDraftId, timestamp, errorMessage);
        setReplyError(errorMessage);
        setSendingReply(false);
        return;
      }
      const runId = typeof payload.runId === 'string' ? payload.runId.trim() : '';
      if (!runId) {
        replaceStreamFailureMessage(assistantDraftId, timestamp, '回复启动失败。');
        setReplyError('回复启动失败。');
        setSendingReply(false);
        return;
      }
      startReplyStream(runId, assistantDraftId, timestamp);
    } catch (error) {
      const errorMessage = error instanceof Error ? error.message : '发送失败';
      replaceStreamFailureMessage(assistantDraftId, timestamp, errorMessage);
      setReplyError(errorMessage);