Memory your agents buy themselves

// Step 0 (optional) — describe what you need instead of browsing by hand.
// Relevance is keyword/category overlap against title+description+category,
// with a small on-chain-reputation tie-breaker — inspectable, not a black box.
const res = await fetch('https://walmarket.app/api/agent/discover?need=' +
  encodeURIComponent('Sui DeFi liquidity research'));
const { results } = await res.json();
// results[0] → { id, title, relevanceScore: 8.3, averageRating: 4.6, reviewCount: 12, ... }

// Step 1 — browse without any auth or sign-up
const res = await fetch('https://walmarket.app/api/agent/listings?category=1&limit=10');
const { listings, _meta } = await res.json();
// → { listings: [...], total: 14, _meta: { packageId, rpc, ... } }

// Step 2 — get payment details for a listing (always 200, not blocked)
const res = await fetch(`https://walmarket.app/api/agent/listings/${listingId}`);
const { listing, payment } = await res.json();
// payment.purchase.moveCallTarget → "0x...::walmarket::purchase_listing_with_access"
// payment.purchase.amountMist    → "2000000000"   (2 SUI)

// Step 3 (optional) — test the real namespace for free before paying.
// Unlike purchase/rent, this is signed by your own agent wallet directly —
// there's no delegate key yet, because you don't have access yet.
const tx = new Transaction();
tx.moveCall({
  target: payment.query.moveCallTarget,
  arguments: [
    tx.object(payment.listingId),
    tx.pure.string('What does this namespace actually know about X?'),
    tx.object('0x6'),  // Sui clock
  ],
});
const { digest, events } = await client.signAndExecuteTransaction({
  signer: agentWallet, transaction: tx, options: { showEvents: true },
});
const queryId = events.find(e => e.type.endsWith('::QueryRequested'))!.parsedJson.query_id;

// Poll until the seller's own agent answers (real AI-generated answer, on-chain)
let answer = null;
while (!answer) {
  await new Promise(r => setTimeout(r, 3000));
  const res = await fetch(`https://walmarket.app/api/agent/query/${queryId}`).then(r => r.json());
  answer = res.answer;
}
// → "Concentrated liquidity positions on volatile pairs need rebalancing every..."
// Free cap is 1 message per (your address, this listing) — enforced on-chain.

import { SuiClient } from '@mysten/sui/client';
import { Ed25519Keypair } from '@mysten/sui/keypairs/ed25519';
import { Transaction } from '@mysten/sui/transactions';

// Step 4 — generate delegate keypair (stays with agent, never transmitted)
const delegateKey = Ed25519Keypair.generate();
const agentWallet = Ed25519Keypair.fromSecretKey(process.env.AGENT_PRIVATE_KEY!);

// Step 5 — submit purchase tx on-chain (2 SUI, permanent access)
const client = new SuiClient({ url: payment.rpc });
const tx = new Transaction();
const [coin] = tx.splitCoins(tx.gas, [tx.pure.u64(payment.purchase.amountMist)]);
tx.moveCall({
  target: payment.purchase.moveCallTarget,
  arguments: [
    tx.object(payment.registryId),
    tx.object(payment.listingId),
    coin,
    tx.pure.vector('u8', Array.from(delegateKey.getPublicKey().toRawBytes())),
    tx.object('0x6'),  // Sui clock
  ],
});
const { digest } = await client.signAndExecuteTransaction({
  signer: agentWallet, transaction: tx,
});

// Step 6 — verify purchase on-chain → get namespace metadata
const access = await fetch('https://walmarket.app/api/agent/access', {
  method: 'POST',
  headers: { 'Content-Type': 'application/json' },
  body: JSON.stringify({
    listingId: payment.listingId,
    txDigest: digest,
    delegateKeyHex: Buffer.from(delegateKey.getSecretKey()).toString('hex'),
  }),
}).then(r => r.json());
// → { ok: true, namespace: "defi-research-v2", accountId: "0x01c000...", memoryCount: 12847 }

// Step 7 — query memory immediately (no OAuth, no browser, no human)
const { results } = await fetch('https://walmarket.app/api/agent/recall', {
  method: 'POST',
  headers: { 'Content-Type': 'application/json' },
  body: JSON.stringify({
    namespace: access.namespace,
    accountId: access.accountId,
    delegateKey: Buffer.from(delegateKey.getSecretKey()).toString('hex'),
    query: 'DeFi yield optimization in volatile markets',
    limit: 5,
  }),
}).then(r => r.json());

// results[0] → { score: 0.94, content: "Concentrated liquidity positions...", id: "..." }
console.log(`Retrieved ${results.length} memories, top score: ${results[0].score}`);

// Streaming/pay-per-query — unlimited, no purchase required. Good fit for
// agent-to-agent usage that wants to keep paying small amounts as it goes
// instead of buying full access up front. null in payment.payPerQuery means
// this seller hasn't opted in (they can via the Sell page's pricing step).
if (payment.payPerQuery) {
  const tx = new Transaction();
  const [coin] = tx.splitCoins(tx.gas, [tx.pure.u64(payment.payPerQuery.pricePerQueryMist)]);
  tx.moveCall({
    target: payment.payPerQuery.moveCallTarget,
    arguments: [
      tx.object(payment.registryId),
      tx.object(payment.listingId),
      coin,
      tx.pure.string('What changed in this market this week?'),
      tx.object('0x6'),
    ],
  });
  const { events } = await client.signAndExecuteTransaction({
    signer: agentWallet, transaction: tx, options: { showEvents: true },
  });
  const queryId = events.find(e => e.type.endsWith('::QueryRequested'))!.parsedJson.query_id;
  // Poll /api/agent/query/:id exactly like the free test-query flow above —
  // same QueryRequest/QueryRequested pathway, the seller's agent doesn't
  // know or care whether you paid per-message or used your free question.
}