support for Hono , closes #149

Author: lroal

dist/index.browser.mjs

@@ -85,7 +85,7 @@
     },
     "peerDependencies": {
         "@electric-sql/pglite": "^0.3.0",
-        "better-sqlite3": "^11.8.1",
+        "better-sqlite3": "^11.8.1 || ^12.6.2",
         "msnodesqlv8": "^4.1.0 || ^5.0.0",
         "mysql2": "^2.2.5 || ^3.9.4",
         "oracledb": "^6.3.0",
@@ -124,17 +124,19 @@
     },
     "devDependencies": {
         "@electric-sql/pglite": "^0.3.0",
+        "@hono/node-server": "^1.14.4",
         "@rollup/plugin-commonjs": "^28.0.2",
         "@rollup/plugin-json": "^6.1.0",
         "@rollup/plugin-node-resolve": "^13.0.0",
         "@typescript-eslint/eslint-plugin": "^6.x",
         "@typescript-eslint/parser": "^6.x",
         "@vitest/coverage-v8": "^3.2.4",
-        "better-sqlite3": "^11.8.1",
+        "better-sqlite3": "^12.6.2",
         "cors": "^2.8.5",
         "eslint": "^8.57.0",
         "eslint-plugin-jest": "^27.1.7",
         "express": "^4.18.2",
+        "hono": "^4.8.2",
         "msnodesqlv8": "^4.1.0",
         "mysql2": "^3.9.4",
         "oracledb": "^6.3.0",

dist/index.mjs

@@ -7,6 +7,7 @@ let newPool = require('./newPool');
 let lock = require('../lock');
 let executeSchema = require('../pg/schema');
 let express = require('../hostExpress');
+let hono = require('../hostHono');
 let hostLocal = require('../hostLocal');
 let doQuery = require('../query');
 let releaseDbClient = require('../table/releaseDbClient');
@@ -17,7 +18,7 @@ function newDatabase(connectionString, poolOptions) {
 	poolOptions = poolOptions || { min: 1 };
 	var pool = newPool(connectionString, poolOptions);
 
-	let c = { poolFactory: pool, hostLocal, express };
+	let c = { poolFactory: pool, hostLocal, express, hono };
 
 	c.transaction = function(options, fn) {
 		if ((arguments.length === 1) && (typeof options === 'function')) {

package-lock.json

@@ -5,6 +5,7 @@ let commit = require('../table/commit');
 let rollback = require('../table/rollback');
 let newPool = require('./newPool');
 let express = require('../hostExpress');
+let hono = require('../hostHono');
 let hostLocal = require('../hostLocal');
 let doQuery = require('../query');
 let doSqliteFunction = require('../sqliteFunction');
@@ -16,7 +17,7 @@ function newDatabase(connectionString, poolOptions) {
 	poolOptions = poolOptions || { min: 1 };
 	var pool = newPool(connectionString, poolOptions);
 
-	let c = {poolFactory: pool, hostLocal, express};
+	let c = { poolFactory: pool, hostLocal, express, hono };
 
 	c.transaction = function(options, fn) {
 		if ((arguments.length === 1) && (typeof options === 'function')) {

package.json

@@ -65,6 +65,7 @@ function createProviders(index) {
 	});
 
 	dbMap.express = index.express;
+	dbMap.hono = index.hono;
 
 	function createPool(providerName, ...args) {
 		const provider = index[providerName];
@@ -138,4 +139,4 @@ function negotiateCachedPool(fn, providers) {
 
 
 
-module.exports = createProviders;
+module.exports = createProviders;

src/bunPg/newDatabase.js

@@ -66,6 +66,7 @@ function rdbClient(options = {}) {
 	client.http = onProvider.bind(null, 'http');//todo
 	client.mysql = onProvider.bind(null, 'mysql');
 	client.express = express;
+	client.hono = hono;
 	client.close = close;
 
 	function close() {
@@ -153,6 +154,14 @@ function rdbClient(options = {}) {
 			throw new Error('Cannot host express clientside');
 	}
 
+	function hono(arg) {
+		if (providers.hono) {
+			return providers.hono(client, { ...options, ...arg });
+		}
+		else
+			throw new Error('Cannot host hono clientside');
+	}
+
 
 
 	function _createPatch(original, modified, ...restArgs) {

src/bunSqlite/newDatabase.js

@@ -5,6 +5,7 @@ let commit = require('../table/commit');
 let rollback = require('../table/rollback');
 let newPool = require('./newPool');
 let express = require('../hostExpress');
+let hono = require('../hostHono');
 let hostLocal = require('../hostLocal');
 let doQuery = require('../query');
 let releaseDbClient = require('../table/releaseDbClient');
@@ -15,7 +16,7 @@ function newDatabase(d1Database, poolOptions) {
 	poolOptions = poolOptions || { min: 1 };
 	var pool = newPool(d1Database, poolOptions);
 
-	let c = {poolFactory: pool, hostLocal, express};
+	let c = { poolFactory: pool, hostLocal, express, hono };
 
 	c.transaction = function(options, fn) {
 		if ((arguments.length === 1) && (typeof options === 'function')) {