import "dotenv/config";
import yargs from "yargs";
import { hideBin } from "yargs/helpers";
import { BaseConfig } from "agent-logic/config";
import { newConfirmLock } from "agent-logic/confirm";
import { LiquidityManager } from "agent-logic/liquidity";
import { MulticallSettler } from "cloud-agent/accept-settle";
import { CloudSettlementBackend } from "cloud-agent/backend";
import { runFillLoop, FillDirection, type FillParams } from "cloud-agent/fill-loop";
import { populateInstruments } from "cloud-agent";
type Args = {
amount: number;
maxPrice?: number;
pollPeriod: number;
minSettlement: number;
};
async function parseArgs(): Promise<Args> {
const argv = await yargs(hideBin(process.argv))
.option("amount", {
type: "number",
demandOption: true,
describe: "Amount to buy",
})
.option("max_price", {
type: "number",
describe: "Maximum acceptable price",
})
.option("poll_period", {
type: "number",
default: 600,
describe: "Polling period in seconds",
})
.option("min_settlement", {
type: "number",
default: 5.0,
describe: "Minimum settlement amount",
})
.strict()
.parse();
return {
amount: argv.amount,
maxPrice: argv.max_price,
pollPeriod: argv.poll_period,
minSettlement: argv.min_settlement,
};
}
async function main(): Promise<void> {
const args = await parseArgs();
console.info("Starting buy flow");
// 1. Load config from .env + agent.toml
const config = await BaseConfig.loadOrDefaults("agent.toml");
// 2. Fetch instrument registry from orderbook-rpc
await populateInstruments(config);
// 3. Create backend
const confirmLock = newConfirmLock();
const lm = new LiquidityManager(
config.feeReserveCc,
config.liquidityMargin,
config.flowEmaWindowHours,
config.depletionMaxHours,
config.depletionMinHours
);
const backend = new CloudSettlementBackend(
structuredClone(config),
false,
false,
false,
false,
confirmLock,
lm
);
// 4. Create settler for atomic multicall settlement
const settler = new MulticallSettler({
config: structuredClone(config),
amuletCache: backend.amuletCache(),
verbose: false,
dryRun: false,
force: false,
confirm: false,
confirmLock,
});
// 5. Run the fill loop
const params: FillParams = {
direction: FillDirection.Buy,
marketId: "CC-USDC",
totalAmount: args.amount,
priceLimit: args.maxPrice,
minSettlement: args.minSettlement,
maxSettlement: args.amount,
intervalSecs: args.pollPeriod,
};
const _backendGuard = backend;
await runFillLoop(config, settler, params, null, null);
}
main().catch((error) => {
console.error("Fatal error:", error);
process.exit(1);
})
