Add Sentry txn observability for webhooks (#877)

* Add txn logging

* Delete unused index.ts files

* Fix tests

* Add http status to txn

Author: brian-lou

src/webhooks/bootstrap-dev-env/index.ts

@@ -88,7 +88,7 @@ describe('cron jobs testing', function () {
       }
     );
     const reply = new MockReply() as FastifyReply;
-    await handleRoute(mockError, {} as FastifyRequest, reply);
+    await handleRoute(mockError, {} as FastifyRequest, reply, '');
     expect(mockError).toHaveBeenCalled();
     expect(reply.statusCode).toBe(400);
   });

src/webhooks/gocd/index.ts

@@ -1,3 +1,5 @@
+import '@sentry/tracing';
+
 import * as Sentry from '@sentry/node';
 import { FastifyReply, FastifyRequest } from 'fastify';
 
@@ -9,38 +11,48 @@ import { kafkactlWebhook } from './kafka-control-plane/kafka-control-plane';
 import { sentryOptionsWebhook } from './sentry-options/sentry-options';
 import { webpackWebhook } from './webpack/webpack';
 
+type WebhookHandler = (
+  request: FastifyRequest<any>,
+  reply: FastifyReply
+) => Promise<void>;
+
 // Error handling wrapper function
 export async function handleRoute(
-  handler,
+  handler: WebhookHandler,
   request: FastifyRequest,
-  reply: FastifyReply
+  reply: FastifyReply,
+  name: string
 ): Promise<void> {
+  const tx = Sentry.startTransaction({
+    op: 'webhooks',
+    name: 'webhooks.' + name,
+  });
   try {
     await handler(request, reply);
   } catch (err) {
-    console.error(err);
     Sentry.captureException(err);
     reply.code(400).send('Bad Request');
-    return;
+    tx.setHttpStatus(400);
   }
+  tx.finish();
 }
 
 // Function that maps routes to their respective handlers
 export async function routeHandlers(server: Fastify, _options): Promise<void> {
   server.post('/metrics/bootstrap-dev-env/webhook', (request, reply) =>
-    handleRoute(bootstrapWebhook, request, reply)
+    handleRoute(bootstrapWebhook, request, reply, 'bootstrap-dev-env')
   );
   server.post('/metrics/gocd/webhook', (request, reply) =>
-    handleRoute(gocdWebhook, request, reply)
+    handleRoute(gocdWebhook, request, reply, 'gocd')
   );
   server.post('/metrics/kafka-control-plane/webhook', (request, reply) =>
-    handleRoute(kafkactlWebhook, request, reply)
+    handleRoute(kafkactlWebhook, request, reply, 'kafka-control-plane')
   );
   server.post('/metrics/sentry-options/webhook', (request, reply) =>
-    handleRoute(sentryOptionsWebhook, request, reply)
+    handleRoute(sentryOptionsWebhook, request, reply, 'sentry-options')
   );
   server.post('/metrics/webpack/webhook', (request, reply) =>
-    handleRoute(webpackWebhook, request, reply)
+    handleRoute(webpackWebhook, request, reply, 'webpack')
   );
 
   // Default handler for invalid routes