metrics: uTP streams opened

Author: ScottyPoi

packages/portalnetwork/src/util/metrics.ts

@@ -79,12 +79,27 @@ const ultralightMetrics = [
     metric: MetricType.Counter,
     help: 'how many UTP packets have been received',
   },
+  {
+    name: 'utpStreamsTotal',
+    metric: MetricType.Gauge,
+    help: 'how many total UTP streams were opened',
+  },
+  {
+    name: 'utpWriteStreams',
+    metric: MetricType.Gauge,
+    help: 'how many UTP write streams were opened',
+  },
+  {
+    name: 'utpReadStreams',
+    metric: MetricType.Gauge,
+    help: 'how many UTP read streams were opened',
+  },
 ]
 
 export const setupMetrics = (
   networks: NetworkId[] = [NetworkId.HistoryNetwork],
 ): PortalNetworkMetrics => {
-  const metrics = createMetrics(ultralightMetrics, [...networks, NetworkId.UTPNetwork])
+  const metrics = createMetrics(ultralightMetrics, [...networks])
   return {
     ...metrics,
     totalContentLookups: new Gauge<string>({

packages/portalnetwork/src/wire/utp/PortalNetworkUtp/index.ts

@@ -90,6 +90,23 @@ export class PortalNetworkUTP {
 
   async handleNewRequest(params: INewRequest): Promise<ContentRequestType> {
     const { contentKeys, enr, connectionId, requestCode } = params
+    if (this.client.metrics) {
+      const utpMetric = (NetworkNames[params.networkId] +
+        '_utpStreamsTotal') as keyof PortalNetworkMetrics
+      this.client.metrics[utpMetric].inc()
+      if (
+        requestCode === RequestCode.FOUNDCONTENT_WRITE ||
+        requestCode === RequestCode.OFFER_WRITE
+      ) {
+        const utpWriteMetric = (NetworkNames[params.networkId] +
+          '_utpWriteStreams') as keyof PortalNetworkMetrics
+        this.client.metrics[utpWriteMetric].inc()
+      } else {
+        const utpReadMetric = (NetworkNames[params.networkId] +
+          '_utpReadStreams') as keyof PortalNetworkMetrics
+        this.client.metrics[utpReadMetric].inc()
+      }
+    }
     if (this.requestManagers[enr.nodeId] === undefined) {
       this.requestManagers[enr.nodeId] = new RequestManager(enr.nodeId, this.logger)
     }