-
Notifications
You must be signed in to change notification settings - Fork 192
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
* initial commit of limo example * Update to use the latest sdk * Update apis --------- Co-authored-by: ani <anirudhtx@gmail.com>
- Loading branch information
Showing
9 changed files
with
5,471 additions
and
2,217 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
215 changes: 215 additions & 0 deletions
215
express_relay/sdk/js/src/examples/simpleSearcherLimo.ts
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,215 @@ | ||
| import yargs from "yargs"; | ||
| import { hideBin } from "yargs/helpers"; | ||
| import { Client } from "../index"; | ||
| import { BidStatusUpdate } from "../types"; | ||
| import { SVM_CONSTANTS } from "../const"; | ||
|
|
||
| import * as anchor from "@coral-xyz/anchor"; | ||
| import { Keypair, PublicKey, Connection } from "@solana/web3.js"; | ||
|
|
||
| import * as limo from "@kamino-finance/limo-sdk"; | ||
| import { Decimal } from "decimal.js"; | ||
| import { | ||
| getPdaAuthority, | ||
| OrderStateAndAddress, | ||
| } from "@kamino-finance/limo-sdk/dist/utils"; | ||
|
|
||
| const DAY_IN_SECONDS = 60 * 60 * 24; | ||
|
|
||
| class SimpleSearcherLimo { | ||
| private client: Client; | ||
| private connectionSvm: Connection; | ||
| private clientLimo: limo.LimoClient; | ||
| private searcher: Keypair; | ||
| constructor( | ||
| public endpointExpressRelay: string, | ||
| public chainId: string, | ||
| privateKey: string, | ||
| public endpointSvm: string, | ||
| public globalConfig: PublicKey, | ||
| public apiKey?: string | ||
| ) { | ||
| this.client = new Client( | ||
| { | ||
| baseUrl: endpointExpressRelay, | ||
| apiKey, | ||
| }, | ||
| undefined, | ||
| () => { | ||
| return Promise.resolve(); | ||
| }, | ||
| this.bidStatusHandler.bind(this) | ||
| ); | ||
| this.connectionSvm = new Connection(endpointSvm, "confirmed"); | ||
| this.clientLimo = new limo.LimoClient(this.connectionSvm, globalConfig); | ||
| const secretKey = anchor.utils.bytes.bs58.decode(privateKey); | ||
| this.searcher = Keypair.fromSecretKey(secretKey); | ||
| } | ||
|
|
||
| async bidStatusHandler(bidStatus: BidStatusUpdate) { | ||
| let resultDetails = ""; | ||
| if (bidStatus.type == "submitted" || bidStatus.type == "won") { | ||
| resultDetails = `, transaction ${bidStatus.result}`; | ||
| } else if (bidStatus.type == "lost") { | ||
| if (bidStatus.result) { | ||
| resultDetails = `, transaction ${bidStatus.result}`; | ||
| } | ||
| } | ||
| console.log( | ||
| `Bid status for bid ${bidStatus.id}: ${bidStatus.type}${resultDetails}` | ||
| ); | ||
| } | ||
|
|
||
| async evaluateOrder(order: OrderStateAndAddress) { | ||
| const inputMintDecimals = await this.clientLimo.getOrderInputMintDecimals( | ||
| order | ||
| ); | ||
| const outputMintDecimals = await this.clientLimo.getOrderOutputMintDecimals( | ||
| order | ||
| ); | ||
| const inputAmount = new Decimal( | ||
| order.state.remainingInputAmount.toNumber() | ||
| ).div(new Decimal(10).pow(inputMintDecimals)); | ||
|
|
||
| const outputAmount = new Decimal( | ||
| order.state.expectedOutputAmount.toNumber() | ||
| ).div(new Decimal(10).pow(outputMintDecimals)); | ||
|
|
||
| console.log("Order address", order.address.toBase58()); | ||
| console.log( | ||
| "Sell token", | ||
| order.state.inputMint.toBase58(), | ||
| "amount:", | ||
| inputAmount.toString() | ||
| ); | ||
| console.log( | ||
| "Buy token", | ||
| order.state.outputMint.toBase58(), | ||
| "amount:", | ||
| outputAmount.toString() | ||
| ); | ||
|
|
||
| const ixsTakeOrder = await this.clientLimo.takeOrderIx( | ||
| this.searcher.publicKey, | ||
| order, | ||
| inputAmount, | ||
| SVM_CONSTANTS[this.chainId].expressRelayProgram, | ||
| inputMintDecimals, | ||
| outputMintDecimals | ||
| ); | ||
| const txRaw = new anchor.web3.Transaction().add(...ixsTakeOrder); | ||
|
|
||
| const router = getPdaAuthority( | ||
| this.clientLimo.getProgramID(), | ||
| this.globalConfig | ||
| ); | ||
| const bidAmount = new anchor.BN(argv.bid); | ||
|
|
||
| const bid = await this.client.constructSvmBid( | ||
| txRaw, | ||
| this.searcher.publicKey, | ||
| router, | ||
| order.address, | ||
| bidAmount, | ||
| new anchor.BN(Math.round(Date.now() / 1000 + DAY_IN_SECONDS)), | ||
| this.chainId | ||
| ); | ||
|
|
||
| try { | ||
| const { blockhash } = await this.connectionSvm.getLatestBlockhash(); | ||
| bid.transaction.recentBlockhash = blockhash; | ||
| bid.transaction.sign(this.searcher); | ||
| const bidId = await this.client.submitBid(bid); | ||
| console.log(`Successful bid. Bid id ${bidId}`); | ||
| } catch (error) { | ||
| console.error(`Failed to bid: ${error}`); | ||
| } | ||
| } | ||
|
|
||
| async bidOnNewOrders() { | ||
| let allOrders = | ||
| await this.clientLimo.getAllOrdersStateAndAddressWithFilters([]); | ||
| allOrders = allOrders.filter( | ||
| (order) => !order.state.remainingInputAmount.isZero() | ||
| ); | ||
| if (allOrders.length === 0) { | ||
| console.log("No orders to bid on"); | ||
| return; | ||
| } | ||
| for (const order of allOrders) { | ||
| await this.evaluateOrder(order); | ||
| } | ||
| // Note: You need to parallelize this in production with something like: | ||
| // await Promise.all(allOrders.map((order) => this.evaluateOrder(order))); | ||
| } | ||
|
|
||
| async start() { | ||
| for (;;) { | ||
| await this.bidOnNewOrders(); | ||
| await new Promise((resolve) => setTimeout(resolve, 2000)); | ||
| } | ||
| } | ||
| } | ||
|
|
||
| const argv = yargs(hideBin(process.argv)) | ||
| .option("endpoint-express-relay", { | ||
| description: | ||
| "Express relay endpoint. e.g: https://per-staging.dourolabs.app/", | ||
| type: "string", | ||
| demandOption: true, | ||
| }) | ||
| .option("chain-id", { | ||
| description: "Chain id to bid on Limo opportunities for. e.g: solana", | ||
| type: "string", | ||
| demandOption: true, | ||
| }) | ||
| .option("global-config", { | ||
| description: "Global config address", | ||
| type: "string", | ||
| demandOption: true, | ||
| }) | ||
| .option("bid", { | ||
| description: "Bid amount in lamports", | ||
| type: "string", | ||
| default: "100", | ||
| }) | ||
| .option("private-key", { | ||
| description: "Private key to sign the bid with. In 64-byte base58 format", | ||
| type: "string", | ||
| demandOption: true, | ||
| }) | ||
| .option("api-key", { | ||
| description: | ||
| "The API key of the searcher to authenticate with the server for fetching and submitting bids", | ||
| type: "string", | ||
| demandOption: false, | ||
| }) | ||
| .option("endpoint-svm", { | ||
| description: "SVM RPC endpoint", | ||
| type: "string", | ||
| demandOption: true, | ||
| }) | ||
| .help() | ||
| .alias("help", "h") | ||
| .parseSync(); | ||
| async function run() { | ||
| if (!SVM_CONSTANTS[argv.chainId]) { | ||
| throw new Error(`SVM constants not found for chain ${argv.chainId}`); | ||
| } | ||
| const searcherSvm = Keypair.fromSecretKey( | ||
| anchor.utils.bytes.bs58.decode(argv.privateKey) | ||
| ); | ||
| console.log(`Using searcher pubkey: ${searcherSvm.publicKey.toBase58()}`); | ||
|
|
||
| const simpleSearcher = new SimpleSearcherLimo( | ||
| argv.endpointExpressRelay, | ||
| argv.chainId, | ||
| argv.privateKey, | ||
| argv.endpointSvm, | ||
| new PublicKey(argv.globalConfig), | ||
| argv.apiKey | ||
| ); | ||
| await simpleSearcher.start(); | ||
| } | ||
|
|
||
| run(); |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Oops, something went wrong.