Add Node.js driver first implementation

Author: ai

.github/workflows/test.yml

@@ -9,7 +9,7 @@ permissions:
   contents: read
 jobs:
   full:
-    name: Node.js Latest Full
+    name: Node.js Latest
     runs-on: ubuntu-latest
     steps:
       - name: Checkout the repository
@@ -27,28 +27,3 @@ jobs:
         run: pnpm install --ignore-scripts
       - name: Run tests
         run: pnpm test
-  short:
-    runs-on: ubuntu-latest
-    strategy:
-      matrix:
-        node-version:
-          - 24
-          - 22
-          - 20
-    name: Node.js ${{ matrix.node-version }} Quick
-    steps:
-      - name: Checkout the repository
-        uses: actions/checkout@de0fac2e4500dabe0009e67214ff5f5447ce83dd # v6.0.2
-      - name: Install pnpm
-        uses: pnpm/action-setup@41ff72655975bd51cab0327fa583b6e92b6d3061 # v4.2.0
-        with:
-          version: 10
-      - name: Install Node.js ${{ matrix.node-version }}
-        uses: actions/setup-node@6044e13b5dc448c55e2357c09f80417699197238 # v6.2.0
-        with:
-          node-version: ${{ matrix.node-version }}
-          cache: pnpm
-      - name: Install dependencies
-        run: pnpm install --ignore-scripts
-      - name: Run unit tests
-        run: pnpm bnt

README.md

@@ -83,6 +83,19 @@ import { expoDriver } from '@nanostores/sql/expo'
 export const db = openDb(expoDriver('app.sqlite'))
 ```
 
+### Node.js
+
+For CI test you can use `nodeDriver`.
+
+`node:sqlite` has no live queries and we use hacks for that, so it is not very efficient.
+
+```ts
+import { openDb } from '@nanostores/sql'
+import { nodeDriver } from '@nanostores/sql/node'
+
+export const db = openDb(nodeDriver(':memory:'))
+```
+
 ### PGLite
 
 [PGLite](https://pglite.dev) to use PostgreSQL rich features in browsers:

node/index.d.ts

@@ -0,0 +1,3 @@
+import type { Driver } from '../index.js'
+
+export function nodeDriver(filename: string): Driver

node/index.js

@@ -0,0 +1,53 @@
+import { DatabaseSync } from 'node:sqlite'
+
+export function nodeDriver(filename) {
+  let db = new DatabaseSync(filename)
+  let subscribers = new Map()
+  let nextId = 0
+
+  function notifySubscribers() {
+    for (let [, sub] of subscribers) {
+      let rows = db.prepare(sub.query).all(...sub.params)
+      sub.cb(rows)
+    }
+  }
+
+  let driver = {
+    subscribe(query, params, cb) {
+      let id = nextId++
+      subscribers.set(id, { query, params, cb })
+      let rows = db.prepare(query).all(...params)
+      cb(rows)
+      return () => {
+        subscribers.delete(id)
+      }
+    },
+
+    exec(query, params) {
+      return new Promise(resolve => {
+        let result = db.prepare(query).run(...params)
+        notifySubscribers()
+        resolve(result)
+      })
+    },
+
+    async transaction(callback) {
+      db.exec('BEGIN')
+      try {
+        let result = await callback(driver)
+        db.exec('COMMIT')
+        notifySubscribers()
+        return result
+      } catch (e) {
+        db.exec('ROLLBACK')
+        throw e
+      }
+    },
+
+    close() {
+      subscribers.clear()
+      db.close()
+    }
+  }
+  return driver
+}

package.json

@@ -28,6 +28,7 @@
     ".": "./index.js",
     "./expo": "./expo/index.js",
     "./sqlocal": "./sqlocal/index.js",
+    "./node": "./node/index.js",
     "./pglite": "./pglite/index.js",
     "./package.json": "./package.json"
   },