Add singleton principle to RestService

Author: Claimundefine

schemaregistry/package.json

@@ -59,6 +59,7 @@
   "scripts": {
     "lint": "make lint",
     "test": "make test",
+    "integtest": "make integtest",
     "build": "rm -rf ./dist && tsc -p tsconfig-build.json"
   },
   "keywords": [

schemaregistry/rest-service.ts

@@ -51,14 +51,15 @@ export interface ClientConfig {
 const toBase64 = (str: string): string => Buffer.from(str).toString('base64');
 
 export class RestService {
+  private static instance: RestService;
   private client: AxiosInstance;
   private baseURLs: string[];
   private oauthClient?: OAuthClient;
   private oauthBearer: boolean = false;
 
   constructor(baseURLs: string[], isForward?: boolean, axiosDefaults?: CreateAxiosDefaults,
-              basicAuthCredentials?: BasicAuthCredentials, bearerAuthCredentials?: BearerAuthCredentials,
-              maxRetries?: number, retriesWaitMs?: number, retriesMaxWaitMs?: number) {
+    basicAuthCredentials?: BasicAuthCredentials, bearerAuthCredentials?: BearerAuthCredentials,
+    maxRetries?: number, retriesWaitMs?: number, retriesMaxWaitMs?: number) {
     this.client = axios.create(axiosDefaults);
     axiosRetry(this.client, {
       retries: maxRetries ?? 2,
@@ -80,6 +81,16 @@ export class RestService {
     this.handleBearerAuth(maxRetries ?? 2, retriesWaitMs ?? 1000, retriesMaxWaitMs ?? 20000, bearerAuthCredentials);
   }
 
+  static getInstance(baseURLs: string[], isForward?: boolean, axiosDefaults?: CreateAxiosDefaults,
+    basicAuthCredentials?: BasicAuthCredentials, bearerAuthCredentials?: BearerAuthCredentials,
+    maxRetries?: number, retriesWaitMs?: number, retriesMaxWaitMs?: number): RestService {
+    if (!this.instance) {
+      this.instance = new RestService(baseURLs, isForward, axiosDefaults, basicAuthCredentials, bearerAuthCredentials,
+        maxRetries, retriesWaitMs, retriesMaxWaitMs);
+    }
+    return this.instance;
+  }
+
   handleBasicAuth(basicAuthCredentials?: BasicAuthCredentials): void {
     if (basicAuthCredentials) {
       switch (basicAuthCredentials.credentialsSource) {
@@ -111,7 +122,7 @@ export class RestService {
     }
   }
 
-  handleBearerAuth(maxRetries: number, 
+  handleBearerAuth(maxRetries: number,
     retriesWaitMs: number, retriesMaxWaitMs: number, bearerAuthCredentials?: BearerAuthCredentials): void {
     if (bearerAuthCredentials) {
       delete this.client.defaults.auth;
@@ -150,7 +161,7 @@ export class RestService {
           }
           const issuerEndPointUrl = new URL(bearerAuthCredentials.issuerEndpointUrl!);
           this.oauthClient = new OAuthClient(bearerAuthCredentials.clientId!, bearerAuthCredentials.clientSecret!,
-            issuerEndPointUrl.origin, issuerEndPointUrl.pathname, bearerAuthCredentials.scope!, 
+            issuerEndPointUrl.origin, issuerEndPointUrl.pathname, bearerAuthCredentials.scope!,
             maxRetries, retriesWaitMs, retriesMaxWaitMs);
           break;
         default:

schemaregistry/rules/encryption/dekregistry/dekregistry-client.ts

@@ -70,7 +70,7 @@ class DekRegistryClient implements DekClient {
     };
 
 
-    this.restService = new RestService(config.baseURLs, config.isForward, config.createAxiosDefaults,
+    this.restService = RestService.getInstance(config.baseURLs, config.isForward, config.createAxiosDefaults,
       config.basicAuthCredentials, config.bearerAuthCredentials,
       config.maxRetries, config.retriesWaitMs, config.retriesMaxWaitMs);
     this.kekCache = new LRUCache<string, Kek>(cacheOptions);

schemaregistry/schemaregistry-client.ts

@@ -201,7 +201,7 @@ export class SchemaRegistryClient implements Client {
       ...(config.cacheLatestTtlSecs !== undefined && { ttl: config.cacheLatestTtlSecs * 1000 })
     };
 
-    this.restService = new RestService(config.baseURLs, config.isForward, config.createAxiosDefaults,
+    this.restService = RestService.getInstance(config.baseURLs, config.isForward, config.createAxiosDefaults,
       config.basicAuthCredentials, config.bearerAuthCredentials,
       config.maxRetries, config.retriesWaitMs, config.retriesMaxWaitMs);