Added winston file transport and updated console.log usage

src/network/web/coinbase/reporter.js

@@ -1,5 +1,8 @@
+
+
 const crypto = require("crypto");
 const nfetch = require("node-fetch");
+const winston = require("winston");
 
 const Oracle = require("../../../messaging/oracle");
 
@@ -61,8 +64,8 @@ class Reporter extends Oracle {
       this._setStablecoins();
     } catch (e) {
       if (e instanceof nfetch.FetchError)
-        console.log("Coinbase fetch failed. Connection probably timed out");
-      else console.log("Coinbase fetch failed. Error converting to JSON");
+        winston.debug("Coinbase fetch failed. Connection probably timed out");
+      else winston.debug("Coinbase fetch failed. Error converting to JSON");
     }
   }
 }

src/network/webthree/providers.js

@@ -1,5 +1,6 @@
 const Web3 = require("web3");
 const net = require("net");
+const winston = require("winston");
 
 const IPCProvider = path => {
   return new Web3(path, net);
@@ -110,7 +111,7 @@ class MultiSendProvider {
         try {
           p.currentProvider.connection.destroy();
         } catch {
-          console.log("Cannot close HTTP provider's connection");
+          winston.debug("Cannot close HTTP provider's connection");
         }
       }
     });

src/setup.js

@@ -17,11 +17,22 @@ winston.configure({
     winston.format.simple()
   ),
   transports: [
-    new winston.transports.Console({ handleExceptions: true }),
+    new winston.transports.Console({
+      handleExceptions: true,
+      level: "debug"
+    }),
     new SlackHook({
       level: "info",
       webhookUrl: process.env.SLACK_WEBHOOK,
       mrkdwn: true
+    }),
+    new winston.transports.File({
+      level: 'debug',
+      filename: `./logs/nantucket.log`,
+      handleExceptions: true,
+      json: true,
+      maxsize: 2242880, // ~2MB
+      colorize: false,
     })
   ],
   exitOnError: false

src/start.js

@@ -188,7 +188,7 @@ for (let symbol in Tokens.mainnet) {
 }
 
 process.on("SIGINT", () => {
-  console.log("\nCaught interrupt signal");
+  winston.debug("\nCaught interrupt signal");
 
   clearInterval(handle1);
   clearInterval(handle2);

src/start_txmanager.js

@@ -8,10 +8,10 @@ const Message = require("./messaging/message");
 const Oracle = require("./messaging/oracle");
 
 if (process.argv.length < 7) {
-  console.log("TxManager process requires config.json and 4 arguments");
+  winston.debug("TxManager process requires config.json and 4 arguments");
   process.exit();
 }
-console.log(`TxManager ${process.pid} is running`);
+winston.debug(`TxManager ${process.pid} is running`);
 
 // src.network.webthree
 const Wallet = require("./network/webthree/wallet");
@@ -65,6 +65,6 @@ process.on("SIGINT", code => {
   }
   txManager.stop();
 
-  console.log(`TxManager ${process.pid} has exited cleanly`);
+  winston.debug(`TxManager ${process.pid} has exited cleanly`);
   process.exit();
 });

src/start_worker.js

@@ -7,10 +7,10 @@ const Message = require("./messaging/message");
 const Oracle = require("./messaging/oracle");
 
 if (process.argv.length < 7) {
-  console.log("Worker process requires config.json and 4 arguments");
+  winston.debug("Worker process requires config.json and 4 arguments");
   process.exit();
 }
-console.log(`Worker ${process.pid} is running`);
+winston.debug(`Worker ${process.pid} is running`);
 
 const Worker = require("./worker");
 const worker = new Worker(
@@ -52,6 +52,6 @@ process.on("SIGINT", code => {
   }
   worker.stop();
 
-  console.log(`Worker ${process.pid} has exited cleanly`);
+  winston.debug(`Worker ${process.pid} has exited cleanly`);
   process.exit();
 });

src/worker.js

@@ -1,4 +1,6 @@
 // src
+import * as winston from "winston";
+
 const Database = require("./database");
 // src.messaging
 const Candidate = require("./messaging/candidate");
@@ -133,11 +135,11 @@ class Worker extends Database {
   }
 
   _removeCandidate(address) {
-    console.log(`Removing candidate ${address}`);
+    winston.debug(`Removing candidate ${address}`);
     for (let i = 0; i < this._candidates.length; i++) {
       if (this._candidates[i].address !== address.toLowerCase()) continue;
       this._candidates.splice(i, 1);
-      console.log(`Candidate ${address} was being watched`);
+      winston.debug(`Candidate ${address} was being watched`);
       break;
     }
   }