Add eth_getPlumeSignature RPC handler

src/wallet.ts

@@ -62,6 +62,10 @@ export interface WalletMiddlewareOptions {
     req: JsonRpcRequest<unknown>,
     version: string,
   ) => Promise<string>;
+  processPlumeSignature?: (
+    msgParams: MessageParams,
+    req: JsonRpcRequest<unknown>,
+  ) => Promise<string>;
 }
 
 export function createWalletMiddleware({
@@ -75,6 +79,7 @@ export function createWalletMiddleware({
   processTypedMessage,
   processTypedMessageV3,
   processTypedMessageV4,
+  processPlumeSignature,
 }: WalletMiddlewareOptions): JsonRpcMiddleware<string, Block> {
   if (!getAccounts) {
     throw new Error('opts.getAccounts is required');
@@ -96,6 +101,7 @@ export function createWalletMiddleware({
     eth_getEncryptionPublicKey: createAsyncMiddleware(encryptionPublicKey),
     eth_decrypt: createAsyncMiddleware(decryptMessage),
     personal_ecRecover: createAsyncMiddleware(personalRecover),
+    eth_getPlumeSignature: createAsyncMiddleware(plumeSignature),
   });
 
   //
@@ -356,6 +362,30 @@ export function createWalletMiddleware({
     res.result = await processDecryptMessage(msgParams, req);
   }
 
+  async function plumeSignature(
+    req: JsonRpcRequest<unknown>,
+    res: PendingJsonRpcResponse<unknown>,
+  ): Promise<void> {
+    if (!processPlumeSignature) {
+      throw ethErrors.rpc.methodNotSupported();
+    }
+
+    const message: string = (req.params as string[])[0];
+    const address: string = await validateAndNormalizeKeyholder(
+      (req.params as string[])[1],
+      req,
+    );
+    const extraParams: Record<string, unknown> =
+      (req.params as Record<string, unknown>[])[2] || {};
+    const msgParams: MessageParams = {
+      ...extraParams,
+      from: address,
+      data: message,
+    };
+
+    res.result = await processPlumeSignature(msgParams, req);
+  }
+
   //
   // utility
   //