Merge pull request #208 from JocaPC/master

Added logging in json/nodejs/todo app

Author: jovanpop-msft

samples/features/json/todo-app/nodejs-express4-rest-api/db.js

@@ -19,28 +19,29 @@ function createRequest(query, connection) {
     var req =
         new Request(query, 
                 function (err, rowCount) {
-                    if (err) {
-                        throw err;
-                    }
-                    connection && connection.close();
+                        if (err) {
+                            console.trace(err);
+                            throw err;
+                        }
+                        connection && connection.close();
+                        console.log('Connection closed');
                 });
-
     return req;
 }
 
 function stream (query, connection, output, defaultContent) {
 
     var request = query;
     if (typeof query == "string") {
-        request = this.createRequest(query, connection);
+        request = createRequest(query, connection);
     }
-    pipe(request, output, defaultContent);
-}
 
-function pipe (request, output, defaultContent) {
     var empty = true;
     request.on('row', function (columns) {
-        empty = false;
+        if(empty) {
+            console.log('Response fetched from SQL Database!');
+            empty = false;
+        }
         output.write(columns[0].value);
     });
 
@@ -50,19 +51,28 @@ function pipe (request, output, defaultContent) {
 
     request.on('doneProc', function (rowCount, more, rows) {
         _OnDone(empty, defaultContent, output);
-    }); 
+    });
+
+    executeRequest (request, connection);
 }
 
 function _OnDone(empty, defaultContent, output) { 
         if(empty) { 
             output.write(defaultContent);
+            console.log('No results from database - default content is returned.');
         } 
-        try { output.end(); } catch (err) { /* Ignore stream close error. */ }
+        try {
+            console.log('Closing Http Response output.');
+            output.end();
+        } catch (err) {  
+            console.error(err);
+        }
     }
 
 function executeRequest (request, connection) { 
         connection.on('connect', function (err) {
             if (err) {
+                console.trace(err);
                 throw err;
             }
             connection.execSql(request);
@@ -72,5 +82,4 @@ function executeRequest (request, connection) {
 module.exports.createConnection = createConnection;
 module.exports.createRequest = createRequest; 
 module.exports.executeRequest = executeRequest;
-module.exports.stream = stream;
-module.exports.pipe = pipe;
+module.exports.stream = stream;