feat: add verifySignatureSetsSameMessage BLS api

packages/beacon-node/src/chain/bls/interface.ts

@@ -1,3 +1,4 @@
+import {PublicKey} from "@chainsafe/bls/types";
 import {ISignatureSet} from "@lodestar/state-transition";
 
 export type VerifySignatureOpts = {
@@ -45,6 +46,18 @@ export interface IBlsVerifier {
    */
   verifySignatureSets(sets: ISignatureSet[], opts?: VerifySignatureOpts): Promise<boolean>;
 
+  /**
+   * Similar to verifySignatureSets but:
+   *   - all signatures have the same message
+   *   - return an array of boolean, each element indicates whether the corresponding signature set is valid
+   *   - only support `batchable` option
+   */
+  verifySignatureSetsSameMessage(
+    sets: {publicKey: PublicKey; signature: Uint8Array}[],
+    messsage: Uint8Array,
+    opts?: Omit<VerifySignatureOpts, "verifyOnMainThread">
+  ): Promise<boolean[]>;
+
   /** For multithread pool awaits terminating all workers */
   close(): Promise<void>;
 

packages/beacon-node/src/chain/bls/maybeBatch.ts

@@ -14,26 +14,33 @@ export type SignatureSetDeserialized = {
  * Abstracted in a separate file to be consumed by the threaded pool and the main thread implementation.
  */
 export function verifySignatureSetsMaybeBatch(sets: SignatureSetDeserialized[]): boolean {
-  if (sets.length >= MIN_SET_COUNT_TO_BATCH) {
-    return bls.Signature.verifyMultipleSignatures(
-      sets.map((s) => ({
-        publicKey: s.publicKey,
-        message: s.message,
-        // true = validate signature
-        signature: bls.Signature.fromBytes(s.signature, CoordType.affine, true),
-      }))
-    );
-  }
+  try {
+    if (sets.length >= MIN_SET_COUNT_TO_BATCH) {
+      return bls.Signature.verifyMultipleSignatures(
+        sets.map((s) => ({
+          publicKey: s.publicKey,
+          message: s.message,
+          // true = validate signature
+          signature: bls.Signature.fromBytes(s.signature, CoordType.affine, true),
+        }))
+      );
+    }
 
-  // .every on an empty array returns true
-  if (sets.length === 0) {
-    throw Error("Empty signature set");
-  }
+    // .every on an empty array returns true
+    if (sets.length === 0) {
+      throw Error("Empty signature set");
+    }
 
-  // If too few signature sets verify them without batching
-  return sets.every((set) => {
-    // true = validate signature
-    const sig = bls.Signature.fromBytes(set.signature, CoordType.affine, true);
-    return sig.verify(set.publicKey, set.message);
-  });
+    // If too few signature sets verify them without batching
+    return sets.every((set) => {
+      // true = validate signature
+      const sig = bls.Signature.fromBytes(set.signature, CoordType.affine, true);
+      return sig.verify(set.publicKey, set.message);
+    });
+  } catch (_) {
+    // A signature could be malformed, in that case fromBytes throws error
+    // blst-ts `verifyMultipleSignatures` is also a fallible operation if mul_n_aggregate fails
+    // see https://github.com/ChainSafe/blst-ts/blob/b1ba6333f664b08e5c50b2b0d18c4f079203962b/src/lib.ts#L291
+    return false;
+  }
 }