Function createCommandHandler

services/cloud-agent-next/wrapper/src/server.ts:514–625

(config: ServerConfig, deps: ServerDependencies)

      } catch (error) {
        const msg = error instanceof Error ? error.message : String(error);
        logToFile(`job/prompt: failed to materialize attachments: ${msg}`);
        acknowledgeDelivery('failed');
        return errorResponse('SEND_ERROR', `Failed to materialize attachments: ${msg}`, 500);
      }
    }

    const attributionError = await applyCommitAttribution(
      config.workspacePath,
      prompt.finalization?.commitCoAuthor,
      deps.configureCommitCoAuthor ?? configureCommitCoAuthorHook
    );
    if (attributionError) {
      acknowledgeDelivery('failed');
      return attributionError;
    }

    if (!state.isConnected) {
      try {
        await openConnection();
        logToFile('job/prompt: subscription confirmed, connection opened');
      } catch (error) {
        const msg = error instanceof Error ? error.message : String(error);
        logToFile(`job/prompt: failed to open connection: ${msg}`);
        acknowledgeDelivery('failed');
        return errorResponse('CONNECTION_ERROR', `Failed to open connection: ${msg}`, 500);
      }
    }

    const addedMessage = state.acceptMessage(messageId, {
      autoCommit: prompt.finalization?.autoCommit ?? false,
      condenseOnComplete: prompt.finalization?.condenseOnComplete ?? false,
      model: prompt.agent?.model?.modelID,
      upstreamBranch: binding?.upstreamBranch,
      ...(prompt.finalization?.commitCoAuthor
        ? { commitCoAuthor: prompt.finalization.commitCoAuthor }
        : {}),
    });

    try {
      const snapshotInitialization = snapshotInitializationForPlatform(session.platform);
      await kiloClient.sendPromptAsync({
        sessionId: session.kiloSessionId,
        messageId,
        parts: prompt.message.parts,
        prompt: prompt.message.prompt,
        variant: prompt.agent?.variant,
        agent: prompt.agent?.mode,
        model: prompt.agent?.model,
        system: prompt.agent?.system,
        tools: prompt.agent?.tools,
        ...(snapshotInitialization ? { snapshotInitialization } : {}),
      });
      logToFile(`job/prompt: sent messageId=${messageId}`);
      acknowledgeDelivery('async-prompt');
    } catch (error) {
      if (addedMessage) state.removeMessage(messageId);
      acknowledgeDelivery('failed');
      const msg = error instanceof Error ? error.message : String(error);