Function handleLocalOpAuthLoginInner

packages/server/src/api-extension.ts:8835–8923

(
    _req: IncomingMessage,
    res: ServerResponse,
    body: LocalOpAuthHostRequest,
  )

    },
  );
  async function handleLocalOpAuthLoginInner(
    _req: IncomingMessage,
    res: ServerResponse,
    body: LocalOpAuthHostRequest,
  ): Promise<void> {
    const host = body.host ?? 'github.com';

    if (!localOpGuard.tryAcquire(LOCAL_OP_AUTH_LOGIN_KEY)) {
      const stale = authLoginInFlight;
      if (!stale) {
        console.error(
          JSON.stringify({
            event: 'ok-local-op:auth-login-slot-no-controller',
            channel: 'auth',
            transport: 'http',
          }),
        );
        errorResponse(
          res,
          429,
          'urn:ok:error:concurrent-operation',
          'An auth login operation is already in progress.',
          { handler: HANDLE_LOCAL_OP_AUTH_LOGIN, extraHeaders: { 'Retry-After': '5' } },
        );
        return;
      }
      stale.cancel();
      authLoginInFlight = null;
      console.warn(
        JSON.stringify({
          event: 'ok-local-op:idempotent-start-replaced-stale-slot',
          channel: 'auth',
          transport: 'http',
        }),
      );
    }

    res.writeHead(200, {
      'Content-Type': 'application/x-ndjson',
      'Transfer-Encoding': 'chunked',
      'X-Content-Type-Options': 'nosniff',
      'Cache-Control': 'no-cache',
    });

    const writeStreamError = createStreamingErrorWriter(res, HANDLE_LOCAL_OP_AUTH_LOGIN);

    const flow = runDeviceFlowSubprocess({
      cliArgs: localOpCliArgs,
      host,
      timeoutMs: LOCAL_OP_TIMEOUT_MS,
      onEvent: (event: AuthEvent) => {
        if (event.type === 'error') {
          writeStreamError(500, 'urn:ok:error:auth-failed', 'Auth subprocess reported an error.', {
            cause: event.message ? new Error(event.message) : undefined,
          });
          return;
        }
        resumeSyncOnAuthEvent(event, getSyncEngine);