Fixup test

Author: santigimeno

test/integrations/fastify/v5/test-http-route.mjs

@@ -69,6 +69,14 @@ function checkHttpRouteAttribute(metricsData, expectedRoutes) {
   return foundRoutes;
 }
 
+function createMetricsTimeout(ms) {
+  return new Promise((_, reject) => {
+    setTimeout(() => {
+      reject(new Error(`Timed out waiting for metrics after ${ms}ms`));
+    }, ms);
+  });
+}
+
 async function runTest() {
   // Start gRPC server as child process
   const grpcServer = new GRPCServer();
@@ -109,6 +117,7 @@ async function runTest() {
   // Track which routes we've seen
   const expectedRoutes = new Set(['/users/:id', '/posts/:postId', '/health']);
   const foundRoutes = new Set();
+  const metricsTimeoutMs = 10_000;
 
   // Listen for metrics
   const metricsPromise = new Promise((resolve, reject) => {
@@ -127,6 +136,10 @@ async function runTest() {
       }
     });
   });
+  const waitForMetrics = Promise.race([
+    metricsPromise,
+    createMetricsTimeout(metricsTimeoutMs),
+  ]);
 
   // Make HTTP requests to trigger routes
   console.log('Making HTTP requests...');
@@ -146,13 +159,20 @@ async function runTest() {
   assert.strictEqual(response.status, 200);
   console.log('Requested /health');
 
-  // Wait for all metrics to be reported
-  await metricsPromise;
-
-  // Cleanup
-  console.log('Cleaning up...');
-  await fastify.close();
-  grpcServer.close();
+  try {
+    // Wait for all metrics to be reported
+    await waitForMetrics;
+  } finally {
+    console.log('Cleaning up...');
+    await fastify.close().catch((err) => {
+      console.error('Failed to close Fastify server', err);
+    });
+    try {
+      grpcServer.close();
+    } catch (err) {
+      console.error('Failed to close gRPC server', err);
+    }
+  }
 }
 
 await runTest();