Function createFetchHandler

services/cloud-agent-next/wrapper/src/server.ts:1089–1193

(
  config: ServerConfig,
  deps: ServerDependencies,
  triggerDrainAndClose: () => void
)

    let result: WrapperSessionReadyResponse;
    try {
      result = await pending.promise;
    } finally {
      if (inFlight === pending) inFlight = undefined;
    }
    if (result.status === 'error') {
      const status = result.error.code === 'INVALID_REQUEST' ? 400 : 503;
      return jsonResponse(
        {
          error: result.error.code,
          message: result.error.message,
          ...(result.error.subtype ? { subtype: result.error.subtype } : {}),
          ...(result.error.detail ? { detail: result.error.detail } : {}),
          ...(result.error.retryable !== undefined ? { retryable: result.error.retryable } : {}),
          ...(result.error.wrapperRunId ? { wrapperRunId: result.error.wrapperRunId } : {}),
        },
        status
      );
    }

    return jsonResponse(result);
  };
}

export function createRuntimeEnvironmentHandler(deps: ServerDependencies) {
  return async (req: Request): Promise<Response> => {
    if (!deps.updateRuntimeEnvironment) {
      return errorResponse('NOT_READY', 'Runtime environment updater is not configured', 503);
    }

    let body: unknown;
    try {
      body = await req.json();
    } catch {
      return errorResponse('INVALID_REQUEST', 'Invalid JSON body', 400);
    }
    if (
      typeof body !== 'object' ||
      body === null ||
      !('env' in body) ||
      typeof body.env !== 'object' ||
      body.env === null ||
      Array.isArray(body.env)
    ) {
      return errorResponse('INVALID_REQUEST', 'Invalid runtime environment request', 400);
    }

    const env: Record<string, string> = {};
    for (const [name, value] of Object.entries(body.env)) {
      if (typeof value !== 'string') {
        return errorResponse('INVALID_REQUEST', 'Invalid runtime environment request', 400);
      }
      env[name] = value;
    }

    try {
      await deps.updateRuntimeEnvironment(env);
    } catch {