Method constructor

src/proxy/lifecycle/manager.js:448–513

({ hubUrl, store, logger, getTaskMeta } = {})

class LifecycleManager {
  constructor({ hubUrl, store, logger, getTaskMeta } = {}) {
    this.hubUrl = (hubUrl || process.env.A2A_HUB_URL || '').replace(/\/+$/, '');
    this.store = store;
    this.logger = logger || console;
    this.getTaskMeta = getTaskMeta || null;
    this._heartbeatTimer = null;
    this._running = false;
    this._startedAt = null;
    this._lastHeartbeatTickAt = 0;
    this._consecutiveFailures = 0;
    this._reauthInProgress = false;
    this._helloRateLimitUntil = 0;
    this._reauthBackoffUntil = 0;
    this._consecutiveReauthFailures = 0;
    this._driftInterval = null;
    this._lastDriftCheckAt = 0;
    this._hubUnreachableFailures = 0;
    this._hubUnreachableUntil = 0;
    this._envSecretSuppressionMarker = normalizeNodeSecretEnvSuppression(this.store && this.store.getState
      ? this.store.getState('node_secret_env_suppressed')
      : null);
    this._envSuppressionClearedForSecret = null;
    this._suppressEnvSecret = Boolean(this._envSecretSuppressionMarker && getEnvNodeSecret());

    // H4 fix: persist the legacy node_id file as soon as the in-memory
    // node_id is known, NOT only after a successful hello(). The original
    // code persisted only in hello() (see ~L390-398) — but proxy-mode boot
    // can fire `reportForceUpdateOutcome` BEFORE hello() returns:
    //
    //   - First-tick heartbeat hits 426 → executeForceUpdate() → exit(78)
    //     all happens BEFORE the hello() response is processed.
    //   - enrich.js force_update path can fire during the same window.
    //
    // `_shortNodeIdForStatePath` in a2aProtocol.js then picks the
    // state-file suffix from `_cachedNodeId` (never set in proxy mode —
    // only getNodeId() sets it, and proxy never calls getNodeId()) or the
    // legacy ~/.evomap/node_id file. With both empty, it falls through
    // to 'anon', and the outcome lands at `force_update_last.anon.json`.
    // Next boot's hello() writes the real id, the heartbeat reads
    // `force_update_last.<8hex>.json`, the anon file is orphaned and the
    // outcome is silently lost.
    //
    // Persisting at construction closes the window. _persistLegacyNodeId
    // early-returns on invalid input (NODE_ID_RE gate, same regex as the
    // hello() path uses) so a malformed/empty store value is a no-op,
    // and it is idempotent on matching content so the cost is one
    // existsSync + one readFileSync per construction. We keep the
    // existing post-hello call as a safety net in case hello() mints or
    // mutates the id.
    try {
      const earlyNodeId = this.store && this.store.getState
        ? this.store.getState('node_id')
        : null;
      if (earlyNodeId && NODE_ID_RE.test(earlyNodeId)) {
        _persistLegacyNodeId(earlyNodeId);
      }
    } catch (e) {
      // Best-effort: persistence failure must never break construction.