Further changes for #8. Have not added redis part as don't know how t…

…o extract and transform data. Have logged a question on another github page. See what happens ....

config/default.json

@@ -73,9 +73,10 @@
     {
       "name": "bittrex",
       "docurl": "https://www.npmjs.com/package/node.bittrex.api",
-      "wssurl": "???",
+      "wssurl": "Not Available",
       "pairs": [
-        { "symbol": "NONE"}
+        { "symbol": "BTC-ETH"},
+        { "symbol": "BTC-XRP"}
       ],
       "active": "N"
     },

functions/exchange_functions.js

@@ -156,7 +156,7 @@ function processHUOBIAPI(client,exchange_name,exchange_wss,exchange_symbol)
 
   // Parse channel information and send to Redis
   // IMPORTANT: Do not know why wss.on works and not wss.onmessage. Created stackoverflow question for this at https://tinyurl.com/y7tj5a9o.
-  //            Seems to be to do with fact that it is a wrapper but not exactly sure why. 
+  //            Seems to be to do with fact that it is a wrapper but not exactly sure why.
   wss.on ('message', (data) => {
   {
     console.log("Receive message", data);
@@ -185,9 +185,42 @@ function processHUOBIAPI(client,exchange_name,exchange_wss,exchange_symbol)
   }});
 }
 
+
+// Function to subscribe to stream, transform data and publish to Redis from BITTREX
+function processBITTREX(client,exchange_name,exchange_wss,exchange_symbol)
+{
+  // Define constants
+  var bittrex = require('../node_modules/node.bittrex.api/node.bittrex.api');
+
+  bittrex.options({
+    websockets: {
+      onConnect: function() {
+        console.log('Websocket connected');
+        bittrex.websockets.subscribe(['BTC-ETH','BTC-XRP'], function(data) {
+          if (data.M === 'updateExchangeState') {
+            data.A.forEach(function(data_for) {
+              console.log(data_for);
+            });
+          }
+        });
+      },
+      onDisconnect: function() {
+        console.log('Websocket disconnected');
+      }
+    }
+  });
+
+  var websocketClient;
+  bittrex.websockets.client(function(client) {
+    websocketClient = client;
+  });
+
+}
+
 module.exports = {
   processBITFINEX,
   processHITBTC,
   processGEMINI,
-  processHUOBIAPI
+  processHUOBIAPI,
+  processBITTREX
 };

package.json

@@ -23,6 +23,7 @@
     "chai": "^4.1.2",
     "config": "^1.29.0",
     "express": "^4.15.2",
+    "node.bittrex.api": "^1.0.0",
     "pako": "^1.0.6",
     "redis": "^2.8.0",
     "websockets": "^0.2.0",

src/server.js

@@ -2,6 +2,7 @@
 
 //  General Libraries Needed By Application
 var sys = require('util');
+//var bittrex = require('../node_modules/node.bittrex.api/node.bittrex.api');
 var config = require('../config/default.json');
 
 // Connect to Redis
@@ -54,7 +55,7 @@ function main () {
       }
     }
 
-    if ( exchange_name == 'HUOBIAPI')
+    if ( exchange_name == 'xHUOBIAPI')
     {
       for(var j = 0; j < exchange_symbol_array.length; j++)
       {
@@ -64,6 +65,24 @@ function main () {
       }
     }
 
+    if ( exchange_name == 'BITTREX')
+    {
+      for(var j = 0; j < exchange_symbol_array.length; j++)
+      {
+        // concatenate all of the symbols together because thats the way this API works for some reason
+        if ( j == 0 ) {
+          exchange_symbol = "\'" + exchange_symbol_array[j].symbol + "\'" ;
+        } else {
+          exchange_symbol = exchange_symbol + "," + "\'" + exchange_symbol_array[j].symbol + "\'";
+        }
+        if ( j ==  ( exchange_symbol_array.length - 1) )
+        {
+          console.log(exchange_name, exchange_wss, exchange_symbol);
+          exFn.processBITTREX(client, exchange_name, exchange_wss, exchange_symbol);
+        }
+      }
+    }
+
   }
 
   // End of main function