Repository Public
1// V5 through the real API and a real signer process boundary (own database, own fake JSON-RPC node, no outside network):2// agents on several networks, the tradable-symbols endpoint, vault indices, the gas reserve gate, mandates per network,3// registration of universe-generic strategies (the laboratory is called for real when its environment is installed).4import { createHash } from 'node:crypto';5import { existsSync, mkdtempSync } from 'node:fs';6import { createServer, type Server } from 'node:http';7import { tmpdir } from 'node:os';8import { join } from 'node:path';9import { createTestDb } from './test-db.ts';10import { afterAll, beforeAll, describe, expect, it } from 'vitest';11import { cashLegs, DEFAULT_POLICY, getNetwork, hasMarketData, MANDATE_NETWORKS, MARKET_LISTINGS, NETWORKS, tradableSymbols } from '@spw/core';12import { TestPasskey } from '../../../tests/helpers/passkey.ts';13import { deriveKeys } from '../../isolated-signer/src/keys.ts';14import { createSignerServer } from '../../isolated-signer/src/server.ts';15import { Signer } from '../../isolated-signer/src/signer.ts';16import { Store } from '../../isolated-signer/src/store.ts';1718const ORIGIN = 'https://wallet.test', RP = 'wallet.test', SECRET = 'k'.repeat(48), DB_LABEL = 'agent_networks';19const keys = deriveKeys('abandon abandon abandon abandon abandon abandon abandon abandon abandon abandon abandon about');20const owner = new TestPasskey(RP, ORIGIN);21const LAB = existsSync(join(import.meta.dirname, '../../../research/.venv')); // `cd research && uv sync` (or any `uv run`) creates it22let signerSrv: Server, node: Server, app: any, sql: any, adapters: any, cookie = '';23const gasPrice: Record<string, bigint> = {}; // wei per gas the fake node reports, per network24const native: Record<string, bigint> = {}; // native balance of every vault, per network25const rpcBackup: Record<string, string[]> = {};26const RISK = { maxExposurePct: 80, maxLossPct: 5, maxOrderUsd: 20, maxDailyUsd: 100, maxOrdersPerDay: 12, mandateDays: 30, slippageBps: 100 };2728async function api(method: string, path: string, body?: unknown) {29 const headers: Record<string, string> = cookie ? { cookie } : {};30 if (method !== 'GET') Object.assign(headers, { origin: ORIGIN, 'x-spw-csrf': '1', 'content-type': 'application/json' });31 const r = await app.inject({ method, url: `/api/v1${path}`, headers, payload: method === 'GET' ? undefined : JSON.stringify(body ?? {}) });32 return { status: r.statusCode, json: (() => { try { return r.json(); } catch { return null; } })(), setCookie: r.headers['set-cookie'] as string | undefined };33}34const create = (o: Record<string, unknown>) => api('POST', '/agents', { name: 'Agent', interval: '1h', capitalUsdc: '100', risk: RISK, ...o });3536beforeAll(async () => {37 const DB = (await createTestDb(DB_LABEL)).name;38 const dir = mkdtempSync(join(tmpdir(), 'spw-v5-agents-'));39 const store = new Store(join(dir, 'state.json'), join(dir, 'policy.json'));40 store.state.setupTokenHash = createHash('sha256').update('the-setup-token').digest('hex');41 signerSrv = createSignerServer(new Signer(keys, store, { rpId: RP, origin: ORIGIN }), SECRET).listen(0, '127.0.0.1');42 await new Promise((r) => signerSrv.once('listening', r));43 // a JSON-RPC node that only knows the fee history; the network id is in the path44 node = createServer((req, res) => { let b = ''; req.on('data', (c) => { b += c; }); req.on('end', () => { const j = JSON.parse(b), id = req.url!.slice(1), p = gasPrice[id];45 const result = j.method === 'eth_feeHistory' && p !== undefined ? { baseFeePerGas: Array(21).fill(`0x${p.toString(16)}`), reward: Array(20).fill(['0x0']) } : undefined;46 res.setHeader('content-type', 'application/json'); res.end(JSON.stringify(result ? { jsonrpc: '2.0', id: j.id, result } : { jsonrpc: '2.0', id: j.id, error: { code: -32601, message: 'not available in this test' } })); }); }).listen(0, '127.0.0.1');47 await new Promise((r) => node.once('listening', r));48 const nodeUrl = `http://127.0.0.1:${(node.address() as { port: number }).port}`;49 for (const id of MANDATE_NETWORKS) { rpcBackup[id] = NETWORKS[id]!.rpc; NETWORKS[id]!.rpc = [`${nodeUrl}/${id}`]; gasPrice[id] = id === 'ethereum' ? 3_000_000_000n : 10_000_000n; } // 0.01 gwei on the cheap networks, 3 gwei on Ethereum (the reserve is cached one minute)50 Object.assign(process.env, { SPW_ORIGIN: ORIGIN, SPW_RP_ID: RP, DATABASE_URL: `postgres:///${DB}`, SPW_SIGNER_SECRET: SECRET,51 SPW_SIGNER_URL: `http://127.0.0.1:${(signerSrv.address() as { port: number }).port}`, SPW_BROADCAST: 'off', SPW_WORKERS: 'off' });52 const db = await import('../src/db.ts');53 sql = db.sql;54 await sql.unsafe('drop schema public cascade; create schema public;');55 await db.migrate();56 await db.setSetting('prices', false); // no outside price feed: prices come from stored candles57 adapters = (await import('../src/chains/index.ts')).adapters;58 for (const id of MANDATE_NETWORKS) adapters[id].balances = async () => ({ native: native[id] ?? 0n });59 app = await (await import('../src/server.ts')).buildServer({ swapProviders: [] });60 const o = (await api('POST', '/auth/setup/options')).json;61 const s = await api('POST', '/auth/setup/verify', { challengeId: o.challengeId, response: owner.register(o.options.challenge), setupToken: 'the-setup-token' });62 expect(s.status).toBe(200);63 cookie = String(s.setCookie).split(';')[0]!;64 // one fresh hourly bar per symbol, on two sources65 const ts = new Date(Math.floor(Date.now() / 3_600_000) * 3_600_000 - 3_600_000);66 for (const [symbol, close] of Object.entries({ ETH: 2000, LINK: 10, UNI: 5, AAVE: 100, AVAX: 20, BTC: 60_000, POL: 0.5, HYPE: 25, BNB: 600 })) for (const source of ['coinbase', 'kraken'])67 await sql`insert into candles (source, symbol, interval, ts, open, high, low, close, volume) values (${source}, ${symbol}, '1h', ${ts}, ${close}, ${close}, ${close}, ${close}, 1)`;68}, 60_000);69afterAll(async () => { for (const [id, rpc] of Object.entries(rpcBackup)) NETWORKS[id]!.rpc = rpc; await app?.close(); signerSrv?.close(); node?.close(); await sql?.end(); });7071describe('what an agent can trade, per network', () => {72 it('GET /agents/networks lists the eight networks with cash legs, symbols, representations, data availability and gas', async () => {73 await sql`insert into market_quality (symbol, interval, checked_at, last_ts, fresh, gaps, status) values ('ETH', '1h', now(), now(), true, 0, 'ok'), ('LINK', '1h', now(), now(), false, 3, 'gap')`;74 const r = await api('GET', '/agents/networks');75 expect(r.status).toBe(200);76 expect(r.json.networks.map((n: any) => n.id)).toEqual([...MANDATE_NETWORKS]); // every execution-enabled network, in that order77 expect(r.json.networks.map((n: any) => n.id)).toEqual(expect.arrayContaining(['base', 'ethereum', 'arbitrum', 'polygon', 'optimism', 'bsc', 'avalanche', 'hyperevm']));78 expect(r.json).toMatchObject({ maxSymbols: 12, maxLiveSymbols: 11 });79 const by = Object.fromEntries(r.json.networks.map((n: any) => [n.id, n]));80 expect(by.base).toMatchObject({ name: 'Base', native: 'ETH', enabled: true, defaultCash: 'USDC', feeWarning: false });81 expect(by.base.symbols.map((s: any) => s.symbol)).toEqual(expect.arrayContaining(['ETH', 'LINK', 'AAVE']));82 const eth = by.ethereum.symbols.find((s: any) => s.symbol === 'ETH'), btc = by.ethereum.symbols.find((s: any) => s.symbol === 'BTC');83 expect(eth.representations.map((x: any) => [x.assetSymbol, x.kind])).toEqual([['ETH', 'native'], ['WETH', 'wrapped']]);84 expect(eth).toMatchObject({ defaultAsset: 'native', live: true });85 expect(btc.representations[0]).toMatchObject({ assetSymbol: 'WBTC', name: 'Wrapped Bitcoin', kind: 'wrapped', issuer: expect.stringMatching(/BitGo/) });86 expect(by.ethereum.feeWarning).toBe(true); // always flagged87 expect(by.base.symbols.find((s: any) => s.symbol === 'ETH').data['1h']).toMatchObject({ status: 'ok', fresh: true });88 expect(by.base.symbols.find((s: any) => s.symbol === 'LINK').data['1h']).toMatchObject({ status: 'gap', fresh: false });89 expect(by.base.symbols.find((s: any) => s.symbol === 'AAVE').data).toEqual({ '1h': null, '1d': null }); // no data yet90 expect(by.base.symbols.find((s: any) => s.symbol === 'EUR')).toMatchObject({ live: false, sources: ['bitstamp', 'kraken'] });91 // network by network, exactly what the registry says: the cash legs (by registry id and name), the symbols and their default asset92 for (const id of MANDATE_NETWORKS) { const n = getNetwork(id), legs = cashLegs(n), t = tradableSymbols(n);93 expect(by[id].cash, id).toEqual(legs.map((c) => ({ symbol: c.symbol, asset: c.id, name: c.name })));94 expect(by[id], id).toMatchObject({ enabled: legs.length > 0 && t.length > 0, defaultCash: legs.some((c) => c.symbol === 'USDC') ? 'USDC' : null, native: n.native.symbol });95 expect(by[id].symbols.map((x: any) => [x.symbol, x.defaultAsset, x.live]), id).toEqual(t.map((x) => [x.symbol, x.defaultId, x.live]));96 for (const x of by[id].symbols) for (const rep of x.representations) if (rep.kind === 'wrapped' || rep.kind === 'pegged') expect(rep.issuer, `${id}:${rep.assetSymbol}`).toBeTruthy(); }97 // BNB Smart Chain is enabled since registry v5: Binance-Peg USDC (default) and USDT, named as such98 expect(by.bsc).toMatchObject({ enabled: true, defaultCash: 'USDC', cash: [{ symbol: 'USDC', name: 'Binance-Peg USD Coin' }, { symbol: 'USDT', name: 'Binance-Peg BSC-USD (USDT)' }] });99 expect(by.bsc.symbols.find((x: any) => x.symbol === 'BTC').representations.map((x: any) => x.assetSymbol)).toEqual(['WBTC', 'BTCB']);100 expect(by.bsc.symbols.find((x: any) => x.symbol === 'ETH').representations).toEqual([expect.objectContaining({ assetSymbol: 'ETH', name: 'Binance-Peg Ethereum', kind: 'token' })]); // a token there, not the native coin101 expect(by.ethereum.symbols.find((x: any) => x.symbol === 'BTC').representations.map((x: any) => x.assetSymbol)).toEqual(expect.arrayContaining(['WBTC', 'cbBTC', 'tBTC']));102 for (const id of MANDATE_NETWORKS) for (const x of by[id].symbols) for (const rep of x.representations) expect(['USDC.e', 'USDT0', 'BTC.b', 'WETH.e', 'LINK.e'], `${id}:${rep.assetSymbol}`).not.toContain(rep.assetSymbol); // bridged variants: not offered103 expect(by.avalanche.cash.map((c: any) => c.symbol)).toEqual(['USDC', 'USDT']);104 // gas: 450 000 gas at 0.01 gwei per order; the reserve is the floor of two orders at the policy ceiling105 expect(by.arbitrum.gas).toMatchObject({ perOrder: '0.0000045', gasPriceGwei: 0.01, reserve: '0.0006' });106 expect(by.arbitrum.gas.perOrderUsd).toBeCloseTo(0.009, 6); // priced from the stored ETH candle107 expect(by.polygon.gas.reserve).toBe('1'); // 2 × 0.5 POL108 });109});110111describe('agents on several networks', () => {112 let base: any, arb: any, avax: any;113 it('creates agents on Base, Arbitrum and Avalanche: one vault index each, the chosen assets recorded', async () => {114 base = (await create({ name: 'Base five', universe: ['ETH', 'LINK', 'AAVE'] })).json; // network defaults to Base, as before V5115 const r = await create({ name: 'Arb four', network: 'arbitrum', universe: ['ETH', 'LINK', 'UNI', 'AAVE'] });116 expect(r.status).toBe(200); arb = r.json;117 avax = (await create({ name: 'Avax', network: 'avalanche', universe: ['AVAX', 'BTC'], cash: 'USDT' })).json;118 expect([base.network, arb.network, avax.network]).toEqual(['base', 'arbitrum', 'avalanche']);119 expect([base.vaultIndex, arb.vaultIndex, avax.vaultIndex]).toEqual([1, 2, 3]); // never shared: the same index is the same address on every EVM network120 expect(new Set([base.vaultAddress, arb.vaultAddress, avax.vaultAddress]).size).toBe(3);121 expect(arb.vaultAddress).toBe(keys.vault(2).address);122 const A = getNetwork('arbitrum'), id = (s: string) => A.tokens.find((t) => t.symbol === s)!.id;123 expect(arb.holdings.map((h: any) => [h.symbol, h.asset])).toEqual([['USDC', id('USDC')], ['ETH', 'native'], ['LINK', id('LINK')], ['UNI', id('UNI')], ['AAVE', id('AAVE')]]);124 expect(avax.cash).toBe('USDT');125 expect(avax.holdings.map((h: any) => [h.symbol, h.assetSymbol, h.kind])).toEqual([['USDT', 'USDT', 'cash'], ['AVAX', 'AVAX', 'native'], ['BTC', 'WBTC', 'wrapped']]);126 expect(avax.holdings[2].issuer).toMatch(/BitGo/);127 const rows = await sql`select network, cash, assets, vault_index from agents order by vault_index`;128 expect(rows.map((x: any) => [x.network, x.cash])).toEqual([['base', 'USDC'], ['arbitrum', 'USDC'], ['avalanche', 'USDT']]);129 expect(rows[1].assets).toEqual({ ETH: 'native', LINK: id('LINK'), UNI: id('UNI'), AAVE: id('AAVE') }); // recorded: a later registry change cannot move it130 await expect(sql`update agents set vault_index = 1 where id = ${arb.id}`).rejects.toThrow(/unique|duplicate/i); // the database refuses a shared index too131 expect((await api('GET', `/agents/${arb.id}`)).json.vault.map((v: any) => [v.symbol, v.role])).toEqual([['USDC', 'cash'], ['ETH', 'asset'], ['LINK', 'asset'], ['UNI', 'asset'], ['AAVE', 'asset']]);132 const v = (await api('GET', `/agents/${avax.id}`)).json.vault;133 expect(v.map((x: any) => x.assetSymbol)).toEqual(['USDT', 'AVAX', 'WBTC']);134 });135136 // v8 hardening (D4): the agent page lists the SIMULATED positions next to the real (empty) vault137 it('GET /agents/:id carries the paper book read-only, apart from the real vault: null before any simulation, never seeded by the read', async () => {138 const before = (await api('GET', `/agents/${base.id}`)).json;139 expect(before.paper).toBeNull(); // never ran on paper: no book140 expect(await sql`select 1 from agent_paper where agent_id = ${base.id}`).toHaveLength(0); // and the read did not create one141 // a book as the engine leaves it after paper fills: 60 of cash, three symbols (one sold back to zero, one the server cannot price)142 for (const [symbol, units] of [['USDC', 60], ['LINK', 2], ['ETH', 0.01], ['AAVE', 0], ['ZZZ', 5]] as const) await sql`insert into agent_paper (agent_id, symbol, units) values (${base.id}, ${symbol}, ${units})`;143 try {144 const t0 = Date.now(), d = (await api('GET', `/agents/${base.id}`)).json;145 expect(d.paper.positions).toEqual([{ symbol: 'ETH', units: '0.01', usd: 20 }, { symbol: 'LINK', units: '2', usd: 20 }, { symbol: 'ZZZ', units: '5', usd: null }]); // universe order; no price = null, not 0146 expect(d.paper).toMatchObject({ cashSymbol: 'USDC', cashUsd: 60 });147 expect(d.paper.asOf).toBeGreaterThanOrEqual(t0);148 expect(d.vault.map((x: any) => [x.symbol, x.amount])).toEqual([['USDC', '0'], ['ETH', '0'], ['LINK', '0'], ['AAVE', '0']]); // the real vault is untouched and still empty149 expect((await sql`select symbol, units from agent_paper where agent_id = ${base.id} order by symbol`).map((r: any) => [r.symbol, r.units])).toEqual([['AAVE', 0], ['ETH', 0.01], ['LINK', 2], ['USDC', 60], ['ZZZ', 5]]); // read-only150 expect((await api('GET', `/agents/${arb.id}`)).json.paper).toBeNull(); // another agent's book is its own151 } finally { await sql`delete from agent_paper where agent_id = ${base.id}`; }152 });153154 it('refuses what the registry or the listings do not support, with a reason', async () => {155 // derived from the registry, so they stay refusals when it grows: a symbol the exchanges list but that no asset of Base tracks,156 // and a network whose only cash leg is USDC (a bridged USDT0 or USDC.e there is NOT a cash leg)157 const absent = Object.keys(MARKET_LISTINGS).find((x) => /^[A-Z0-9]{2,10}$/.test(x) && hasMarketData(x) && !['USDC', 'USDT'].includes(x) && !tradableSymbols(getNetwork('base')).some((t) => t.symbol === x))!;158 const usdcOnly = getNetwork(MANDATE_NETWORKS.find((id) => cashLegs(getNetwork(id)).map((c) => c.symbol).join() === 'USDC')!);159 expect(absent).toBeTruthy(); expect(usdcOnly.tokens.some((t) => t.symbol === 'USDT0' || t.symbol === 'USDC.e')).toBe(true);160 const cases: [Record<string, unknown>, RegExp][] = [161 [{ network: 'solana', universe: ['SOL'] }, /agents trade on Base, Ethereum/],162 [{ network: 'nowhere', universe: ['ETH'] }, /agents trade on/],163 [{ network: 'base', universe: [absent] }, new RegExp(`no asset of the wallet registry tracks ${absent} on Base`)],164 [{ network: 'base', universe: ['NOPE'] }, /no market data/],165 [{ network: usdcOnly.id, universe: [usdcOnly.native.symbol], cash: 'USDT' }, new RegExp(`USDT is not in the wallet registry on ${usdcOnly.name}; choose USDC`)],166 [{ network: 'avalanche', universe: ['ETH'] }, /no asset of the wallet registry tracks ETH on Avalanche/], // WETH.e is not ETH without a reviewed entry167 [{ network: 'avalanche', universe: ['AVAX'], assets: { AVAX: getNetwork('avalanche').tokens.find((t) => t.symbol === 'BTC.b')!.id } }, /does not track/],168 [{ network: 'bsc', universe: ['BNB'], assets: { BNB: getNetwork('bsc').tokens.find((t) => t.symbol === 'ETH')!.id } }, /does not track/], // Binance-Peg ETH is not BNB169 [{ network: 'base', universe: ['ETH', 'ETH'] }, /duplicate/],170 [{ network: 'base', universe: ['USDC'] }, /cash leg/],171 [{ network: 'ethereum', universe: ['ETH'], assets: { ETH: getNetwork('ethereum').tokens.find((t) => t.symbol === 'LINK')!.id } }, /does not track/],172 ];173 for (const [body, why] of cases) { const r = await create(body); expect(r.status, JSON.stringify(body)).toBe(422); expect(r.json.message, JSON.stringify(body)).toMatch(why); }174 expect((await create({ universe: [] })).status).toBe(400);175 expect((await create({ universe: Array.from({ length: 13 }, (_, k) => `S${k}X`) })).status).toBe(400); // 12 symbols at most176 expect((await sql`select count(*)::int as n from agents`)[0].n).toBe(3); // a refused creation takes no vault index177 });178179 it('warns — without blocking — when fees eat the orders or a symbol can only be paper traded', async () => {180 // Ethereum at 3 gwei: 0.00135 ETH ≈ 2.70 USD per order, 13.5 % of a 20 USD order181 const r = await create({ name: 'Mainnet small', network: 'ethereum', universe: ['ETH', 'BTC'], assets: { ETH: getNetwork('ethereum').tokens.find((t) => t.symbol === 'WETH')!.id } });182 expect(r.status).toBe(200);183 expect(r.json.holdings.map((h: any) => h.assetSymbol)).toEqual(['USDC', 'WETH', 'WBTC']); // the owner's choice of representation184 expect(r.json.warnings.map((w: any) => w.code)).toEqual(['fees']);185 expect(r.json.warnings[0].message).toMatch(/one order costs about 2\.70 USD in network fees: 13\.5 % of this agent's largest order/);186 const paper = await create({ name: 'Euro', network: 'base', universe: ['ETH', 'EUR'] });187 expect(paper.json.warnings).toEqual([expect.objectContaining({ code: 'paper_only', message: expect.stringMatching(/EUR: not listed on both Coinbase and Kraken/) })]);188 expect(base.warnings).toEqual([]);189 // WETH as ETH: the native coin is then held for gas only, shown apart190 const v = (await api('GET', `/agents/${r.json.id}`)).json.vault;191 expect(v.map((x: any) => [x.symbol, x.assetSymbol, x.role])).toEqual([['USDC', 'USDC', 'cash'], ['ETH', 'WETH', 'asset'], ['BTC', 'WBTC', 'asset'], ['ETH', 'ETH', 'gas']]);192 });193194 it('BNB Smart Chain: an 18-decimal cash leg end to end — creation, vault view, mandate caps, signer approval', async () => {195 const B = getNetwork('bsc'), id = (x: string) => B.tokens.find((t) => t.symbol === x)!.id;196 const r = await create({ name: 'BNB three', network: 'bsc', universe: ['BNB', 'ETH', 'BTC'], capitalUsdc: '100' });197 expect(r.status).toBe(200);198 expect(r.json).toMatchObject({ network: 'bsc', cash: 'USDC', capitalUsdc: '100' }); // the allocated capital is a USD amount: 100, not 100 × 10^-12199 expect(r.json.holdings.map((h: any) => [h.symbol, h.asset, h.assetSymbol, h.kind])).toEqual([['USDC', id('USDC'), 'USDC', 'cash'], ['BNB', 'native', 'BNB', 'native'], ['ETH', id('ETH'), 'ETH', 'token'], ['BTC', id('WBTC'), 'WBTC', 'wrapped']]);200 expect((await sql`select capital_usdc from agents where id = ${r.json.id}`)[0].capital_usdc).toBe('100000000'); // stored in 6-decimal units by design, whatever the cash leg201 // the vault holds 12.5 USDC (18 decimals) and 0.01 BNB: shown and valued in the asset's own decimals202 const saved = adapters.bsc.balances;203 adapters.bsc.balances = async () => ({ native: 10_000_000_000_000_000n, [id('USDC')]: 12_500_000_000_000_000_000n, [id('WBTC')]: 50_000n });204 try {205 const v = (await api('GET', `/agents/${r.json.id}`)).json.vault;206 expect(v.map((x: any) => [x.symbol, x.display, x.usd])).toEqual([['USDC', '12.5', 12.5], ['BNB', '0.01', 6], ['ETH', '0', 0], ['BTC', '0.0005', 30]]);207 const vid = '7a1c1f0e-8f5f-4b1e-9c56-0000000000b5';208 await sql`insert into strategy_versions (id, agent_id, name, version, code_sha256, path, status, report) values (${vid}, ${r.json.id}, 'ts_momentum', '3', ${'ef'.repeat(32)}, 'strategies/ts_momentum/3', 'approved', '{"metrics":{}}')`;209 await sql`update agents set strategy_version_id = ${vid}, state = 'AWAITING_APPROVAL' where id = ${r.json.id}`;210 const ok = await api('POST', `/agents/${r.json.id}/mandate/prepare`);211 expect(ok.status).toBe(200);212 const m = ok.json.mandate;213 expect(m).toMatchObject({ network: 'bsc', vault: r.json.vaultAddress, provider: 'kyberswap' });214 expect(m.assets).toEqual([id('USDC'), 'native', id('ETH'), id('WBTC')]);215 // RISK: 20 USD per order, 100 USD a day — in base units of each asset: USDC 18 decimals, BNB at 600 USD, Binance-Peg ETH at 2 000 USD, WBTC (8 decimals) at 60 000 USD216 expect(m.maxOrder).toEqual({ [id('USDC')]: '20000000000000000000', native: '33333330000000000', [id('ETH')]: '10000000000000000', [id('WBTC')]: '33333' });217 expect(m.maxDaily[id('USDC')]).toBe('100000000000000000000');218 expect(ok.json.limits.map((l: any) => [l.symbol, l.maxOrder, l.maxDaily])).toEqual([['USDC', '20', '100'], ['BNB', '0.03333333', '0.16666667'], ['ETH', '0.01', '0.05'], ['WBTC (BTC)', '0.00033333', '0.00166667']]);219 expect(ok.json.gasReserve).toMatchObject({ symbol: 'BNB', required: '0.002', held: '0.01' }); // two orders at the policy's fee ceiling for BNB Smart Chain220 const live = await api('POST', `/agents/${r.json.id}/mandate/approve`, { assertion: owner.assert(Buffer.from(ok.json.options.challenge, 'base64url')) });221 expect(live.status).toBe(200); expect(live.json.state).toBe('LIVE'); // the signer validated the same mandate against its own registry222 const st = (await api('GET', `/agents/${r.json.id}`)).json.mandateStatus;223 expect(st).toMatchObject({ active: true, maxOrder: m.maxOrder });224 } finally { adapters.bsc.balances = saved; }225 });226227 it('prepares a mandate for the agent\'s own network only with the gas reserve in the vault', async () => {228 const vid = '7a1c1f0e-8f5f-4b1e-9c56-0000000000aa';229 await sql`insert into strategy_versions (id, agent_id, name, version, code_sha256, path, status, report) values (${vid}, ${arb.id}, 'ts_momentum', '3', ${'ab'.repeat(32)}, 'strategies/ts_momentum/3', 'approved', '{"metrics":{}}')`;230 await sql`update agents set strategy_version_id = ${vid}, state = 'AWAITING_APPROVAL' where id = ${arb.id}`;231 const dry = await api('POST', `/agents/${arb.id}/mandate/prepare`);232 expect(dry.status).toBe(409);233 expect(dry.json).toMatchObject({ error: 'insufficient_gas', message: expect.stringMatching(/the vault holds 0 ETH; live trading on Arbitrum One needs a gas reserve of 0\.0006 ETH/) });234 native.arbitrum = 599_999_999_999_999n; // one wei short235 expect((await api('POST', `/agents/${arb.id}/mandate/prepare`)).status).toBe(409);236 native.arbitrum = 600_000_000_000_000n;237 gasPrice.arbitrum = 1_000_000_000n; // gas rises to 1 gwei: 8 orders × 0.00045 ETH, capped per order by the 0.0003 ETH ceiling → 0.0024 ETH238 await new Promise((r) => setTimeout(r, 10));239 const st = await import('../src/agents/gas.ts');240 expect((await st.gasReserve(getNetwork('arbitrum'), DEFAULT_POLICY.maxFee.arbitrum, Date.now() + 61_000)).reserve).toBe(2_400_000_000_000_000n);241 native.arbitrum = 5_000_000_000_000_000n;242 const ok = await api('POST', `/agents/${arb.id}/mandate/prepare`);243 expect(ok.status).toBe(200);244 const A = getNetwork('arbitrum'), m = ok.json.mandate;245 expect(m).toMatchObject({ network: 'arbitrum', vaultIndex: 2, vault: keys.vault(2).address, provider: 'kyberswap', strategySha256: 'ab'.repeat(32) });246 expect(m.assets).toEqual([cashLegs(A)[0]!.id, 'native', ...['LINK', 'UNI', 'AAVE'].map((s) => A.tokens.find((t) => t.symbol === s)!.id)]);247 expect(m.maxOrder.native).toBe('10000000000000000'); // 20 USD of ETH at 2 000 USD, from the stored candle248 expect(ok.json.limits.map((l: any) => l.symbol)).toEqual(['USDC', 'ETH', 'LINK', 'UNI', 'AAVE']);249 expect(ok.json.gasReserve).toMatchObject({ symbol: 'ETH', held: '0.005' });250 // the signer accepts it for Arbitrum (passkey over the hash) and reports it; then the agent is LIVE251 const live = await api('POST', `/agents/${arb.id}/mandate/approve`, { assertion: owner.assert(Buffer.from(ok.json.options.challenge, 'base64url')) });252 expect(live.status).toBe(200); expect(live.json.state).toBe('LIVE');253 const detail = (await api('GET', `/agents/${arb.id}`)).json;254 expect(detail.mandateStatus).toMatchObject({ active: true });255 // paper-only universes cannot get a mandate at all256 const euro = (await sql`select id from agents where name = 'Euro'`)[0].id;257 await sql`insert into strategy_versions (id, agent_id, name, version, code_sha256, path, status, report) values (${'7a1c1f0e-8f5f-4b1e-9c56-0000000000ab'}, ${euro}, 'x', '3', ${'cd'.repeat(32)}, 'strategies/ts_momentum/3', 'approved', '{"metrics":{}}')`;258 await sql`update agents set strategy_version_id = ${'7a1c1f0e-8f5f-4b1e-9c56-0000000000ab'} where id = ${euro}`;259 await sql`insert into candles (source, symbol, interval, ts, open, high, low, close, volume) values ('kraken', 'EUR', '1h', ${new Date(Math.floor(Date.now() / 3_600_000) * 3_600_000 - 3_600_000)}, 1.1, 1.1, 1.1, 1.1, 1)`;260 const no = await api('POST', `/agents/${euro}/mandate/prepare`);261 expect(no.status).toBe(422); expect(no.json.error).toBe('no_signer_price');262 });263});264265describe.skipIf(!LAB)('registration of library strategies (the laboratory describes them for real)', () => {266 it('GET /strategies reports which versions are universe-generic', async () => {267 const lib = (await api('GET', '/strategies')).json.strategies as any[];268 const of = (name: string, v: string) => lib.find((x) => x.meta.name === name && x.meta.version === v);269 for (const name of ['ts_momentum', 'ma_trend', 'donchian_breakout', 'vol_target_trend', 'mean_reversion', 'xs_momentum']) {270 expect(of(name, '3'), name).toMatchObject({ generic: true, meta: { universe: ['*'] }, maxSymbols: 12 });271 expect(of(name, '1'), name).toMatchObject({ generic: false, minSymbols: 4, maxSymbols: 4 });272 expect(of(name, '3').readme).toMatch(/Universe-generic version/);273 }274 expect(of('xs_momentum', '3').minSymbols).toBe(3); expect(of('ts_momentum', '3').minSymbols).toBe(1);275 expect(of('garch_regime', '1').generic).toBe(false);276 }, 120_000);277278 it('accepts a generic strategy for any agent universe, a fixed one only for its own symbols', async () => {279 const two = (await create({ name: 'Two', network: 'optimism', universe: ['ETH', 'UNI'] })).json;280 const four = (await sql`select id from agents where name = 'Arb four'`)[0].id as string;281 await sql`update agents set state = 'STOPPED' where id = ${four}`; // registration is refused on nothing but a bad fit; LIVE is irrelevant here282 const reg = (id: string, path: string) => api('POST', `/agents/${id}/strategies`, { path });283 const fixed = await reg(two.id, 'ts_momentum/1'); // written for ETH, BTC, LINK, SOL284 expect(fixed.status).toBe(422); expect(fixed.json).toMatchObject({ error: 'universe_mismatch', message: expect.stringMatching(/this strategy trades ETH, BTC, LINK, SOL; the agent's assets are ETH, UNI/) });285 const xs = await reg(two.id, 'xs_momentum/3'); // a ranking needs three symbols286 expect(xs.status).toBe(422); expect(xs.json).toMatchObject({ error: 'universe_size', message: expect.stringMatching(/between 3 and 12 symbols; the agent trades 2/) });287 const ok = await reg(two.id, 'ts_momentum/3');288 expect(ok.status).toBe(200); expect(ok.json).toMatchObject({ generic: true, symbols: ['ETH', 'UNI'], status: 'backtesting' });289 const xs4 = await reg(four, 'xs_momentum/3');290 expect(xs4.status).toBe(200); expect(xs4.json.symbols).toEqual(['ETH', 'LINK', 'UNI', 'AAVE']);291 expect((await reg(four, 'ma_trend/2')).json.error).toBe('universe_mismatch'); // ETH, LINK, AAVE: not this agent's four292 const rows = await sql`select meta, code_sha256 from strategy_versions where agent_id = ${two.id}`;293 expect(rows).toHaveLength(1);294 expect(rows[0].meta).toMatchObject({ name: 'ts_momentum', version: '3', universe: ['*'], generic: true, symbols: ['ETH', 'UNI'] });295 // the backtest was started with the agent's symbols; there is no history in this database, so it ends without a report and says why296 let v: any;297 for (let k = 0; k < 120; k++) { v = (await sql`select status, notes, report from strategy_versions where agent_id = ${two.id}`)[0]; if (v.status === 'draft' && v.notes) break; await new Promise((r) => setTimeout(r, 500)); }298 expect(v.report).toBeNull(); expect(v.notes).toMatch(/backtest failed/);299 const early = await api('POST', `/agents/${two.id}/strategies/${(await sql`select id from strategy_versions where agent_id = ${two.id}`)[0].id}/approve`);300 expect(early.status).toBe(409); // approval still needs the report301 for (let k = 0; k < 120; k++) { const left = await sql`select 1 from strategy_versions where status = 'backtesting'`; if (!left.length) break; await new Promise((r) => setTimeout(r, 500)); }302 }, 180_000);303});304