fez5587/Superalgos
1
0 Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

ExchangeAPI reviewed

Browse Source
This commit is contained in:
Luis Fernando Molina committed 2018-03-06 19:29:34 +01:00
1 parent 6ccce0e8f6
commit 72977a1644
6 files changed
+61 -62
Download Patch File Download Diff File Expand all files Collapse all files

No files matched your search

.vs/AACloudPlatform/v15/.suo
BIN
View File
Binary file not shown.
Assistant.js
+17 -17
View File
@@ -57,27 +57,27 @@
break;
case 'Retry Later': { // Something bad happened, but if we retry in a while it might go through the next time.
logger.write("[ERROR] initialize -> onDone -> Retry Later. Requesting Execution Retry.");
callBackFunction(err);
callBackFunction(err.message);
return;
}
break;
case 'Retry Later': { // This is an unexpected exception that we do not know how to handle.
logger.write("[ERROR] initialize -> onDone -> Operation Failed. Aborting the process.");
callBackFunction(err);
callBackFunction(err.message);
return;
}
break;
}
} catch (err) {
logger.write("[ERROR] initialize -> onDone -> err = " + err);
logger.write("[ERROR] initialize -> onDone -> err = " + err.message);
callBackFunction("Operation Failed");
}
}
} catch (err) {
logger.write("[ERROR] initialize -> err = " + err);
logger.write("[ERROR] initialize -> err = " + err.message);
callBackFunction("Operation Failed");
}
}
@@ -106,20 +106,20 @@
break;
case 'Retry Later': { // Something bad happened, but if we retry in a while it might go through the next time.
logger.write("[ERROR] getPositionsAtExchange -> onResponse -> Retry Later. Requesting Execution Retry.");
callBack(err);
callBack(err.message);
return;
}
break;
case 'Operation Failed': { // This is an unexpected exception that we do not know how to handle.
logger.write("[ERROR] getPositionsAtExchange -> onResponse -> Operation Failed. Aborting the process.");
callBack(err);
callBack(err.message);
return;
}
break;
}
}
} catch (err) {
logger.write("[ERROR] getPositionsAtExchange -> err = " + err);
logger.write("[ERROR] getPositionsAtExchange -> err = " + err.message);
callBack("Operation Failed");
}
}
@@ -261,7 +261,7 @@
next();
} catch (err) {
logger.write("[ERROR] ordersExecutionCheck -> loopBody -> confirmOrderWasPartiallyExecuted -> err = " + err);
logger.write("[ERROR] ordersExecutionCheck -> loopBody -> confirmOrderWasPartiallyExecuted -> err = " + err.message);
callBack("Operation Failed");
return;
}
@@ -336,7 +336,7 @@
next();
} catch (err) {
logger.write("[ERROR] ordersExecutionCheck -> loopBody -> confirmOrderWasExecuted -> err = " + err);
logger.write("[ERROR] ordersExecutionCheck -> loopBody -> confirmOrderWasExecuted -> err = " + err.message);
callBack("Operation Failed");
return;
}
@@ -375,18 +375,18 @@
break;
}
} catch (err) {
logger.write("[ERROR] ordersExecutionCheck -> loopBody -> getPositionTradesAtExchange -> onResponse -> err = " + err);
logger.write("[ERROR] ordersExecutionCheck -> loopBody -> getPositionTradesAtExchange -> onResponse -> err = " + err.message);
callBack("Operation Failed");
}
}
} catch (err) {
logger.write("[ERROR] ordersExecutionCheck -> loopBody -> getPositionTradesAtExchange -> err = " + err);
logger.write("[ERROR] ordersExecutionCheck -> loopBody -> getPositionTradesAtExchange -> err = " + err.message);
callBack("Operation Failed");
}
}
} catch (err) {
logger.write("[ERROR] ordersExecutionCheck -> loopBody -> err = " + err);
logger.write("[ERROR] ordersExecutionCheck -> loopBody -> err = " + err.message);
callBack("Operation Failed");
return;
}
@@ -418,7 +418,7 @@
}
} catch (err) {
logger.write("[ERROR] ordersExecutionCheck -> err = " + err);
logger.write("[ERROR] ordersExecutionCheck -> err = " + err.message);
callBack("Operation Failed");
}
}
@@ -474,12 +474,12 @@
break;
}
} catch (err) {
logger.write("[ERROR] putPositionAtExchange -> onResponse -> err = " + err);
logger.write("[ERROR] putPositionAtExchange -> onResponse -> err = " + err.message);
callBack("Operation Failed");
}
}
} catch (err) {
logger.write("[ERROR] putPositionAtExchange -> err = " + err);
logger.write("[ERROR] putPositionAtExchange -> err = " + err.message);
callBack("Operation Failed");
}
}
@@ -548,12 +548,12 @@
break;
}
} catch (err) {
logger.write("[ERROR] movePositionAtExchange -> onResponse -> err = " + err);
logger.write("[ERROR] movePositionAtExchange -> onResponse -> err = " + err.message);
callBack("Operation Failed");
}
}
} catch (err) {
logger.write("[ERROR] movePositionAtExchange -> err = " + err);
logger.write("[ERROR] movePositionAtExchange -> err = " + err.message);
callBack("Operation Failed");
}
}
Context.js
+11 -11
View File
@@ -94,20 +94,20 @@
break;
case 'Retry Later': { // Something bad happened, but if we retry in a while it might go through the next time.
logger.write("[ERROR] initialize -> onDone -> Retry Later. Requesting Execution Retry.");
callBackFunction(err);
callBackFunction(err.message);
return;
}
break;
case 'Retry Later': { // This is an unexpected exception that we do not know how to handle.
logger.write("[ERROR] initialize -> onDone -> Operation Failed. Aborting the process.");
callBackFunction(err);
callBackFunction(err.message);
return;
}
break;
}
} catch (err) {
logger.write("[ERROR] initialize -> onDone -> err = " + err);
logger.write("[ERROR] initialize -> onDone -> err = " + err.message);
callBackFunction("Operation Failed");
}
}
@@ -153,7 +153,7 @@
}
}
} catch (err) {
logger.write("[ERROR] initialize -> getExecutionHistory -> err = " + err);
logger.write("[ERROR] initialize -> getExecutionHistory -> err = " + err.message);
callBack("Operation Failed");
}
}
@@ -188,7 +188,7 @@
}
}
} catch (err) {
logger.write("[ERROR] initialize -> getExecutionHistory -> err = " + err);
logger.write("[ERROR] initialize -> getExecutionHistory -> err = " + err.message);
callBack("Operation Failed");
}
}
@@ -230,7 +230,7 @@
}
} catch (err) {
logger.write("[ERROR] initialize -> getExecutionContext -> err = " + err);
logger.write("[ERROR] initialize -> getExecutionContext -> err = " + err.message);
callBack("Operation Failed");
}
}
@@ -263,13 +263,13 @@
callBack(null);
} catch (err) {
logger.write("[ERROR] initialize -> createConext -> err = " + err);
logger.write("[ERROR] initialize -> createConext -> err = " + err.message);
callBack("Operation Failed");
}
}
} catch (err) {
logger.write("[ERROR] initialize -> err = " + err);
logger.write("[ERROR] initialize -> err = " + err.message);
callBackFunction("Operation Failed");
}
}
@@ -290,20 +290,20 @@
break;
case 'Retry Later': { // Something bad happened, but if we retry in a while it might go through the next time.
logger.write("[ERROR] saveThemAll -> onDone -> Retry Later. Requesting Execution Retry.");
callBackFunction(err);
callBackFunction(err.message);
return;
}
break;
case 'Retry Later': { // This is an unexpected exception that we do not know how to handle.
logger.write("[ERROR] saveThemAll -> onDone -> Operation Failed. Aborting the process.");
callBackFunction(err);
callBackFunction(err.message);
return;
}
break;
}
} catch (err) {
logger.write("[ERROR] saveThemAll -> onDone -> err = " + err);
logger.write("[ERROR] saveThemAll -> onDone -> err = " + err.message);
callBackFunction("Operation Failed");
}
}
Datasource.js
+13 -13
View File
@@ -75,20 +75,20 @@
break;
case 'Retry Later': { // Something bad happened, but if we retry in a while it might go through the next time.
logger.write("[ERROR] initialize -> onDone -> Retry Later. Requesting Execution Retry.");
callBackFunction(err);
callBackFunction(err.message);
return;
}
break;
case 'Retry Later': { // This is an unexpected exception that we do not know how to handle.
logger.write("[ERROR] initialize -> onDone -> Operation Failed. Aborting the process.");
callBackFunction(err);
callBackFunction(err.message);
return;
}
break;
}
} catch (err) {
logger.write("[ERROR] initialize -> onDone -> err = " + err);
logger.write("[ERROR] initialize -> onDone -> err = " + err.message);
callBackFunction("Operation Failed");
}
}
@@ -130,7 +130,7 @@
}
}
} catch (err) {
logger.write("[ERROR] getCandles -> getMarketFiles -> err = " + err);
logger.write("[ERROR] getCandles -> getMarketFiles -> err = " + err.message);
callBack("Operation Failed");
}
}
@@ -157,7 +157,7 @@
}
}
} catch (err) {
logger.write("[ERROR] getCandles -> getDailyFiles -> err = " + err);
logger.write("[ERROR] getCandles -> getDailyFiles -> err = " + err.message);
callBack("Operation Failed");
}
}
@@ -220,13 +220,13 @@
}
}
} catch (err) {
logger.write("[ERROR] getCandles -> getCandlesWeAreIn -> err = " + err);
logger.write("[ERROR] getCandles -> getCandlesWeAreIn -> err = " + err.message);
callBack("Operation Failed");
}
}
} catch (err) {
logger.write("[ERROR] getCandles -> err = " + err);
logger.write("[ERROR] getCandles -> err = " + err.message);
callBack("Operation Failed");
}
}
@@ -267,7 +267,7 @@
}
}
} catch (err) {
logger.write("[ERROR] getPatterns -> getMarketFiles -> err = " + err);
logger.write("[ERROR] getPatterns -> getMarketFiles -> err = " + err.message);
callBack("Operation Failed");
}
}
@@ -294,7 +294,7 @@
}
}
} catch (err) {
logger.write("[ERROR] getPatterns -> getDailyFiles -> err = " + err);
logger.write("[ERROR] getPatterns -> getDailyFiles -> err = " + err.message);
callBack("Operation Failed");
}
}
@@ -359,13 +359,13 @@
}
}
} catch (err) {
logger.write("[ERROR] getPatterns -> getStairsWeAreIn -> err = " + err);
logger.write("[ERROR] getPatterns -> getStairsWeAreIn -> err = " + err.message);
callBack("Operation Failed");
}
}
} catch (err) {
logger.write("[ERROR] getPatterns -> err = " + err);
logger.write("[ERROR] getPatterns -> err = " + err.message);
callBack("Operation Failed");
}
}
@@ -407,14 +407,14 @@
}
} catch (err) {
logger.write("[ERROR] getPatterns -> err = " + err);
logger.write("[ERROR] getPatterns -> err = " + err.message);
outerCallBack("Operation Failed");
}
}
} catch (err) {
logger.write("[ERROR] initialize -> err = " + err);
logger.write("[ERROR] initialize -> err = " + err.message);
callBackFunction("Operation Failed");
}
}
Debug Log.js
+2 -2
View File
@@ -48,7 +48,7 @@
}
catch (err) {
console.log("Error trying to create the folders needed. Error: " + err);
console.log("Error trying to create the folders needed. Error: " + err.message);
}
@@ -75,7 +75,7 @@
}
catch (err) {
console.log("Error trying to log info into a file. File: " + filePath + " Error:" + err);
console.log("Error trying to log info into a file. File: " + filePath + " Error:" + err.message);
}
}
ExchangeAPI.js
+18 -19
View File
@@ -1,4 +1,4 @@
exports.newExchangeAPI = function newExchangeAPI(BOT) {
exports.newExchangeAPI = function newExchangeAPI(BOT, DEBUG_MODULE, POLONIEX_CLIENT_MODULE) {
/*
@@ -18,11 +18,9 @@
let bot = BOT;
const DEBUG_MODULE = require('./Debug Log');
const logger = DEBUG_MODULE.newDebugLog();
logger.fileName = MODULE_NAME;
const POLONIEX_CLIENT_MODULE = require('./Poloniex API Client');
let poloniexApiClient;
return thisObject;
@@ -34,6 +32,8 @@
let apiKey = readApiKey();
poloniexApiClient = new POLONIEX_CLIENT_MODULE(apiKey.Key, apiKey.Secret);
callBackFunction(null);
function readApiKey() {
try {
@@ -42,7 +42,7 @@
return JSON.parse(fs.readFileSync(filePath, 'utf8'));
}
catch (err) {
logger.write("[ERROR] initialize -> readApiKey -> err = " + err);
logger.write("[ERROR] initialize -> readApiKey -> err = " + err.message);
logger.write("[HINT] You need to have a file at this path -> " + filePath);
logger.write("[HINT] The file must have the keys to access your poloniex account, in this format -> " + '{ "Key" : "4FB9TMEB-234VH2W1-BYJIXHGM-GL15DSA1", "Secret" : "1a24298skdjdf734uuyhbdagdasdtyut276587256hdsdas765asdasdasd76asdasda765asdasfas6asfda57657asd5a76sd5a7s65d7a6sd57as65d7as65d"}');
logger.write("[HINT] You get this key logging in to your Poloniex web account, enabling API keys and getting a new one. ");
@@ -53,7 +53,7 @@
} catch (err) {
logger.write("[ERROR] initialize -> err = " + err);
logger.write("[ERROR] initialize -> err = " + err.message);
callBackFunction("Operation Failed");
}
}
@@ -98,8 +98,6 @@
return;
}
return;
} else {
/*
@@ -142,7 +140,7 @@
}
}
} catch (err) {
logger.write("[ERROR] getOpenPositions -> onExchangeCallReturned -> Error = " + err.message);
logger.write("[ERROR] getOpenPositions -> Error = " + err.message);
callBackFunction("Operation Failed");
}
}
@@ -186,9 +184,6 @@
callBackFunction("Operation Failed");
return;
}
return;
} else {
/*
@@ -238,7 +233,7 @@
}
}
} catch (err) {
logger.write("[ERROR] getExecutedTrades -> onExchangeCallReturned -> Error = " + err.message);
logger.write("[ERROR] getExecutedTrades -> Error = " + err.message);
callBackFunction("Operation Failed");
}
}
@@ -249,10 +244,18 @@
if (pType === "buy") {
poloniexApiClient.buy(pMarket.assetA, pMarket.assetB, pRate, pAmountB, onExchangeCallReturned);
} else {
return;
}
if (pType === "sell") {
poloniexApiClient.sell(pMarket.assetA, pMarket.assetB, pRate, pAmountB, onExchangeCallReturned);
return;
}
logger.write("[ERROR] putPosition -> pType must be either 'buy' or 'sell'.");
callBackFunction("Operation Failed");
return;
function onExchangeCallReturned(err, exchangeResponse) {
try {
@@ -287,8 +290,6 @@
return;
}
return;
} else {
/*
@@ -320,7 +321,7 @@
}
} catch (err) {
logger.write("[ERROR] putPosition -> err = " + err);
logger.write("[ERROR] putPosition -> err = " + err.message);
callBackFunction("Operation Failed");
}
}
@@ -365,8 +366,6 @@
return;
}
return;
} else {
if (exchangeResponse.success !== 1) {
@@ -403,7 +402,7 @@
}
} catch (err) {
logger.write("[ERROR] movePosition -> err = " + err);
logger.write("[ERROR] movePosition -> err = " + err.message);
callBackFunction("Operation Failed");
}
}