Add isBlockhashValid method to web3.js

web3.js/src/connection.ts

@@ -1042,6 +1042,16 @@ const BlockProductionResponseStruct = jsonRpcResultAndContext(
   }),
 );
 
+/**
+ * Configuration object for changing `isBlockhashValid` query behavior
+ */
+export type IsBlockhashValidConfig = {
+  /** The level of commitment desired */
+  commitment?: Commitment;
+  /** The minimum slot that the request can be evaluated at */
+  minContextSlot?: number;
+};
+
 /**
  * A performance sample
  */
@@ -3547,6 +3557,33 @@ export class Connection {
     return res.result;
   }
 
+  /**
+   * Check whether a blockhash is still valid or not
+   */
+  async isBlockhashValid(
+    blockhash: string,
+    config?: IsBlockhashValidConfig,
+  ): Promise<RpcResponseAndContext<boolean>> {
+    const {commitment, config: configWithoutCommitment} =
+      extractCommitmentFromConfig(config);
+    const args = this._buildArgs(
+      [blockhash],
+      commitment,
+      'jsonParsed',
+      configWithoutCommitment,
+    );
+
+    const unsafeRes = await this._rpcRequest('isBlockhashValid', args);
+    const res = create(unsafeRes, jsonRpcResultAndContext(boolean()));
+    if ('error' in res) {
+      throw new SolanaJSONRPCError(
+        res.error,
+        'Could not determine if blockhash `' + blockhash + '` was valid',
+      );
+    }
+    return res.result;
+  }
+
   /**
    * Fetch the node version
    */

web3.js/test/connection.test.ts

@@ -3087,6 +3087,68 @@ describe('Connection', function () {
     }
   });
 
+  describe('is blockhash valid', () => {
+    it('is blockhash valid - blockhash only (mock)', async () => {
+      const {blockhash} = await helpers.recentBlockhash({connection});
+
+      await mockRpcResponse({
+        method: 'isBlockhashValid',
+        params: [blockhash],
+        value: true,
+        withContext: true,
+      });
+
+      const isValid = await connection.isBlockhashValid(blockhash);
+      expect(isValid.value).to.be.true;
+    });
+
+    it('is blockhash valid - blockhash and min slot (mock)', async () => {
+      const {blockhash} = await helpers.recentBlockhash({connection});
+
+      await mockRpcResponse({
+        method: 'isBlockhashValid',
+        params: [blockhash, {minContextSlot: 2}],
+        value: true,
+        withContext: true,
+      });
+
+      const isValid = await connection.isBlockhashValid(blockhash, {
+        minContextSlot: 2,
+      });
+      expect(isValid.value).to.be.true;
+    });
+
+    if (process.env.TEST_LIVE) {
+      it('is blockhash valid - blockhash only (live)', async () => {
+        const {blockhash} = await helpers.recentBlockhash({connection});
+        const isValid = await connection.isBlockhashValid(blockhash);
+        expect(isValid.value).to.be.true;
+      });
+
+      it('is blockhash valid - blockhash only and min slot (live)', async () => {
+        const blockhash = await connection.getLatestBlockhashAndContext(
+          'processed',
+        );
+
+        const isValid = await connection.isBlockhashValid(
+          blockhash.value.blockhash,
+          {
+            commitment: 'finalized',
+            minContextSlot: blockhash.context.slot,
+          },
+        );
+        expect(isValid.value).to.be.false;
+      });
+
+      it('is blockhash valid - junk blockhash (live)', async () => {
+        const isValid = await connection.isBlockhashValid(
+          '57zQNBZBEiHsCZFqsaY6h176ioXy5MsSLmcvHkEyaLGy',
+        );
+        expect(isValid.value).to.be.false;
+      });
+    }
+  });
+
   it('get minimum ledger slot', async () => {
     await mockRpcResponse({
       method: 'minimumLedgerSlot',