Method start

src/proxy/server/http.js:111–177

()

  }

  async start() {
    // Capture the prior token before clearIfStale wipes it. Daemon restarts
    // routinely fall into the stale branch (the previous PID is gone), and
    // rotating `proxy.token` on every restart invalidates ANTHROPIC_AUTH_TOKEN
    // already exported into long-lived shells (the .bashrc auto-source only
    // runs once per terminal).
    const priorProxy = readSettings().proxy || {};
    const previous = isValidReusableProxyToken(priorProxy.token) ? priorProxy.token.trim() : null;
    // settings.json is operator-edited; previous_tokens may contain non-strings
    // (numbers, booleans, objects) that would later crash Buffer.from(cand, 'utf8')
    // in _handleRequest as ERR_INVALID_ARG_TYPE — an unhandled rejection that
    // takes the daemon down under default --unhandled-rejections=throw.
    const priorPreviousTokens = Array.isArray(priorProxy.previous_tokens)
      ? priorProxy.previous_tokens
        .map((t) => (typeof t === 'string' ? t.trim() : ''))
        .filter((t) => isValidReusableProxyToken(t))
      : [];
    clearIfStale();
    const clientSettingsOpts = this.clientSettings || {};
    const clientToken = this.clientSettings
      ? readReusableClientProxyToken({ ...clientSettingsOpts, port: this.basePort })
      : null;
    this.token = previous || clientToken || crypto.randomBytes(32).toString('hex');
    this._priorPreviousTokens = priorPreviousTokens;
    this.server = http.createServer((req, res) => this._handleRequest(req, res));

    let port = this.basePort;
    for (let i = 0; i < MAX_PORT_ATTEMPTS; i++) {
      const ok = await tryListen(this.server, port);
      if (ok) {
        this.actualPort = port;
        const url = `http://127.0.0.1:${port}`;
        const proxyBlock = {
          url,
          pid: process.pid,
          started_at: new Date().toISOString(),
          token: this.token,
        };
        if (this._priorPreviousTokens && this._priorPreviousTokens.length) {
          proxyBlock.previous_tokens = this._priorPreviousTokens;
        }
        writeSettings({ proxy: proxyBlock });
        if (this.clientSettings) {
          try {
            const syncResult = syncClaudeProxySettings({
              ...clientSettingsOpts,
              url,
              port: this.basePort,
              token: this.token,
              runtimeEnv: process.env,
            });
            if (syncResult.synced && syncResult.changed) {
              this.logger.log(`[proxy] Synced Claude client settings at ${syncResult.file}`);
            } else if (syncResult.reason === 'invalid_settings_json') {
              this.logger.warn?.(`[proxy] Skipped Claude client settings sync because ${syncResult.file} is not valid JSON`);
            }
          } catch (err) {
            this.logger.warn?.('[proxy] Claude client settings sync failed: ' + (err && err.message ? err.message : err));