feat: adds factory pattern for relay class, to support future redis client …

.eslintrc.js

@@ -39,7 +39,6 @@ module.exports = {
         "@typescript-eslint/no-explicit-any": "off",
         "@typescript-eslint/no-var-requires": "warn",
         "@typescript-eslint/no-unused-vars": "warn",
-        "@typescript-eslint/ban-types": "warn",
         "no-trailing-spaces": "error",
         "no-useless-escape": "warn",
         "prefer-const": "error",

packages/relay/src/lib/relay.ts

@@ -116,13 +116,13 @@ export class Relay {
   private readonly rpcMethodDispatcher: RpcMethodDispatcher;
 
   /**
-   * Initializes the main components of the relay service, including Hedera network clients,
-   * Ethereum-compatible interfaces, caching, metrics, and subscription management.
+   * Private constructor to prevent direct instantiation.
+   * Use Relay.init() static factory method instead.
    *
    * @param {Logger} logger - Logger instance for logging system messages.
    * @param {Registry} register - Registry instance for registering metrics.
    */
-  constructor(
+  private constructor(
     private readonly logger: Logger,
     register: Registry,
   ) {
@@ -341,4 +341,28 @@ export class Relay {
       this.logger.info(`Operator account '${operator}' has balance: ${balance}`);
     }
   }
+
+  /**
+   * Static factory method to create and initialize a Relay instance.
+   * This is the recommended way to create a Relay instance as it ensures
+   * all async initialization (operator balance check) is complete.
+   *
+   * @param {Logger} logger - Logger instance for logging system messages.
+   * @param {Registry} register - Registry instance for registering metrics.
+   * @returns {Promise<Relay>} A fully initialized Relay instance.
+   *
+   * @example
+   * ```typescript
+   * const relay = await Relay.init(logger, register);
+   * ```
+   */
+  static async init(logger: Logger, register: Registry): Promise<Relay> {
+    // Create Relay instance
+    const relay = new Relay(logger, register);
+
+    // Check operator balance if not in read-only mode
+    await relay.ensureOperatorHasBalance();
+
+    return relay;
+  }
 }

packages/server/src/index.ts

@@ -2,21 +2,21 @@
 
 import { ConfigService } from '@hashgraph/json-rpc-config-service/dist/services';
 
-import { setServerTimeout } from './koaJsonRpc/lib/utils'; // Import the 'setServerTimeout' function from the correct location
-import app, { logger, relay } from './server';
+import { setServerTimeout } from './koaJsonRpc/lib/utils';
+import { initializeServer, logger } from './server';
 
 async function main() {
   try {
-    await relay.ensureOperatorHasBalance();
+    // Initialize server with the fully initialized Relay
+    const { app } = await initializeServer();
+    const server = app.listen({ port: ConfigService.get('SERVER_PORT'), host: ConfigService.get('SERVER_HOST') });
+
+    // set request timeout to ensure sockets are closed after specified time of inactivity
+    setServerTimeout(server);
   } catch (error) {
     logger.fatal(error);
     process.exit(1);
   }
-
-  const server = app.listen({ port: ConfigService.get('SERVER_PORT'), host: ConfigService.get('SERVER_HOST') });
-
-  // set request timeout to ensure sockets are closed after specified time of inactivity
-  setServerTimeout(server);
 }
 
 main();