feat: throw GrpcError if state transaction was broadcasted twice

lib/grpcServer/handlers/platform/broadcastStateTransitionHandlerFactory.js

@@ -2,6 +2,7 @@ const {
   server: {
     error: {
       InvalidArgumentGrpcError,
+      FailedPreconditionGrpcError,
     },
   },
 } = require('@dashevo/grpc-common');
@@ -41,6 +42,10 @@ function broadcastStateTransitionHandlerFactory(rpcClient, handleAbciResponseErr
     const { result, error: jsonRpcError } = await rpcClient.request('broadcast_tx_commit', { tx });
 
     if (jsonRpcError) {
+      if (jsonRpcError.data === 'error on broadcastTxCommit: tx already exists in cache') {
+        throw new FailedPreconditionGrpcError(jsonRpcError.data, jsonRpcError);
+      }
+
       const error = new Error();
       Object.assign(error, jsonRpcError);
 

test/unit/grpcServer/handlers/platform/broadcastStateTransitionHandlerFactory.js

@@ -2,6 +2,7 @@ const {
   server: {
     error: {
       InvalidArgumentGrpcError,
+      FailedPreconditionGrpcError,
     },
   },
 } = require('@dashevo/grpc-common');
@@ -156,4 +157,21 @@ describe('broadcastStateTransitionHandlerFactory', () => {
       expect(e.code).to.equal(error.code);
     }
   });
+
+  it('should throw FailedPreconditionGrpcError if transaction was broadcasted twice', async () => {
+    const error = {
+      code: -32603,
+      message: 'Internal error',
+      data: 'error on broadcastTxCommit: tx already exists in cache',
+    };
+
+    response.error = error;
+
+    try {
+      await broadcastStateTransitionHandler(call);
+    } catch (e) {
+      expect(e).to.be.an.instanceOf(FailedPreconditionGrpcError);
+      expect(e.getMessage()).to.equal(`Failed precondition: ${error.data}`);
+    }
+  });
 });