feat: priorty fee support

src/utils/keypair.ts

@@ -0,0 +1,7 @@
+import { Keypair } from "@solana/web3.js";
+import bs58 from "bs58";
+
+export const keypair = Keypair.generate();
+
+console.log(keypair.publicKey.toString());
+console.log(bs58.encode(keypair.secretKey));

src/utils/send_tx.ts

@@ -0,0 +1,89 @@
+import { SolanaAgentKit } from "../agent";
+import { Transaction, Keypair } from "@solana/web3.js";
+import { Connection, ComputeBudgetProgram } from "@solana/web3.js";
+
+/**
+ * Get priority fees for the current block
+ * @param connection - Solana RPC connection
+ * @returns Priority fees statistics and instructions for different fee levels
+ */
+async function getPriorityFees(connection: Connection) {
+  try {
+    // Get recent prioritization fees
+    const priorityFees = await connection.getRecentPrioritizationFees();
+
+    if (!priorityFees.length) {
+      return {
+        min: 0,
+        median: 0,
+        max: 0,
+      };
+    }
+
+    // Sort fees by value
+    const sortedFees = priorityFees
+      .map((x) => x.prioritizationFee)
+      .sort((a, b) => a - b);
+
+    // Calculate statistics
+    const min = sortedFees[0] ?? 0;
+    const max = sortedFees[sortedFees.length - 1] ?? 0;
+    const mid = Math.floor(sortedFees.length / 2);
+    const median =
+      sortedFees.length % 2 === 0
+        ? ((sortedFees[mid - 1] ?? 0) + (sortedFees[mid] ?? 0)) / 2
+        : sortedFees[mid] ?? 0;
+
+    // Helper to create priority fee IX based on chosen strategy
+    const createPriorityFeeIx = (fee: number) => {
+      return ComputeBudgetProgram.setComputeUnitPrice({
+        microLamports: fee,
+      });
+    };
+
+    return {
+      min,
+      median,
+      max,
+      // Return instructions for different fee levels
+      instructions: {
+        low: createPriorityFeeIx(min),
+        medium: createPriorityFeeIx(median),
+        high: createPriorityFeeIx(max),
+      },
+    };
+  } catch (error) {
+    console.error("Error getting priority fees:", error);
+    throw error;
+  }
+}
+
+/**
+ * Send a transaction with priority fees
+ * @param agent - SolanaAgentKit instance
+ * @param tx - Transaction to send
+ * @returns Transaction ID
+ */
+export async function sendTx(
+  agent: SolanaAgentKit,
+  tx: Transaction,
+  otherKeypairs?: Keypair[]
+) {
+  tx.recentBlockhash = (await agent.connection.getLatestBlockhash()).blockhash;
+  tx.feePayer = agent.wallet_address;
+  const fees = await getPriorityFees(agent.connection);
+  if (fees.instructions) {
+    tx.add(fees.instructions.medium!);
+  }
+
+  tx.sign(agent.wallet, ...(otherKeypairs ?? []));
+  let txid = await agent.connection.sendRawTransaction(tx.serialize());
+  await agent.connection.confirmTransaction({
+    signature: txid,
+    blockhash: (await agent.connection.getLatestBlockhash()).blockhash,
+    lastValidBlockHeight: (
+      await agent.connection.getLatestBlockhash()
+    ).lastValidBlockHeight,
+  });
+  return txid;
+}