Merge pull request #436 from g-ongenae/feature/keep-alive

Ensure calls on categories

Author: fabong

config/default.json

@@ -26,5 +26,7 @@
   "customerIdPassword": "password",
   "activateBridgeRequestInterceptor": true,
   "forceBridgeUsersDeletion": false,
-  "disableMasking": false
+  "disableMasking": false,
+  "cacheTtlOfCategory": 604800,
+  "cacheTtlOfBankInfo": 86400
 }

package-lock.json

@@ -31,6 +31,7 @@
     "@nestjs/core": "^8.4.7",
     "@nestjs/platform-express": "^8.4.7",
     "axios": "^0.27.2",
+    "axios-retry": "^4.5.0",
     "cache-manager": "^4.0.1",
     "class-transformer": "^0.5.1",
     "class-validator": "^0.14.0",

package.json

@@ -8,7 +8,6 @@ import {
   BridgeAccount,
   BridgeRefreshStatus,
   BridgeTransaction,
-  BridgeUserInformation,
   UserAccount,
 } from '../interfaces/bridge.interface';
 import { BridgeClient, ClientConfig } from './bridge/bridge.client';

src/aggregator/services/aggregator.service.ts

@@ -1,6 +1,8 @@
+import { Agent } from 'node:http';
 import { HttpService } from '@nestjs/axios';
 import { CACHE_MANAGER, Inject, Injectable, Logger } from '@nestjs/common';
 import { AxiosError, AxiosRequestConfig, AxiosRequestHeaders, AxiosResponse, AxiosResponseHeaders } from 'axios';
+import axiosRetry, { exponentialDelay } from 'axios-retry';
 import { Cache } from 'cache-manager';
 import { isNil } from 'lodash';
 import { config } from 'node-config-ts';
@@ -44,6 +46,19 @@ export class BridgeClient {
   private readonly logger: Logger = new Logger(BridgeClient.name);
 
   constructor(@Inject(CACHE_MANAGER) private readonly cacheManager: Cache, private readonly httpService: HttpService) {
+    const httpAgent = new Agent({ keepAlive: true });
+
+    this.httpService.axiosRef.defaults.httpAgent = httpAgent;
+    this.httpService.axiosRef.defaults.httpsAgent = httpAgent;
+
+    axiosRetry(this.httpService.axiosRef, {
+      retries: 3,
+      retryDelay: exponentialDelay,
+      retryCondition: (err: AxiosError) =>
+        axiosRetry.isNetworkOrIdempotentRequestError(err) ||
+        ['ECONNRESET', 'ETIMEDOUT', 'EAI_AGAIN'].includes(err.code as string),
+    });
+
     if (config.activateBridgeRequestInterceptor) {
       this.httpService.axiosRef.interceptors.request.use((_config: AxiosRequestConfig): AxiosRequestConfig => {
         this.logger.log(`${_config.method} ${_config.url} - Request to Bridge`);
@@ -82,7 +97,9 @@ export class BridgeClient {
     const url: string = `${config.bridge.baseUrl}/v2/users`;
 
     const resp: AxiosResponse<UserResponse> = await BridgeClient.toPromise(
-      this.httpService.post(url, userAccount, { headers: { ...BridgeClient.getHeaders(clientConfig) } }),
+      this.httpService.post(url, userAccount, {
+        headers: { ...BridgeClient.getHeaders(clientConfig) },
+      }),
     );
     this.logger.debug(`User created with email ${userAccount.email}`);
 
@@ -232,7 +249,7 @@ export class BridgeClient {
         }),
       );
       const { name } = resp.data;
-      await this.cacheManager.set(url, name, { ttl: 86400 });
+      await this.cacheManager.set(url, name, { ttl: config.cacheTtlOfCategory });
 
       return name;
     } catch (err) {
@@ -274,7 +291,7 @@ export class BridgeClient {
         name: resp.data.name,
         logoUrl: resp.data.logo_url,
       };
-      await this.cacheManager.set(url, bankInfo, { ttl: 86400 });
+      await this.cacheManager.set(url, bankInfo, { ttl: config.cacheTtlOfBankInfo });
 
       return bankInfo;
     } catch (err) {