index.ts

#!/usr/bin/env bun
import { cac } from 'cac';
import pkg from './package.json';
import { checkAction } from './commands/check.ts';
import { mintAction } from './commands/mint.ts';
import { requestAction } from './commands/request.ts';
import { listPaidApisAction } from './commands/list-paid-apis.ts';
import { getApiDetailAction } from './commands/get-api-detail.ts';
import { invokePaidApiAction } from './commands/invoke-paid-api.ts';
import { tasksAction } from './commands/tasks.ts';
import { EXIT_CODES } from './utils.ts';

const cli = cac('paynode-402');

// Global Options
cli.option('--json', 'Output results in JSON format');
cli.option('--network <name>', 'Network to use: mainnet or testnet/sepolia');
cli.option('--rpc <url>', 'Custom RPC URL');
cli.option('--rpc-timeout <ms>', 'Custom RPC timeout in milliseconds (default: 15000)');
cli.option('--confirm-mainnet', 'Required flag for mainnet operations (real USDC)');
cli.option('--dry-run', 'Show request details without sending');
cli.option('--market-url <url>', 'Marketplace base URL');

// Command: check
cli
  .command('check', 'Check wallet balance (ETH and USDC) on Base L2')
  .action((options) => {
    return checkAction(options);
  });

// Command: mint
cli
  .command('mint', 'Mint USDC on Base Sepolia')
  .option('--amount <amount>', 'Amount to mint (default: 1000)')
  .action((options) => {
    return mintAction(options);
  });

// Command: request
cli
  .command('request <url> [...params]', 'Access protected API and handle x402 payments. Params: key=value pairs for query/body.')
  .option('-X, --method <method>', 'HTTP method (GET, POST, etc.)')
  .option('-d, --data <data>', 'Raw request body data')
  .option('-H, --header [header]', 'HTTP header in "Key: Value" format (can be used multiple times)', { default: [] })
  .option('--background', 'Execute in background, return immediately (AI-friendly)')
  .option('--output <path>', 'Output file path for result (used with --background)')
  .option('--max-age <seconds>', 'Auto-delete task files older than N seconds (default: 3600)')
  .option('--task-dir <path>', 'Task directory for background results (default: <TMPDIR>/paynode-tasks)')
  .option('--task-id <id>', 'Internal: task ID for background worker')
  .action((url, params, options) => {
    return requestAction(url, params, options);
  });

// Command: list-paid-apis
cli
  .command('list-paid-apis', 'List paid APIs from the marketplace catalog')
  .option('--limit <n>', 'Maximum number of APIs to return')
  .option('--tag [tag]', 'Catalog tag filter (can be used multiple times)', { default: [] })
  .option('--seller <seller>', 'Seller identifier filter')
  .action((options) => {
    return listPaidApisAction(options);
  });

// Command: get-api-detail
cli
  .command('get-api-detail <apiId>', 'Get full detail for one paid API')
  .action((apiId, options) => {
    return getApiDetailAction(apiId, options);
  });

// Command: invoke-paid-api
cli
  .command('invoke-paid-api <apiId>', 'Invoke one paid API through the marketplace flow')
  .option('-X, --method <method>', 'HTTP method override')
  .option('-d, --data <data>', 'Invocation payload as raw JSON string')
  .option('-H, --header [header]', 'HTTP header in "Key: Value" format (can be used multiple times)', { default: [] })
  .option('--background', 'Execute in background, return immediately (AI-friendly)')
  .option('--output <path>', 'Output file path for result (used with --background)')
  .option('--max-age <seconds>', 'Auto-delete task files older than N seconds (default: 3600)')
  .option('--task-dir <path>', 'Task directory for background results (default: <TMPDIR>/paynode-tasks)')
  .option('--task-id <id>', 'Internal: task ID for background worker')
  .action((apiId, options) => {
    return invokePaidApiAction(apiId, options);
  });

// Command: tasks
cli
  .command('tasks [subcommand]', 'Manage background tasks (subcommands: list, clean)')
  .option('--clean', 'Clean all task files immediately')
  .action((subcommand, options) => {
    return tasksAction(subcommand, options);
  });


cli.help();
cli.version(pkg.version);

try {
  const result = cli.parse();
  if (result instanceof Promise) {
    result.catch((err) => {
      console.error(`❌ Global Error: ${err.message}`);
      process.exit(EXIT_CODES.GENERIC_ERROR);
    });
  }
} catch (error: any) {
  if (error.name === 'CACError') {
    console.error(`❌ Command Error: ${error.message}`);
    process.exit(EXIT_CODES.INVALID_ARGS);
  } else {
    console.error(`❌ Parse Error: ${error.message}`);
    process.exit(EXIT_CODES.GENERIC_ERROR);
  }
}