From 57d365a1ffbb4ebe207801e575bf554c782c97b3 Mon Sep 17 00:00:00 2001 From: Luis Fernando Molina Date: Mon, 16 Apr 2018 18:47:17 +0200 Subject: [PATCH] Data Set Debugged until File Not Found --- .vs/AACloud/v15/.suo | Bin 96768 -> 101376 bytes Assistant.js | 2 +- Data Set.js | 10 ++++- Extraction Bot Process Main Loop.js | 21 +++++++++++ Indicator Bot Process Main Loop.js | 21 +++++++++++ Run.js | 10 ++--- Trading Bot Process Main Loop.js | 56 ++++++++++++++++++++++++++++ this.config.json | 4 +- 8 files changed, 112 insertions(+), 12 deletions(-) diff --git a/.vs/AACloud/v15/.suo b/.vs/AACloud/v15/.suo index a77a0e353942f2b02b3382e54fee69aa0b8c7df9..0dee02ef0c1efaf64095f9acc1b6e959e920b330 100644 GIT binary patch delta 6227 zcmeHL4N%l&8sF#7E-bj>vU~;z%SNySD3B?BqzD*(3x=kdibJo0ym9{4Akj#df;MjZ!d_Bfb6{`aZ0cwVfD0zlYgXAUaqWB zmg@LRWvUTcy%A91`teDerS#+4fJs~snjMx6;St%4VFbSB&-;b183%3*FbYTp?f_B% zImQAy60idyfB`TAvL-_;x(V|fpg)ibtOufj+kkrj(QEh8exNr4&jJH3$*7mN>FsOw zVfHmN^FfCKp}<(c2FMB9Kt}+HKoJlJj0T1PnLrRQ9+(VF1d@O-;6)%3m;mGfS-=$F zcAyZDvoV}=!m?+2r?b3tpqI`8T>{Jn%79BddV3e}+Tg^b2mK^f;2#1cEK5PFffam^ z6RnSVr3Ij?06Akd=o-KQxRk13M@(_PBy;xVWFD2gt?|#B?{X71NxUR`a-9sxqEP=V zra^Y2ELyP^4*0Std;PO0b7aw`yB|t&nWS+VaCI7o@fKtHnm4c_TV(iBD7>WbF2Fy9 zC00a3 zsqq^zc^p{j6+QtfwI>R$ka%agL)#HjPXE_#2G}&4`82sg3xY|?Tmig2GAK}jV~pSx zp(~W}XrrN1xF9oIDbn$y1Ew0K3iW>4hC4-|^@Im2ti)S2TmD7TtT7je<3nc!?z-_& zt9?7;f)rOA?1`ODhBD|s%RRAa+z>af!K!y9R6EP#xh^5uS)SZ~D508wTmY#|3?2(6 z|I%b+_H;0J0i_~9E@yfv*xuRT?*Zoc$$EKt;)7_pXR^m=)|Ao!WiUJppUUk@mLU^% zL~u{!AzcUv4@LyW1A2m7u0tcp+5Y&oY5uBbxK z`%PXCzU?rVAB{r7qUW+Ty3>^xqy>%W2}qI{NS!|q2>&$bGhRLlG?JJA1J!V{*=KrnbY`C^jyt4wKUKmC+qmJ+)3OXo)uURowH{CDtDqMcoO5w#}6+y z#zA2A6DlKg+LtpzOs;beaO(VhJ9z|Z;5v1&YZ@de;Bdo0o}dm z#gFKo#BT9Q#yar6SZ@IDi8ZM7pq~SEz;nRsfJ9&R_(xyn5`Ce*!DTyQoaMQc>nyq1 zWzrj@`UW{mZu3O$+roA)ls#cv*RV+6l2Le7&e4Gr$m~Y^od=&St z)70QlTos3cDGSmouI;YqFxnxMw~Nm>gM3mf=AKm(uWR@_^5wua%cccW2ozKNcS$EPO_DyzL;@x$J&f?&;Y=9onZ$0)@<%s zHjxiK3|AhW#s#@KVmpLN8rvQ@?b{q(?kSPNSq9mi`J~su6EuO(0 zyN9`It(tXPC$+S+lTlod;`H4Z(jSu;K&R6#wknsC;op$>#>vonp7al?*8TJesg8S_CS2*zMlyID`o=J{Y_%zxtqujWU1`~L9mfnF$F!c8f|Q1>N=tjY!i{^) zT-uPK?>vu`>6=Ee`=baoKZ7#Z(Uj-bkj_SF%Z6hCP{{3Z%R@|0Cib>HfzMv=#^-6y$Tr=TSD_^+k9EcBdI*`-c=IIsX=PzVv1LnJVe&8a+Hw~mkX80K#Um4t3SwR_aCCz zdZzw|kH-*xb5;VMK2v6pcGBmym>W=rSIU`6DpD^jrr7>7u`U%SbP6XmMYFZd&N*`& z?AYrUXT&Ro_`(6dXh7s2LYzIc&#C5xp+v}CdO+DX+&1>)m|OOBSVmO6*%9{Jd|iF= z#DT|QhUdEovFdw@N;yf1%ePaKWqvXd$7_}I19t??dPjP(j;SL}sy*Z^ zUb@ogjXL#U4sD^${BqX#8T4JE>Z25aV7jS0Hdyu>$^6o zJN2|P^hL>(XIR|7q1K58noCh8pA1x9_R&D$PB~od>Q6!H&LA3~)`gQ@y|;kgrpZWf zcuzO5FwFX)9X&(^sn3Q+@1bUgAv-=&>xZ-c*0&iA;Wx`$FzSiavOlfj$R z)x#)XEv}_9wLX`uswsvt)y&~^m)dM1d+W*=dW{lu`*wA;$;(ZKcp~A$X#K05ZX(s4 zN_KuV#*EM#wY(#FhT9@h}v02F^tajBolJO{Kbdit>L5SGcsi1e_C0b6d(ChGrDdw8tUmD^2g%-k(*I~x_3DtPbtV#V;P0+ ztD)-aKH2lt`$}mvKXa$`8=n4tz7JVYE;)ERZRCRyBG9h zbhlyag*`u$Uua>M3bQW;x;oFM{dRQWe^y~r%6o?_pBk4fsX9FGOxGtf{~?x83#gOahZ1tEK=e?0gMg4R- z`BCHf_4b{Ov|erGH8*bR==z^>|7v5**I4W>o2A)1W_?TEIqH2|-~UPEe%6g3$~3W#K| zR-;fQvjdl^r7*gp2CyV|l~EK8g4J59_*|?$GjSB#R@7$t+mo3%XlP~Wf9=Wo zviI3%-*eC1d*5?z;@KJP={IaENuHzA>GWVA5C}l%2$Xc!jZ$L!l5%%!fBjXO%Qq^m zN*nQ~%0hO=w8oMhKGA@8&&lL`C8o6ySG^!tqRGI&Fj=_C#L`B=UJgn@HZX#*U?xZa zvIv>j3dBD?Bt@SF{en<`1mrld2AIHPoo<+hS;kCDjVg#{c)yUy8xl4sx8u!CSRhtq9r4;xo6Hx};Ohn-oiASLvAaph z$575fK31P^n1taZ?Q~+S!b+}7DI;xdZWn3Rv@c1sq%S4IC2-inr_*!TmvNcTqIk2L zEu&#e2N}Q$GJy?D0K7FjyHx@dNdX3=KN+$J6oaW?8ki1bYzE{^Py$LrHnGowUI8jY zHYa2is0Opa9B>hs3+93Oq^s5~fFc*yK-PjKU=dgh>Vb@fS&se>z%p=YXl#W@zH!Vo zNWt4H<>6;c3`CexGKYpH1vc%xCw4nn9OQ5iWXp9PP6_nZ-p6CV#eT~Y8>){(~NMpRKi zZP`LeF{^aTaU|Wqfz8JZ!4oGK9qzy7xKXxbIo`q%Fvvl&T06ZeM(@4l=(qL0cCI2@ z54)RR8=TtRveo-gaFb%Uw}xkV3&^AW#?pXu zzmv=pQK#}PCC#@_@!h5L95_bC&FIQe628VPTT&X3<~8jrnE)x1P6G1q`H=Ev$YF*P zS0{&?l!F|j@;x>k6azUv`LCu41rnUuU=EPeZZ4PyWU>VzSp!)MdS%%?P&<^2) zAvQdW`W#7K-yFT4ZAKve`r3LxbD#P?0L+w-AiM+xi*?VIFvy397xUL>@*9PMVZc0!yTkdBw50_e<7nHzFQ&t?o)hS3aXg1l?%D{88h#G`VIc_^>_*K zMr+cUiAD# zzr#$u#GZdPabNOzaq=P!*1FE$8c&;}P^9!s`7p~km_}s^wW&wqsGOhweWkw_%O%yb zg$#Z}I(Km2aTptrib zh~m}XP9{64;-Ze7LOEO)lPx**A289jvxH-0-mIdE>Vg92G-q*f#m#$z^FMKeQ?-^- zj2cr&hbVG^qt70`;iF`ZnB1(j{w<%*lfxt2YING+_f}9!_&^f794t}5IrOmn(gzQ8 zrjx>%r*herlcaTjIGfa~O2}-IW1(7{y}^|q|H#DaKYHc-N|?fJDU>PP`(D#fkoF*9 zih8`1^7-z+C;ER`L{BQg>D2YpXg1fn8r0p>$;$gbp1_$W#&bhVvfq(Sy;0hpkH;w~ z(czgP{{)r*XIC)ns|#r^*;EJ{RdJmw>+9;!UB}9CIoSH1k|jETb1yk(l>bXKF)t;y0^JDSb~>Vg5W|1`=LrYIh6OoO>-! z<@8q^4?3EO=t_Qd<`}Lkx-j_Zp*}g8rl^m#&}`$`V*JY zhj<=8-p@dkZ$MF3PNfOzfl{)nffBNxdy#h*lJNm#)3t>#dkJPg$CA$Z4psT$P&KB= ze-Q@Tsi)4lDE)YIeNn@gV4j*+OpE#WNxL@slUu1%!F%xX$#LIL6{ZYdg=g#n-$RLY z8nNi?+7f?BGwHu$(ew pFolderPath = " + pFolderPath); } if (FULL_LOG === true) { logger.write("[INFO] getTextFile -> pFileName = " + pFileName); } - cloudStorage.getTextFile(pFolderPath, pFileName, onFileReceived); + let filePathRoot = dependencyConfig.devTeam + "/" + dependencyConfig.bot + "." + dependencyConfig.botVersion.major + "." + dependencyConfig.botVersion.minor + "/" + global.PLATFORM_CONFIG.codeName + "." + global.PLATFORM_CONFIG.version.major + "." + global.PLATFORM_CONFIG.version.minor + "/" + global.EXCHANGE_NAME + "/" + dependencyConfig.dataSetVersion; + let filePath = filePathRoot + "/Output/" + pFolderPath; + + cloudStorage.getTextFile(filePath, pFileName, onFileReceived); function onFileReceived(err, text) { @@ -109,7 +112,10 @@ return; } - cloudStorage.createTextFile(pFolderPath, pFileName, pFileContent, onFileCreated); + let filePathRoot = dependencyConfig.devTeam + "/" + dependencyConfig.bot + "." + dependencyConfig.botVersion.major + "." + dependencyConfig.botVersion.minor + "/" + global.PLATFORM_CONFIG.codeName + "." + global.PLATFORM_CONFIG.version.major + "." + global.PLATFORM_CONFIG.version.minor + "/" + global.EXCHANGE_NAME + "/" + dependencyConfig.dataSetVersion; + let filePath = filePathRoot + "/Output/" + pFolderPath; + + cloudStorage.createTextFile(filePath, pFileName, pFileContent, onFileCreated); function onFileCreated(err) { diff --git a/Extraction Bot Process Main Loop.js b/Extraction Bot Process Main Loop.js index bc05f9e1c..f9b03944e 100644 --- a/Extraction Bot Process Main Loop.js +++ b/Extraction Bot Process Main Loop.js @@ -109,6 +109,13 @@ callBackFunction(err); return; } + default: { + logger.write("[ERROR] run -> loop -> initializeStatusDependencies -> onInizialized > Unhandled err.result received. -> err.result = " + err.result); + logger.write("[ERROR] run -> loop -> initializeStatusDependencies -> onInizialized > Unhandled err.result received. -> err.message = " + err.message); + + callBackFunction(global.DEFAULT_FAIL_RESPONSE); + return; + } } } } @@ -140,6 +147,13 @@ callBackFunction(err); return; } + default: { + logger.write("[ERROR] run -> loop -> initializeUserBot -> onInizialized > Unhandled err.result received. -> err.result = " + err.result); + logger.write("[ERROR] run -> loop -> initializeUserBot -> onInizialized > Unhandled err.result received. -> err.message = " + err.message); + + callBackFunction(global.DEFAULT_FAIL_RESPONSE); + return; + } } } } @@ -213,6 +227,13 @@ } } } + default: { + logger.write("[ERROR] run -> loop -> startUserBot -> onFinished > Unhandled err.result received. -> err.result = " + err.result); + logger.write("[ERROR] run -> loop -> startUserBot -> onFinished > Unhandled err.result received. -> err.message = " + err.message); + + callBackFunction(global.DEFAULT_FAIL_RESPONSE); + return; + } } } } diff --git a/Indicator Bot Process Main Loop.js b/Indicator Bot Process Main Loop.js index d67faa7e8..28fc84534 100644 --- a/Indicator Bot Process Main Loop.js +++ b/Indicator Bot Process Main Loop.js @@ -109,6 +109,13 @@ callBackFunction(err); return; } + default: { + logger.write("[ERROR] run -> loop -> initializeStatusDependencies -> onInizialized > Unhandled err.result received. -> err.result = " + err.result); + logger.write("[ERROR] run -> loop -> initializeStatusDependencies -> onInizialized > Unhandled err.result received. -> err.message = " + err.message); + + callBackFunction(global.DEFAULT_FAIL_RESPONSE); + return; + } } } } @@ -140,6 +147,13 @@ callBackFunction(err); return; } + default: { + logger.write("[ERROR] run -> loop -> initializeUserBot -> onInizialized > Unhandled err.result received. -> err.result = " + err.result); + logger.write("[ERROR] run -> loop -> initializeUserBot -> onInizialized > Unhandled err.result received. -> err.message = " + err.message); + + callBackFunction(global.DEFAULT_FAIL_RESPONSE); + return; + } } } } @@ -213,6 +227,13 @@ } } } + default: { + logger.write("[ERROR] run -> loop -> startUserBot -> onFinished > Unhandled err.result received. -> err.result = " + err.result); + logger.write("[ERROR] run -> loop -> startUserBot -> onFinished > Unhandled err.result received. -> err.message = " + err.message); + + callBackFunction(global.DEFAULT_FAIL_RESPONSE); + return; + } } } } diff --git a/Run.js b/Run.js index f04147d0d..cf3c5e684 100644 --- a/Run.js +++ b/Run.js @@ -128,9 +128,8 @@ function pad(str, max) { return str.length < max ? pad("0" + str, max) : str; } -/* Some LAGACY code starts here. Pending for clean up. */ +/* Process Loops Declarations. */ -const INTERVAL_EXECUTOR_MODULE = require('./Interval Executor'); const TRADING_BOT_MAIN_LOOP_MODULE = require('./Trading Bot Process Main Loop'); const INDICATOR_BOT_MAIN_LOOP_MODULE = require('./Indicator Bot Process Main Loop'); const EXTRACTION_BOT_MAIN_LOOP_MODULE = require('./Extraction Bot Process Main Loop'); @@ -428,11 +427,8 @@ for (let p = 0; p < global.PLATFORM_CONFIG.executionList.length; p++) { function whenRunFinishes(err) { let botId; - if (pYear !== undefined) { - botId = pBotConfig.devTeam + "." + pBotConfig.codeName + "." + pBotConfig.process + "." + pYear + "." + pMonth; - } else { - botId = pBotConfig.devTeam + "." + pBotConfig.codeName + "." + pBotConfig.process; - } + + botId = pBotConfig.devTeam + "." + pBotConfig.codeName + "." + pBotConfig.process; if (err.result === global.DEFAULT_OK_RESPONSE.result) { diff --git a/Trading Bot Process Main Loop.js b/Trading Bot Process Main Loop.js index 8ebfba91f..e7fabb498 100644 --- a/Trading Bot Process Main Loop.js +++ b/Trading Bot Process Main Loop.js @@ -119,6 +119,13 @@ callBackFunction(err); return; } + default: { + logger.write("[ERROR] run -> loop -> initializeStatusDependencies -> onInizialized > Unhandled err.result received. -> err.result = " + err.result); + logger.write("[ERROR] run -> loop -> initializeStatusDependencies -> onInizialized > Unhandled err.result received. -> err.message = " + err.message); + + callBackFunction(global.DEFAULT_FAIL_RESPONSE); + return; + } } } } @@ -150,6 +157,13 @@ callBackFunction(err); return; } + default: { + logger.write("[ERROR] run -> loop -> initializeDataDependencies -> onInizialized > Unhandled err.result received. -> err.result = " + err.result); + logger.write("[ERROR] run -> loop -> initializeDataDependencies -> onInizialized > Unhandled err.result received. -> err.message = " + err.message); + + callBackFunction(global.DEFAULT_FAIL_RESPONSE); + return; + } } } } @@ -180,6 +194,13 @@ callBackFunction(err); return; } + default: { + logger.write("[ERROR] run -> loop -> initializeContext -> onInizialized > Unhandled err.result received. -> err.result = " + err.result); + logger.write("[ERROR] run -> loop -> initializeContext -> onInizialized > Unhandled err.result received. -> err.message = " + err.message); + + callBackFunction(global.DEFAULT_FAIL_RESPONSE); + return; + } } } } @@ -210,6 +231,13 @@ callBackFunction(err); return; } + default: { + logger.write("[ERROR] run -> loop -> initializeExchangeAPI -> onInizialized > Unhandled err.result received. -> err.result = " + err.result); + logger.write("[ERROR] run -> loop -> initializeExchangeAPI -> onInizialized > Unhandled err.result received. -> err.message = " + err.message); + + callBackFunction(global.DEFAULT_FAIL_RESPONSE); + return; + } } } } @@ -240,6 +268,13 @@ callBackFunction(err); return; } + default: { + logger.write("[ERROR] run -> loop -> initializeAssistant -> onInizialized > Unhandled err.result received. -> err.result = " + err.result); + logger.write("[ERROR] run -> loop -> initializeAssistant -> onInizialized > Unhandled err.result received. -> err.message = " + err.message); + + callBackFunction(global.DEFAULT_FAIL_RESPONSE); + return; + } } } } @@ -271,6 +306,13 @@ callBackFunction(err); return; } + default: { + logger.write("[ERROR] run -> loop -> initializeUserBot -> onInizialized > Unhandled err.result received. -> err.result = " + err.result); + logger.write("[ERROR] run -> loop -> initializeUserBot -> onInizialized > Unhandled err.result received. -> err.message = " + err.message); + + callBackFunction(global.DEFAULT_FAIL_RESPONSE); + return; + } } } } @@ -300,6 +342,13 @@ callBackFunction(err); return; } + default: { + logger.write("[ERROR] run -> loop -> startUserBot -> onFinished > Unhandled err.result received. -> err.result = " + err.result); + logger.write("[ERROR] run -> loop -> startUserBot -> onFinished > Unhandled err.result received. -> err.message = " + err.message); + + callBackFunction(global.DEFAULT_FAIL_RESPONSE); + return; + } } } } @@ -329,6 +378,13 @@ callBackFunction(err); return; } + default: { + logger.write("[ERROR] run -> loop -> saveContext -> onFinished > Unhandled err.result received. -> err.result = " + err.result); + logger.write("[ERROR] run -> loop -> saveContext -> onFinished > Unhandled err.result received. -> err.message = " + err.message); + + callBackFunction(global.DEFAULT_FAIL_RESPONSE); + return; + } } } } diff --git a/this.config.json b/this.config.json index c96f6c4ec..74522385e 100644 --- a/this.config.json +++ b/this.config.json @@ -7,7 +7,7 @@ }, "executionList": [ { - "enabled": "false", + "enabled": "true", "botPath": "../Bots/AAMasters/AAMariam-Trading-Bot", "process": "Trading-Process" }, @@ -37,7 +37,7 @@ "process": "Poloniex-Live-Trades" }, { - "enabled": "true", + "enabled": "false", "botPath": "../Bots/AAMasters/AAMiguel-Indicator-Bot", "process": "Trades-Files-To-Blobs" }