fix: included telemetry service back into backend and connector

packages/backend/src/index.ts

@@ -49,7 +49,7 @@ import { createIlpPaymentService } from './payment-method/ilp/service'
 import { createSPSPRoutes } from './payment-method/ilp/spsp/routes'
 import { createStreamCredentialsService } from './payment-method/ilp/stream-credentials/service'
 import { createRatesService } from './rates/service'
-import { createTelemetryService } from './telemetry/service'
+import { TelemetryService, createTelemetryService } from './telemetry/service'
 import { createWebhookService } from './webhook/service'
 
 BigInt.prototype.toJSON = function () {
@@ -358,6 +358,10 @@ export function initIocContainer(
 
   container.singleton('connectorApp', async (deps) => {
     const config = await deps.use('config')
+    let telemetry: TelemetryService | undefined
+    if (config.enableTelemetry) {
+      telemetry = await deps.use('telemetry')
+    }
     return await createConnectorService({
       logger: await deps.use('logger'),
       redis: await deps.use('redis'),
@@ -367,7 +371,8 @@ export function initIocContainer(
       peerService: await deps.use('peerService'),
       ratesService: await deps.use('ratesService'),
       streamServer: await deps.use('streamServer'),
-      ilpAddress: config.ilpAddress
+      ilpAddress: config.ilpAddress,
+      telemetry
     })
   })
 

packages/backend/src/payment-method/ilp/connector/index.ts

@@ -27,6 +27,7 @@ import {
   createStreamAddressMiddleware,
   createStreamController
 } from './core'
+import { TelemetryService } from '../../../telemetry/service'
 
 interface ServiceDependencies extends BaseService {
   redis: Redis
@@ -37,6 +38,7 @@ interface ServiceDependencies extends BaseService {
   peerService: PeerService
   streamServer: StreamServer
   ilpAddress: string
+  telemetry?: TelemetryService
 }
 
 export async function createConnectorService({
@@ -48,7 +50,8 @@ export async function createConnectorService({
   incomingPaymentService,
   peerService,
   streamServer,
-  ilpAddress
+  ilpAddress,
+  telemetry,
 }: ServiceDependencies): Promise<Rafiki> {
   return createApp(
     {
@@ -62,7 +65,8 @@ export async function createConnectorService({
       peers: peerService,
       redis,
       rates: ratesService,
-      streamServer
+      streamServer,
+      telemetry
     },
     compose([
       // Incoming Rules