src/cli.ts

#!/usr/bin/env node

import process from 'node:process';
import { restoreAuthSession, startKeepAlivePing, startAutoBackup } from './hf_sync.js';
import { createTemplateAgentHttpServer } from './a2a-http.js';
import { buildAgentCard, resolveTemplateAgentConfig } from './metadata.js';
import { startMcpServer } from './mcp-server.js';
import { executeBugBountyAgentAction, type BugBountyAgentAction } from './runtime.js';
import { startAutonomousIdleLoop } from './idle-monetization.js';

function triggerFleetSelfHealing(_err: unknown, _ctx: { command: string; args: string[] }) {
  process.stderr.write(`[SELF-HEAL] Error in ${_ctx.command}: ${_err instanceof Error ? _err.message : String(_err)}\n`);
}

async function main(): Promise<void> {
  const command = process.argv[2] || 'help';
  try {
    switch (command) {
    case 'serve':
    case 'serve-a2a':
      await serveA2A();
      return;
    case 'serve-mcp':
      await startMcpServer();
      return;
    case 'print-card':
      printJson(buildAgentCard(resolveTemplateAgentConfig().publicBaseUrl));
      return;
    case 'run-action':
      await runAction();
      return;
    default:
      printUsage();
    }
  } catch (err: any) {
    triggerFleetSelfHealing(err, { command, args: process.argv });
    process.stderr.write(`${err.message}\n`);
    process.exitCode = 1;
  }
}

async function serveA2A() {
  const config = resolveTemplateAgentConfig();
  const handle = createTemplateAgentHttpServer();
  await handle.start();
  
  // 💸 Start Autonomous Monetization & Hacking Loop
  startAutonomousIdleLoop();
  printJson({ ok: true, command: 'serve-a2a', host: config.host, port: config.port, baseUrl: config.publicBaseUrl });
}

async function runAction() {
  const raw = process.argv[3]?.trim() || (await readStdin()).trim();
  if (!raw) throw new Error('missing_action_json');
  printJson(await executeBugBountyAgentAction(JSON.parse(raw) as BugBountyAgentAction));
}

function printUsage() {
  process.stderr.write(
    ['Usage:', '  sin-bugbounty serve-a2a', '  sin-bugbounty serve-mcp', '  sin-bugbounty print-card', `  sin-bugbounty run-action '{"action":"agent.help"}'`].join('\n') + '\n',
  );
}

function printJson(payload: unknown) {
  process.stdout.write(`${JSON.stringify(payload, null, 2)}\n`);
}

async function readStdin() {
  const chunks: Buffer[] = [];
  for await (const chunk of process.stdin) chunks.push(Buffer.isBuffer(chunk) ? chunk : Buffer.from(chunk));
  return Buffer.concat(chunks).toString('utf8');
}

main().catch((error) => {
  process.stderr.write(`${error instanceof Error ? error.message : String(error)}\n`);
  process.exitCode = 1;
});