[misc] deno CI addition

Author: rusher

.github/workflows/ci.yml

@@ -36,10 +36,10 @@ jobs:
         name: build matrix
         uses: mariadb-corporation/connector-ci-build-matrix@main
         with:
-          additional-matrix: '[{"name": "MariaDB 11.4", "os": "ubuntu-latest", "db-type": "community", "db-tag": "11.4", "node": 24}, {"name": "MariaDB 11.4", "os": "ubuntu-latest", "db-type": "community", "db-tag": "11.4", "node": 20}]'
+          additional-matrix: '[{"name": "MariaDB 11.4", "os": "ubuntu-latest", "db-type": "community", "db-tag": "11.4", "node": 24}, {"name": "MariaDB 11.4", "os": "ubuntu-latest", "db-type": "community", "db-tag": "11.4", "node": 20}, {"name": "MariaDB 11.4 - DENO", "os": "ubuntu-latest", "db-type": "community", "db-tag": "11.4", "deno": "lts"}]'
 
   ci:
-    name: ${{ matrix.name }}${{ matrix.node != 22 && format(' - node {0}', matrix.node) || '' }}
+    name: ${{ matrix.name }}${{ !matrix.deno && matrix.node != 22 && format(' - node {0}', matrix.node) || '' }}
     needs: setup
     timeout-minutes: 50
     strategy:
@@ -66,13 +66,22 @@ jobs:
           os: ${{ matrix.os }}
 
       - uses: actions/setup-node@v4
+        if: ${{ !matrix.deno }}
         with:
           node-version: ${{ matrix.node }}
 
+      - name: Setup Deno
+        uses: denoland/setup-deno@v2
+        if: ${{ matrix.deno }}
+        with:
+          deno-version: ${{ matrix.deno }}
+
       - name: Install dependencies
+        if: ${{ !matrix.deno }}
         run: npm install
 
-      - name: Run Tests
+      - name: Run Tests node
+        if: ${{ !matrix.deno }}
         run: npm run coverage:test
         env:
           LOCAL_DB: ${{ steps.setup-env.outputs.database-type }}
@@ -81,7 +90,19 @@ jobs:
           DB_VERSION: ${{ matrix.db-tag }}
           TEST_TRACE: 'true'
 
+      - name: Run Tests deno
+        if: ${{ matrix.deno }}
+        run: |
+          deno task test
+        env:
+          LOCAL_DB: ${{ steps.setup-env.outputs.database-type }}
+          DB_TYPE: ${{ matrix.db-type }}
+          TEST_DB_SERVER_CERT: ${{ matrix.db-type == 'container' && './.github/workflows/certs/server.crt' || '' }}
+          DB_VERSION: ${{ matrix.db-tag }}
+          TEST_TRACE: 'true'
+
       - name: Download Codecov uploader
+        if: ${{ !matrix.deno }}
         shell: bash
         run: |
           case "$RUNNER_OS" in
@@ -105,6 +126,7 @@ jobs:
 
       - name: Generate Coverage Report
         shell: bash
+        if: ${{ !matrix.deno }}
         run: |
           npm run coverage:create
           case "$RUNNER_OS" in

deno.json

@@ -11,7 +11,7 @@
     "vitest": "npm:[email protected]"
   },
   "tasks": {
-    "test": "deno run -A npm:vitest  test/integration/query.test.js"
+    "test": "deno run -A npm:vitest test/**/*.js"
   },
   "fmt": {
     "files": {

test/base.js

@@ -121,6 +121,13 @@ export function getEnv(key) {
   return undefined;
 }
 
+export function isWindows() {
+  if (typeof Deno !== 'undefined') {
+    return 'windows' === Deno.build.os;
+  }
+  return process.platform === 'win32';
+}
+
 export function isLocalDb() {
   const localEnv = getEnv('LOCAL_DB');
   return localEnv === 'local' || localEnv === undefined;

test/integration/auth-plugin.test.js

@@ -3,14 +3,13 @@
 
 'use strict';
 
-import * as base from '../base.js';
 import Conf from '../conf.js';
 import { assert, describe, test, beforeAll, afterAll } from 'vitest';
 
 import fs from 'node:fs';
 import os from 'node:os';
 import path from 'node:path';
-import { isMaxscale, getHostSuffix, getEnv, createConnection, isLocalDb } from '../base.js';
+import { isMaxscale, getHostSuffix, getEnv, createConnection, isLocalDb, isWindows } from '../base.js';
 
 describe.concurrent('authentication plugin', () => {
   let rsaPublicKey = getEnv('TEST_RSA_PUBLIC_KEY');
@@ -157,7 +156,7 @@ describe.concurrent('authentication plugin', () => {
 
   test('name pipe authentication plugin', async ({ skip }) => {
     if (
-      process.platform !== 'win32' ||
+      !isWindows() ||
       isMaxscale(shareConn) ||
       !shareConn.info.isMariaDB() ||
       !shareConn.info.hasMinVersion(10, 1, 11) ||
@@ -193,7 +192,7 @@ describe.concurrent('authentication plugin', () => {
   test('unix socket authentication plugin', async ({ skip }) => {
     if (
       isMaxscale(shareConn) ||
-      process.platform === 'win32' ||
+      isWindows() ||
       !shareConn.info.isMariaDB() ||
       !shareConn.info.hasMinVersion(10, 1, 11) ||
       !isLocalDb() ||

test/integration/batch-callback.test.js

@@ -4,7 +4,7 @@
 'use strict';
 
 import * as base from '../base.js';
-import * as Capabilities from '../../lib/const/capabilities';
+import * as Capabilities from '../../lib/const/capabilities.js';
 import fs from 'node:fs';
 import os from 'node:os';
 import path from 'node:path';

test/integration/batch-geometry-type.test.js

@@ -5,7 +5,7 @@
 
 import * as base from '../base.js';
 import Conf from '../conf.js';
-import * as Capabilities from '../../lib/const/capabilities';
+import * as Capabilities from '../../lib/const/capabilities.js';
 import { assert, describe, test, beforeAll, afterAll } from 'vitest';
 import { createConnection } from '../base.js';
 

test/integration/cluster.test.js

@@ -4,9 +4,9 @@
 'use strict';
 
 import Conf from '../conf.js';
-import * as basePromise from '../../promise';
-import * as baseCallback from '../../callback';
-import Proxy from '../tools/proxy';
+import * as basePromise from '../../promise.js';
+import * as baseCallback from '../../callback.js';
+import Proxy from '../tools/proxy.js';
 import { createConnection, isMaxscale } from '../base.js';
 import { assert, expect, describe, test, beforeAll, afterAll, beforeEach } from 'vitest';
 

test/integration/connection-meta.test.js

@@ -2,8 +2,8 @@
 //  Copyright (c) 2015-2025 MariaDB Corporation Ab
 
 'use strict';
-import * as basePromise from '../../promise';
-import * as baseCallback from '../../callback';
+import * as basePromise from '../../promise.js';
+import * as baseCallback from '../../callback.js';
 import * as base from '../base.js';
 import { createConnection, isMaxscale } from '../base.js';
 import { getEnv } from '../base.js';

test/integration/connection-opts.test.js

@@ -64,6 +64,7 @@ describe.sequential('connection option', () => {
   });
 
   test.sequential('timezone Z', async ({ skip }) => {
+    if (!process) return skip();
     // node.js before v13 doesn't permit setting TZ value repeatedly
     if (parseInt(process.versions.node.split('.')[0]) <= 12) return skip();
 
@@ -93,6 +94,7 @@ describe.sequential('connection option', () => {
   });
 
   test.sequential('timezone +10h00', async ({ skip }) => {
+    if (!process) return;
     // node.js before v13 doesn't permit setting TZ value repeatedly
     if (parseInt(process.versions.node.split('.')[0]) <= 12) return skip();
 
@@ -111,6 +113,7 @@ describe.sequential('connection option', () => {
   });
 
   test.sequential('timezone Etc/GMT-10', async ({ skip }) => {
+    if (!process) return skip();
     // node.js before v13 doesn't permit setting TZ value repeatedly
     if (parseInt(process.versions.node.split('.')[0]) <= 12) return skip();
 
@@ -129,6 +132,7 @@ describe.sequential('connection option', () => {
   });
 
   test.sequential('timezone GMT+10', async ({ skip }) => {
+    if (!process) return skip();
     // node.js before v13 doesn't permit setting TZ value repeatedly
     if (parseInt(process.versions.node.split('.')[0]) <= 12) return skip();
 
@@ -159,6 +163,7 @@ describe.sequential('connection option', () => {
   });
 
   test.sequential('Server with different tz', async ({ skip }) => {
+    if (!process) return skip();
     // node.js before v13 doesn't permit setting TZ value repeatedly
     if (parseInt(process.versions.node.split('.')[0]) <= 12) return skip();
     if (isMaxscale(shareConn)) return skip();

test/integration/connection.test.js

@@ -5,8 +5,8 @@
 
 import Collations from '../../lib/const/collations.js';
 import Conf from '../conf.js';
-import Connection from '../../lib/connection';
-import ConnOptions from '../../lib/config/connection-options';
+import Connection from '../../lib/connection.js';
+import ConnOptions from '../../lib/config/connection-options.js';
 import { isMaxscale, getHostSuffix, createConnection, createCallbackConnection, utf8Collation } from '../base.js';
 import { expect, assert, describe, test, beforeAll, afterAll } from 'vitest';
 
@@ -114,7 +114,9 @@ describe.concurrent('connection', () => {
         assert.isTrue(err.message.includes('close forced'));
         resolve();
       });
-      process.nextTick(conn.__tests.getSocket().destroy.bind(conn.__tests.getSocket(), new Error('close forced')));
+      setTimeout(() => {
+        conn.__tests.getSocket().destroy(new Error('close forced'));
+      }, 0);
     });
   });
 
@@ -126,7 +128,9 @@ describe.concurrent('connection', () => {
         assert.isTrue(err.message.includes('Connection timeout: failed to create socket after'));
         resolve();
       });
-      process.nextTick(conn.__tests.getSocket().destroy.bind(conn.__tests.getSocket()));
+      setTimeout(() => {
+        conn.__tests.getSocket().destroy();
+      }, 0);
     });
   });
 
@@ -760,25 +764,25 @@ describe.concurrent('connection', () => {
   test('pause socket', async () => {
     const conn = await createConnection();
     conn.pause();
-    const startTime = process.hrtime();
+    const startTime = performance.now();
     setTimeout(() => {
       conn.resume();
     }, 500);
 
     const rows = await conn.query("SELECT '1'");
     assert.deepEqual(rows, [{ 1: '1' }]);
-    const diff = process.hrtime(startTime);
+    const diff = performance.now() - startTime;
     await conn.end();
     //query has taken more than 500ms
-    assert.isTrue(diff[1] > 499000000, ' diff[1]:' + diff[1] + ' expected to be more than 500000000');
+    assert.isTrue(diff > 499, ' diff:' + diff + ' expected to be more than 500');
   });
 
   test('pause socket callback', async () => {
     const conn = createCallbackConnection();
     await new Promise((resolve, reject) => {
       conn.connect((err) => {
         conn.pause();
-        const startTime = process.hrtime();
+        const startTime = performance.now();
         setTimeout(() => {
           conn.resume();
         }, 500);
@@ -788,9 +792,9 @@ describe.concurrent('connection', () => {
             reject(err);
           } else {
             assert.deepEqual(rows, [{ 1: '1' }]);
-            const diff = process.hrtime(startTime);
+            const diff = performance.now() - startTime;
             //query has taken more than 500ms
-            assert.isTrue(diff[1] > 499000000, ' diff[1]:' + diff[1] + ' expected to be more than 500000000');
+            assert.isTrue(diff > 499, ' diff:' + diff + ' expected to be more than 500');
             conn.end();
             resolve();
           }
@@ -934,7 +938,7 @@ describe.concurrent('connection', () => {
         });
         throw new Error('must have thrown error !');
       } catch (err) {
-        console.log(err);
+        // console.log(err);
         assert.equal(err.sqlState, 'HY000', err.message);
         assert.equal(err.code, 'ER_MUST_CHANGE_PASSWORD_LOGIN');
       } finally {