소스 검색

fix(syncing-server): add opentelemetry sdk shutdown

Karol Sójko 1 년 전
부모
커밋
a0e523e64c

+ 4 - 0
packages/domain-events-infra/src/Infra/OpenTelemetry/OpenTelemetrySDK.ts

@@ -98,4 +98,8 @@ export class OpenTelemetrySDK implements OpenTelemetrySDKInterface {
   start(): void {
   start(): void {
     this.sdk.start()
     this.sdk.start()
   }
   }
+
+  async shutdown(): Promise<void> {
+    await this.sdk.shutdown()
+  }
 }
 }

+ 1 - 0
packages/domain-events-infra/src/Infra/OpenTelemetry/OpenTelemetrySDKInterface.ts

@@ -1,3 +1,4 @@
 export interface OpenTelemetrySDKInterface {
 export interface OpenTelemetrySDKInterface {
   start(): void
   start(): void
+  shutdown(): Promise<void>
 }
 }

+ 8 - 0
packages/syncing-server/bin/server.ts

@@ -146,6 +146,14 @@ void container.load().then((container) => {
         logger.info('gRPC server closed')
         logger.info('gRPC server closed')
       }
       }
     })
     })
+    sdk
+      .shutdown()
+      .then(() => {
+        logger.info('OpenTelemetry SDK shut down')
+      })
+      .catch((error) => {
+        logger.error(`Failed to shut down OpenTelemetry SDK: ${error.message}`)
+      })
   })
   })
 
 
   logger.info(`Server started on port ${process.env.PORT}`)
   logger.info(`Server started on port ${process.env.PORT}`)