Included experimental support with Deno

Author: maneesht

packages/database/src/core/util/util.ts

@@ -618,10 +618,20 @@ export const setTimeoutNonBlocking = function (
   time: number
 ): number | object {
   const timeout: number | object = setTimeout(fn, time);
-  // eslint-disable-next-line @typescript-eslint/no-explicit-any
-  if (typeof timeout === 'object' && (timeout as any)['unref']) {
+  // @ts-ignore Deno and unrefTimer are only defined in Deno environments.
+  // Note: at the time of this comment, unrefTimer is under the unstable set of APIs. Run with --unstable to enable the API.
+  if (
+    typeof timeout === 'number' &&
+    typeof Deno !== 'undefined' &&
+    Deno['unrefTimer']
+  ) {
+    // @ts-ignore Deno and unrefTimer are only defined in Deno environments.
+    Deno.unrefTimer(timeout);
+    // eslint-disable-next-line @typescript-eslint/no-explicit-any
+  } else if (typeof timeout === 'object' && (timeout as any)['unref']) {
     // eslint-disable-next-line @typescript-eslint/no-explicit-any
     (timeout as any)['unref']();
   }
+
   return timeout;
 };

packages/database/test/deno.test.ts

@@ -0,0 +1,35 @@
+import { expect, use } from 'chai';
+import * as sinon from 'sinon';
+import sinonChai from 'sinon-chai';
+
+import { setTimeoutNonBlocking } from '../src/core/util/util';
+use(sinonChai);
+describe('Deno tests', () => {
+    let oldSetTimeout;
+    beforeEach(() => {
+        oldSetTimeout = globalThis.setTimeout;
+    });
+    afterEach(() => {
+        globalThis.setTimeout = oldSetTimeout;
+    });
+    it('should call the deno unrefTimer() if in Deno', () => {
+        // @ts-ignore override nodejs behavior
+        global.Deno = {
+            unrefTimer: sinon.spy()
+        };
+        // @ts-ignore override nodejs behavior
+        global.setTimeout = () => 1;
+        setTimeoutNonBlocking(() => {}, 0);
+        expect(globalThis.Deno.unrefTimer).to.have.been.called;
+    });
+    it('should not call the deno unrefTimer() if not in Deno', () => {
+        // @ts-ignore override nodejs behavior
+        global.Deno2 = {
+            unrefTimer: sinon.spy()
+        };
+        // @ts-ignore override node.js behavior
+        global.setTimeout = () => 1;
+        setTimeoutNonBlocking(() => {}, 0);
+        expect(globalThis.Deno2.unrefTimer).to.not.have.been.called;
+    });
+});

scripts/emulator-testing/emulators/database-emulator.ts

@@ -19,7 +19,7 @@ import * as request from 'request';
 
 import { Emulator } from './emulator';
 
-import * as rulesJSON from '../../../config/database.rules.json';
+import rulesJSON from '../../../config/database.rules.json';
 
 export class DatabaseEmulator extends Emulator {
   namespace: string;