From 87a8814fe0037624e005e757c9cbf6aa008a730a Mon Sep 17 00:00:00 2001
From: dceejay <conway@uk.ibm.com>
Date: Wed, 18 Mar 2015 08:47:09 +0000
Subject: [PATCH] Fix for sqlite not retrying to open database (and crashing)
 Fix for #106

---
 storage/sqlite/package.json | 2 +-
 storage/sqlite/sqlite.js    | 8 ++++----
 2 files changed, 5 insertions(+), 5 deletions(-)

diff --git a/storage/sqlite/package.json b/storage/sqlite/package.json
index b8e674d2..0987661b 100644
--- a/storage/sqlite/package.json
+++ b/storage/sqlite/package.json
@@ -1,6 +1,6 @@
 {
     "name"          : "node-red-node-sqlite",
-    "version"       : "0.0.4",
+    "version"       : "0.0.5",
     "description"   : "A sqlite node for Node-RED",
     "dependencies"  : {
         "sqlite3"   : "3.0.*"
diff --git a/storage/sqlite/sqlite.js b/storage/sqlite/sqlite.js
index 69121fc9..8a505c74 100644
--- a/storage/sqlite/sqlite.js
+++ b/storage/sqlite/sqlite.js
@@ -32,9 +32,9 @@ module.exports = function(RED) {
                  node.log("opened "+node.dbname+" ok");
             });
             node.db.on('error', function(err) {
-                node.warn(err);
+                node.error(err);
                 node.log("failed to open "+node.dbname);
-                node.tick = setTimeout(doConnect, reconnect);
+                node.tick = setTimeout(function() { node.doConnect(); }, reconnect);
             });
         }
 
@@ -59,7 +59,7 @@ module.exports = function(RED) {
                     //console.log("query:",msg.topic);
                     var bind = Array.isArray(msg.payload) ? msg.payload : [];
                     node.mydbConfig.db.all(msg.topic, bind, function(err, row) {
-                        if (err) { node.warn(err); }
+                        if (err) { node.error(err,msg); }
                         else {
                             msg.payload = row;
                             node.send(msg);
@@ -68,7 +68,7 @@ module.exports = function(RED) {
                 }
                 else {
                     if (typeof msg.topic !== 'string') {
-                        node.error("msg.topic : the query is not defined as a string");
+                        node.error("msg.topic : the query is not defined as a string",msg);
                     }
                 }
             });