Function ensureValidatorStake

src/gep/validator/stakeBootstrap.js:206–324

* Attempt to stake credits so this node becomes eligible for validation tasks. * Safe to call repeatedly; internally throttled by the retry state machine. * * @param {{ amount?: number, force?: boolean }} [opts]

(opts)

 * @param {{ amount?: number, force?: boolean }} [opts]
 */
async function ensureValidatorStake(opts) {
  const options = opts || {};
  const now = Date.now();

  _loadStateFromDisk();

  if (_state.disabledUntilRestart && !options.force) {
    return { ok: false, skipped: 'disabled_until_restart' };
  }

  if (!options.force && _state.nextAttemptAt > now) {
    return { ok: true, skipped: 'backoff', nextAttemptAt: _state.nextAttemptAt };
  }

  const nodeId = getNodeId();
  if (!nodeId) {
    _state.nextAttemptAt = now + pickDelay('transient');
    _persistState();
    return { ok: false, error: 'no_node_id' };
  }

  const hubUrl = resolveHubUrl();
  const url = hubUrl.replace(/\/+$/, '') + '/a2a/validator/stake';
  const amount = Math.max(100, Math.round(Number(options.amount) || DEFAULT_STAKE_AMOUNT));

  const controller = new AbortController();
  const timer = setTimeout(() => controller.abort(), STAKE_TIMEOUT_MS);

  const body = {
    sender_id: nodeId,
    node_id: nodeId,
    payload: { stake_amount: amount },
    message_id: 'msg_' + Date.now().toString(36) + '_' + crypto.randomBytes(3).toString('hex'),
    timestamp: new Date().toISOString(),
  };

  logStakeEvent('attempt', { node_id: nodeId, amount, hub: hubUrl });

  let res;
  let text = '';
  try {
    res = await hubFetch(url, {
      method: 'POST',
      headers: buildStakeHubHeaders(),
      body: JSON.stringify(body),
      signal: controller.signal,
    });
    clearTimeout(timer);
    text = await res.text();
  } catch (err) {
    clearTimeout(timer);
    _state.transientFailures += 1;
    _state.nextAttemptAt = now + pickDelay('transient');
    _persistState();
    const msg = err && err.message ? err.message : String(err);
    logStakeEvent('failed_network', {
      node_id: nodeId,
      error: msg,