bazaar-trigger.mjs

#!/usr/bin/env node

import { McpServer } from "@modelcontextprotocol/sdk/server/mcp.js";
import axios from "axios";
import { x402Client, wrapAxiosWithPayment } from "@x402/axios";
import { registerExactEvmScheme } from "@x402/evm/exact/client";
import { privateKeyToAccount } from "viem/accounts";
import { createWalletClient, createPublicClient, http } from "viem";
import { base } from "viem/chains";
import { config } from "dotenv";

config();

const evmPrivateKey = process.env.EVM_PRIVATE_KEY;
const gatewayURL = process.env.SPRAAY_GATEWAY_URL || "https://gateway.spraay.app";

if (!evmPrivateKey) {
  console.error("❌ Set EVM_PRIVATE_KEY environment variable");
  process.exit(1);
}

async function createPaymentClient() {
  const client = new x402Client();
  const account = privateKeyToAccount(evmPrivateKey);
  const walletClient = createWalletClient({
    account,
    chain: base,
    transport: http(),
  });
  const publicClient = createPublicClient({
    chain: base,
    transport: http(),
  });
  const signer = {
    ...walletClient,
    readContract: publicClient.readContract,
  };
  registerExactEvmScheme(client, { signer });
  return wrapAxiosWithPayment(axios.create({ baseURL: gatewayURL }), client);
}

async function main() {
  const api = await createPaymentClient();

  const endpoints = [
    { name: "models",         method: "GET",  path: "/api/v1/models" },
    { name: "tokens",         method: "GET",  path: "/api/v1/swap/tokens" },
    { name: "prices",         method: "GET",  path: "/api/v1/prices" },
    { name: "balances",       method: "GET",  path: "/api/v1/balances?address=0xd8dA6BF26964aF9D7eEd9e03E53415D37aA96045" },
    { name: "resolve",        method: "GET",  path: "/api/v1/resolve?name=vitalik.eth" },
    { name: "batch_estimate", method: "POST", path: "/api/v1/batch/estimate", data: { recipientCount: 1 } },
    { name: "swap_quote",     method: "GET",  path: "/api/v1/swap/quote?tokenIn=0x833589fCD6eDb6E08f4c7C32D4f71b54bdA02913&tokenOut=0x4200000000000000000000000000000000000006&amountIn=1000000" },
    { name: "chat",           method: "POST", path: "/api/v1/chat/completions", data: { model: "openai/gpt-4o-mini", messages: [{ role: "user", content: "say ok" }] } },
    { name: "batch_execute",  method: "POST", path: "/api/v1/batch/execute",  data: { token: "0x833589fCD6eDb6E08f4c7C32D4f71b54bdA02913", recipients: ["0x0000000000000000000000000000000000000001"], amounts: ["1000"], sender: "0xAd62f03C7514bb8c51f1eA70C2b75C37404695c8" } },
  ];

  console.log(`🚀 Triggering Bazaar indexing for ${endpoints.length} endpoints...\n`);

  for (const ep of endpoints) {
    try {
      let res;
      if (ep.method === "GET") {
        res = await api.get(ep.path);
      } else {
        res = await api.post(ep.path, ep.data || {});
      }
      console.log(`✅ ${ep.name.padEnd(16)} — ${res.status} — paid`);
    } catch (err) {
      const status = err.response?.status || "ERR";
      const msg = err.response?.data?.error || err.response?.data?.message || err.message;
      console.log(`⚠️  ${ep.name.padEnd(16)} — ${status} — ${typeof msg === 'string' ? msg.slice(0, 100) : JSON.stringify(msg).slice(0, 100)}`);
    }
  }

  console.log("\n🏁 Done!");
}

main().catch(console.error);