my-project-public

repository

loading code, commits, and activity

repositories

loading repo index

#1	/**
#2	* leviathan/src/agent/percolator.ts — Typed wrapper for @openclawdsolana/percolator CLI
#3	*
#4	* Devnet-only enforcement is baked in. Every command injects --cluster=devnet
#5	* unless the PERCOLATOR_MAINNET env var is explicitly set to '1' (requires human).
#6	*
#7	* Commands map to the percolator CLI: `percolator <command> [options]`
#8	*/
#9
#10	import { execa } from 'execa';
#11
#12	const PERCOLATOR_TIMEOUT = 15_000;
#13
#14	export function resolveCluster(): string {
#15	if (process.env['PERCOLATOR_MAINNET'] === '1') return 'mainnet-beta';
#16	return process.env['PERCOLATOR_CLUSTER'] ?? 'devnet';
#17	}
#18
#19	export interface PercolatorMarket {
#20	pubkey: string;
#21	name: string;
#22	baseSymbol: string;
#23	quoteSymbol: string;
#24	openInterest: string;
#25	fundingRate: string;
#26	}
#27
#28	export interface PercolatorSlab {
#29	pubkey: string;
#30	bids: Array<{ price: string; size: string }>;
#31	asks: Array<{ price: string; size: string }>;
#32	timestamp: string;
#33	}
#34
#35	export interface PercolatorTradeResult {
#36	signature: string;
#37	side: 'long' \| 'short';
#38	size: string;
#39	price: string;
#40	fee: string;
#41	}
#42
#43	async function runCmd(args: string[], timeoutMs = PERCOLATOR_TIMEOUT): Promise<{ stdout: string; success: boolean; error?: string }> {
#44	const cluster = resolveCluster();
#45	const fullArgs = [...args, `--cluster=${cluster}`, '--output=json'];
#46	try {
#47	const result = await execa('percolator', fullArgs, { timeout: timeoutMs });
#48	return { stdout: result.stdout, success: true };
#49	} catch (e: unknown) {
#50	const msg = e instanceof Error ? e.message : String(e);
#51	return { stdout: '', success: false, error: msg.slice(0, 200) };
#52	}
#53	}
#54
#55	export const Percolator = {
#56	async listMarkets(): Promise<PercolatorMarket[] \| string> {
#57	const r = await runCmd(['list-markets']);
#58	if (!r.success) return `percolator list-markets failed: ${r.error}`;
#59	try { return JSON.parse(r.stdout) as PercolatorMarket[]; }
#60	catch { return r.stdout.slice(0, 500); }
#61	},
#62
#63	async slabGet(pubkey: string): Promise<PercolatorSlab \| string> {
#64	const r = await runCmd(['slab:get', pubkey]);
#65	if (!r.success) return `percolator slab:get failed: ${r.error}`;
#66	try { return JSON.parse(r.stdout) as PercolatorSlab; }
#67	catch { return r.stdout.slice(0, 500); }
#68	},
#69
#70	async getPosition(wallet: string): Promise<unknown> {
#71	const r = await runCmd(['position:get', '--wallet', wallet]);
#72	if (!r.success) return `percolator position:get failed: ${r.error}`;
#73	try { return JSON.parse(r.stdout); }
#74	catch { return r.stdout.slice(0, 500); }
#75	},
#76
#77	async quoteMarket(market: string, side: 'long' \| 'short', size: string): Promise<unknown> {
#78	const r = await runCmd(['trade-quote', '--market', market, `--side=${side}`, `--size=${size}`]);
#79	if (!r.success) return `percolator trade-quote failed: ${r.error}`;
#80	try { return JSON.parse(r.stdout); }
#81	catch { return r.stdout.slice(0, 500); }
#82	},
#83
#84	async checkLiquidation(positionPubkey: string): Promise<unknown> {
#85	const r = await runCmd(['liquidate-at-oracle', '--position', positionPubkey, '--dry-run']);
#86	if (!r.success) return `percolator liquidate check failed: ${r.error}`;
#87	try { return JSON.parse(r.stdout); }
#88	catch { return r.stdout.slice(0, 500); }
#89	},
#90
#91	async fundingRate(market: string): Promise<unknown> {
#92	const r = await runCmd(['funding-rate', '--market', market]);
#93	if (!r.success) return `percolator funding-rate failed: ${r.error}`;
#94	try { return JSON.parse(r.stdout); }
#95	catch { return r.stdout.slice(0, 500); }
#96	},
#97	};
#98

z6Mkq5mY3JWtxoxUobWcfNHm7AkRubgSWEZTkBVqZXJviFZ5/my-project-public