Function handleMessage

scripts/codex-app-server-capture.js:184–234

(msg)

}

function handleMessage(msg) {
  serverMessages.push(msg);
  const approvalResponse = buildAppServerApprovalResponse(msg, { decision: approvalDecision });
  if (approvalResponse) {
    approvalResponses.push({
      requestId: msg.id,
      method: msg.method,
      itemId: msg.params?.itemId || null,
      decision: approvalResponse.result?.decision || approvalResponse.result,
    });
    send(approvalResponse);
    return;
  }
  if (msg.id !== undefined && msg.method) {
    unhandledServerRequests.push({
      id: msg.id,
      method: msg.method,
    });
  }
  if (msg.id === 1 && msg.result) {
    send({ method: 'initialized', params: {} });
    if (startThread) {
      send({ method: 'thread/start', id: 2, params: { cwd: projectRoot } });
    } else {
      scheduleFinish('initialize-complete');
    }
  }

  if (msg.id === 2 && msg.result?.thread?.id) {
    threadId = msg.result.thread.id;
    if (turnText) {
      const params = {
        threadId,
        input: [{ type: 'text', text: turnText }],
      };
      if (turnApprovalPolicy) params.approvalPolicy = turnApprovalPolicy;
      if (turnSandboxPolicy) params.sandboxPolicy = turnSandboxPolicy;
      send({
        method: 'turn/start',
        id: 3,
        params,
      });
    } else {
      scheduleFinish('thread-started');
    }
  }

  if (turnText && msg.method === 'turn/completed') {
    scheduleFinish('turn-completed');
  }
}

proc.stdout.on('data', (chunk) => {
  stdoutBuffer += chunk.toString();