Add unit test for retries

Signed-off-by: Matthew Whitehead <matthew1001@gmail.com>

Author: matthew1001

src/tokens/tokens.service.spec.ts

@@ -196,6 +196,14 @@ describe('TokensService', () => {
     );
   };
 
+  const mockECONNErrors = (count: number) => {
+    for (let i = 0; i < count; i++) {
+      http.post.mockImplementationOnce(() => {
+        throw new Error('connect ECONNREFUSED 10.1.2.3');
+      });
+    }
+  };
+
   beforeEach(async () => {
     http = {
       get: jest.fn(),
@@ -234,8 +242,8 @@ describe('TokensService', () => {
 
     let blockchainRetryCfg: RetryConfiguration = {
       retryBackOffFactor: 2,
-      retryBackOffLimit: 10000,
-      retryBackOffInitial: 100,
+      retryBackOffLimit: 500,
+      retryBackOffInitial: 50,
       retryCondition: '.*ECONN.*',
       retriesMax: 15,
     };
@@ -1050,6 +1058,49 @@ describe('TokensService', () => {
       expect(http.post).toHaveBeenCalledWith(BASE_URL, mockEthConnectRequest, { headers });
     });
 
+    it('should mint ERC721WithData token with correct abi, custom uri, and inputs after 6 ECONNREFUSED retries', async () => {
+      const ctx = newContext();
+      const headers = {
+        'x-firefly-request-id': ctx.requestId,
+      };
+
+      const request: TokenMint = {
+        tokenIndex: '721',
+        signer: IDENTITY,
+        poolLocator: ERC721_WITH_DATA_V1_POOL_ID,
+        to: '0x123',
+        uri: 'ipfs://CID',
+      };
+
+      const response: EthConnectAsyncResponse = {
+        id: 'responseId',
+        sent: true,
+      };
+
+      const mockEthConnectRequest: EthConnectMsgRequest = {
+        headers: {
+          type: 'SendTransaction',
+        },
+        from: IDENTITY,
+        to: CONTRACT_ADDRESS,
+        method: ERC721WithDataV1ABI.abi.find(abi => abi.name === MINT_WITH_URI) as IAbiMethod,
+        params: ['0x123', '721', '0x00', 'ipfs://CID'],
+      };
+
+      http.post.mockReturnValueOnce(
+        new FakeObservable(<EthConnectReturn>{
+          output: true,
+        }),
+      );
+      mockECONNErrors(6);
+      http.post.mockReturnValueOnce(new FakeObservable(response));
+
+      await service.mint(ctx, request);
+
+      expect(http.post).toHaveBeenCalledWith(BASE_URL, mockEthConnectRequest, { headers });
+      expect(http.post).toHaveBeenCalledTimes(8); // Expect initial submit OK, 6 ECONN errors, final call OK = 8 POSTs
+    });
+
     it('should mint ERC721WithData token with correct abi, custom uri, auto-indexing, and inputs', async () => {
       const ctx = newContext();
       const headers = {

test/app.e2e-context.ts

@@ -12,7 +12,7 @@ import { EventStreamService } from '../src/event-stream/event-stream.service';
 import { EventStreamProxyGateway } from '../src/eventstream-proxy/eventstream-proxy.gateway';
 import { TokensService } from '../src/tokens/tokens.service';
 import { requestIDMiddleware } from '../src/request-context/request-id.middleware';
-import { BlockchainConnectorService } from '../src/tokens/blockchain.service';
+import { BlockchainConnectorService, RetryConfiguration } from '../src/tokens/blockchain.service';
 
 export const BASE_URL = 'http://eth';
 export const INSTANCE_PATH = '/tokens';
@@ -69,11 +69,19 @@ export class TestContext {
     this.app.use(requestIDMiddleware);
     await this.app.init();
 
+    let blockchainRetryCfg: RetryConfiguration = {
+      retryBackOffFactor: 2,
+      retryBackOffLimit: 500,
+      retryBackOffInitial: 50,
+      retryCondition: '.*ECONN.*',
+      retriesMax: 15,
+    };
+
     this.app.get(EventStreamProxyGateway).configure('url', TOPIC);
     this.app.get(TokensService).configure(BASE_URL, TOPIC, '');
     this.app
       .get(BlockchainConnectorService)
-      .configure(BASE_URL, '', '', '', [], 2, 1000, 250, '.*ECONN.*', 15);
+      .configure(BASE_URL, '', '', '', [], blockchainRetryCfg);
 
     (this.app.getHttpServer() as Server).listen();
     this.server = request(this.app.getHttpServer());