test runner improvements

Author: mydea

dev-packages/node-integration-tests/package.json

@@ -27,9 +27,9 @@
   "dependencies": {
     "@aws-sdk/client-s3": "^3.552.0",
     "@hapi/hapi": "^21.3.10",
-    "@nestjs/common": "10.4.5",
-    "@nestjs/core": "10.4.5",
-    "@nestjs/platform-express": "10.4.5",
+    "@nestjs/common": "10.4.0",
+    "@nestjs/core": "10.4.0",
+    "@nestjs/platform-express": "10.4.0",
     "@prisma/client": "5.9.1",
     "@sentry/aws-serverless": "8.37.1",
     "@sentry/node": "8.37.1",

dev-packages/node-integration-tests/utils/runner.ts

@@ -15,6 +15,7 @@ import type {
 } from '@sentry/types';
 import axios from 'axios';
 import { createBasicSentryServer } from './server';
+import { normalize } from '@sentry/utils';
 
 export function assertSentryEvent(actual: Event, expected: Event): void {
   expect(actual).toMatchObject({
@@ -130,8 +131,7 @@ async function runDockerCompose(options: DockerOptions): Promise<VoidFunction> {
     function newData(data: Buffer): void {
       const text = data.toString('utf8');
 
-      // eslint-disable-next-line no-console
-      if (process.env.DEBUG) console.log(text);
+      if (process.env.DEBUG) log(text);
 
       for (const match of options.readyMatches) {
         if (text.includes(match)) {
@@ -254,7 +254,7 @@ export function createRunner(...paths: string[]) {
 
       function complete(error?: Error): void {
         child?.kill();
-        done?.(error);
+        done?.(normalize(error));
       }
 
       /** Called after each expect callback to check if we're complete */
@@ -379,6 +379,8 @@ export function createRunner(...paths: string[]) {
         ? runDockerCompose(dockerOptions)
         : Promise.resolve(undefined);
 
+      log('before start');
+
       const startup = Promise.all([dockerStartup, serverStartup]) as Promise<[DockerStartup, ServerStartup]>;
 
       startup
@@ -397,8 +399,7 @@ export function createRunner(...paths: string[]) {
             ? { ...process.env, ...withEnv, SENTRY_DSN: `http://public@localhost:${mockServerPort}/1337` }
             : { ...process.env, ...withEnv };
 
-          // eslint-disable-next-line no-console
-          if (process.env.DEBUG) console.log('starting scenario', testPath, flags, env.SENTRY_DSN);
+          if (process.env.DEBUG) log('starting scenario', testPath, flags, env.SENTRY_DSN);
 
           child = spawn('node', [...flags, testPath], { env });
 
@@ -425,8 +426,7 @@ export function createRunner(...paths: string[]) {
 
           // Pass error to done to end the test quickly
           child.on('error', e => {
-            // eslint-disable-next-line no-console
-            if (process.env.DEBUG) console.log('scenario error', e);
+            if (process.env.DEBUG) log('scenario error', e);
             complete(e);
           });
 
@@ -465,8 +465,7 @@ export function createRunner(...paths: string[]) {
               logs.push(line.trim());
 
               buffer = Buffer.from(buffer.subarray(splitIndex + 1));
-              // eslint-disable-next-line no-console
-              if (process.env.DEBUG) console.log('line', line);
+              if (process.env.DEBUG) log('line', line);
               tryParseEnvelopeFromStdoutLine(line);
             }
           });
@@ -490,28 +489,34 @@ export function createRunner(...paths: string[]) {
             await waitFor(() => scenarioServerPort !== undefined);
           } catch (e) {
             complete(e as Error);
-            return undefined;
+            return;
           }
 
           const url = `http://localhost:${scenarioServerPort}${path}`;
-          if (expectError) {
-            try {
-              if (method === 'get') {
-                await axios.get(url, { headers });
-              } else {
-                await axios.post(url, data, { headers });
-              }
-            } catch (e) {
+
+          try {
+            if (method === 'post') {
+              const res = await axios.post(url, data, { headers });
+              return res.data;
+            } else {
+              const res = await axios.get(url, { headers });
+              return res.data;
+            }
+          } catch (e) {
+            if (expectError) {
               return;
             }
+
+            complete(e as Error);
             return;
-          } else if (method === 'get') {
-            return (await axios.get(url, { headers })).data;
-          } else {
-            return (await axios.post(url, data, { headers })).data;
           }
         },
       };
     },
   };
 }
+
+function log(...args: unknown[]): void {
+  // eslint-disable-next-line no-console
+  console.log(...args.map(arg => normalize(arg)));
+}

packages/nestjs/package.json

@@ -50,8 +50,8 @@
     "@sentry/utils": "8.37.1"
   },
   "devDependencies": {
-    "@nestjs/common": "10.4.5",
-    "@nestjs/core": "10.4.5"
+    "@nestjs/common": "10.4.1",
+    "@nestjs/core": "10.4.1"
   },
   "peerDependencies": {
     "@nestjs/common": "^8.0.0 || ^9.0.0 || ^10.0.0",