perp-cli

Instructions

Implementation Reference

• src/commands/risk.ts:16-64 (handler)

  The function `runHealthCheck` handles the execution of health checks across multiple exchanges (pacifica, hyperliquid, lighter) and prints the status or returns it as JSON.

  export async function runHealthCheck(isJson: () => boolean): Promise<void> {
        const [pacPing, hlPing, ltPing] = await Promise.all([
          pingPacifica(),
          pingHyperliquid(),
          pingLighter(),
        ]);
        const toPingResult = (name: string, p: { ok: boolean; latencyMs: number; status: number }): HealthResult => ({
          exchange: name,
          status: p.ok ? "ok" : "down",
          latency_ms: p.latencyMs,
          error: p.ok ? undefined : `HTTP ${p.status}`,
        });
        const checks: HealthResult[] = [
          toPingResult("pacifica", pacPing),
          toPingResult("hyperliquid", hlPing),
          toPingResult("lighter", ltPing),
        ];
  
        const allOk = checks.every(c => c.status === "ok");
  
        if (isJson()) {
          return printJson(jsonOk({ healthy: allOk, exchanges: checks }));
        }
  
        console.log(chalk.cyan.bold("\n  Exchange Health Check\n"));
        const rows = checks.map(c => {
          const statusIcon = c.status === "ok"
            ? chalk.green("OK")
            : c.status === "degraded"
            ? chalk.yellow("DEGRADED")
            : chalk.red("DOWN");
          const latency = c.latency_ms < 500
            ? chalk.green(`${c.latency_ms}ms`)
            : c.latency_ms < 2000
            ? chalk.yellow(`${c.latency_ms}ms`)
            : chalk.red(`${c.latency_ms}ms`);
          return [
            chalk.white.bold(c.exchange),
            statusIcon,
            latency,
            c.error ? chalk.red(c.error) : chalk.gray("-"),
          ];
        });
  
        console.log(makeTable(["Exchange", "Status", "Latency", "Error"], rows));
  
        const overall = allOk ? chalk.green("ALL HEALTHY") : chalk.red("ISSUES DETECTED");
        console.log(`\n  Overall: ${overall}\n`);
  }