add test and add guards for unref

Author: AbhiPrasad

dev-packages/node-integration-tests/suites/metrics/should-exit-forced.js

@@ -0,0 +1,19 @@
+const Sentry = require('@sentry/node');
+
+function configureSentry() {
+  Sentry.init({
+    dsn: 'https://[email protected]/1337',
+    release: '1.0',
+    autoSessionTracking: false,
+  });
+
+  Sentry.metrics.increment('test');
+}
+
+async function main() {
+  configureSentry();
+  await new Promise(resolve => setTimeout(resolve, 1000));
+  process.exit(0);
+}
+
+main();

dev-packages/node-integration-tests/suites/metrics/should-exit.js

@@ -0,0 +1,18 @@
+const Sentry = require('@sentry/node');
+
+function configureSentry() {
+  Sentry.init({
+    dsn: 'https://[email protected]/1337',
+    release: '1.0',
+    autoSessionTracking: false,
+  });
+
+  Sentry.metrics.increment('test');
+}
+
+async function main() {
+  configureSentry();
+  await new Promise(resolve => setTimeout(resolve, 1000));
+}
+
+main();

dev-packages/node-integration-tests/suites/metrics/test.ts

@@ -0,0 +1,21 @@
+import { createRunner } from '../../utils/runner';
+
+describe('metrics', () => {
+  test('should exit', done => {
+    const runner = createRunner(__dirname, 'should-exit.js').start();
+
+    setTimeout(() => {
+      expect(runner.childHasExited()).toBe(true);
+      done();
+    }, 5_000);
+  });
+
+  test('should exit forced', done => {
+    const runner = createRunner(__dirname, 'should-exit-forced.js').start();
+
+    setTimeout(() => {
+      expect(runner.childHasExited()).toBe(true);
+      done();
+    }, 5_000);
+  });
+});

dev-packages/node-integration-tests/suites/tracing/metric-summaries/scenario.js

@@ -8,9 +8,6 @@ Sentry.init({
   transport: loggingTransport,
 });
 
-// Stop the process from exiting before the transaction is sent
-setInterval(() => {}, 1000);
-
 Sentry.startSpan(
   {
     name: 'Test Transaction',

packages/core/src/metrics/aggregator.ts

@@ -37,7 +37,10 @@ export class MetricsAggregator implements MetricsAggregatorBase {
   public constructor(private readonly _client: Client) {
     this._buckets = new Map();
     this._bucketsTotalWeight = 0;
-    this._interval = setInterval(() => this._flush(), DEFAULT_FLUSH_INTERVAL).unref();
+    this._interval = setInterval(() => this._flush(), DEFAULT_FLUSH_INTERVAL);
+    if (this._interval.unref) {
+      this._interval.unref();
+    }
     this._flushShift = Math.floor((Math.random() * DEFAULT_FLUSH_INTERVAL) / 1000);
     this._forceFlush = false;
   }

packages/core/src/sessionflusher.ts

@@ -31,7 +31,10 @@ export class SessionFlusher implements SessionFlusherLike {
     this._isEnabled = true;
 
     // Call to setInterval, so that flush is called every 60 seconds.
-    this._intervalId = setInterval(() => this.flush(), this.flushTimeout * 1000).unref();
+    this._intervalId = setInterval(() => this.flush(), this.flushTimeout * 1000);
+    if (this._intervalId.unref) {
+      this._intervalId.unref();
+    }
     this._sessionAttrs = attrs;
   }