Function runValidatorCycle

src/gep/validator/index.js:198–240

* Run one validator cycle. Intended to be called from the main evolve loop. * Returns a summary object (useful for logging/tests). * * @param {{ skipStake?: boolean }} [opts]

(opts)

 * @param {{ skipStake?: boolean }} [opts]
 */
async function runValidatorCycle(opts) {
  const options = opts || {};
  if (!isValidatorEnabled()) {
    return { skipped: 'disabled' };
  }
  // Lazy preflight gate: refuse to talk to the Hub if the local toolchain
  // cannot even run a trivial `node <script>` in the sandbox. Without this,
  // every validation task posted to this node returns duration_ms=1 /
  // commands_passed=0 and the Hub auto-quarantines the node for chronic
  // env_fail.
  const pf = await _ensurePreflight();
  if (!pf.ok) {
    return { skipped: 'preflight_failed', reason: pf.reason || 'unknown' };
  }
  if (!options.skipStake) {
    try {
      await ensureValidatorStake({});
    } catch (err) {
      // non-fatal -- stake may already exist or will retry later
    }
  }

  const tasks = await fetchValidationTasks();
  if (!tasks || tasks.length === 0) {
    return { tasks: 0, processed: 0 };
  }

  const slice = tasks.slice(0, MAX_TASKS_PER_CYCLE);
  const outcomes = [];
  for (const t of slice) {
    try {
      const outcome = await validateOneTask(t);
      outcomes.push({ task_id: t.task_id, ...outcome });
    } catch (err) {
      outcomes.push({
        task_id: t.task_id,
        status: 'error',
        reason: err && err.message ? err.message : String(err),
      });
    }
  }
  return { tasks: tasks.length, processed: outcomes.length, outcomes };
}

// --- Background daemon ---
//