Merge pull request #71 from autonomys/fix-express-app

feat: refactor RPC server setup and configuration management

Author: clostao

services/object-mapping-indexer/src/config.ts

@@ -1,11 +1,12 @@
+import 'dotenv/config'
 import { env, notNaN } from './utils/env.js'
 
 export const config = {
   port: Number(env('OBJECT_MAPPING_INDEXER_PORT', '3000')),
   requestSizeLimit: env('REQUEST_SIZE_LIMIT', '200mb'),
   corsAllowOrigins: env('CORS_ALLOW_ORIGINS', ''),
   nodeRpcUrl: env('NODE_RPC_URL'),
-  recoveryInterval: notNaN(Number(env('RECOVERY_INTERVAL', '100'))),
+  recoveryInterval: notNaN(Number(env('RECOVERY_INTERVAL', '1000'))),
   logLevel: env(
     'LOG_LEVEL',
     process.env.NODE_ENV === 'production' ? 'info' : 'debug',

services/object-mapping-indexer/src/index.ts

@@ -1,2 +1,2 @@
-import './server.js'
+import './rpc/server.js'
 import './listeners.js'

services/object-mapping-indexer/src/rpc/server.ts

@@ -2,8 +2,11 @@ import http from 'http'
 import { objectMappingRouter } from '../services/objectMappingRouter/index.js'
 import { ObjectMappingIndexerRPCApi } from '@auto-files/rpc-apis'
 import { expressApp } from '../http/api.js'
+import { Application } from 'express'
+import { config } from '../config.js'
+import { logger } from '../drivers/logger.js'
 
-const createObjectMappingsRPCServer = (app: Express.Application) => {
+const createObjectMappingsRPCServer = (app: Application) => {
   return ObjectMappingIndexerRPCApi.createServer(
     {
       subscribe_object_mappings: async (_, { connection }) => {
@@ -40,7 +43,9 @@ const createObjectMappingsRPCServer = (app: Express.Application) => {
     },
     {
       server: {
-        httpServer: http.createServer(app),
+        httpServer: app.listen(config.port, () => {
+          logger.info(`Server is running on port ${config.port}`)
+        }),
         callbacks: {},
       },
     },