fix: db close with subs

Author: stewartoallen

.eslintcache

@@ -1 +1 @@
-[{"/Users/charlesallen/Development/GitHub/GridSpace/net-level/lib/cli.js":"1","/Users/charlesallen/Development/GitHub/GridSpace/net-level/lib/client.js":"2","/Users/charlesallen/Development/GitHub/GridSpace/net-level/lib/clone.js":"3","/Users/charlesallen/Development/GitHub/GridSpace/net-level/lib/server.js":"4","/Users/charlesallen/Development/GitHub/GridSpace/net-level/lib/util.js":"5"},{"size":9522,"mtime":1707860428014,"results":"6","hashOfConfig":"7"},{"size":9627,"mtime":1707915522115,"results":"8","hashOfConfig":"7"},{"size":2152,"mtime":1707860428014,"results":"9","hashOfConfig":"7"},{"size":18873,"mtime":1707860428015,"results":"10","hashOfConfig":"7"},{"size":3287,"mtime":1707860428015,"results":"11","hashOfConfig":"7"},{"filePath":"12","messages":"13","suppressedMessages":"14","errorCount":0,"fatalErrorCount":0,"warningCount":0,"fixableErrorCount":0,"fixableWarningCount":0},"47j2ll",{"filePath":"15","messages":"16","suppressedMessages":"17","errorCount":0,"fatalErrorCount":0,"warningCount":0,"fixableErrorCount":0,"fixableWarningCount":0},{"filePath":"18","messages":"19","suppressedMessages":"20","errorCount":0,"fatalErrorCount":0,"warningCount":0,"fixableErrorCount":0,"fixableWarningCount":0},{"filePath":"21","messages":"22","suppressedMessages":"23","errorCount":0,"fatalErrorCount":0,"warningCount":0,"fixableErrorCount":0,"fixableWarningCount":0},{"filePath":"24","messages":"25","suppressedMessages":"26","errorCount":0,"fatalErrorCount":0,"warningCount":0,"fixableErrorCount":0,"fixableWarningCount":0},"/Users/charlesallen/Development/GitHub/GridSpace/net-level/lib/cli.js",[],[],"/Users/charlesallen/Development/GitHub/GridSpace/net-level/lib/client.js",[],[],"/Users/charlesallen/Development/GitHub/GridSpace/net-level/lib/clone.js",[],[],"/Users/charlesallen/Development/GitHub/GridSpace/net-level/lib/server.js",[],[],"/Users/charlesallen/Development/GitHub/GridSpace/net-level/lib/util.js",[],[]]
+[{"/Users/stewart/Code/net-level/lib/server.js":"1"},{"size":25497,"mtime":1755398221157,"results":"2","hashOfConfig":"3"},{"filePath":"4","messages":"5","suppressedMessages":"6","errorCount":0,"fatalErrorCount":0,"warningCount":0,"fixableErrorCount":0,"fixableWarningCount":0},"1tgfjf5","/Users/stewart/Code/net-level/lib/server.js",[],[]]

client/script-pre.sh

@@ -1,2 +1,2 @@
-mkdir lib
+mkdir -p lib
 cp ../lib/*js lib/

lib/server.js

@@ -40,7 +40,7 @@ function validName(n) {
 }
 
 async function pause(ms) {
-    return new Promise(resolve => setTimeout(resolve, ms));
+    return new Promise((resolve) => setTimeout(resolve, ms));
 }
 
 class LevelServer {
@@ -65,7 +65,7 @@ class LevelServer {
         dels: 0,
         iter: 0
     };
-    #webdir = "web";
+    #webdir = 'web';
     #webport = 4040;
     #webhost = '127.0.0.1';
 
@@ -202,7 +202,7 @@ class LevelServer {
             check_perms,
             check_db,
             check_db_open,
-            close,
+            close
         });
 
         function close(drec) {
@@ -215,6 +215,7 @@ class LevelServer {
                 // close base when last user of it disconnects
                 if (uids.length === 0) {
                     if (state.db) {
+                        state.db = state.path[0];
                         state.db.close();
                     }
                     state.path = [];
@@ -291,7 +292,7 @@ class LevelServer {
             dels: server.#stats.dels,
             iter: server.#stats.iter,
             dbug: server.#dbug,
-            path: state.path.map(db => db.name),
+            path: state.path.map((db) => db.name),
             user: state.unam
         };
         if (opt.list) {
@@ -379,7 +380,7 @@ class LevelServer {
                     return send({ user, list: Object.keys(users) });
                 }
             default:
-                return send({ user, error: "invalid user command" });
+                return send({ user, error: 'invalid user command' });
         }
         send({ user });
         this.#users_save();
@@ -418,7 +419,7 @@ class LevelServer {
         send({ auth });
     }
 
-    #cmd_use(conn, send, use, opt = { }) {
+    #cmd_use(conn, send, use, opt = {}) {
         const { state, server } = conn;
         const { addr, perms, urec, unam, uuid } = state;
         if (!(perms.use || (urec && urec.base && urec.base[use] && urec.base[use].use))) {
@@ -464,14 +465,14 @@ class LevelServer {
                 console.log({ db_error: error });
                 state.close(server.#base[use]);
             });
-            state.dinf = server.#bases[use] = (dinf || {
+            state.dinf = server.#bases[use] = dinf || {
                 gets: 0,
                 puts: 0,
                 dels: 0,
                 iter: 0,
                 created: Date.now(),
                 creator: state.unam
-            });
+            };
             state.drec = server.#base[use] = { uids: [uuid], db };
             state.path.length = 0;
             state.path.push(db);
@@ -485,7 +486,7 @@ class LevelServer {
         state.dbperms = urec && urec.base ? urec.base[use] || {} : {};
     }
 
-    #cmd_sub(conn, send, sub, opt = { }) {
+    #cmd_sub(conn, send, sub, opt = {}) {
         const { state } = conn;
         const { path } = state;
         let { db } = state;
@@ -611,7 +612,7 @@ class LevelServer {
                     if (pre && !key.startsWith(pre)) {
                         break;
                     }
-                    if (opt.skip && (read % opt.skip) !== 0) {
+                    if (opt.skip && read % opt.skip !== 0) {
                         read++;
                         continue;
                     }
@@ -776,14 +777,12 @@ if (module.parent) {
     new LevelServer({
         host: args.host || process.env.DB_HOST || 'localhost',
         port: args.port || parseInt(process.env.DB_PORT || 3000),
-        webhost: args.webhost || 'localhost',
-        webport: args.webport || 4040,
+        webhost: args.webhost || process.env.WEB_HOST || 'localhost',
+        webport: args.webport || parseInt(process.env.WEB_PORT || 4040),
         webdir: args.webdir || 'web',
         dir: args.dir || args.base || process.env.DB_BASE || 'data',
         user: args.user || process.env.DB_USER || undefined,
         pass: args.pass || process.env.DB_PASS || undefined,
-        pash: args.pash || process.env.DB_PASH || undefined,
-        webhost: args.webhost || process.env.WEB_HOST,
-        webport: args.webport || parseInt(process.env.WEB_PORT || 4040)
+        pash: args.pash || process.env.DB_PASH || undefined
     });
 }