test(node): Add captureMessage integration tests (#4785)

Author: onurtemizkan

packages/node-integration-tests/suites/public-api/capture-message/scenario.ts renamed to packages/node-integration-tests/suites/public-api/captureMessage/simple_message/scenario.ts

@@ -1,6 +1,6 @@
-import { assertSentryEvent, getEventRequest, runServer } from '../../../utils';
+import { assertSentryEvent, getEventRequest, runServer } from '../../../../utils';
 
-test('should send captureMessage', async () => {
+test('should capture a simple message string', async () => {
   const url = await runServer(__dirname);
   const requestBody = await getEventRequest(url);
 

packages/node-integration-tests/suites/public-api/capture-message/test.ts renamed to packages/node-integration-tests/suites/public-api/captureMessage/simple_message/test.ts

@@ -0,0 +1,14 @@
+import * as Sentry from '@sentry/node';
+
+Sentry.init({
+  dsn: 'https://[email protected]/1337',
+  release: '1.0',
+});
+
+Sentry.captureMessage('debug_message', Sentry.Severity.Debug);
+Sentry.captureMessage('info_message', Sentry.Severity.Info);
+Sentry.captureMessage('warning_message', Sentry.Severity.Warning);
+Sentry.captureMessage('error_message', Sentry.Severity.Error);
+Sentry.captureMessage('fatal_message', Sentry.Severity.Fatal);
+Sentry.captureMessage('critical_message', Sentry.Severity.Critical);
+Sentry.captureMessage('log_message', Sentry.Severity.Log);

packages/node-integration-tests/suites/public-api/captureMessage/with_level/scenario.ts

@@ -0,0 +1,41 @@
+import { assertSentryEvent, getMultipleEventRequests, runServer } from '../../../../utils';
+
+test('should capture with different severity levels', async () => {
+  const url = await runServer(__dirname);
+  const events = await getMultipleEventRequests(url, 7);
+
+  assertSentryEvent(events[0], {
+    message: 'debug_message',
+    level: 'debug',
+  });
+
+  assertSentryEvent(events[1], {
+    message: 'info_message',
+    level: 'info',
+  });
+
+  assertSentryEvent(events[2], {
+    message: 'warning_message',
+    level: 'warning',
+  });
+
+  assertSentryEvent(events[3], {
+    message: 'error_message',
+    level: 'error',
+  });
+
+  assertSentryEvent(events[4], {
+    message: 'fatal_message',
+    level: 'fatal',
+  });
+
+  assertSentryEvent(events[5], {
+    message: 'critical_message',
+    level: 'critical',
+  });
+
+  assertSentryEvent(events[6], {
+    message: 'log_message',
+    level: 'log',
+  });
+});

packages/node-integration-tests/suites/public-api/captureMessage/with_level/test.ts

@@ -5,15 +5,15 @@ import nock from 'nock';
 import * as path from 'path';
 import { getPortPromise } from 'portfinder';
 
-const assertSentryEvent = (actual: Record<string, unknown>, expected: Record<string, unknown>): void => {
+export const assertSentryEvent = (actual: Record<string, unknown>, expected: Record<string, unknown>): void => {
   expect(actual).toMatchObject({
     event_id: expect.any(String),
     timestamp: expect.any(Number),
     ...expected,
   });
 };
 
-const assertSentryTransaction = (actual: Record<string, unknown>, expected: Record<string, unknown>): void => {
+export const assertSentryTransaction = (actual: Record<string, unknown>, expected: Record<string, unknown>): void => {
   expect(actual).toMatchObject({
     event_id: expect.any(String),
     timestamp: expect.any(Number),
@@ -24,24 +24,34 @@ const assertSentryTransaction = (actual: Record<string, unknown>, expected: Reco
   });
 };
 
-const parseEnvelope = (body: string): Array<Record<string, unknown>> => {
+export const parseEnvelope = (body: string): Array<Record<string, unknown>> => {
   return body.split('\n').map(e => JSON.parse(e));
 };
 
-const getEventRequest = async (url: string): Promise<Record<string, unknown>> => {
+export const getMultipleEventRequests = async (url: string, count: number): Promise<Array<Record<string, unknown>>> => {
+  const events: Record<string, unknown>[] = [];
+
   return new Promise(resolve => {
     nock('https://dsn.ingest.sentry.io')
       .post('/api/1337/store/', body => {
-        resolve(body);
+        events.push(body);
+
+        if (events.length === count) {
+          resolve(events);
+        }
         return true;
       })
+      .times(7)
       .reply(200);
-
     http.get(url);
   });
 };
 
-const getEnvelopeRequest = async (url: string): Promise<Array<Record<string, unknown>>> => {
+export const getEventRequest = async (url: string): Promise<Record<string, unknown>> => {
+  return (await getMultipleEventRequests(url, 1))[0];
+};
+
+export const getEnvelopeRequest = async (url: string): Promise<Array<Record<string, unknown>>> => {
   return new Promise(resolve => {
     nock('https://dsn.ingest.sentry.io')
       .post('/api/1337/envelope/', body => {
@@ -55,7 +65,7 @@ const getEnvelopeRequest = async (url: string): Promise<Array<Record<string, unk
   });
 };
 
-async function runServer(testDir: string, serverPath?: string, scenarioPath?: string): Promise<string> {
+export async function runServer(testDir: string, serverPath?: string, scenarioPath?: string): Promise<string> {
   const port = await getPortPromise();
   const url = `http://localhost:${port}/test`;
   const defaultServerPath = path.resolve(process.cwd(), 'utils', 'defaults', 'server');
@@ -77,5 +87,3 @@ async function runServer(testDir: string, serverPath?: string, scenarioPath?: st
 
   return url;
 }
-
-export { assertSentryEvent, assertSentryTransaction, parseEnvelope, getEventRequest, getEnvelopeRequest, runServer };