SEC intelligence your AI agent can buy on demand.

import { x402Client } from "@x402/core/client";
import { x402HTTPClient } from "@x402/core/http";
import { registerExactEvmScheme } from "@x402/evm/exact/client";
import { PAYMENT_IDENTIFIER, appendPaymentIdentifierToExtensions,
  generatePaymentId } from "@x402/extensions/payment-identifier";
import { privateKeyToAccount } from "viem/accounts";

const url = "https://nodavyr.com/v1/agent/AAPL";
const approvedRecipient = process.env.APPROVED_RECIPIENT?.toLowerCase();
const privateKey = process.env.BUYER_PRIVATE_KEY;

const unpaid = await fetch(url, { redirect: "error" });
if (unpaid.status !== 402) throw new Error(`STOP: expected 402, got ${unpaid.status}`);

const core = new x402Client();
const http = new x402HTTPClient(core);
const required = http.getPaymentRequiredResponse(name => unpaid.headers.get(name));
const options = required?.accepts;
if (required?.x402Version !== 2 || !Array.isArray(options) || options.length !== 1) {
  throw new Error("STOP: unexpected x402 requirements");
}
const payment = options[0];
if (payment.scheme !== "exact" || payment.network !== "eip155:8453" ||
    payment.asset?.toLowerCase() !== "0x833589fcd6edb6e08f4c7c32d4f71b54bda02913" ||
    String(payment.amount) !== "100000" || payment.payTo?.toLowerCase() !== approvedRecipient) {
  throw new Error("STOP: payment policy mismatch");
}
if (required?.extensions?.[PAYMENT_IDENTIFIER]?.info?.required !== true) {
  throw new Error("STOP: payment identifier is not required");
}
if (!privateKey) throw new Error("STOP: BUYER_PRIVATE_KEY is required");
const signer = privateKeyToAccount(privateKey);
const paymentIdentifier = generatePaymentId();
// Retain this identifier securely before payment if your recovery flow requires it.
core.registerExtension({
  key: PAYMENT_IDENTIFIER,
  async enrichPaymentPayload(payload) {
    payload.extensions = appendPaymentIdentifierToExtensions(
      payload.extensions ?? {}, paymentIdentifier
    );
    return payload;
  },
});
registerExactEvmScheme(core, { signer, networks: ["eip155:8453"] });
const payload = await http.createPaymentPayload(required);
const headers = http.encodePaymentSignatureHeader(payload);

// Send at most one payment-bearing request. Never blindly retry an ambiguous result.
const paid = await fetch(url, { headers, redirect: "error" });
if (paid.status !== 200) throw new Error(`STOP: paid request unresolved (${paid.status})`);
console.log(await paid.json());