Merge pull request #16 from fasblom/Session-close

Session close

Author: webmaxru

neo4j.js

@@ -6,6 +6,7 @@ module.exports = function (RED) {
 
     var sessions = []
     var readySessionList = []
+    const SESSION_TIMEOUT_MS = 4000; // 4 seconds of inactivity
 
     node.server = RED.nodes.getNode(config.server)
 
@@ -38,6 +39,10 @@ module.exports = function (RED) {
             database: msg.database || config.database || 'neo4j'
           });
 
+          if (boltSession.inactivityTimeout) {
+            clearTimeout(boltSession.inactivityTimeout);
+          }
+          
           let params = null
           if (typeof (msg.params) === 'string') {
             params = JSON.parse(msg.params)
@@ -119,7 +124,14 @@ module.exports = function (RED) {
           .catch(err => {
             node.error(err, msg);
           }).finally(() => {
+             // Return the session to the ready pool and set an inactivity timeout
             readySessionList.push(readySession) 
+            boltSession.inactivityTimeout = setTimeout(() => {
+              // Close the session if not used within the timeout period
+              boltSession.close();
+              sessions[readySession] = null; // Remove from the session pool
+              //console.log(`Session ${readySession} closed due to inactivity.`);
+            }, SESSION_TIMEOUT_MS);
           })
         } else {
           // no sessions available, send the message out on the third  port for further processing bty caller

package.json

@@ -37,5 +37,5 @@
   "engines": {
     "node": ">=7.4.0"
   },
-  "version": "2.5.2"
+  "version": "2.5.3"
 }