chore: instrument wallet connect provider (#165)

src/helpers/metrics.ts

@@ -2,6 +2,7 @@ import init, { client } from '@snapshot-labs/snapshot-metrics';
 import type { Express } from 'express';
 import { capture } from '@snapshot-labs/snapshot-sentry';
 import db from './mysql';
+import { getSubscribersFromWalletConnect } from '../providers/walletconnectNotify';
 
 export default function initMetrics(app: Express) {
   init(app, {
@@ -48,6 +49,10 @@ new client.Gauge({
         )
       )[0].count as any
     );
+    this.set(
+      { type: 'walletconnect' },
+      (await getSubscribersFromWalletConnect()).length
+    );
   }
 });
 

src/providers/walletconnectNotify.ts

@@ -1,5 +1,6 @@
 import fetch from 'node-fetch';
 import { capture } from '@snapshot-labs/snapshot-sentry';
+import { timeOutgoingRequest } from '../helpers/metrics';
 
 const WALLETCONNECT_NOTIFY_SERVER_URL =
   process.env.WALLETCONNECT_NOTIFY_SERVER_URL;
@@ -95,6 +96,9 @@ export async function sendNotification(notification, accounts) {
     notification
   };
 
+  const end = timeOutgoingRequest.startTimer({ provider: 'walletconnect' });
+  let success = false;
+
   try {
     const notifyRs = await fetch(notifyUrl, {
       method: 'POST',
@@ -106,10 +110,12 @@ export async function sendNotification(notification, accounts) {
     });
 
     const notifySuccess = await notifyRs.json();
-
+    success = true;
     return notifySuccess;
   } catch (e) {
     capture('[WalletConnect] failed to notify subscribers', e);
+  } finally {
+    end({ status: success ? 200 : 500 });
   }
 }