feat: add getRecentPrioritizationFees API

packages/library-legacy/src/connection.ts

@@ -788,6 +788,23 @@ const GetInflationRewardResult = jsonRpcResult(
   ),
 );
 
+export type RecentPrioritizationFees = {
+  /** slot in which the fee was observed */
+  slot: number;
+  /** the per-compute-unit fee paid by at least one successfully landed transaction, specified in increments of 0.000001 lamports*/
+  prioritizationFee: number;
+};
+
+/**
+ * Expected JSON RPC response for the "getRecentPrioritizationFees" message
+ */
+const GetRecentPrioritizationFeesResult = array(
+  pick({
+    slot: number(),
+    prioritizationFee: number(),
+  }),
+);
+
 export type InflationRate = {
   /** total inflation */
   total: number;
@@ -1662,6 +1679,13 @@ const GetInflationGovernorRpcResult = jsonRpcResult(GetInflationGovernorResult);
  */
 const GetInflationRateRpcResult = jsonRpcResult(GetInflationRateResult);
 
+/**
+ * Expected JSON RPC response for the "getRecentPrioritizationFees" message
+ */
+const GetRecentPrioritizationFeesRpcResult = jsonRpcResult(
+  GetRecentPrioritizationFeesResult,
+);
+
 /**
  * Expected JSON RPC response for the "getEpochInfo" message
  */
@@ -4468,6 +4492,27 @@ export class Connection {
     return res.result;
   }
 
+  /**
+   * Fetch a list of prioritization fees from recent blocks.
+   */
+  async getRecentPrioritizationFees(
+    publicKeys?: PublicKey[],
+  ): Promise<RecentPrioritizationFees[]> {
+    const keys = publicKeys ? publicKeys?.map(key => key.toBase58()) : [];
+    const args = this._buildArgs([keys]);
+    const unsafeRes = await this._rpcRequest(
+      'getRecentPrioritizationFees',
+      args,
+    );
+    const res = create(unsafeRes, GetRecentPrioritizationFeesRpcResult);
+    if ('error' in res) {
+      throw new SolanaJSONRPCError(
+        res.error,
+        'failed to get recent prioritization fees',
+      );
+    }
+    return res.result;
+  }
   /**
    * Fetch a recent blockhash from the cluster
    * @return {Promise<{blockhash: Blockhash, feeCalculator: FeeCalculator}>}

packages/library-legacy/test/connection.test.ts

@@ -4436,6 +4436,39 @@ describe('Connection', function () {
     expect(fee).to.eq(5000);
   });
 
+  it('get recent prioritization fee', async () => {
+    if (mockServer) {
+      const pubkey = Keypair.generate().publicKey;
+      await mockRpcResponse({
+        method: 'getRecentPrioritizationFees',
+        params: [[pubkey.toBase58()]],
+        value: [
+          {
+            slot: 348127,
+            prioritizationFee: 500,
+          },
+          {
+            slot: 348128,
+            prioritizationFee: 0,
+          },
+        ],
+      });
+
+      const recentPrioritizationFee =
+        await connection.getRecentPrioritizationFees([pubkey]);
+      expect(recentPrioritizationFee).to.eql([
+        {
+          slot: 348127,
+          prioritizationFee: 500,
+        },
+        {
+          slot: 348128,
+          prioritizationFee: 0,
+        },
+      ]);
+    }
+  });
+
   it('get block time', async () => {
     await mockRpcResponse({
       method: 'getBlockTime',