feat: rescan gRPC method (#489)

lib/cli/commands/Rescan.ts

@@ -0,0 +1,24 @@
+import { Arguments } from 'yargs';
+import { RescanRequest } from '../../proto/boltzrpc_pb';
+import BuilderComponents from '../BuilderComponents';
+import { callback, loadBoltzClient } from '../Command';
+
+export const command = 'rescan <symbol> <startHeight>';
+
+export const describe = 'rescans the chain of a symbol';
+
+export const builder = {
+  symbol: BuilderComponents.symbol,
+  startHeight: {
+    describe: 'block height to start the rescan from',
+    type: 'number',
+  },
+};
+
+export const handler = (argv: Arguments<any>): void => {
+  const request = new RescanRequest();
+  request.setSymbol(argv.symbol);
+  request.setStartHeight(argv.startHeight);
+
+  loadBoltzClient(argv).rescan(request, callback());
+};

lib/grpc/GrpcServer.ts

@@ -27,6 +27,7 @@ class GrpcServer {
       updateTimeoutBlockDelta: grpcService.updateTimeoutBlockDelta,
       addReferral: grpcService.addReferral,
       sweepSwaps: grpcService.sweepSwaps,
+      rescan: grpcService.rescan,
     });
   }
 

lib/grpc/GrpcService.ts

@@ -203,6 +203,23 @@ class GrpcService {
     });
   };
 
+  public rescan: handleUnaryCall<
+    boltzrpc.RescanRequest,
+    boltzrpc.RescanResponse
+  > = async (call, callback) => {
+    await this.handleCallback(call, callback, async () => {
+      const { symbol, startHeight } = call.request.toObject();
+
+      const endHeight = await this.service.rescan(symbol, startHeight);
+
+      const response = new boltzrpc.RescanResponse();
+      response.setStartHeight(startHeight);
+      response.setEndHeight(endHeight);
+
+      return response;
+    });
+  };
+
   private handleCallback = async <R, T>(
     call: R,
     callback: (error: any, res: T | null) => void,