From d4f467d4f8ccbc1c154223cb976384c28bf7cc43 Mon Sep 17 00:00:00 2001
From: Ben Ariss <bariss@bp-3.com>
Date: Thu, 30 Nov 2017 08:42:58 +0000
Subject: [PATCH 1/3] Fixed error handlers to correctly flow errors to Catch
 nodes if present Added support for fetchAll option on the SOQL query node to
 support large result sets

---
 README.md    | 1 +
 dml.js       | 2 +-
 soql.html    | 7 ++++++-
 soql.js      | 5 +++--
 sosl.js      | 2 +-
 streaming.js | 2 +-
 6 files changed, 13 insertions(+), 6 deletions(-)

diff --git a/README.md b/README.md
index 09d08bc..aadcb45 100644
--- a/README.md
+++ b/README.md
@@ -28,6 +28,7 @@ limit 2
 <li>msg.payload.records - the array of records returned from the query.</li>
 </ul></p>
 <p>The query can be configured in the node, however if left blank, the query should be set in an incoming message on <code>msg.query</code>.</p>
+<p>By default the query will return the first 2,000 records from the query result.  If you wish to return the full result set then tick the 'Fetch All Records' checkbox.</p>
 <p>See the <a href="https://developer.salesforce.com/docs/atlas.en-us.soql_sosl.meta/soql_sosl">Salesforce SOQL documentation</a> for more information.</p>
 
 <h3>SOSL</h3>
diff --git a/dml.js b/dml.js
index 8a76038..fec7f4d 100644
--- a/dml.js
+++ b/dml.js
@@ -76,7 +76,7 @@ module.exports = function(RED) {
         node.status({});
       }).error(function(err) {
         node.status({fill:"red",shape:"dot",text:"Error!"});
-        node.error(err);
+        node.error(err, msg);
       });
 
     });
diff --git a/soql.html b/soql.html
index d407d54..08a3138 100644
--- a/soql.html
+++ b/soql.html
@@ -5,7 +5,8 @@
         defaults: {
           name: {value:""},
           query: {value:""},
-          connection: {value:"", type:"connection-config", required: true}
+          connection: {value:"", type:"connection-config", required: true},
+          fetchAll: {value:false}
         },
         inputs:1,
         outputs:1,
@@ -29,6 +30,10 @@
         <label for="node-input-query"><i class="fa fa-database"></i> Query</label>
         <textarea id="node-input-query" style="width:300px"></textarea>
     </div>
+    <div class="form-row" style="white-space:nowrap">
+        <label for="node-input-fetchAll"><i class="fa fa-list"></i> Fetch all result records</label>
+        <input type="checkbox" id="node-input-fetchAll" style="position:absolute;left:20px">
+    </div>
 </script>
 
 <script type="text/x-red" data-help-name="soql">
diff --git a/soql.js b/soql.js
index 839d9bc..18cc3f0 100644
--- a/soql.js
+++ b/soql.js
@@ -27,7 +27,7 @@ module.exports = function(RED) {
 
       // auth and run query
       org.authenticate({ username: this.connection.username, password: this.connection.password }).then(function(){
-        return org.query({ query: config.query })
+        return org.query({ fetchAll: config.fetchAll, query: config.query });
       }).then(function(results) {
         msg.payload = {
           size: results.totalSize,
@@ -37,7 +37,8 @@ module.exports = function(RED) {
         node.status({});
       }).error(function(err) {
         node.status({fill:"red",shape:"dot",text:"Error!"});
-        node.error(err);
+        node.log("Inside error catch block");
+        node.error(err, msg);
       });
 
     });
diff --git a/sosl.js b/sosl.js
index 309a6f3..90ed355 100644
--- a/sosl.js
+++ b/sosl.js
@@ -38,7 +38,7 @@ module.exports = function(RED) {
         node.status({});
       }).error(function(err) {
         node.status({fill:"red",shape:"dot",text:"Error!"});
-        node.error(err);
+        node.error(err, msg);
       });
 
     });
diff --git a/streaming.js b/streaming.js
index e5a026b..f2d3298 100644
--- a/streaming.js
+++ b/streaming.js
@@ -18,7 +18,7 @@ module.exports = function(RED) {
 
     org.authenticate({ username: this.connection.username, password: this.connection.password }, function(err, oauth) {
 
-      if(err) node.err(err);
+      if(err) return node.error(err, msg);
 
       var client = org.createStreamClient();
       var stream = client.subscribe({ topic: config.pushTopic });

From 663c1ddbf52169fd6de9d3a9dd3a0dad233dec47 Mon Sep 17 00:00:00 2001
From: Ben Ariss <bariss@bp-3.com>
Date: Thu, 30 Nov 2017 09:03:36 +0000
Subject: [PATCH 2/3] Removed debug logging

---
 soql.js | 1 -
 1 file changed, 1 deletion(-)

diff --git a/soql.js b/soql.js
index 18cc3f0..14f1318 100644
--- a/soql.js
+++ b/soql.js
@@ -37,7 +37,6 @@ module.exports = function(RED) {
         node.status({});
       }).error(function(err) {
         node.status({fill:"red",shape:"dot",text:"Error!"});
-        node.log("Inside error catch block");
         node.error(err, msg);
       });
 

From 570f296252dabd094689d2c0b2a59964ea0c5bda Mon Sep 17 00:00:00 2001
From: Ben Ariss <bariss@bp-3.com>
Date: Thu, 30 Nov 2017 09:11:26 +0000
Subject: [PATCH 3/3] Incremented package version

---
 package.json | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/package.json b/package.json
index e5e8ba7..414fae8 100644
--- a/package.json
+++ b/package.json
@@ -1,6 +1,6 @@
 {
   "name": "node-red-contrib-salesforce",
-  "version": "0.0.5",
+  "version": "0.0.6",
   "description": "A set of Node-RED nodes to interact with Salesforce and Force.com.",
   "author": {
     "name": "Jeff Douglas",