From 3536d2659aa57038a86a831ddfa37115472abf75 Mon Sep 17 00:00:00 2001 From: Julian Molina Date: Thu, 21 Jan 2021 14:38:09 +0100 Subject: [PATCH 01/16] User Manual Book wip --- Projects/Superalgos/Schemas/Docs-Books/user-manual.json | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/Projects/Superalgos/Schemas/Docs-Books/user-manual.json b/Projects/Superalgos/Schemas/Docs-Books/user-manual.json index 02cb7f670..20d2b162c 100644 --- a/Projects/Superalgos/Schemas/Docs-Books/user-manual.json +++ b/Projects/Superalgos/Schemas/Docs-Books/user-manual.json @@ -36,8 +36,9 @@ "updated": 1610310832197 }, { - "style": "Text", - "text": "Work in Progress" + "style": "Chapter", + "text": "VII->Superalgos->Topic->Low-Frequency Trading Bot->In Superalgos, the Trading Bot plays no part in the definition of the trading logic. Instead, it is the program that executes the trading logic, interacts with the exchange, and keeps track of orders.", + "updated": 1611236020198 }, { "style": "Text", From e0186e2ef7ce0ed5894f111c9728268ad989ebd9 Mon Sep 17 00:00:00 2001 From: Julian Molina Date: Thu, 21 Jan 2021 14:58:29 +0100 Subject: [PATCH 02/16] User Manual Book WIP --- Projects/Superalgos/Schemas/Docs-Books/user-manual.json | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) diff --git a/Projects/Superalgos/Schemas/Docs-Books/user-manual.json b/Projects/Superalgos/Schemas/Docs-Books/user-manual.json index 20d2b162c..67aadeb94 100644 --- a/Projects/Superalgos/Schemas/Docs-Books/user-manual.json +++ b/Projects/Superalgos/Schemas/Docs-Books/user-manual.json @@ -40,9 +40,14 @@ "text": "VII->Superalgos->Topic->Low-Frequency Trading Bot->In Superalgos, the Trading Bot plays no part in the definition of the trading logic. Instead, it is the program that executes the trading logic, interacts with the exchange, and keeps track of orders.", "updated": 1611236020198 }, + { + "style": "Chapter", + "text": "VIII->Superalgos->Topic->Order Management->One of the crucial aspects of trading automation is the management of orders. The system operates with assumptions that must be verified and synchronized with the exchange. Learning how the Low-Frequency Trading Bot manages orders will help you understand the life cycle of orders and how your definitions in the Open Stage and the Close Stage affect the results.", + "updated": 1611237227549 + }, { "style": "Text", - "text": "Work in Progress" + "text": "" }, { "style": "Text", From 6d78112bc2aa949ed57716fb82fe42d7029a9b9c Mon Sep 17 00:00:00 2001 From: Julian Molina Date: Thu, 21 Jan 2021 19:35:12 +0100 Subject: [PATCH 03/16] Trading Engine Topic WIP --- .../Schemas/Docs-Books/user-manual.json | 16 +++++ ...g-bot-003-data-products-visualization.json | 32 +++++++++ ...g-engine-001-trading-engine-hierarchy.json | 24 +++++++ ...ng-engine-002-monitoring-runtime-data.json | 68 +++++++++++++++++++ ...trading-engine-003-trading-bot-output.json | 28 ++++++++ 5 files changed, 168 insertions(+) create mode 100644 Projects/Superalgos/Schemas/Docs-Topics/low-frequency-trading-bot-003-data-products-visualization.json create mode 100644 Projects/Superalgos/Schemas/Docs-Topics/trading-engine-001-trading-engine-hierarchy.json create mode 100644 Projects/Superalgos/Schemas/Docs-Topics/trading-engine-002-monitoring-runtime-data.json create mode 100644 Projects/Superalgos/Schemas/Docs-Topics/trading-engine-003-trading-bot-output.json diff --git a/Projects/Superalgos/Schemas/Docs-Books/user-manual.json b/Projects/Superalgos/Schemas/Docs-Books/user-manual.json index 67aadeb94..6c4651588 100644 --- a/Projects/Superalgos/Schemas/Docs-Books/user-manual.json +++ b/Projects/Superalgos/Schemas/Docs-Books/user-manual.json @@ -56,6 +56,22 @@ { "style": "Text", "text": "Work in Progress" + }, + { + "style": "Text", + "text": "Work in Progress" + }, + { + "style": "Text", + "text": "Work in Progress" + }, + { + "style": "Text", + "text": "Work in Progress" + }, + { + "style": "Text", + "text": "" } ] } \ No newline at end of file diff --git a/Projects/Superalgos/Schemas/Docs-Topics/low-frequency-trading-bot-003-data-products-visualization.json b/Projects/Superalgos/Schemas/Docs-Topics/low-frequency-trading-bot-003-data-products-visualization.json new file mode 100644 index 000000000..a23fb2308 --- /dev/null +++ b/Projects/Superalgos/Schemas/Docs-Topics/low-frequency-trading-bot-003-data-products-visualization.json @@ -0,0 +1,32 @@ +{ + "topic": "Low-Frequency Trading Bot", + "pageNumber": "3", + "type": "Data Products Visualization", + "definition": { + "text": "The Superalgos trading bot outputs several data products which may be visualized on the frontend application in multiple manners.", + "updated": 1611240250659 + }, + "paragraphs": [ + { + "style": "Text", + "text": "The Low-Frequency trading bot outputs tens of data products, which are made available for others to use through the data structure provided by the Trading Engine hierarchy, the Trading System involved in the trading session, and the time machines installed to visualize the trading simulations.", + "updated": 1611252948830 + }, + { + "style": "Success", + "text": "The Trading Bot Layers interactive tutorial available in the Weak-Hands Buster v.2 plugin workspace covers all the trading bot features that enable the visualization of trading information:" + }, + { + "style": "List", + "text": "Visualization of simulations over the chart for all types of trading sessions." + }, + { + "style": "List", + "text": "Visualization of all the trading information managed by the trading bot on the trading engine hierarchy." + }, + { + "style": "List", + "text": "Visualization of event highlights, values, warnings, errors, and general information concerning the trading system." + } + ] +} \ No newline at end of file diff --git a/Projects/Superalgos/Schemas/Docs-Topics/trading-engine-001-trading-engine-hierarchy.json b/Projects/Superalgos/Schemas/Docs-Topics/trading-engine-001-trading-engine-hierarchy.json new file mode 100644 index 000000000..dbba385f0 --- /dev/null +++ b/Projects/Superalgos/Schemas/Docs-Topics/trading-engine-001-trading-engine-hierarchy.json @@ -0,0 +1,24 @@ +{ + "topic": "Trading Engine", + "pageNumber": "1", + "type": "Trading Engine Hierarchy", + "definition": { + "text": "The trading engine provides a feedback loop to trading systems so that your strategies may leverage the information processed by the trading bot.", + "updated": 1611253515308 + }, + "paragraphs": [ + { + "style": "Include", + "text": "Superalgos->Node->Trading Engine->Definition", + "updated": 1611253576142 + }, + { + "style": "Include", + "text": "Superalgos->Node->Trading Engine->Content" + }, + { + "style": "Success", + "text": "The trading engine hierarchy is deep and large, with many ramifications. It is best to learn it through hands-on experimentation, by testing an existing trading system." + } + ] +} \ No newline at end of file diff --git a/Projects/Superalgos/Schemas/Docs-Topics/trading-engine-002-monitoring-runtime-data.json b/Projects/Superalgos/Schemas/Docs-Topics/trading-engine-002-monitoring-runtime-data.json new file mode 100644 index 000000000..39ea663b5 --- /dev/null +++ b/Projects/Superalgos/Schemas/Docs-Topics/trading-engine-002-monitoring-runtime-data.json @@ -0,0 +1,68 @@ +{ + "topic": "Trading Engine", + "pageNumber": "2", + "type": "Monitoring Runtime Data", + "definition": { + "text": "Use the trading engine hierarchy to track every piece of information processed by the trading bot, candle by candle.", + "updated": 1611253725593 + }, + "paragraphs": [ + { + "style": "Text", + "text": "The trading engine hierarchy is a portal into the trading bot’s machine room—the brain. Think of the trading engine as a terminal connected to each of the brain’s neurons, taking a snapshot for every candle, and registering with precision every piece of data handled by the trading bot during the trading session.", + "updated": 1611253749127 + }, + { + "style": "Text", + "text": "Superalgos combines the time navigation features of the charts with the visual environment representing data structures of the design space, to create an immersive user experience." + }, + { + "style": "Callout", + "text": "Each of the nodes in the hierarchy may display its value on the design space, right below the icon representing the node, for each candle." + }, + { + "style": "Note", + "text": "How users may monitor the information featured in the Trading Engine hierarchy is explained and demonstrated on the Trading Bot Layers tutorial available on the Weak-hands Buster V2.0 plugin workspace.", + "updated": 1611253775463 + }, + { + "style": "Text", + "text": "As a quick refresher, the process is more or less as follows:" + }, + { + "style": "List", + "text": "Run a trading session. Start with a backtest, so that you may get a quick feel of how the Trading Engine hierarchy displays data spanning any period.", + "updated": 1611253817389 + }, + { + "style": "List", + "text": "Go to the chart displaying the simulation and find one of the positions.", + "updated": 1611253824254 + }, + { + "style": "List", + "text": "Turn on the Current Position layer in the Trading Engine layer manager. This layer monitors the position structure of nodes under the current node, that is, the information regarding current positions.", + "updated": 1611253835635 + }, + { + "style": "List", + "text": "Split the screen to make room for both the design space and the charting space.", + "updated": 1611253840769 + }, + { + "style": "List", + "text": "Position the view on the design space so that you may see the corresponding structure of nodes.", + "updated": 1611253852074 + }, + { + "style": "List", + "text": "Slide the pointer of the mouse over the charts, across the position, and notice how the values for each node displayed on the design space change. Each node displays the corresponding value for each candle.", + "updated": 1611253859589 + }, + { + "style": "Success", + "text": "Much of the data handled by the trading engine may also be visualized over the charts through the layers and panels in the Trading Charts layer manager. If any of the above is not clear, please refer to the Trading Bot Layers Tutorial available on the Weak-hands Buster V2.0 plugin workspace.", + "updated": 1611253891479 + } + ] +} \ No newline at end of file diff --git a/Projects/Superalgos/Schemas/Docs-Topics/trading-engine-003-trading-bot-output.json b/Projects/Superalgos/Schemas/Docs-Topics/trading-engine-003-trading-bot-output.json new file mode 100644 index 000000000..09aa872d7 --- /dev/null +++ b/Projects/Superalgos/Schemas/Docs-Topics/trading-engine-003-trading-bot-output.json @@ -0,0 +1,28 @@ +{ + "topic": "Trading Engine", + "pageNumber": "3", + "type": "Trading Bot Output", + "definition": { + "text": "The trading bot stores every piece of information processed in files, making all data accessible to others, both online and offline.", + "updated": 1611254037722 + }, + "paragraphs": [ + { + "style": "Text", + "text": "As explained elsewhere, the trading bot makes the information it processes available to users through the hierarchy of the trading engine, which may be visualized both on the design space and over the charts. It also makes it available to trading systems.", + "updated": 1611254053601 + }, + { + "style": "Text", + "text": "On top of that, the information is also stored in files, sorted by concept. These makes the runtime information available to other processes and external systems, to be accessed both online, that is, at runtime, of offline." + }, + { + "style": "Text", + "text": "The trading bot outputs files on the node it runs on, particularly, in the following location:" + }, + { + "style": "Json", + "text": "Data Storage > [Exchange] > [Market] > Masters-Trading > Low-Frequency > Output > [Session] > Concept > Multi-Period-[Daily/Market] > Time Frame" + } + ] +} \ No newline at end of file From 3ea470bf60daa2f117b97afb8b5966eda1ae95d7 Mon Sep 17 00:00:00 2001 From: Luis Fernando Molina Date: Thu, 21 Jan 2021 20:14:57 +0100 Subject: [PATCH 04/16] Bug Fixed Issue #318. Using # in the name of the trading system didn't show backtest results. --- Client/WebServer/index.html | 2 +- Client/httpInterface.js | 7 ++++++- README.md | 2 +- UI/Data-Files/src/FileStorage.js | 7 +++++-- 4 files changed, 13 insertions(+), 5 deletions(-) diff --git a/Client/WebServer/index.html b/Client/WebServer/index.html index d98447b00..68b4975d4 100644 --- a/Client/WebServer/index.html +++ b/Client/WebServer/index.html @@ -62,7 +62,7 @@ Jeff Braun, rico4dev, 9808us, Barry Low, Nikola Bjelogrlic, Hirajin Koizuko, Francisco J. Santillán, Norman, Viktoria B., Guillermo V., Daniel J., Javier A., Gustavo J., Romina GS, Pedro P., Thais M., Andrey M., Loui M., Natalia M., Bashar A., Carlos V., - Diego M., + Diego M., CarnivalBen, Sebastian E., Bogdan P., Marko V., Igor S., Niksa K., Rodrigo M., Nicanor M., Alejandro P., Mateo H., Lan T., Leon A., Uroš R., Filip M., Vladimir J. and Pavle B.

With Superalgos Beta 8, contributing is easier than ever! Become a contributor!

diff --git a/Client/httpInterface.js b/Client/httpInterface.js index 11e66375c..8bb2a9f5c 100644 --- a/Client/httpInterface.js +++ b/Client/httpInterface.js @@ -1349,7 +1349,12 @@ exports.newHttpInterface = function newHttpInterface(WEB_SERVER, DATA_FILE_SERVE case 'Storage': { - respondWithFile(global.env.PATH_TO_DATA_STORAGE + '/' + httpRequest.url.substring(9), httpResponse) + let pathToFile = httpRequest.url.substring(9) + /* Unsavping # */ + for (let i = 0; i < 10; i++) { + pathToFile = pathToFile.replace('HASHTAG', '#') + } + respondWithFile(global.env.PATH_TO_DATA_STORAGE + '/' + pathToFile, httpResponse) } break diff --git a/README.md b/README.md index b29d41ed5..9438be4f4 100644 --- a/README.md +++ b/README.md @@ -261,7 +261,7 @@ Superalgos is a Community Project built by Contributors for Contributors. Learn ## Top Contributors -Luis Fernando Molina, Julian Molina, Andreja Cobeljic, Matías Benitez, Ira Miller, Eduardo Remis, Jeff Braun, rico4dev, 9808us, Barry Low, Nikola Bjelogrlic, Hirajin Koizuko, Francisco J. Santillán, Norman, Viktoria B., Guillermo V., Daniel J., Javier A., Gustavo J., Romina GS, Pedro P., Thais M., Andrey M., Loui M., Natalia M., Bashar A., Carlos V., Diego M., Sebastian E., Bogdan P., Marko V., Igor S., Niksa K., Rodrigo M., Nicanor M., Alejandro P., Mateo H., Lan T., Leon A., Uroš R., Filip M., Vladimir J. and Pavle B. +Luis Fernando Molina, Julian Molina, Andreja Cobeljic, Matías Benitez, Ira Miller, Eduardo Remis, Jeff Braun, rico4dev, 9808us, Barry Low, Nikola Bjelogrlic, Hirajin Koizuko, Francisco J. Santillán, Norman, Viktoria B., Guillermo V., Daniel J., Javier A., Gustavo J., Romina GS, Pedro P., Thais M., Andrey M., Loui M., Natalia M., Bashar A., Carlos V., Diego M., CarnivalBen, Sebastian E., Bogdan P., Marko V., Igor S., Niksa K., Rodrigo M., Nicanor M., Alejandro P., Mateo H., Lan T., Leon A., Uroš R., Filip M., Vladimir J. and Pavle B. # License diff --git a/UI/Data-Files/src/FileStorage.js b/UI/Data-Files/src/FileStorage.js index eda906c26..e4f7ae9ea 100644 --- a/UI/Data-Files/src/FileStorage.js +++ b/UI/Data-Files/src/FileStorage.js @@ -2,7 +2,7 @@ function newFileStorage(host, port) { const MODULE_NAME = 'File Storage' const INFO_LOG = false const logger = newWebDebugLog() - + const MAX_RETRY = 2 let currentRetry = 0 @@ -37,13 +37,16 @@ function newFileStorage(host, port) { if (pathComplete === false || pathComplete === undefined) { folder = 'Storage/' } - let url = folder + filePath + let url + if (host !== undefined && port !== undefined) { url = 'http://' + host + ':' + port + '/' + folder + filePath } else { url = folder + filePath } + /* Scaping # since it breaks the URL */ + url = url.replaceAll('#', 'HASHTAG') httpRequest(undefined, url, (response, fileContent) => { if (response.result === GLOBAL.DEFAULT_OK_RESPONSE.result) { callBackFunction(GLOBAL.DEFAULT_OK_RESPONSE, fileContent) From 04d39bb1117f704c79eec52680e9b0c3868e085c Mon Sep 17 00:00:00 2001 From: Julian Molina Date: Thu, 21 Jan 2021 20:17:43 +0100 Subject: [PATCH 05/16] Trading Engine Topic WIP --- .../Docs-Concepts/reusable-snippets.json | 20 +++++ ...004-temporal-context-current-and-last.json | 76 +++++++++++++++++++ 2 files changed, 96 insertions(+) create mode 100644 Projects/Superalgos/Schemas/Docs-Topics/trading-engine-004-temporal-context-current-and-last.json diff --git a/Projects/Superalgos/Schemas/Docs-Concepts/reusable-snippets.json b/Projects/Superalgos/Schemas/Docs-Concepts/reusable-snippets.json index d0f9b82a3..360e27202 100644 --- a/Projects/Superalgos/Schemas/Docs-Concepts/reusable-snippets.json +++ b/Projects/Superalgos/Schemas/Docs-Concepts/reusable-snippets.json @@ -24,6 +24,26 @@ "text": "Dummy", "updated": 1610121260808 }, + { + "style": "Title", + "text": "Note for Hierarchy Tables No Discussion", + "updated": 1611254828783 + }, + { + "style": "Block", + "text": "Note for Hierarchy Tables No Discussion", + "updated": 1611254840023 + }, + { + "style": "Note", + "text": "Click on any of the nodes to get the details, including particulars on their configuration, when applicable.", + "updated": 1611254904577 + }, + { + "style": "Block", + "text": "Dummy", + "updated": 1611254890702 + }, { "style": "Title", "text": "Important for Live Sessions" diff --git a/Projects/Superalgos/Schemas/Docs-Topics/trading-engine-004-temporal-context-current-and-last.json b/Projects/Superalgos/Schemas/Docs-Topics/trading-engine-004-temporal-context-current-and-last.json new file mode 100644 index 000000000..5b221ed57 --- /dev/null +++ b/Projects/Superalgos/Schemas/Docs-Topics/trading-engine-004-temporal-context-current-and-last.json @@ -0,0 +1,76 @@ +{ + "topic": "Trading Engine", + "pageNumber": "4", + "type": "Temporal Context - Current and Last", + "definition": { + "text": "Much of the information provided by the trading engine may be accessed for the current instance of the object as well as for the last instance that was open, at any point in time.", + "updated": 1611254206670 + }, + "paragraphs": [ + { + "style": "Text", + "text": "The trading engine hierarchy is organized by context. That is, the main offspring nodes—current, last, and exchange orders—describe the context in which their respective offspring live.", + "updated": 1611254225764 + }, + { + "style": "Text", + "text": "For example, the concept of an episode—a whole run of the trading bot— exists only in the context of the current episode, as the system keeps track of one episode at the time only." + }, + { + "style": "Text", + "text": "However, the concept of a position is tracked both as the current position and the last position. This is possible because the system keeps track of all positions occurring within an episode." + }, + { + "style": "Callout", + "text": "Superalgos developers thought it was worth it to provide certain information, positions, for example, in both contexts, as this allows you—visually—and your trading system—using simple syntax—to access information about the current position and the last position at any given point in time." + }, + { + "style": "Title", + "text": "Current", + "updated": 1611254496763 + }, + { + "style": "Include", + "text": "Superalgos->Node->Current->Definition", + "updated": 1611254540559 + }, + { + "style": "Include", + "text": "Superalgos->Node->Current->Content" + }, + { + "style": "Include", + "text": "Superalgos->Concept->Reusable Snippets->Note for Hierarchy Tables No Discussion", + "updated": 1611255184563 + }, + { + "style": "Hierarchy", + "text": "Superalgos->Current->2", + "updated": 1611254736085 + }, + { + "style": "Title", + "text": "Last", + "updated": 1611254547170 + }, + { + "style": "Include", + "text": "Superalgos->Node->Last->Definition", + "updated": 1611254556715 + }, + { + "style": "Include", + "text": "Superalgos->Node->Last->Content" + }, + { + "style": "Include", + "text": "Superalgos->Concept->Reusable Snippets->Note for Hierarchy Tables No Discussion", + "updated": 1611255197793 + }, + { + "style": "Hierarchy", + "text": "Superalgos->Last->2", + "updated": 1611255233693 + } + ] +} \ No newline at end of file From 3a11c1e2b3271249858456295be7a3dabe5b9fe2 Mon Sep 17 00:00:00 2001 From: Luis Fernando Molina Date: Thu, 21 Jan 2021 20:50:43 +0100 Subject: [PATCH 06/16] Improvemnts in error handling --- Client/WebServer/index.html | 2 +- ...001-ts-process-error-unexpected-error.json | 66 +++++++++++++++++++ ...rs-001-ts-task-error-unexpected-error.json | 17 +++++ .../Indicator-Bot/SingleMarketIndicatorBot.js | 1 + .../TS/Function-Libraries/NodeJSFunctions.js | 4 ++ .../Spaces/Floating-Space/UiObjectMessage.js | 29 ++++++-- 6 files changed, 114 insertions(+), 5 deletions(-) diff --git a/Client/WebServer/index.html b/Client/WebServer/index.html index 68b4975d4..086965ed6 100644 --- a/Client/WebServer/index.html +++ b/Client/WebServer/index.html @@ -155,7 +155,7 @@
- +
diff --git a/Projects/Superalgos/Schemas/Docs-Topics/ts-process-errors-001-ts-process-error-unexpected-error.json b/Projects/Superalgos/Schemas/Docs-Topics/ts-process-errors-001-ts-process-error-unexpected-error.json index 029fa082d..25346ec73 100644 --- a/Projects/Superalgos/Schemas/Docs-Topics/ts-process-errors-001-ts-process-error-unexpected-error.json +++ b/Projects/Superalgos/Schemas/Docs-Topics/ts-process-errors-001-ts-process-error-unexpected-error.json @@ -13,6 +13,72 @@ { "style": "Error", "text": "Unexpected Error" + }, + { + "style": "Title", + "text": "Error Details", + "updated": 1611258020914 + }, + { + "style": "Text", + "text": "In the following section you will find the specific information received when this error occured." + }, + { + "style": "Success", + "text": "You will only see it if you opened this page as a result of the error actually happening.", + "updated": 1611258030660 + }, + { + "style": "Subtitle", + "text": "Error Message" + }, + { + "style": "Text", + "text": "The following is the Error Message of the Exception that occured at the TS:" + }, + { + "style": "Placeholder", + "text": "errorMessage" + }, + { + "style": "Subtitle", + "text": "Error Stack" + }, + { + "style": "Text", + "text": "The following is the Error Stack of the Exception that occured at the TS:" + }, + { + "style": "Placeholder", + "text": "errorStack" + }, + { + "style": "Subtitle", + "text": "Error Code" + }, + { + "style": "Text", + "text": "The follwing is the Error Code of the Exception that occured at the TS:" + }, + { + "style": "Placeholder", + "text": "errorCode" + }, + { + "style": "Subtitle", + "text": "Error Details" + }, + { + "style": "Text", + "text": "The follwing are all the Error details of the Exception that occured at the TS:" + }, + { + "style": "Placeholder", + "text": "errorDetails" + }, + { + "style": "Text", + "text": "" } ] } \ No newline at end of file diff --git a/Projects/Superalgos/Schemas/Docs-Topics/ts-task-errors-001-ts-task-error-unexpected-error.json b/Projects/Superalgos/Schemas/Docs-Topics/ts-task-errors-001-ts-task-error-unexpected-error.json index 31430900c..ddc81c487 100644 --- a/Projects/Superalgos/Schemas/Docs-Topics/ts-task-errors-001-ts-task-error-unexpected-error.json +++ b/Projects/Superalgos/Schemas/Docs-Topics/ts-task-errors-001-ts-task-error-unexpected-error.json @@ -68,6 +68,23 @@ "style": "Placeholder", "text": "errorCode" }, + { + "style": "Subtitle", + "text": "Error Details" + }, + { + "style": "Text", + "text": "The follwing are all the Error details of the Exception that occured at the TS:", + "updated": 1611257840235 + }, + { + "style": "Placeholder", + "text": "errorDetails" + }, + { + "style": "Text", + "text": "" + }, { "style": "Text", "text": "" diff --git a/Projects/Superalgos/TS/Bot-Modules/Indicator-Bot/SingleMarketIndicatorBot.js b/Projects/Superalgos/TS/Bot-Modules/Indicator-Bot/SingleMarketIndicatorBot.js index 383a87778..252bdfd1e 100644 --- a/Projects/Superalgos/TS/Bot-Modules/Indicator-Bot/SingleMarketIndicatorBot.js +++ b/Projects/Superalgos/TS/Bot-Modules/Indicator-Bot/SingleMarketIndicatorBot.js @@ -58,6 +58,7 @@ function run(callBackFunction) { try { + require ('CACA') loop() function loop() { diff --git a/Projects/Superalgos/TS/Function-Libraries/NodeJSFunctions.js b/Projects/Superalgos/TS/Function-Libraries/NodeJSFunctions.js index b74a15a4d..84fdab8c7 100644 --- a/Projects/Superalgos/TS/Function-Libraries/NodeJSFunctions.js +++ b/Projects/Superalgos/TS/Function-Libraries/NodeJSFunctions.js @@ -43,6 +43,10 @@ exports.newSuperalgosFunctionLibrariesNodeJSFunctions = function () { text: TS.projects.superalgos.globals.taskVariables.UNEXPECTED_ERROR.code } } + docs.placeholder.errorDetails = { + style: 'Json', + text: JSON.stringify(TS.projects.superalgos.globals.taskVariables.UNEXPECTED_ERROR, undefined, 4) + } } if (TS.projects.superalgos.globals.taskVariables.FATAL_ERROR_MESSAGE || TS.projects.superalgos.globals.taskVariables.UNEXPECTED_ERROR) { diff --git a/Projects/Superalgos/UI/Spaces/Floating-Space/UiObjectMessage.js b/Projects/Superalgos/UI/Spaces/Floating-Space/UiObjectMessage.js index 7f35302d2..12eb18f01 100644 --- a/Projects/Superalgos/UI/Spaces/Floating-Space/UiObjectMessage.js +++ b/Projects/Superalgos/UI/Spaces/Floating-Space/UiObjectMessage.js @@ -25,6 +25,7 @@ function newUiObjectMessage() { thisObject.container.frame.radius = 0 let selfMouseClickEventSubscriptionId + let hoverAnimationCounter = 0 return thisObject @@ -50,6 +51,7 @@ function newUiObjectMessage() { function getContainer(point) { if (thisObject.text === undefined) { return } if (thisObject.container.frame.isThisPointHere(point, true) === true) { + hoverAnimationCounter = 30 return thisObject.container } else { return undefined @@ -68,6 +70,11 @@ function newUiObjectMessage() { thisObject.container.frame.width = FRAME_WIDTH thisObject.container.frame.height = FRAME_HEIGHT + + hoverAnimationCounter-- + if (hoverAnimationCounter < 0) { + hoverAnimationCounter = 0 + } } function onMouseClick(event) { @@ -120,15 +127,29 @@ function newUiObjectMessage() { } } - function drawMessageBackground(borderColor) { + function drawMessageBackground(color) { if (thisObject.text === undefined) { return } + let backgroundColor + let borderColor + let lineWidth + + if (hoverAnimationCounter > 0 && thisObject.docs !== undefined) { + backgroundColor = UI_COLOR.LIGHT_GREY + borderColor = color + lineWidth = 2 + } else { + backgroundColor = UI.projects.superalgos.spaces.floatingSpace.style.backgroundColor + borderColor = color + lineWidth = 0.5 + } + let params = { - cornerRadius: 5, - lineWidth: 0.5, + cornerRadius: 10, + lineWidth: lineWidth, container: thisObject.container, borderColor: borderColor, - backgroundColor: UI.projects.superalgos.spaces.floatingSpace.style.backgroundColor, + backgroundColor: backgroundColor, castShadow: false, opacity: 0.75 } From ae7022634771790500526443411ac5d3b48c63da Mon Sep 17 00:00:00 2001 From: Julian Molina Date: Thu, 21 Jan 2021 20:54:55 +0100 Subject: [PATCH 07/16] Trading Engine Topic WIP --- ...ode-strategy-position-strategy-stages.json | 239 ++++++++++++++++++ ...ngine-006-base-asset-and-quoted-asset.json | 169 +++++++++++++ 2 files changed, 408 insertions(+) create mode 100644 Projects/Superalgos/Schemas/Docs-Topics/trading-engine-005-temporal-context-episode-strategy-position-strategy-stages.json create mode 100644 Projects/Superalgos/Schemas/Docs-Topics/trading-engine-006-base-asset-and-quoted-asset.json diff --git a/Projects/Superalgos/Schemas/Docs-Topics/trading-engine-005-temporal-context-episode-strategy-position-strategy-stages.json b/Projects/Superalgos/Schemas/Docs-Topics/trading-engine-005-temporal-context-episode-strategy-position-strategy-stages.json new file mode 100644 index 000000000..1cc31ee35 --- /dev/null +++ b/Projects/Superalgos/Schemas/Docs-Topics/trading-engine-005-temporal-context-episode-strategy-position-strategy-stages.json @@ -0,0 +1,239 @@ +{ + "topic": "Trading Engine", + "pageNumber": "5", + "type": "Conceptual Context - Episode, Strategy, Position, Strategy Stages", + "definition": { + "text": "Track the properties within each of the major concepts handled by the trading bot, such as episodes, strategies, positions, strategy stages, and exchange orders.", + "updated": 1611256914210 + }, + "paragraphs": [ + { + "style": "Text", + "text": "Episodes, strategies, positions, strategy stages, exchange orders, and other concepts may be seen as different contexts too, although not of the temporal kind.", + "updated": 1611256927199 + }, + { + "style": "Text", + "text": "For instance, you may want to know what the ROI is in the context of the episode—that is, the ROI after several positions have passed—or the ROI of the current position only." + }, + { + "style": "Callout", + "text": "In other words, many properties such as performance metrics—like ROI, or profit loss—or market data—like the begin and end datetimes or any of these concepts—exist in more than one conceptual context." + }, + { + "style": "Text", + "text": "The following pages describe each of these major conceptual contexts, which, in turn, may exist in more than one temporal context." + }, + { + "style": "Note", + "text": "From the perspective of systems design, each of these concepts is handled as an object that may be open or closed, thus has a lifespan. The same object may be open more than once, but only after the previous instance has been closed.", + "updated": 1611256963378 + }, + { + "style": "Title", + "text": "Episode", + "updated": 1611257045974 + }, + { + "style": "Include", + "text": "Superalgos->Node->Episode->Definition", + "updated": 1611257060021 + }, + { + "style": "Include", + "text": "Superalgos->Node->Episode->Content", + "updated": 1611257063548 + }, + { + "style": "Include", + "text": "Superalgos->Concept->Reusable Snippets->Note for Hierarchy Tables No Discussion" + }, + { + "style": "Hierarchy", + "text": "Superalgos->Episode->2", + "updated": 1611257076886 + }, + { + "style": "Text", + "text": "" + }, + { + "style": "Title", + "text": "Strategy", + "updated": 1611257279919 + }, + { + "style": "Text", + "text": "" + }, + { + "style": "Include", + "text": "Superalgos->Node->Strategy->Definition", + "updated": 1611257297317 + }, + { + "style": "Include", + "text": "Superalgos->Node->Strategy->Content", + "updated": 1611257300492 + }, + { + "style": "Include", + "text": "Superalgos->Concept->Reusable Snippets->Note for Hierarchy Tables No Discussion" + }, + { + "style": "Hierarchy", + "text": "Superalgos->Strategy->2", + "updated": 1611257312551 + }, + { + "style": "Title", + "text": "Position", + "updated": 1611257347308 + }, + { + "style": "Include", + "text": "Superalgos->Node->Position->Definition", + "updated": 1611257358664 + }, + { + "style": "Include", + "text": "Superalgos->Node->Position->Content", + "updated": 1611257362447 + }, + { + "style": "Include", + "text": "Superalgos->Concept->Reusable Snippets->Note for Hierarchy Tables No Discussion" + }, + { + "style": "Hierarchy", + "text": "Superalgos->Position->2", + "updated": 1611257376163 + }, + { + "style": "Title", + "text": "Strategy Stages", + "updated": 1611257433526 + }, + { + "style": "Text", + "text": "The Superalgos Protocol implements a trading framework by which strategies within a trading system are described in stages. The trading bot uses these definitions during runtime.", + "updated": 1611257532139 + }, + { + "style": "Text", + "text": "The concept of strategy stages in the context of the trading engine is an extension of the original concept, useful to keep track of the activity of the trading bot and organize the information processed during runtime." + }, + { + "style": "Text", + "text": "Use these sections of the trading engine if you wish to track exactly what is going on, at a granular level, step by step, from the instant a strategy is triggered until it is closed, with the information segregated by strategy stage." + }, + { + "style": "Callout", + "text": "The exercise may be particularly useful to grasp the intricacies of the workings of the trading bot or to research particular behaviors." + }, + { + "style": "Subtitle", + "text": "Strategy Trigger Stage", + "updated": 1611257553903 + }, + { + "style": "Include", + "text": "Superalgos->Node->Strategy Trigger Stage->Definition", + "updated": 1611257563170 + }, + { + "style": "Include", + "text": "Superalgos->Node->Strategy Trigger Stage->Content", + "updated": 1611257566539 + }, + { + "style": "Include", + "text": "Superalgos->Concept->Reusable Snippets->Note for Hierarchy Tables No Discussion" + }, + { + "style": "Hierarchy", + "text": "Superalgos->Strategy Trigger Stage->2", + "updated": 1611257598667 + }, + { + "style": "Text", + "text": "" + }, + { + "style": "Subtitle", + "text": "Strategy Open Stage", + "updated": 1611257613573 + }, + { + "style": "Include", + "text": "Superalgos->Node->Strategy Open Stage->Definition", + "updated": 1611257617299 + }, + { + "style": "Include", + "text": "Superalgos->Node->Strategy Open Stage->Content", + "updated": 1611257621534 + }, + { + "style": "Include", + "text": "Superalgos->Concept->Reusable Snippets->Note for Hierarchy Tables No Discussion" + }, + { + "style": "Hierarchy", + "text": "Superalgos->Strategy Open Stage->3", + "updated": 1611257686884 + }, + { + "style": "Text", + "text": "" + }, + { + "style": "Subtitle", + "text": "Strategy Manage Stage", + "updated": 1611257655850 + }, + { + "style": "Include", + "text": "Superalgos->Node->Strategy Manage Stage->Definition", + "updated": 1611257660113 + }, + { + "style": "Include", + "text": "Superalgos->Node->Strategy Manage Stage->Content", + "updated": 1611257664015 + }, + { + "style": "Include", + "text": "Superalgos->Concept->Reusable Snippets->Note for Hierarchy Tables No Discussion" + }, + { + "style": "Hierarchy", + "text": "Superalgos->Strategy Manage Stage->2", + "updated": 1611257866068 + }, + { + "style": "Subtitle", + "text": "Strategy Close Stage", + "updated": 1611257705432 + }, + { + "style": "Include", + "text": "Superalgos->Node->Strategy Close Stage->Definition", + "updated": 1611257709416 + }, + { + "style": "Include", + "text": "Superalgos->Node->Strategy Close Stage->Content", + "updated": 1611257713254 + }, + { + "style": "Include", + "text": "Superalgos->Concept->Reusable Snippets->Note for Hierarchy Tables No Discussion" + }, + { + "style": "Hierarchy", + "text": "Superalgos->Strategy Close Stage->3", + "updated": 1611257720858 + } + ] +} \ No newline at end of file diff --git a/Projects/Superalgos/Schemas/Docs-Topics/trading-engine-006-base-asset-and-quoted-asset.json b/Projects/Superalgos/Schemas/Docs-Topics/trading-engine-006-base-asset-and-quoted-asset.json new file mode 100644 index 000000000..24975ce46 --- /dev/null +++ b/Projects/Superalgos/Schemas/Docs-Topics/trading-engine-006-base-asset-and-quoted-asset.json @@ -0,0 +1,169 @@ +{ + "topic": "Trading Engine", + "pageNumber": "6", + "type": "Base Asset and Quoted Asset", + "definition": { + "text": "Keep track of accounts denominated in the base asset and the quoted asset, in multiple contexts. On this page: Episode Base Asset, Episode Quoted Asset, Position Base Asset, Position Quoted Asset, Stage Base Asset, Stage Quoted Asset, Order Base Asset, Order Quoted Asset.", + "updated": 1611258310236 + }, + "paragraphs": [ + { + "style": "Text", + "text": "Because the system aims to be as flexible as possible, the trading engine keeps the accounts relative to both the base asset and the quoted asset. This allows the user to set up the trading system with whatever logic is required and decide which set of accounts suits the intent—the goal—of the trading strategy.", + "updated": 1611258333516 + }, + { + "style": "Callout", + "text": "Notice that—usually—the accounts denominated in one asset will be valid, while the accounts denominated in the other asset will likely make no sense." + }, + { + "style": "Text", + "text": "Which set of accounts you will monitor to track the performance of the episode depends on how you define your trading system." + }, + { + "style": "Text", + "text": "For example, If you are trading the BTC/USDT market and developed a trading system to accumulate USDT, then the set of accounts that will make sense for you is the one denominated in the quoted asset, that is, in USDT. This is why:" + }, + { + "style": "Text", + "text": "Your strategy will likely buy BTC (the base asset) expecting the price to go up while the position is open, in order to sell BTC at a higher rate and end up with more USDT (the quoted asset) than you started with." + }, + { + "style": "Title", + "text": "Example", + "updated": 1611258412121 + }, + { + "style": "Text", + "text": "Let’s say you buy 10,000 USDT worth of BTC. BTC price increases by 10%, so you sell the whole amount of BTC to close the position and end up with 10,900 USDT (exchange fees are deducted from the balance)." + }, + { + "style": "Text", + "text": "In terms of the base asset, your begin balance is 0 BTC and your end balance is 0.00000012 BTC, as the exchange left some BTC dust in the account due to rate conversion limitations. Also in terms of the base asset, your profit loss for the position is...", + "updated": 1611258453118 + }, + { + "style": "Text", + "text": "" + }, + { + "style": "Json", + "text": "0.00000012 BTC - 0 BTC = 0.00000012 BTC", + "updated": 1611258465358 + }, + { + "style": "Text", + "text": "ROI and other metrics may be derived from these initial observations as well. Needless to say, such metrics are irrelevant to the intent of the strategy, which is to accumulate USDT." + }, + { + "style": "Text", + "text": "Now, in terms of the base asset, your begin balance is 10,000 USDT and your end balance is 10,900 USDT (exchange fees are deducted from the balance). Also in terms of the quoted asset, your profit loss for the position is...", + "updated": 1611258484205 + }, + { + "style": "Json", + "text": "10,900 USDT - 10,000 USDT = 900 USDT" + }, + { + "style": "Text", + "text": "It should be clear by now that these are the metrics relevant to the intent of the strategy." + }, + { + "style": "Note", + "text": "With other types of strategies, for example, those in which the intent is to accumulate both assets, both sets of metrics may be relevant. Also, the consolidated metrics provided in the context of statistics may be relevant too.", + "updated": 1611258499505 + }, + { + "style": "Text", + "text": "The concepts relative to base and quoted asset, such as the balance of each asset and the performance metrics computed from the perspective of each asset, are tracked in multiple contexts simultaneously." + }, + { + "style": "Text", + "text": "What follows are the definitions of the base and quoted asset in each of the contexts that the concepts are tracked." + }, + { + "style": "Title", + "text": "Episode Base Asset", + "updated": 1611258577948 + }, + { + "style": "Include", + "text": "Superalgos->Node->Episode Base Asset->Definition", + "updated": 1611258580907 + }, + { + "style": "Title", + "text": "Episode Quoted Asset", + "updated": 1611258588997 + }, + { + "style": "Include", + "text": "Superalgos->Node->Episode Quoted Asset->Definition", + "updated": 1611258592849 + }, + { + "style": "Title", + "text": "Position Base Asset", + "updated": 1611258602952 + }, + { + "style": "Include", + "text": "Superalgos->Node->Position Base Asset->Definition", + "updated": 1611258605932 + }, + { + "style": "Title", + "text": "Position Quoted Asset", + "updated": 1611258616805 + }, + { + "style": "Include", + "text": "Superalgos->Node->Position Quoted Asset->Definition", + "updated": 1611258619810 + }, + { + "style": "Title", + "text": "Stage Base Asset", + "updated": 1611258630368 + }, + { + "style": "Include", + "text": "Superalgos->Node->Stage Base Asset->Definition", + "updated": 1611258633312 + }, + { + "style": "Title", + "text": "Stage Quoted Asset", + "updated": 1611258644044 + }, + { + "style": "Include", + "text": "Superalgos->Node->Stage Quoted Asset->Definition", + "updated": 1611258647352 + }, + { + "style": "Title", + "text": "Order Base Asset", + "updated": 1611258657391 + }, + { + "style": "Include", + "text": "Superalgos->Node->Order Base Asset->Definition", + "updated": 1611258660759 + }, + { + "style": "Title", + "text": "Order Quoted Asset", + "updated": 1611258669352 + }, + { + "style": "Include", + "text": "Superalgos->Node->Order Quoted Asset->Definition", + "updated": 1611258672239 + }, + { + "style": "Text", + "text": "" + } + ] +} \ No newline at end of file From 56e961ad018800f0afb3fff1a55584d6ea13a651 Mon Sep 17 00:00:00 2001 From: Luis Fernando Molina Date: Thu, 21 Jan 2021 20:57:45 +0100 Subject: [PATCH 08/16] Improvements in Error Handlng / Error UX --- Client/httpInterface.js | 5 +++-- .../TS/Bot-Modules/Indicator-Bot/SingleMarketIndicatorBot.js | 1 - Projects/Superalgos/UI/Spaces/Docs-Space/CommandInterface.js | 5 ++++- UI/Data-Files/src/FileStorage.js | 3 ++- 4 files changed, 9 insertions(+), 5 deletions(-) diff --git a/Client/httpInterface.js b/Client/httpInterface.js index 8bb2a9f5c..49fcbf6ff 100644 --- a/Client/httpInterface.js +++ b/Client/httpInterface.js @@ -599,7 +599,8 @@ exports.newHttpInterface = function newHttpInterface(WEB_SERVER, DATA_FILE_SERVE /* Unsavping # */ for (let i = 0; i < 10; i++) { - commitMessage = commitMessage.replace('HASHTAG', '#') + commitMessage = commitMessage.replace('_SLASH_', '/') + commitMessage = commitMessage.replace('_HASHTAG_', '#') } contribute() @@ -1352,7 +1353,7 @@ exports.newHttpInterface = function newHttpInterface(WEB_SERVER, DATA_FILE_SERVE let pathToFile = httpRequest.url.substring(9) /* Unsavping # */ for (let i = 0; i < 10; i++) { - pathToFile = pathToFile.replace('HASHTAG', '#') + pathToFile = pathToFile.replace('_HASHTAG_', '#') } respondWithFile(global.env.PATH_TO_DATA_STORAGE + '/' + pathToFile, httpResponse) } diff --git a/Projects/Superalgos/TS/Bot-Modules/Indicator-Bot/SingleMarketIndicatorBot.js b/Projects/Superalgos/TS/Bot-Modules/Indicator-Bot/SingleMarketIndicatorBot.js index 252bdfd1e..383a87778 100644 --- a/Projects/Superalgos/TS/Bot-Modules/Indicator-Bot/SingleMarketIndicatorBot.js +++ b/Projects/Superalgos/TS/Bot-Modules/Indicator-Bot/SingleMarketIndicatorBot.js @@ -58,7 +58,6 @@ function run(callBackFunction) { try { - require ('CACA') loop() function loop() { diff --git a/Projects/Superalgos/UI/Spaces/Docs-Space/CommandInterface.js b/Projects/Superalgos/UI/Spaces/Docs-Space/CommandInterface.js index 410c09784..864371019 100644 --- a/Projects/Superalgos/UI/Spaces/Docs-Space/CommandInterface.js +++ b/Projects/Superalgos/UI/Spaces/Docs-Space/CommandInterface.js @@ -62,10 +62,13 @@ function newSuperalgosDocsCommmandInterface() { return } + message = message.replaceAll('#', '_HASHTAG_') + message = message.replaceAll('/', '_SLASH_') + httpRequest( undefined, 'App/Contribute/' + - message.replaceAll('#', 'HASHTAG') + '/' + + message + '/' + config.username + '/' + config.token + '/' + UI.projects.superalgos.spaces.docsSpace.currentBranch + '/' + diff --git a/UI/Data-Files/src/FileStorage.js b/UI/Data-Files/src/FileStorage.js index e4f7ae9ea..e7421af1e 100644 --- a/UI/Data-Files/src/FileStorage.js +++ b/UI/Data-Files/src/FileStorage.js @@ -46,7 +46,8 @@ function newFileStorage(host, port) { } /* Scaping # since it breaks the URL */ - url = url.replaceAll('#', 'HASHTAG') + url = url.replaceAll('#', '_HASHTAG_') + httpRequest(undefined, url, (response, fileContent) => { if (response.result === GLOBAL.DEFAULT_OK_RESPONSE.result) { callBackFunction(GLOBAL.DEFAULT_OK_RESPONSE, fileContent) From 8f3b6aa7e9a77e2804b39ac31b95677e21679be2 Mon Sep 17 00:00:00 2001 From: Julian Molina Date: Thu, 21 Jan 2021 21:30:08 +0100 Subject: [PATCH 09/16] Trading Engine Topic WIP --- .../Schemas/Docs-Books/user-manual.json | 7 +- .../trading-engine-007-counters.json | 171 ++++++++++++++++++ .../trading-engine-008-statistics.json | 77 ++++++++ 3 files changed, 254 insertions(+), 1 deletion(-) create mode 100644 Projects/Superalgos/Schemas/Docs-Topics/trading-engine-007-counters.json create mode 100644 Projects/Superalgos/Schemas/Docs-Topics/trading-engine-008-statistics.json diff --git a/Projects/Superalgos/Schemas/Docs-Books/user-manual.json b/Projects/Superalgos/Schemas/Docs-Books/user-manual.json index 6c4651588..fe3e608d2 100644 --- a/Projects/Superalgos/Schemas/Docs-Books/user-manual.json +++ b/Projects/Superalgos/Schemas/Docs-Books/user-manual.json @@ -49,9 +49,14 @@ "style": "Text", "text": "" }, + { + "style": "Chapter", + "text": "IX->Superalgos->Topic->Trading Engine->The trading engine is about making the data processed by the Trading Bot accessible. Use it while debugging strategies to visually track every piece of information processed by the trading bot at any point in time. Use it from within trading systems to feed strategies with the details of what happens at runtime.", + "updated": 1611260954268 + }, { "style": "Text", - "text": "Work in Progress" + "text": "" }, { "style": "Text", diff --git a/Projects/Superalgos/Schemas/Docs-Topics/trading-engine-007-counters.json b/Projects/Superalgos/Schemas/Docs-Topics/trading-engine-007-counters.json new file mode 100644 index 000000000..5e64b9baf --- /dev/null +++ b/Projects/Superalgos/Schemas/Docs-Topics/trading-engine-007-counters.json @@ -0,0 +1,171 @@ +{ + "topic": "Trading Engine", + "pageNumber": "7", + "type": "Counters", + "definition": { + "text": "Keep track of how many instances of certain objects have existed in a given context. On this page: Periods, Strategies, Positions, Orders, and Days.", + "updated": 1611259332958 + }, + "paragraphs": [ + { + "style": "Text", + "text": "A counter keeps track of how many instances of certain objects have come to exist—or have taken a certain value—during the duration of a certain context.", + "updated": 1611259349617 + }, + { + "style": "Text", + "text": "For example, how many positions have been open during an episode, or how many of those positions have been hits." + }, + { + "style": "Text", + "text": "Counters are kept in multiple contexts simultaneously. In particular, you will find episode counters, strategy counters, position counters, and order counters." + }, + { + "style": "Text", + "text": "" + }, + { + "style": "Title", + "text": "Counter-specific Nodes" + }, + { + "style": "Subtitle", + "text": "Periods", + "updated": 1611259406618 + }, + { + "style": "Include", + "text": "Superalgos->Node->Periods->Definition", + "updated": 1611259409668 + }, + { + "style": "Subtitle", + "text": "Strategies", + "updated": 1611259416144 + }, + { + "style": "Include", + "text": "Superalgos->Node->Strategies->Definition", + "updated": 1611259419177 + }, + { + "style": "Subtitle", + "text": "Positions", + "updated": 1611259428759 + }, + { + "style": "Include", + "text": "Superalgos->Node->Positions->Definition", + "updated": 1611259431976 + }, + { + "style": "Subtitle", + "text": "Orders", + "updated": 1611259442020 + }, + { + "style": "Include", + "text": "Superalgos->Node->Orders->Definition", + "updated": 1611259444724 + }, + { + "style": "Subtitle", + "text": "Days", + "updated": 1611259453496 + }, + { + "style": "Include", + "text": "Superalgos->Node->Days->Definition", + "updated": 1611259459728 + }, + { + "style": "Include", + "text": "Superalgos->Node->Days->Content", + "updated": 1611259823914 + }, + { + "style": "Text", + "text": "" + }, + { + "style": "Note", + "text": "Other properties typical to counters are defined elsewhere, as they are not specific to counters. Find below the different contexts in which counters are found.", + "updated": 1611259860203 + }, + { + "style": "Title", + "text": "Episode Counters", + "updated": 1611260075956 + }, + { + "style": "Include", + "text": "Superalgos->Node->Episode Counters->Definition", + "updated": 1611260079244 + }, + { + "style": "Include", + "text": "Superalgos->Concept->Reusable Snippets->Note for Hierarchy Tables No Discussion" + }, + { + "style": "Hierarchy", + "text": "Superalgos->Episode Counters->2", + "updated": 1611260082549 + }, + { + "style": "Title", + "text": "Strategy Counters" + }, + { + "style": "Include", + "text": "Superalgos->Node->Strategy Counters->Definition", + "updated": 1611259923717 + }, + { + "style": "Include", + "text": "Superalgos->Concept->Reusable Snippets->Note for Hierarchy Tables No Discussion" + }, + { + "style": "Hierarchy", + "text": "Superalgos->Strategy Counters->2", + "updated": 1611259927606 + }, + { + "style": "Title", + "text": "Position Counters", + "updated": 1611259936812 + }, + { + "style": "Include", + "text": "Superalgos->Node->Position Counters->Definition", + "updated": 1611259939595 + }, + { + "style": "Include", + "text": "Superalgos->Concept->Reusable Snippets->Note for Hierarchy Tables No Discussion" + }, + { + "style": "Hierarchy", + "text": "Superalgos->Position Counters->2", + "updated": 1611259944892 + }, + { + "style": "Title", + "text": "Order Counters", + "updated": 1611259959379 + }, + { + "style": "Include", + "text": "Superalgos->Node->Order Counters->Definition", + "updated": 1611259963832 + }, + { + "style": "Include", + "text": "Superalgos->Concept->Reusable Snippets->Note for Hierarchy Tables No Discussion" + }, + { + "style": "Hierarchy", + "text": "Superalgos->Order Counters->2", + "updated": 1611259967561 + } + ] +} \ No newline at end of file diff --git a/Projects/Superalgos/Schemas/Docs-Topics/trading-engine-008-statistics.json b/Projects/Superalgos/Schemas/Docs-Topics/trading-engine-008-statistics.json new file mode 100644 index 000000000..429c0932d --- /dev/null +++ b/Projects/Superalgos/Schemas/Docs-Topics/trading-engine-008-statistics.json @@ -0,0 +1,77 @@ +{ + "topic": "Trading Engine", + "pageNumber": "8", + "type": "Statistics", + "definition": { + "text": "Track popular statistics consolidating both the base asset and the quoted asset. On this page: Episode Statistics, Position Statistics, and Order Statistics.", + "updated": 1611260196449 + }, + "paragraphs": [ + { + "style": "Text", + "text": "Statistics are accounts and performance metrics calculated by consolidating the base asset and the quoted asset, that is, taking both assets into account.", + "updated": 1611260210428 + }, + { + "style": "Text", + "text": "The mechanics of how both assets are consolidated and how the consolidation affects the calculations are explained in the definitions of each of the concepts." + }, + { + "style": "Title", + "text": "Episode Statistics", + "updated": 1611260256691 + }, + { + "style": "Include", + "text": "Superalgos->Node->Episode Statistics->Definition", + "updated": 1611260259469 + }, + { + "style": "Include", + "text": "Superalgos->Concept->Reusable Snippets->Note for Hierarchy Tables No Discussion" + }, + { + "style": "Hierarchy", + "text": "Superalgos->Episode Statistics->2", + "updated": 1611260262273 + }, + { + "style": "Title", + "text": "Position Statistics", + "updated": 1611260273697 + }, + { + "style": "Include", + "text": "Superalgos->Node->Position Statistics->Definition", + "updated": 1611260277415 + }, + { + "style": "Include", + "text": "Superalgos->Concept->Reusable Snippets->Note for Hierarchy Tables No Discussion" + }, + { + "style": "Hierarchy", + "text": "Superalgos->Position Statistics->2", + "updated": 1611260280519 + }, + { + "style": "Title", + "text": "Order Statistics", + "updated": 1611260292859 + }, + { + "style": "Include", + "text": "Superalgos->Node->Order Statistics->Definition", + "updated": 1611260295959 + }, + { + "style": "Include", + "text": "Superalgos->Concept->Reusable Snippets->Note for Hierarchy Tables No Discussion" + }, + { + "style": "Hierarchy", + "text": "Superalgos->Order Statistics->2", + "updated": 1611260299229 + } + ] +} \ No newline at end of file From e72669ce6169058702916607df5058bde23dcf4b Mon Sep 17 00:00:00 2001 From: Luis Fernando Molina Date: Fri, 22 Jan 2021 07:36:38 +0100 Subject: [PATCH 10/16] Bug Fixed, context menu not dissapearing when docs were closed --- Projects/Superalgos/UI/Spaces/Docs-Space/DocsSpace.js | 1 + 1 file changed, 1 insertion(+) diff --git a/Projects/Superalgos/UI/Spaces/Docs-Space/DocsSpace.js b/Projects/Superalgos/UI/Spaces/Docs-Space/DocsSpace.js index 5b5a66d26..7feccb193 100644 --- a/Projects/Superalgos/UI/Spaces/Docs-Space/DocsSpace.js +++ b/Projects/Superalgos/UI/Spaces/Docs-Space/DocsSpace.js @@ -265,6 +265,7 @@ function newSuperalgosDocSpace() { } function onClosing() { + thisObject.contextMenu.removeContextMenuFromScreen() UI.projects.superalgos.spaces.docsSpace.currentDocumentBeingRendered = undefined thisObject.isVisible = false } From 4433ade3df5786f4b512eb224843c4e40bb17950 Mon Sep 17 00:00:00 2001 From: Luis Fernando Molina Date: Fri, 22 Jan 2021 09:41:54 +0100 Subject: [PATCH 11/16] Bug Fixed on MAC OS not repositionig charts correctly during tutorial. --- .../UI/Spaces/Tutorial-Space/TutorialSpace.js | 16 +++++++++------- 1 file changed, 9 insertions(+), 7 deletions(-) diff --git a/Projects/Superalgos/UI/Spaces/Tutorial-Space/TutorialSpace.js b/Projects/Superalgos/UI/Spaces/Tutorial-Space/TutorialSpace.js index 58ed15569..4fa6497b2 100644 --- a/Projects/Superalgos/UI/Spaces/Tutorial-Space/TutorialSpace.js +++ b/Projects/Superalgos/UI/Spaces/Tutorial-Space/TutorialSpace.js @@ -621,11 +621,13 @@ function newSuperalgosTutorialSpace() { if (timeMachine !== undefined) { repositionAtTimeMachineCounter++ switch (true) { - case (repositionAtTimeMachineCounter > 10 && repositionAtTimeMachineCounter < 20): { - let event = { - delta: -1 + case (repositionAtTimeMachineCounter > 1 && repositionAtTimeMachineCounter < 30): { + for (let i = 0; i < 10; i++) { + let event = { + delta: -1 + } + UI.projects.superalgos.spaces.chartingSpace.viewport.onMouseWheel(event) } - UI.projects.superalgos.spaces.chartingSpace.viewport.onMouseWheel(event) break } case (repositionAtTimeMachineCounter === 30): { @@ -1189,9 +1191,9 @@ function newSuperalgosTutorialSpace() { syncConfigIconWithDocumentIcon() transformDocsInfoIntoTutorialInfo() createTheHTML() - - if (nodeConfig.controlDocs !== undefined ) { - if ( nodeConfig.controlDocs.closeTutorialEditor !== true) { + + if (nodeConfig.controlDocs !== undefined) { + if (nodeConfig.controlDocs.closeTutorialEditor !== true) { UI.projects.superalgos.spaces.docsSpace.navigateTo(nodeConfig.docs.project, 'Tutorial', nodeConfig.docs.type) } } else { From e63771b9eeac6a8ab5b3e278f859f6d6e1c8da36 Mon Sep 17 00:00:00 2001 From: Luis Fernando Molina Date: Fri, 22 Jan 2021 10:46:47 +0100 Subject: [PATCH 12/16] Process Error Handling Improved / UX Improved --- .../Indicator-Bot/MultiPeriodDaily.js | 1 - .../Indicator-Bot/SingleMarketIndicatorBot.js | 203 ++++++++---------- .../Sensor-Bot/SingleMarketSensorBot.js | 139 +++++------- .../Trading-Bot/SingleMarketTradingBot.js | 160 ++++++-------- .../TS/Function-Libraries/ProcessFunctions.js | 77 ++++++- .../Superalgos/TS/Globals/ProcessVariables.js | 2 + .../Superalgos/TS/Globals/TaskVariables.js | 2 +- 7 files changed, 288 insertions(+), 296 deletions(-) diff --git a/Projects/Superalgos/TS/Bot-Modules/Indicator-Bot/MultiPeriodDaily.js b/Projects/Superalgos/TS/Bot-Modules/Indicator-Bot/MultiPeriodDaily.js index cc81d84ce..1cbd6c071 100644 --- a/Projects/Superalgos/TS/Bot-Modules/Indicator-Bot/MultiPeriodDaily.js +++ b/Projects/Superalgos/TS/Bot-Modules/Indicator-Bot/MultiPeriodDaily.js @@ -19,7 +19,6 @@ return thisObject; function initialize(pStatusDependencies, pDataDependencies, callBackFunction) { - statusDependencies = pStatusDependencies; dataDependenciesModule = pDataDependencies; diff --git a/Projects/Superalgos/TS/Bot-Modules/Indicator-Bot/SingleMarketIndicatorBot.js b/Projects/Superalgos/TS/Bot-Modules/Indicator-Bot/SingleMarketIndicatorBot.js index 383a87778..182960258 100644 --- a/Projects/Superalgos/TS/Bot-Modules/Indicator-Bot/SingleMarketIndicatorBot.js +++ b/Projects/Superalgos/TS/Bot-Modules/Indicator-Bot/SingleMarketIndicatorBot.js @@ -96,6 +96,7 @@ function initializeProcessExecutionEvents() { try { + processExecutionEvents = TS.projects.superalgos.processModules.processExecutionEvents.newSuperalgosProcessModulesProcessExecutionEvents(processIndex) processExecutionEvents.initialize(onInizialized); @@ -118,8 +119,8 @@ case TS.projects.superalgos.globals.standardResponses.DEFAULT_FAIL_RESPONSE.result: { // This is an unexpected exception that we do not know how to handle. TS.projects.superalgos.globals.loggerVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).BOT_MAIN_LOOP_LOGGER_MODULE_OBJECT.write(MODULE_NAME, "[ERROR] run -> loop -> initializeProcessExecutionEvents -> onInizialized -> Operation Failed. Aborting the process."); - TS.projects.superalgos.globals.taskVariables.FATAL_ERROR_MESSAGE = err.message - processStopped() + TS.projects.superalgos.globals.processVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).UNEXPECTED_ERROR = err + TS.projects.superalgos.functionLibraries.processFunctions.stopProcess(processIndex, callBackFunction, nextLoopTimeoutHandle) return } default: { @@ -127,24 +128,24 @@ "[ERROR] run -> loop -> initializeProcessExecutionEvents -> onInizialized -> Unhandled err.result received. -> err.result = " + err.result); TS.projects.superalgos.globals.loggerVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).BOT_MAIN_LOOP_LOGGER_MODULE_OBJECT.write(MODULE_NAME, "[ERROR] run -> loop -> initializeProcessExecutionEvents -> onInizialized -> Unhandled err.result received. -> err = " + err.message); - TS.projects.superalgos.globals.taskVariables.FATAL_ERROR_MESSAGE = err.message - processStopped() + TS.projects.superalgos.globals.processVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).UNEXPECTED_ERROR = err + TS.projects.superalgos.functionLibraries.processFunctions.stopProcess(processIndex, callBackFunction, nextLoopTimeoutHandle) return } } } catch (err) { TS.projects.superalgos.globals.loggerVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).BOT_MAIN_LOOP_LOGGER_MODULE_OBJECT.write(MODULE_NAME, "[ERROR] run -> loop -> initializeProcessExecutionEvents -> onInizialized -> err = " + err.stack); - TS.projects.superalgos.globals.taskVariables.FATAL_ERROR_MESSAGE = err.message - processStopped() + TS.projects.superalgos.globals.processVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).UNEXPECTED_ERROR = err + TS.projects.superalgos.functionLibraries.processFunctions.stopProcess(processIndex, callBackFunction, nextLoopTimeoutHandle) return } } } catch (err) { TS.projects.superalgos.globals.loggerVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).BOT_MAIN_LOOP_LOGGER_MODULE_OBJECT.write(MODULE_NAME, "[ERROR] run -> loop -> initializeProcessExecutionEvents -> err = " + err.stack); - TS.projects.superalgos.globals.taskVariables.FATAL_ERROR_MESSAGE = err.message - processStopped() + TS.projects.superalgos.globals.processVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).UNEXPECTED_ERROR = err + TS.projects.superalgos.functionLibraries.processFunctions.stopProcess(processIndex, callBackFunction, nextLoopTimeoutHandle) return } } @@ -178,8 +179,8 @@ case TS.projects.superalgos.globals.standardResponses.DEFAULT_FAIL_RESPONSE.result: { // This is an unexpected exception that we do not know how to handle. TS.projects.superalgos.globals.loggerVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).BOT_MAIN_LOOP_LOGGER_MODULE_OBJECT.write(MODULE_NAME, "[ERROR] run -> loop -> startProcessExecutionEvents -> onStarted -> Operation Failed. Aborting the process."); - TS.projects.superalgos.globals.taskVariables.FATAL_ERROR_MESSAGE = err.message - processStopped() + TS.projects.superalgos.globals.processVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).UNEXPECTED_ERROR = err + TS.projects.superalgos.functionLibraries.processFunctions.stopProcess(processIndex, callBackFunction, nextLoopTimeoutHandle) return } default: { @@ -187,24 +188,24 @@ "[ERROR] run -> loop -> startProcessExecutionEvents -> onStarted -> Unhandled err.result received. -> err.result = " + err.result); TS.projects.superalgos.globals.loggerVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).BOT_MAIN_LOOP_LOGGER_MODULE_OBJECT.write(MODULE_NAME, "[ERROR] run -> loop -> startProcessExecutionEvents -> onStarted -> Unhandled err.result received. -> err = " + err.message); - TS.projects.superalgos.globals.taskVariables.FATAL_ERROR_MESSAGE = err.message - processStopped() + TS.projects.superalgos.globals.processVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).UNEXPECTED_ERROR = err + TS.projects.superalgos.functionLibraries.processFunctions.stopProcess(processIndex, callBackFunction, nextLoopTimeoutHandle) return } } } catch (err) { TS.projects.superalgos.globals.loggerVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).BOT_MAIN_LOOP_LOGGER_MODULE_OBJECT.write(MODULE_NAME, "[ERROR] run -> loop -> startProcessExecutionEvents -> onStarted -> err = " + err.stack); - TS.projects.superalgos.globals.taskVariables.FATAL_ERROR_MESSAGE = err.message - processStopped() + TS.projects.superalgos.globals.processVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).UNEXPECTED_ERROR = err + TS.projects.superalgos.functionLibraries.processFunctions.stopProcess(processIndex, callBackFunction, nextLoopTimeoutHandle) return } } } catch (err) { TS.projects.superalgos.globals.loggerVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).BOT_MAIN_LOOP_LOGGER_MODULE_OBJECT.write(MODULE_NAME, "[ERROR] run -> loop -> startProcessExecutionEvents -> err = " + err.stack); - TS.projects.superalgos.globals.taskVariables.FATAL_ERROR_MESSAGE = err.message - processStopped() + TS.projects.superalgos.globals.processVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).UNEXPECTED_ERROR = err + TS.projects.superalgos.functionLibraries.processFunctions.stopProcess(processIndex, callBackFunction, nextLoopTimeoutHandle) return } } @@ -233,8 +234,8 @@ case TS.projects.superalgos.globals.standardResponses.DEFAULT_FAIL_RESPONSE.result: { // This is an unexpected exception that we do not know how to handle. TS.projects.superalgos.globals.loggerVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).BOT_MAIN_LOOP_LOGGER_MODULE_OBJECT.write(MODULE_NAME, "[ERROR] run -> loop -> initializeStatusDependencies -> onInizialized -> Operation Failed. Aborting the process."); - TS.projects.superalgos.globals.taskVariables.FATAL_ERROR_MESSAGE = err.message - processStopped() + TS.projects.superalgos.globals.processVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).UNEXPECTED_ERROR = err + TS.projects.superalgos.functionLibraries.processFunctions.stopProcess(processIndex, callBackFunction, nextLoopTimeoutHandle) return } default: { @@ -242,24 +243,24 @@ "[ERROR] run -> loop -> initializeStatusDependencies -> onInizialized -> Unhandled err.result received. -> err.result = " + err.result); TS.projects.superalgos.globals.loggerVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).BOT_MAIN_LOOP_LOGGER_MODULE_OBJECT.write(MODULE_NAME, "[ERROR] run -> loop -> initializeStatusDependencies -> onInizialized -> Unhandled err.result received. -> err = " + err.message); - TS.projects.superalgos.globals.taskVariables.FATAL_ERROR_MESSAGE = err.message - processStopped() + TS.projects.superalgos.globals.processVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).UNEXPECTED_ERROR = err + TS.projects.superalgos.functionLibraries.processFunctions.stopProcess(processIndex, callBackFunction, nextLoopTimeoutHandle) return } } } catch (err) { TS.projects.superalgos.globals.loggerVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).BOT_MAIN_LOOP_LOGGER_MODULE_OBJECT.write(MODULE_NAME, "[ERROR] run -> loop -> initializeStatusDependencies -> onInizialized -> err = " + err.stack); - TS.projects.superalgos.globals.taskVariables.FATAL_ERROR_MESSAGE = err.message - processStopped() + TS.projects.superalgos.globals.processVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).UNEXPECTED_ERROR = err + TS.projects.superalgos.functionLibraries.processFunctions.stopProcess(processIndex, callBackFunction, nextLoopTimeoutHandle) return } } } catch (err) { TS.projects.superalgos.globals.loggerVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).BOT_MAIN_LOOP_LOGGER_MODULE_OBJECT.write(MODULE_NAME, "[ERROR] run -> loop -> initializeStatusDependencies -> err = " + err.stack); - TS.projects.superalgos.globals.taskVariables.FATAL_ERROR_MESSAGE = err.message - processStopped() + TS.projects.superalgos.globals.processVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).UNEXPECTED_ERROR = err + TS.projects.superalgos.functionLibraries.processFunctions.stopProcess(processIndex, callBackFunction, nextLoopTimeoutHandle) return } } @@ -296,8 +297,8 @@ TS.projects.superalgos.globals.loggerVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).BOT_MAIN_LOOP_LOGGER_MODULE_OBJECT.write(MODULE_NAME, "[ERROR] run -> loop -> initializeDataDependencies -> onInizialized -> Process Framework Name = " + TS.projects.superalgos.globals.taskConstants.TASK_NODE.bot.processes[processIndex].referenceParent.config.framework.name); - TS.projects.superalgos.globals.taskVariables.FATAL_ERROR_MESSAGE = err.message - processStopped() + TS.projects.superalgos.globals.processVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).UNEXPECTED_ERROR = err + TS.projects.superalgos.functionLibraries.processFunctions.stopProcess(processIndex, callBackFunction, nextLoopTimeoutHandle) return } } @@ -311,11 +312,11 @@ return; } case TS.projects.superalgos.globals.standardResponses.DEFAULT_FAIL_RESPONSE.result: { // This is an unexpected exception that we do not know how to handle. - processStopped() + TS.projects.superalgos.functionLibraries.processFunctions.stopProcess(processIndex, callBackFunction, nextLoopTimeoutHandle) TS.projects.superalgos.globals.loggerVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).BOT_MAIN_LOOP_LOGGER_MODULE_OBJECT.write(MODULE_NAME, "[ERROR] run -> loop -> initializeDataDependencies -> onInizialized -> Operation Failed. Aborting the process."); - TS.projects.superalgos.globals.taskVariables.FATAL_ERROR_MESSAGE = err.message - processStopped() + TS.projects.superalgos.globals.processVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).UNEXPECTED_ERROR = err + TS.projects.superalgos.functionLibraries.processFunctions.stopProcess(processIndex, callBackFunction, nextLoopTimeoutHandle) return } default: { @@ -323,24 +324,24 @@ "[ERROR] run -> loop -> initializeDataDependencies -> onInizialized -> Unhandled err.result received. -> err.result = " + err.result); TS.projects.superalgos.globals.loggerVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).BOT_MAIN_LOOP_LOGGER_MODULE_OBJECT.write(MODULE_NAME, "[ERROR] run -> loop -> initializeDataDependencies -> onInizialized -> Unhandled err.result received. -> err = " + err.message); - TS.projects.superalgos.globals.taskVariables.FATAL_ERROR_MESSAGE = err.message - processStopped() + TS.projects.superalgos.globals.processVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).UNEXPECTED_ERROR = err + TS.projects.superalgos.functionLibraries.processFunctions.stopProcess(processIndex, callBackFunction, nextLoopTimeoutHandle) return } } } catch (err) { TS.projects.superalgos.globals.loggerVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).BOT_MAIN_LOOP_LOGGER_MODULE_OBJECT.write(MODULE_NAME, "[ERROR] run -> loop -> initializeDataDependencies -> onInizialized -> err = " + err.stack); - TS.projects.superalgos.globals.taskVariables.FATAL_ERROR_MESSAGE = err.message - processStopped() + TS.projects.superalgos.globals.processVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).UNEXPECTED_ERROR = err + TS.projects.superalgos.functionLibraries.processFunctions.stopProcess(processIndex, callBackFunction, nextLoopTimeoutHandle) return } } } catch (err) { TS.projects.superalgos.globals.loggerVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).BOT_MAIN_LOOP_LOGGER_MODULE_OBJECT.write(MODULE_NAME, "[ERROR] run -> loop -> initializeDataDependencies -> err = " + err.stack); - TS.projects.superalgos.globals.taskVariables.FATAL_ERROR_MESSAGE = err.message - processStopped() + TS.projects.superalgos.globals.processVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).UNEXPECTED_ERROR = err + TS.projects.superalgos.functionLibraries.processFunctions.stopProcess(processIndex, callBackFunction, nextLoopTimeoutHandle) return } } @@ -368,8 +369,8 @@ case TS.projects.superalgos.globals.standardResponses.DEFAULT_FAIL_RESPONSE.result: { // This is an unexpected exception that we do not know how to handle. TS.projects.superalgos.globals.loggerVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).BOT_MAIN_LOOP_LOGGER_MODULE_OBJECT.write(MODULE_NAME, "[ERROR] run -> loop -> initializeBotModuleObject -> onInizialized -> Operation Failed. Aborting the process."); - TS.projects.superalgos.globals.taskVariables.FATAL_ERROR_MESSAGE = err.message - processStopped() + TS.projects.superalgos.globals.processVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).UNEXPECTED_ERROR = err + TS.projects.superalgos.functionLibraries.processFunctions.stopProcess(processIndex, callBackFunction, nextLoopTimeoutHandle) return } case TS.projects.superalgos.globals.standardResponses.CUSTOM_OK_RESPONSE.result: { @@ -378,8 +379,8 @@ default: { TS.projects.superalgos.globals.loggerVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).BOT_MAIN_LOOP_LOGGER_MODULE_OBJECT.write(MODULE_NAME, "[ERROR] run -> loop -> initializeBotModuleObject -> onInizialized > Unhandled custom response received. -> err = " + err.message); - TS.projects.superalgos.globals.taskVariables.FATAL_ERROR_MESSAGE = err.message - processStopped() + TS.projects.superalgos.globals.processVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).UNEXPECTED_ERROR = err + TS.projects.superalgos.functionLibraries.processFunctions.stopProcess(processIndex, callBackFunction, nextLoopTimeoutHandle) return } } @@ -389,24 +390,24 @@ "[ERROR] run -> loop -> initializeBotModuleObject -> onInizialized -> Unhandled err.result received. -> err.result = " + err.result); TS.projects.superalgos.globals.loggerVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).BOT_MAIN_LOOP_LOGGER_MODULE_OBJECT.write(MODULE_NAME, "[ERROR] run -> loop -> initializeBotModuleObject -> onInizialized -> Unhandled err.result received. -> err = " + err.message); - TS.projects.superalgos.globals.taskVariables.FATAL_ERROR_MESSAGE = err.message - processStopped() + TS.projects.superalgos.globals.processVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).UNEXPECTED_ERROR = err + TS.projects.superalgos.functionLibraries.processFunctions.stopProcess(processIndex, callBackFunction, nextLoopTimeoutHandle) return } } } catch (err) { TS.projects.superalgos.globals.loggerVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).BOT_MAIN_LOOP_LOGGER_MODULE_OBJECT.write(MODULE_NAME, "[ERROR] run -> loop -> initializeBotModuleObject -> onInizialized -> err = " + err.stack); - TS.projects.superalgos.globals.taskVariables.FATAL_ERROR_MESSAGE = err.message - processStopped() + TS.projects.superalgos.globals.processVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).UNEXPECTED_ERROR = err + TS.projects.superalgos.functionLibraries.processFunctions.stopProcess(processIndex, callBackFunction, nextLoopTimeoutHandle) return } } } catch (err) { TS.projects.superalgos.globals.loggerVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).BOT_MAIN_LOOP_LOGGER_MODULE_OBJECT.write(MODULE_NAME, "[ERROR] run -> loop -> initializeBotModuleObject -> err = " + err.stack); - TS.projects.superalgos.globals.taskVariables.FATAL_ERROR_MESSAGE = err.message - processStopped() + TS.projects.superalgos.globals.processVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).UNEXPECTED_ERROR = err + TS.projects.superalgos.functionLibraries.processFunctions.stopProcess(processIndex, callBackFunction, nextLoopTimeoutHandle) return } } @@ -434,8 +435,8 @@ case TS.projects.superalgos.globals.standardResponses.DEFAULT_FAIL_RESPONSE.result: { // This is an unexpected exception that we do not know how to handle. TS.projects.superalgos.globals.loggerVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).BOT_MAIN_LOOP_LOGGER_MODULE_OBJECT.write(MODULE_NAME, "[ERROR] run -> loop -> startBotModuleObject -> onFinished -> Operation Failed. Aborting the process."); - TS.projects.superalgos.globals.taskVariables.FATAL_ERROR_MESSAGE = err.message - processStopped() + TS.projects.superalgos.globals.processVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).UNEXPECTED_ERROR = err + TS.projects.superalgos.functionLibraries.processFunctions.stopProcess(processIndex, callBackFunction, nextLoopTimeoutHandle) return } case TS.projects.superalgos.globals.standardResponses.CUSTOM_OK_RESPONSE.result: { @@ -458,8 +459,8 @@ default: { TS.projects.superalgos.globals.loggerVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).BOT_MAIN_LOOP_LOGGER_MODULE_OBJECT.write(MODULE_NAME, "[ERROR] run -> loop -> startBotModuleObject -> onFinished -> Unhandled custom response received. -> err = " + err.message); - TS.projects.superalgos.globals.taskVariables.FATAL_ERROR_MESSAGE = err.message - processStopped() + TS.projects.superalgos.globals.processVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).UNEXPECTED_ERROR = err + TS.projects.superalgos.functionLibraries.processFunctions.stopProcess(processIndex, callBackFunction, nextLoopTimeoutHandle) return } } @@ -469,24 +470,24 @@ "[ERROR] run -> loop -> startBotModuleObject -> onFinished -> Unhandled err.result received. -> err.result = " + err.result); TS.projects.superalgos.globals.loggerVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).BOT_MAIN_LOOP_LOGGER_MODULE_OBJECT.write(MODULE_NAME, "[ERROR] run -> loop -> startBotModuleObject -> onFinished -> Unhandled err.result received. -> err = " + err.message); - TS.projects.superalgos.globals.taskVariables.FATAL_ERROR_MESSAGE = err.message - processStopped() + TS.projects.superalgos.globals.processVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).UNEXPECTED_ERROR = err + TS.projects.superalgos.functionLibraries.processFunctions.stopProcess(processIndex, callBackFunction, nextLoopTimeoutHandle) return } } } catch (err) { TS.projects.superalgos.globals.loggerVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).BOT_MAIN_LOOP_LOGGER_MODULE_OBJECT.write(MODULE_NAME, "[ERROR] run -> loop -> startBotModuleObject -> onFinished -> err = " + err.stack); - TS.projects.superalgos.globals.taskVariables.FATAL_ERROR_MESSAGE = err.message - processStopped() + TS.projects.superalgos.globals.processVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).UNEXPECTED_ERROR = err + TS.projects.superalgos.functionLibraries.processFunctions.stopProcess(processIndex, callBackFunction, nextLoopTimeoutHandle) return } } } catch (err) { TS.projects.superalgos.globals.loggerVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).BOT_MAIN_LOOP_LOGGER_MODULE_OBJECT.write(MODULE_NAME, "[ERROR] run -> loop -> startBotModuleObject -> err = " + err.stack); - TS.projects.superalgos.globals.taskVariables.FATAL_ERROR_MESSAGE = err.message - processStopped() + TS.projects.superalgos.globals.processVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).UNEXPECTED_ERROR = err + TS.projects.superalgos.functionLibraries.processFunctions.stopProcess(processIndex, callBackFunction, nextLoopTimeoutHandle) return } } @@ -514,8 +515,8 @@ case TS.projects.superalgos.globals.standardResponses.DEFAULT_FAIL_RESPONSE.result: { // This is an unexpected exception that we do not know how to handle. TS.projects.superalgos.globals.loggerVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).BOT_MAIN_LOOP_LOGGER_MODULE_OBJECT.write(MODULE_NAME, "[ERROR] run -> loop -> intitializeProcessFramework -> onInizialized -> Operation Failed. Aborting the process."); - TS.projects.superalgos.globals.taskVariables.FATAL_ERROR_MESSAGE = err.message - processStopped() + TS.projects.superalgos.globals.processVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).UNEXPECTED_ERROR = err + TS.projects.superalgos.functionLibraries.processFunctions.stopProcess(processIndex, callBackFunction, nextLoopTimeoutHandle) return } case TS.projects.superalgos.globals.standardResponses.CUSTOM_OK_RESPONSE.result: { @@ -524,8 +525,8 @@ default: { TS.projects.superalgos.globals.loggerVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).BOT_MAIN_LOOP_LOGGER_MODULE_OBJECT.write(MODULE_NAME, "[ERROR] run -> loop -> intitializeProcessFramework -> onInizialized > Unhandled custom response received. -> err = " + err.message); - TS.projects.superalgos.globals.taskVariables.FATAL_ERROR_MESSAGE = err.message - processStopped() + TS.projects.superalgos.globals.processVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).UNEXPECTED_ERROR = err + TS.projects.superalgos.functionLibraries.processFunctions.stopProcess(processIndex, callBackFunction, nextLoopTimeoutHandle) return } } @@ -535,24 +536,24 @@ "[ERROR] run -> loop -> intitializeProcessFramework -> onInizialized -> Unhandled err.result received. -> err.result = " + err.result); TS.projects.superalgos.globals.loggerVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).BOT_MAIN_LOOP_LOGGER_MODULE_OBJECT.write(MODULE_NAME, "[ERROR] run -> loop -> intitializeProcessFramework -> onInizialized -> Unhandled err.result received. -> err = " + err.message); - TS.projects.superalgos.globals.taskVariables.FATAL_ERROR_MESSAGE = err.message - processStopped() + TS.projects.superalgos.globals.processVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).UNEXPECTED_ERROR = err + TS.projects.superalgos.functionLibraries.processFunctions.stopProcess(processIndex, callBackFunction, nextLoopTimeoutHandle) return } } } catch (err) { TS.projects.superalgos.globals.loggerVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).BOT_MAIN_LOOP_LOGGER_MODULE_OBJECT.write(MODULE_NAME, "[ERROR] run -> loop -> intitializeProcessFramework -> onInizialized -> err = " + err.stack); - TS.projects.superalgos.globals.taskVariables.FATAL_ERROR_MESSAGE = err.message - processStopped() + TS.projects.superalgos.globals.processVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).UNEXPECTED_ERROR = err + TS.projects.superalgos.functionLibraries.processFunctions.stopProcess(processIndex, callBackFunction, nextLoopTimeoutHandle) return } } } catch (err) { TS.projects.superalgos.globals.loggerVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).BOT_MAIN_LOOP_LOGGER_MODULE_OBJECT.write(MODULE_NAME, "[ERROR] run -> loop -> intitializeProcessFramework -> err = " + err.stack); - TS.projects.superalgos.globals.taskVariables.FATAL_ERROR_MESSAGE = err.message - processStopped() + TS.projects.superalgos.globals.processVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).UNEXPECTED_ERROR = err + TS.projects.superalgos.functionLibraries.processFunctions.stopProcess(processIndex, callBackFunction, nextLoopTimeoutHandle) return } } @@ -587,8 +588,8 @@ case TS.projects.superalgos.globals.standardResponses.DEFAULT_FAIL_RESPONSE.result: { // This is an unexpected exception that we do not know how to handle. TS.projects.superalgos.globals.loggerVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).BOT_MAIN_LOOP_LOGGER_MODULE_OBJECT.write(MODULE_NAME, "[ERROR] run -> loop -> startProcessFramework -> onFinished -> Operation Failed. Aborting the process."); - TS.projects.superalgos.globals.taskVariables.FATAL_ERROR_MESSAGE = err.message - processStopped() + TS.projects.superalgos.globals.processVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).UNEXPECTED_ERROR = err + TS.projects.superalgos.functionLibraries.processFunctions.stopProcess(processIndex, callBackFunction, nextLoopTimeoutHandle) return } case TS.projects.superalgos.globals.standardResponses.CUSTOM_OK_RESPONSE.result: { @@ -611,8 +612,8 @@ default: { TS.projects.superalgos.globals.loggerVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).BOT_MAIN_LOOP_LOGGER_MODULE_OBJECT.write(MODULE_NAME, "[ERROR] run -> loop -> startProcessFramework -> onFinished -> Unhandled custom response received. -> err = " + err.message); - TS.projects.superalgos.globals.taskVariables.FATAL_ERROR_MESSAGE = err.message - processStopped() + TS.projects.superalgos.globals.processVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).UNEXPECTED_ERROR = err + TS.projects.superalgos.functionLibraries.processFunctions.stopProcess(processIndex, callBackFunction, nextLoopTimeoutHandle) return } } @@ -622,24 +623,24 @@ "[ERROR] run -> loop -> startProcessFramework -> onFinished -> Unhandled err.result received. -> err.result = " + err.result); TS.projects.superalgos.globals.loggerVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).BOT_MAIN_LOOP_LOGGER_MODULE_OBJECT.write(MODULE_NAME, "[ERROR] run -> loop -> startProcessFramework -> onFinished -> Unhandled err.result received. -> err = " + err.message); - TS.projects.superalgos.globals.taskVariables.FATAL_ERROR_MESSAGE = err.message - processStopped() + TS.projects.superalgos.globals.processVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).UNEXPECTED_ERROR = err + TS.projects.superalgos.functionLibraries.processFunctions.stopProcess(processIndex, callBackFunction, nextLoopTimeoutHandle) return } } } catch (err) { TS.projects.superalgos.globals.loggerVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).BOT_MAIN_LOOP_LOGGER_MODULE_OBJECT.write(MODULE_NAME, "[ERROR] run -> loop -> startProcessFramework -> onFinished -> err = " + err.stack); - TS.projects.superalgos.globals.taskVariables.FATAL_ERROR_MESSAGE = err.message - processStopped() + TS.projects.superalgos.globals.processVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).UNEXPECTED_ERROR = err + TS.projects.superalgos.functionLibraries.processFunctions.stopProcess(processIndex, callBackFunction, nextLoopTimeoutHandle) return } } } catch (err) { TS.projects.superalgos.globals.loggerVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).BOT_MAIN_LOOP_LOGGER_MODULE_OBJECT.write(MODULE_NAME, "[ERROR] run -> loop -> startProcessFramework -> err = " + err.stack); - TS.projects.superalgos.globals.taskVariables.FATAL_ERROR_MESSAGE = err.message - processStopped() + TS.projects.superalgos.globals.processVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).UNEXPECTED_ERROR = err + TS.projects.superalgos.functionLibraries.processFunctions.stopProcess(processIndex, callBackFunction, nextLoopTimeoutHandle) return } } @@ -671,8 +672,8 @@ case TS.projects.superalgos.globals.standardResponses.DEFAULT_FAIL_RESPONSE.result: { // This is an unexpected exception that we do not know how to handle. TS.projects.superalgos.globals.loggerVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).BOT_MAIN_LOOP_LOGGER_MODULE_OBJECT.write(MODULE_NAME, "[ERROR] run -> loop -> finishProcessExecutionEvents -> onFinished -> Operation Failed. Aborting the process."); - TS.projects.superalgos.globals.taskVariables.FATAL_ERROR_MESSAGE = err.message - processStopped() + TS.projects.superalgos.globals.processVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).UNEXPECTED_ERROR = err + TS.projects.superalgos.functionLibraries.processFunctions.stopProcess(processIndex, callBackFunction, nextLoopTimeoutHandle) return } default: { @@ -680,24 +681,24 @@ "[ERROR] run -> loop -> finishProcessExecutionEvents -> onFinished -> Unhandled err.result received. -> err.result = " + err.result); TS.projects.superalgos.globals.loggerVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).BOT_MAIN_LOOP_LOGGER_MODULE_OBJECT.write(MODULE_NAME, "[ERROR] run -> loop -> finishProcessExecutionEvents -> onFinished -> Unhandled err.result received. -> err = " + err.message); - TS.projects.superalgos.globals.taskVariables.FATAL_ERROR_MESSAGE = err.message - processStopped() + TS.projects.superalgos.globals.processVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).UNEXPECTED_ERROR = err + TS.projects.superalgos.functionLibraries.processFunctions.stopProcess(processIndex, callBackFunction, nextLoopTimeoutHandle) return } } } catch (err) { TS.projects.superalgos.globals.loggerVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).BOT_MAIN_LOOP_LOGGER_MODULE_OBJECT.write(MODULE_NAME, "[ERROR] run -> loop -> finishProcessExecutionEvents -> onFinished -> err = " + err.stack); - TS.projects.superalgos.globals.taskVariables.FATAL_ERROR_MESSAGE = err.message - processStopped() + TS.projects.superalgos.globals.processVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).UNEXPECTED_ERROR = err + TS.projects.superalgos.functionLibraries.processFunctions.stopProcess(processIndex, callBackFunction, nextLoopTimeoutHandle) return } } } catch (err) { TS.projects.superalgos.globals.loggerVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).BOT_MAIN_LOOP_LOGGER_MODULE_OBJECT.write(MODULE_NAME, "[ERROR] run -> loop -> finishProcessExecutionEvents -> err = " + err.stack); - TS.projects.superalgos.globals.taskVariables.FATAL_ERROR_MESSAGE = err.message - processStopped() + TS.projects.superalgos.globals.processVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).UNEXPECTED_ERROR = err + TS.projects.superalgos.functionLibraries.processFunctions.stopProcess(processIndex, callBackFunction, nextLoopTimeoutHandle) return } } @@ -715,7 +716,7 @@ function onStop() { TS.projects.superalgos.globals.loggerVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).BOT_MAIN_LOOP_LOGGER_MODULE_OBJECT.write(MODULE_NAME, "[INFO] run -> loop -> loopControl -> onStop -> Stopping the Loop Gracefully. See you next time!") - processStopped() + TS.projects.superalgos.functionLibraries.processFunctions.stopProcess(processIndex, callBackFunction, nextLoopTimeoutHandle) return; } @@ -777,46 +778,20 @@ } catch (err) { TS.projects.superalgos.globals.loggerVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).BOT_MAIN_LOOP_LOGGER_MODULE_OBJECT.write(MODULE_NAME, "[ERROR] run -> loop -> shallWeStop -> err = " + err.stack); - TS.projects.superalgos.globals.taskVariables.FATAL_ERROR_MESSAGE = err.message - processStopped() + TS.projects.superalgos.globals.processVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).UNEXPECTED_ERROR = err + TS.projects.superalgos.functionLibraries.processFunctions.stopProcess(processIndex, callBackFunction, nextLoopTimeoutHandle) return } } } catch (err) { TS.projects.superalgos.globals.loggerVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).PROCESS_INSTANCE_LOGGER_MODULE_OBJECT.write(MODULE_NAME, "[ERROR] run -> loop -> err = " + err.stack); - TS.projects.superalgos.globals.taskVariables.FATAL_ERROR_MESSAGE = err.message - processStopped() + TS.projects.superalgos.globals.processVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).UNEXPECTED_ERROR = err + TS.projects.superalgos.functionLibraries.processFunctions.stopProcess(processIndex, callBackFunction, nextLoopTimeoutHandle) return } } - function processStopped() { - if (TS.projects.superalgos.globals.taskVariables.FATAL_ERROR_MESSAGE !== undefined) { - TS.projects.superalgos.functionLibraries.processFunctions.processError - ( - TS.projects.superalgos.globals.processVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).PROCESS_KEY, - undefined, - "An unexpected error caused the Process to stop.", - { - project: 'Superalgos', - category: 'Topic', - type: 'TS Process Error - Unexpected Error' - } - ) - } else { - TS.projects.superalgos.globals.taskConstants.EVENT_SERVER_CLIENT_MODULE_OBJECT.raiseEvent( - TS.projects.superalgos.globals.processVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).PROCESS_KEY, 'Stopped') - } - TS.projects.superalgos.globals.loggerVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).BOT_MAIN_LOOP_LOGGER_MODULE_OBJECT.persist(); - clearTimeout(nextLoopTimeoutHandle); - if (TS.projects.superalgos.globals.taskVariables.FATAL_ERROR_MESSAGE !== undefined) { - callBackFunction(TS.projects.superalgos.globals.standardResponses.DEFAULT_FAIL_RESPONSE) - } else { - callBackFunction(TS.projects.superalgos.globals.standardResponses.DEFAULT_OK_RESPONSE) - } - } - } catch (err) { TS.projects.superalgos.globals.taskVariables.UNEXPECTED_ERROR = err diff --git a/Projects/Superalgos/TS/Bot-Modules/Sensor-Bot/SingleMarketSensorBot.js b/Projects/Superalgos/TS/Bot-Modules/Sensor-Bot/SingleMarketSensorBot.js index a807b955c..78c916d87 100644 --- a/Projects/Superalgos/TS/Bot-Modules/Sensor-Bot/SingleMarketSensorBot.js +++ b/Projects/Superalgos/TS/Bot-Modules/Sensor-Bot/SingleMarketSensorBot.js @@ -118,8 +118,8 @@ case TS.projects.superalgos.globals.standardResponses.DEFAULT_FAIL_RESPONSE.result: { // This is an unexpected exception that we do not know how to handle. TS.projects.superalgos.globals.loggerVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).BOT_MAIN_LOOP_LOGGER_MODULE_OBJECT.write(MODULE_NAME, "[ERROR] run -> loop -> initializeProcessExecutionEvents -> onInizialized -> Operation Failed. Aborting the process."); - TS.projects.superalgos.globals.taskVariables.FATAL_ERROR_MESSAGE = err.message - processStopped() + TS.projects.superalgos.globals.processVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).UNEXPECTED_ERROR = err + TS.projects.superalgos.functionLibraries.processFunctions.stopProcess(processIndex, callBackFunction, nextLoopTimeoutHandle) return } default: { @@ -127,16 +127,16 @@ "[ERROR] run -> loop -> initializeProcessExecutionEvents -> onInizialized -> Unhandled err.result received. -> err.result = " + err.result); TS.projects.superalgos.globals.loggerVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).BOT_MAIN_LOOP_LOGGER_MODULE_OBJECT.write(MODULE_NAME, "[ERROR] run -> loop -> initializeProcessExecutionEvents -> onInizialized -> Unhandled err.result received. -> err = " + err.message); - TS.projects.superalgos.globals.taskVariables.FATAL_ERROR_MESSAGE = err.message - processStopped() + TS.projects.superalgos.globals.processVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).UNEXPECTED_ERROR = err + TS.projects.superalgos.functionLibraries.processFunctions.stopProcess(processIndex, callBackFunction, nextLoopTimeoutHandle) return } } } catch (err) { TS.projects.superalgos.globals.loggerVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).BOT_MAIN_LOOP_LOGGER_MODULE_OBJECT.write(MODULE_NAME, "[ERROR] run -> loop -> initializeProcessExecutionEvents -> onInizialized -> err = " + err.stack); - TS.projects.superalgos.globals.taskVariables.FATAL_ERROR_MESSAGE = err.message - processStopped() + TS.projects.superalgos.globals.processVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).UNEXPECTED_ERROR = err + TS.projects.superalgos.functionLibraries.processFunctions.stopProcess(processIndex, callBackFunction, nextLoopTimeoutHandle) return } } @@ -144,8 +144,8 @@ } catch (err) { TS.projects.superalgos.globals.loggerVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).BOT_MAIN_LOOP_LOGGER_MODULE_OBJECT.write(MODULE_NAME, "[ERROR] run -> loop -> initializeProcessExecutionEvents -> err = " + err.stack); - TS.projects.superalgos.globals.taskVariables.FATAL_ERROR_MESSAGE = err.message - processStopped() + TS.projects.superalgos.globals.processVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).UNEXPECTED_ERROR = err + TS.projects.superalgos.functionLibraries.processFunctions.stopProcess(processIndex, callBackFunction, nextLoopTimeoutHandle) return } } @@ -179,8 +179,8 @@ case TS.projects.superalgos.globals.standardResponses.DEFAULT_FAIL_RESPONSE.result: { // This is an unexpected exception that we do not know how to handle. TS.projects.superalgos.globals.loggerVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).BOT_MAIN_LOOP_LOGGER_MODULE_OBJECT.write(MODULE_NAME, "[ERROR] run -> loop -> startProcessExecutionEvents -> onStarted -> Operation Failed. Aborting the process."); - TS.projects.superalgos.globals.taskVariables.FATAL_ERROR_MESSAGE = err.message - processStopped() + TS.projects.superalgos.globals.processVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).UNEXPECTED_ERROR = err + TS.projects.superalgos.functionLibraries.processFunctions.stopProcess(processIndex, callBackFunction, nextLoopTimeoutHandle) return } default: { @@ -188,24 +188,24 @@ "[ERROR] run -> loop -> startProcessExecutionEvents -> onStarted -> Unhandled err.result received. -> err.result = " + err.result); TS.projects.superalgos.globals.loggerVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).BOT_MAIN_LOOP_LOGGER_MODULE_OBJECT.write(MODULE_NAME, "[ERROR] run -> loop -> startProcessExecutionEvents -> onStarted -> Unhandled err.result received. -> err = " + err.message); - TS.projects.superalgos.globals.taskVariables.FATAL_ERROR_MESSAGE = err.message - processStopped() + TS.projects.superalgos.globals.processVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).UNEXPECTED_ERROR = err + TS.projects.superalgos.functionLibraries.processFunctions.stopProcess(processIndex, callBackFunction, nextLoopTimeoutHandle) return } } } catch (err) { TS.projects.superalgos.globals.loggerVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).BOT_MAIN_LOOP_LOGGER_MODULE_OBJECT.write(MODULE_NAME, "[ERROR] run -> loop -> startProcessExecutionEvents -> onStarted -> err = " + err.stack); - TS.projects.superalgos.globals.taskVariables.FATAL_ERROR_MESSAGE = err.message - processStopped() + TS.projects.superalgos.globals.processVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).UNEXPECTED_ERROR = err + TS.projects.superalgos.functionLibraries.processFunctions.stopProcess(processIndex, callBackFunction, nextLoopTimeoutHandle) return } } } catch (err) { TS.projects.superalgos.globals.loggerVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).BOT_MAIN_LOOP_LOGGER_MODULE_OBJECT.write(MODULE_NAME, "[ERROR] run -> loop -> startProcessExecutionEvents -> err = " + err.stack); - TS.projects.superalgos.globals.taskVariables.FATAL_ERROR_MESSAGE = err.message - processStopped() + TS.projects.superalgos.globals.processVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).UNEXPECTED_ERROR = err + TS.projects.superalgos.functionLibraries.processFunctions.stopProcess(processIndex, callBackFunction, nextLoopTimeoutHandle) return } } @@ -234,8 +234,8 @@ case TS.projects.superalgos.globals.standardResponses.DEFAULT_FAIL_RESPONSE.result: { // This is an unexpected exception that we do not know how to handle. TS.projects.superalgos.globals.loggerVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).BOT_MAIN_LOOP_LOGGER_MODULE_OBJECT.write(MODULE_NAME, "[ERROR] run -> loop -> initializeStatusDependencies -> onInizialized -> Operation Failed. Aborting the process."); - TS.projects.superalgos.globals.taskVariables.FATAL_ERROR_MESSAGE = err.message - processStopped() + TS.projects.superalgos.globals.processVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).UNEXPECTED_ERROR = err + TS.projects.superalgos.functionLibraries.processFunctions.stopProcess(processIndex, callBackFunction, nextLoopTimeoutHandle) return } default: { @@ -243,24 +243,24 @@ "[ERROR] run -> loop -> initializeStatusDependencies -> onInizialized -> Unhandled err.result received. -> err.result = " + err.result); TS.projects.superalgos.globals.loggerVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).BOT_MAIN_LOOP_LOGGER_MODULE_OBJECT.write(MODULE_NAME, "[ERROR] run -> loop -> initializeStatusDependencies -> onInizialized -> Unhandled err.result received. -> err = " + err.message); - TS.projects.superalgos.globals.taskVariables.FATAL_ERROR_MESSAGE = err.message - processStopped() + TS.projects.superalgos.globals.processVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).UNEXPECTED_ERROR = err + TS.projects.superalgos.functionLibraries.processFunctions.stopProcess(processIndex, callBackFunction, nextLoopTimeoutHandle) return } } } catch (err) { TS.projects.superalgos.globals.loggerVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).BOT_MAIN_LOOP_LOGGER_MODULE_OBJECT.write(MODULE_NAME, "[ERROR] run -> loop -> initializeStatusDependencies -> onInizialized -> err = " + err.stack); - TS.projects.superalgos.globals.taskVariables.FATAL_ERROR_MESSAGE = err.message - processStopped() + TS.projects.superalgos.globals.processVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).UNEXPECTED_ERROR = err + TS.projects.superalgos.functionLibraries.processFunctions.stopProcess(processIndex, callBackFunction, nextLoopTimeoutHandle) return } } } catch (err) { TS.projects.superalgos.globals.loggerVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).BOT_MAIN_LOOP_LOGGER_MODULE_OBJECT.write(MODULE_NAME, "[ERROR] run -> loop -> initializeStatusDependencies -> err = " + err.stack); - TS.projects.superalgos.globals.taskVariables.FATAL_ERROR_MESSAGE = err.message - processStopped() + TS.projects.superalgos.globals.processVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).UNEXPECTED_ERROR = err + TS.projects.superalgos.functionLibraries.processFunctions.stopProcess(processIndex, callBackFunction, nextLoopTimeoutHandle) return } } @@ -288,8 +288,8 @@ case TS.projects.superalgos.globals.standardResponses.DEFAULT_FAIL_RESPONSE.result: { // This is an unexpected exception that we do not know how to handle. TS.projects.superalgos.globals.loggerVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).BOT_MAIN_LOOP_LOGGER_MODULE_OBJECT.write(MODULE_NAME, "[ERROR] run -> loop -> initializeBotModuleObject -> onInizialized > Operation Failed. Aborting the process."); - TS.projects.superalgos.globals.taskVariables.FATAL_ERROR_MESSAGE = err.message - processStopped() + TS.projects.superalgos.globals.processVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).UNEXPECTED_ERROR = err + TS.projects.superalgos.functionLibraries.processFunctions.stopProcess(processIndex, callBackFunction, nextLoopTimeoutHandle) return } case TS.projects.superalgos.globals.standardResponses.CUSTOM_OK_RESPONSE.result: { @@ -298,8 +298,8 @@ default: { TS.projects.superalgos.globals.loggerVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).BOT_MAIN_LOOP_LOGGER_MODULE_OBJECT.write(MODULE_NAME, "[ERROR] run -> loop -> initializeBotModuleObject -> onInizialized > Unhandled custom response received. -> err = " + err.message); - TS.projects.superalgos.globals.taskVariables.FATAL_ERROR_MESSAGE = err.message - processStopped() + TS.projects.superalgos.globals.processVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).UNEXPECTED_ERROR = err + TS.projects.superalgos.functionLibraries.processFunctions.stopProcess(processIndex, callBackFunction, nextLoopTimeoutHandle) return } } @@ -309,24 +309,24 @@ "[ERROR] run -> loop -> initializeBotModuleObject -> onInizialized > Unhandled err.result received. -> err.result = " + err.result); TS.projects.superalgos.globals.loggerVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).BOT_MAIN_LOOP_LOGGER_MODULE_OBJECT.write(MODULE_NAME, "[ERROR] run -> loop -> initializeBotModuleObject -> onInizialized > Unhandled err.result received. -> err = " + err.message); - TS.projects.superalgos.globals.taskVariables.FATAL_ERROR_MESSAGE = err.message - processStopped() + TS.projects.superalgos.globals.processVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).UNEXPECTED_ERROR = err + TS.projects.superalgos.functionLibraries.processFunctions.stopProcess(processIndex, callBackFunction, nextLoopTimeoutHandle) return } } } catch (err) { TS.projects.superalgos.globals.loggerVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).BOT_MAIN_LOOP_LOGGER_MODULE_OBJECT.write(MODULE_NAME, "[ERROR] run -> loop -> initializeBotModuleObject -> onInizialized -> err = " + err.stack); - TS.projects.superalgos.globals.taskVariables.FATAL_ERROR_MESSAGE = err.message - processStopped() + TS.projects.superalgos.globals.processVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).UNEXPECTED_ERROR = err + TS.projects.superalgos.functionLibraries.processFunctions.stopProcess(processIndex, callBackFunction, nextLoopTimeoutHandle) return } } } catch (err) { TS.projects.superalgos.globals.loggerVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).BOT_MAIN_LOOP_LOGGER_MODULE_OBJECT.write(MODULE_NAME, "[ERROR] run -> loop -> initializeBotModuleObject -> err = " + err.stack); - TS.projects.superalgos.globals.taskVariables.FATAL_ERROR_MESSAGE = err.message - processStopped() + TS.projects.superalgos.globals.processVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).UNEXPECTED_ERROR = err + TS.projects.superalgos.functionLibraries.processFunctions.stopProcess(processIndex, callBackFunction, nextLoopTimeoutHandle) return } } @@ -354,8 +354,8 @@ case TS.projects.superalgos.globals.standardResponses.DEFAULT_FAIL_RESPONSE.result: { // This is an unexpected exception that we do not know how to handle. TS.projects.superalgos.globals.loggerVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).BOT_MAIN_LOOP_LOGGER_MODULE_OBJECT.write(MODULE_NAME, "[ERROR] run -> loop -> startBotModuleObject -> onFinished > Operation Failed. Aborting the process."); - TS.projects.superalgos.globals.taskVariables.FATAL_ERROR_MESSAGE = err.message - processStopped() + TS.projects.superalgos.globals.processVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).UNEXPECTED_ERROR = err + TS.projects.superalgos.functionLibraries.processFunctions.stopProcess(processIndex, callBackFunction, nextLoopTimeoutHandle) return } case TS.projects.superalgos.globals.standardResponses.CUSTOM_OK_RESPONSE.result: { @@ -378,8 +378,8 @@ default: { TS.projects.superalgos.globals.loggerVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).BOT_MAIN_LOOP_LOGGER_MODULE_OBJECT.write(MODULE_NAME, "[ERROR] run -> loop -> startBotModuleObject -> onFinished > Unhandled custom response received. -> err = " + err.message); - TS.projects.superalgos.globals.taskVariables.FATAL_ERROR_MESSAGE = err.message - processStopped() + TS.projects.superalgos.globals.processVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).UNEXPECTED_ERROR = err + TS.projects.superalgos.functionLibraries.processFunctions.stopProcess(processIndex, callBackFunction, nextLoopTimeoutHandle) return } } @@ -389,24 +389,24 @@ "[ERROR] run -> loop -> startBotModuleObject -> onFinished > Unhandled err.result received. -> err.result = " + err.result); TS.projects.superalgos.globals.loggerVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).BOT_MAIN_LOOP_LOGGER_MODULE_OBJECT.write(MODULE_NAME, "[ERROR] run -> loop -> startBotModuleObject -> onFinished > Unhandled err.result received. -> err = " + err.message); - TS.projects.superalgos.globals.taskVariables.FATAL_ERROR_MESSAGE = err.message - processStopped() + TS.projects.superalgos.globals.processVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).UNEXPECTED_ERROR = err + TS.projects.superalgos.functionLibraries.processFunctions.stopProcess(processIndex, callBackFunction, nextLoopTimeoutHandle) return } } } catch (err) { TS.projects.superalgos.globals.loggerVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).BOT_MAIN_LOOP_LOGGER_MODULE_OBJECT.write(MODULE_NAME, "[ERROR] run -> loop -> startBotModuleObject -> onFinished -> err = " + err.stack); - TS.projects.superalgos.globals.taskVariables.FATAL_ERROR_MESSAGE = err.message - processStopped() + TS.projects.superalgos.globals.processVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).UNEXPECTED_ERROR = err + TS.projects.superalgos.functionLibraries.processFunctions.stopProcess(processIndex, callBackFunction, nextLoopTimeoutHandle) return } } } catch (err) { TS.projects.superalgos.globals.loggerVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).BOT_MAIN_LOOP_LOGGER_MODULE_OBJECT.write(MODULE_NAME, "[ERROR] run -> loop -> startBotModuleObject -> err = " + err.stack); - TS.projects.superalgos.globals.taskVariables.FATAL_ERROR_MESSAGE = err.message - processStopped() + TS.projects.superalgos.globals.processVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).UNEXPECTED_ERROR = err + TS.projects.superalgos.functionLibraries.processFunctions.stopProcess(processIndex, callBackFunction, nextLoopTimeoutHandle) return } } @@ -438,8 +438,8 @@ case TS.projects.superalgos.globals.standardResponses.DEFAULT_FAIL_RESPONSE.result: { // This is an unexpected exception that we do not know how to handle. TS.projects.superalgos.globals.loggerVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).BOT_MAIN_LOOP_LOGGER_MODULE_OBJECT.write(MODULE_NAME, "[ERROR] run -> loop -> finishProcessExecutionEvents -> onFinished -> Operation Failed. Aborting the process."); - TS.projects.superalgos.globals.taskVariables.FATAL_ERROR_MESSAGE = err.message - processStopped() + TS.projects.superalgos.globals.processVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).UNEXPECTED_ERROR = err + TS.projects.superalgos.functionLibraries.processFunctions.stopProcess(processIndex, callBackFunction, nextLoopTimeoutHandle) return } default: { @@ -447,24 +447,24 @@ "[ERROR] run -> loop -> finishProcessExecutionEvents -> onFinished -> Unhandled err.result received. -> err.result = " + err.result); TS.projects.superalgos.globals.loggerVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).BOT_MAIN_LOOP_LOGGER_MODULE_OBJECT.write(MODULE_NAME, "[ERROR] run -> loop -> finishProcessExecutionEvents -> onFinished -> Unhandled err.result received. -> err = " + err.message); - TS.projects.superalgos.globals.taskVariables.FATAL_ERROR_MESSAGE = err.message - processStopped() + TS.projects.superalgos.globals.processVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).UNEXPECTED_ERROR = err + TS.projects.superalgos.functionLibraries.processFunctions.stopProcess(processIndex, callBackFunction, nextLoopTimeoutHandle) return } } } catch (err) { TS.projects.superalgos.globals.loggerVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).BOT_MAIN_LOOP_LOGGER_MODULE_OBJECT.write(MODULE_NAME, "[ERROR] run -> loop -> finishProcessExecutionEvents -> onFinished -> err = " + err.stack); - TS.projects.superalgos.globals.taskVariables.FATAL_ERROR_MESSAGE = err.message - processStopped() + TS.projects.superalgos.globals.processVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).UNEXPECTED_ERROR = err + TS.projects.superalgos.functionLibraries.processFunctions.stopProcess(processIndex, callBackFunction, nextLoopTimeoutHandle) return } } } catch (err) { TS.projects.superalgos.globals.loggerVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).BOT_MAIN_LOOP_LOGGER_MODULE_OBJECT.write(MODULE_NAME, "[ERROR] run -> loop -> finishProcessExecutionEvents -> err = " + err.stack); - TS.projects.superalgos.globals.taskVariables.FATAL_ERROR_MESSAGE = err.message - processStopped() + TS.projects.superalgos.globals.processVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).UNEXPECTED_ERROR = err + TS.projects.superalgos.functionLibraries.processFunctions.stopProcess(processIndex, callBackFunction, nextLoopTimeoutHandle) return } } @@ -480,7 +480,7 @@ function onStop() { TS.projects.superalgos.globals.loggerVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).BOT_MAIN_LOOP_LOGGER_MODULE_OBJECT.write(MODULE_NAME, "[INFO] run -> loop -> loopControl -> onStop -> Stopping the Loop Gracefully. See you next time!") - processStopped() + TS.projects.superalgos.functionLibraries.processFunctions.stopProcess(processIndex, callBackFunction, nextLoopTimeoutHandle) return; } @@ -534,8 +534,8 @@ } catch (err) { TS.projects.superalgos.globals.loggerVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).BOT_MAIN_LOOP_LOGGER_MODULE_OBJECT.write(MODULE_NAME, "[ERROR] run -> loop -> shallWeStop -> err = " + err.stack); - TS.projects.superalgos.globals.taskVariables.FATAL_ERROR_MESSAGE = err.message - processStopped() + TS.projects.superalgos.globals.processVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).UNEXPECTED_ERROR = err + TS.projects.superalgos.functionLibraries.processFunctions.stopProcess(processIndex, callBackFunction, nextLoopTimeoutHandle) return } } @@ -543,36 +543,11 @@ } catch (err) { TS.projects.superalgos.globals.loggerVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).PROCESS_INSTANCE_LOGGER_MODULE_OBJECT.write(MODULE_NAME, "[ERROR] run -> loop -> err = " + err.stack); - TS.projects.superalgos.globals.taskVariables.FATAL_ERROR_MESSAGE = err.message - processStopped() + TS.projects.superalgos.globals.processVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).UNEXPECTED_ERROR = err + TS.projects.superalgos.functionLibraries.processFunctions.stopProcess(processIndex, callBackFunction, nextLoopTimeoutHandle) return } } - - function processStopped() { - if (TS.projects.superalgos.globals.taskVariables.FATAL_ERROR_MESSAGE !== undefined) { - TS.projects.superalgos.functionLibraries.processFunctions.processError - ( - TS.projects.superalgos.globals.processVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).PROCESS_KEY, - undefined, - "An unexpected error caused the Process to stop.", - { - project: 'Superalgos', - category: 'Topic', - type: 'TS Process Error - Unexpected Error' - } - ) - } else { - TS.projects.superalgos.globals.taskConstants.EVENT_SERVER_CLIENT_MODULE_OBJECT.raiseEvent(TS.projects.superalgos.globals.processVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).PROCESS_KEY, 'Stopped') - } - TS.projects.superalgos.globals.loggerVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).BOT_MAIN_LOOP_LOGGER_MODULE_OBJECT.persist(); - clearTimeout(nextLoopTimeoutHandle); - if (TS.projects.superalgos.globals.taskVariables.FATAL_ERROR_MESSAGE !== undefined) { - callBackFunction(TS.projects.superalgos.globals.standardResponses.DEFAULT_FAIL_RESPONSE) - } else { - callBackFunction(TS.projects.superalgos.globals.standardResponses.DEFAULT_OK_RESPONSE) - } - } } catch (err) { diff --git a/Projects/Superalgos/TS/Bot-Modules/Trading-Bot/SingleMarketTradingBot.js b/Projects/Superalgos/TS/Bot-Modules/Trading-Bot/SingleMarketTradingBot.js index 9d6da5c2b..cefebca19 100644 --- a/Projects/Superalgos/TS/Bot-Modules/Trading-Bot/SingleMarketTradingBot.js +++ b/Projects/Superalgos/TS/Bot-Modules/Trading-Bot/SingleMarketTradingBot.js @@ -128,8 +128,8 @@ case TS.projects.superalgos.globals.standardResponses.DEFAULT_FAIL_RESPONSE.result: { // This is an unexpected exception that we do not know how to handle. TS.projects.superalgos.globals.loggerVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).BOT_MAIN_LOOP_LOGGER_MODULE_OBJECT.write(MODULE_NAME, "[ERROR] run -> loop -> initializeProcessExecutionEvents -> onInizialized -> Operation Failed. Aborting the process."); - TS.projects.superalgos.globals.taskVariables.FATAL_ERROR_MESSAGE = err.message - processStopped() + TS.projects.superalgos.globals.processVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).UNEXPECTED_ERROR = err + TS.projects.superalgos.functionLibraries.processFunctions.stopProcess(processIndex, callBackFunction, nextLoopTimeoutHandle) return } default: { @@ -137,24 +137,24 @@ "[ERROR] run -> loop -> initializeProcessExecutionEvents -> onInizialized -> Unhandled err.result received. -> err.result = " + err.result); TS.projects.superalgos.globals.loggerVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).BOT_MAIN_LOOP_LOGGER_MODULE_OBJECT.write(MODULE_NAME, "[ERROR] run -> loop -> initializeProcessExecutionEvents -> onInizialized -> Unhandled err.result received. -> err = " + err.message); - TS.projects.superalgos.globals.taskVariables.FATAL_ERROR_MESSAGE = err.message - processStopped() + TS.projects.superalgos.globals.processVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).UNEXPECTED_ERROR = err + TS.projects.superalgos.functionLibraries.processFunctions.stopProcess(processIndex, callBackFunction, nextLoopTimeoutHandle) return } } } catch (err) { TS.projects.superalgos.globals.loggerVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).BOT_MAIN_LOOP_LOGGER_MODULE_OBJECT.write(MODULE_NAME, "[ERROR] run -> loop -> initializeProcessExecutionEvents -> onInizialized -> err = " + err.stack); - TS.projects.superalgos.globals.taskVariables.FATAL_ERROR_MESSAGE = err.message - processStopped() + TS.projects.superalgos.globals.processVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).UNEXPECTED_ERROR = err + TS.projects.superalgos.functionLibraries.processFunctions.stopProcess(processIndex, callBackFunction, nextLoopTimeoutHandle) return } } } catch (err) { TS.projects.superalgos.globals.loggerVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).BOT_MAIN_LOOP_LOGGER_MODULE_OBJECT.write(MODULE_NAME, "[ERROR] run -> loop -> initializeProcessExecutionEvents -> err = " + err.stack); - TS.projects.superalgos.globals.taskVariables.FATAL_ERROR_MESSAGE = err.message - processStopped() + TS.projects.superalgos.globals.processVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).UNEXPECTED_ERROR = err + TS.projects.superalgos.functionLibraries.processFunctions.stopProcess(processIndex, callBackFunction, nextLoopTimeoutHandle) return } } @@ -188,8 +188,8 @@ case TS.projects.superalgos.globals.standardResponses.DEFAULT_FAIL_RESPONSE.result: { // This is an unexpected exception that we do not know how to handle. TS.projects.superalgos.globals.loggerVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).BOT_MAIN_LOOP_LOGGER_MODULE_OBJECT.write(MODULE_NAME, "[ERROR] run -> loop -> startProcessExecutionEvents -> onStarted -> Operation Failed. Aborting the process."); - TS.projects.superalgos.globals.taskVariables.FATAL_ERROR_MESSAGE = err.message - processStopped() + TS.projects.superalgos.globals.processVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).UNEXPECTED_ERROR = err + TS.projects.superalgos.functionLibraries.processFunctions.stopProcess(processIndex, callBackFunction, nextLoopTimeoutHandle) return } default: { @@ -197,24 +197,24 @@ "[ERROR] run -> loop -> startProcessExecutionEvents -> onStarted -> Unhandled err.result received. -> err.result = " + err.result); TS.projects.superalgos.globals.loggerVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).BOT_MAIN_LOOP_LOGGER_MODULE_OBJECT.write(MODULE_NAME, "[ERROR] run -> loop -> startProcessExecutionEvents -> onStarted -> Unhandled err.result received. -> err = " + err.message); - TS.projects.superalgos.globals.taskVariables.FATAL_ERROR_MESSAGE = err.message - processStopped() + TS.projects.superalgos.globals.processVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).UNEXPECTED_ERROR = err + TS.projects.superalgos.functionLibraries.processFunctions.stopProcess(processIndex, callBackFunction, nextLoopTimeoutHandle) return } } } catch (err) { TS.projects.superalgos.globals.loggerVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).BOT_MAIN_LOOP_LOGGER_MODULE_OBJECT.write(MODULE_NAME, "[ERROR] run -> loop -> startProcessExecutionEvents -> onStarted -> err = " + err.stack); - TS.projects.superalgos.globals.taskVariables.FATAL_ERROR_MESSAGE = err.message - processStopped() + TS.projects.superalgos.globals.processVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).UNEXPECTED_ERROR = err + TS.projects.superalgos.functionLibraries.processFunctions.stopProcess(processIndex, callBackFunction, nextLoopTimeoutHandle) return } } } catch (err) { TS.projects.superalgos.globals.loggerVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).BOT_MAIN_LOOP_LOGGER_MODULE_OBJECT.write(MODULE_NAME, "[ERROR] run -> loop -> startProcessExecutionEvents -> err = " + err.stack); - TS.projects.superalgos.globals.taskVariables.FATAL_ERROR_MESSAGE = err.message - processStopped() + TS.projects.superalgos.globals.processVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).UNEXPECTED_ERROR = err + TS.projects.superalgos.functionLibraries.processFunctions.stopProcess(processIndex, callBackFunction, nextLoopTimeoutHandle) return } } @@ -243,8 +243,8 @@ case TS.projects.superalgos.globals.standardResponses.DEFAULT_FAIL_RESPONSE.result: { // This is an unexpected exception that we do not know how to handle. TS.projects.superalgos.globals.loggerVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).BOT_MAIN_LOOP_LOGGER_MODULE_OBJECT.write(MODULE_NAME, "[ERROR] run -> loop -> initializeStatusDependencies -> onInizialized -> Operation Failed. Aborting the process."); - TS.projects.superalgos.globals.taskVariables.FATAL_ERROR_MESSAGE = err.message - processStopped() + TS.projects.superalgos.globals.processVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).UNEXPECTED_ERROR = err + TS.projects.superalgos.functionLibraries.processFunctions.stopProcess(processIndex, callBackFunction, nextLoopTimeoutHandle) return } default: { @@ -252,24 +252,24 @@ "[ERROR] run -> loop -> initializeStatusDependencies -> onInizialized -> Unhandled err.result received. -> err.result = " + err.result); TS.projects.superalgos.globals.loggerVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).BOT_MAIN_LOOP_LOGGER_MODULE_OBJECT.write(MODULE_NAME, "[ERROR] run -> loop -> initializeStatusDependencies -> onInizialized -> Unhandled err.result received. -> err = " + err.message); - TS.projects.superalgos.globals.taskVariables.FATAL_ERROR_MESSAGE = err.message - processStopped() + TS.projects.superalgos.globals.processVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).UNEXPECTED_ERROR = err + TS.projects.superalgos.functionLibraries.processFunctions.stopProcess(processIndex, callBackFunction, nextLoopTimeoutHandle) return } } } catch (err) { TS.projects.superalgos.globals.loggerVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).BOT_MAIN_LOOP_LOGGER_MODULE_OBJECT.write(MODULE_NAME, "[ERROR] run -> loop -> initializeStatusDependencies -> onInizialized -> err = " + err.stack); - TS.projects.superalgos.globals.taskVariables.FATAL_ERROR_MESSAGE = err.message - processStopped() + TS.projects.superalgos.globals.processVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).UNEXPECTED_ERROR = err + TS.projects.superalgos.functionLibraries.processFunctions.stopProcess(processIndex, callBackFunction, nextLoopTimeoutHandle) return } } } catch (err) { TS.projects.superalgos.globals.loggerVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).BOT_MAIN_LOOP_LOGGER_MODULE_OBJECT.write(MODULE_NAME, "[ERROR] run -> loop -> initializeStatusDependencies -> err = " + err.stack); - TS.projects.superalgos.globals.taskVariables.FATAL_ERROR_MESSAGE = err.message - processStopped() + TS.projects.superalgos.globals.processVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).UNEXPECTED_ERROR = err + TS.projects.superalgos.functionLibraries.processFunctions.stopProcess(processIndex, callBackFunction, nextLoopTimeoutHandle) return } } @@ -296,8 +296,8 @@ "[ERROR] run -> loop -> initializeDataDependencies -> onInizialized -> Process Framework not Supported."); TS.projects.superalgos.globals.loggerVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).BOT_MAIN_LOOP_LOGGER_MODULE_OBJECT.write(MODULE_NAME, "[ERROR] run -> loop -> initializeDataDependencies -> onInizialized -> Process Framework Name = " + TS.projects.superalgos.globals.taskConstants.TASK_NODE.bot.processes[processIndex].referenceParent.config.framework.name); - TS.projects.superalgos.globals.taskVariables.FATAL_ERROR_MESSAGE = err.message - processStopped() + TS.projects.superalgos.globals.processVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).UNEXPECTED_ERROR = err + TS.projects.superalgos.functionLibraries.processFunctions.stopProcess(processIndex, callBackFunction, nextLoopTimeoutHandle) return } } @@ -313,8 +313,8 @@ case TS.projects.superalgos.globals.standardResponses.DEFAULT_FAIL_RESPONSE.result: { // This is an unexpected exception that we do not know how to handle. TS.projects.superalgos.globals.loggerVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).BOT_MAIN_LOOP_LOGGER_MODULE_OBJECT.write(MODULE_NAME, "[ERROR] run -> loop -> initializeDataDependencies -> onInizialized -> Operation Failed. Aborting the process."); - TS.projects.superalgos.globals.taskVariables.FATAL_ERROR_MESSAGE = err.message - processStopped() + TS.projects.superalgos.globals.processVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).UNEXPECTED_ERROR = err + TS.projects.superalgos.functionLibraries.processFunctions.stopProcess(processIndex, callBackFunction, nextLoopTimeoutHandle) return } default: { @@ -322,24 +322,24 @@ "[ERROR] run -> loop -> initializeDataDependencies -> onInizialized -> Unhandled err.result received. -> err.result = " + err.result); TS.projects.superalgos.globals.loggerVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).BOT_MAIN_LOOP_LOGGER_MODULE_OBJECT.write(MODULE_NAME, "[ERROR] run -> loop -> initializeDataDependencies -> onInizialized -> Unhandled err.result received. -> err = " + err.message); - TS.projects.superalgos.globals.taskVariables.FATAL_ERROR_MESSAGE = err.message - processStopped() + TS.projects.superalgos.globals.processVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).UNEXPECTED_ERROR = err + TS.projects.superalgos.functionLibraries.processFunctions.stopProcess(processIndex, callBackFunction, nextLoopTimeoutHandle) return } } } catch (err) { TS.projects.superalgos.globals.loggerVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).BOT_MAIN_LOOP_LOGGER_MODULE_OBJECT.write(MODULE_NAME, "[ERROR] run -> loop -> initializeDataDependencies -> onInizialized -> err = " + err.stack); - TS.projects.superalgos.globals.taskVariables.FATAL_ERROR_MESSAGE = err.message - processStopped() + TS.projects.superalgos.globals.processVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).UNEXPECTED_ERROR = err + TS.projects.superalgos.functionLibraries.processFunctions.stopProcess(processIndex, callBackFunction, nextLoopTimeoutHandle) return } } } catch (err) { TS.projects.superalgos.globals.loggerVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).BOT_MAIN_LOOP_LOGGER_MODULE_OBJECT.write(MODULE_NAME, "[ERROR] run -> loop -> initializeDataDependencies -> err = " + err.stack); - TS.projects.superalgos.globals.taskVariables.FATAL_ERROR_MESSAGE = err.message - processStopped() + TS.projects.superalgos.globals.processVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).UNEXPECTED_ERROR = err + TS.projects.superalgos.functionLibraries.processFunctions.stopProcess(processIndex, callBackFunction, nextLoopTimeoutHandle) return } } @@ -367,15 +367,15 @@ case TS.projects.superalgos.globals.standardResponses.DEFAULT_FAIL_RESPONSE.result: { // This is an unexpected exception that we do not know how to handle. TS.projects.superalgos.globals.loggerVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).BOT_MAIN_LOOP_LOGGER_MODULE_OBJECT.write(MODULE_NAME, "[ERROR] run -> loop -> intitializeProcessFramework -> onInizialized -> Operation Failed. Aborting the process."); - TS.projects.superalgos.globals.taskVariables.FATAL_ERROR_MESSAGE = err.message - processStopped() + TS.projects.superalgos.globals.processVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).UNEXPECTED_ERROR = err + TS.projects.superalgos.functionLibraries.processFunctions.stopProcess(processIndex, callBackFunction, nextLoopTimeoutHandle) return } case TS.projects.superalgos.globals.standardResponses.CUSTOM_OK_RESPONSE.result: { TS.projects.superalgos.globals.loggerVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).BOT_MAIN_LOOP_LOGGER_MODULE_OBJECT.write(MODULE_NAME, "[ERROR] run -> loop -> intitializeProcessFramework -> onInizialized > Unhandled custom response received. -> err = " + err.message); - TS.projects.superalgos.globals.taskVariables.FATAL_ERROR_MESSAGE = err.message - processStopped() + TS.projects.superalgos.globals.processVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).UNEXPECTED_ERROR = err + TS.projects.superalgos.functionLibraries.processFunctions.stopProcess(processIndex, callBackFunction, nextLoopTimeoutHandle) return } default: { @@ -383,24 +383,24 @@ "[ERROR] run -> loop -> intitializeProcessFramework -> onInizialized -> Unhandled err.result received. -> err.result = " + err.result); TS.projects.superalgos.globals.loggerVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).BOT_MAIN_LOOP_LOGGER_MODULE_OBJECT.write(MODULE_NAME, "[ERROR] run -> loop -> intitializeProcessFramework -> onInizialized -> Unhandled err.result received. -> err = " + err.message); - TS.projects.superalgos.globals.taskVariables.FATAL_ERROR_MESSAGE = err.message - processStopped() + TS.projects.superalgos.globals.processVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).UNEXPECTED_ERROR = err + TS.projects.superalgos.functionLibraries.processFunctions.stopProcess(processIndex, callBackFunction, nextLoopTimeoutHandle) return } } } catch (err) { TS.projects.superalgos.globals.loggerVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).BOT_MAIN_LOOP_LOGGER_MODULE_OBJECT.write(MODULE_NAME, "[ERROR] run -> loop -> intitializeProcessFramework -> onInizialized -> err = " + err.stack); - TS.projects.superalgos.globals.taskVariables.FATAL_ERROR_MESSAGE = err.message - processStopped() + TS.projects.superalgos.globals.processVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).UNEXPECTED_ERROR = err + TS.projects.superalgos.functionLibraries.processFunctions.stopProcess(processIndex, callBackFunction, nextLoopTimeoutHandle) return } } } catch (err) { TS.projects.superalgos.globals.loggerVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).BOT_MAIN_LOOP_LOGGER_MODULE_OBJECT.write(MODULE_NAME, "[ERROR] run -> loop -> intitializeProcessFramework -> err = " + err.stack); - TS.projects.superalgos.globals.taskVariables.FATAL_ERROR_MESSAGE = err.message - processStopped() + TS.projects.superalgos.globals.processVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).UNEXPECTED_ERROR = err + TS.projects.superalgos.functionLibraries.processFunctions.stopProcess(processIndex, callBackFunction, nextLoopTimeoutHandle) return } } @@ -436,8 +436,8 @@ case TS.projects.superalgos.globals.standardResponses.DEFAULT_FAIL_RESPONSE.result: { // This is an unexpected exception that we do not know how to handle. TS.projects.superalgos.globals.loggerVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).BOT_MAIN_LOOP_LOGGER_MODULE_OBJECT.write(MODULE_NAME, "[ERROR] run -> loop -> startProcessFramework -> onFinished -> Operation Failed. Aborting the process."); - TS.projects.superalgos.globals.taskVariables.FATAL_ERROR_MESSAGE = err.message - processStopped() + TS.projects.superalgos.globals.processVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).UNEXPECTED_ERROR = err + TS.projects.superalgos.functionLibraries.processFunctions.stopProcess(processIndex, callBackFunction, nextLoopTimeoutHandle) return } case TS.projects.superalgos.globals.standardResponses.CUSTOM_OK_RESPONSE.result: { @@ -460,8 +460,8 @@ default: { TS.projects.superalgos.globals.loggerVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).BOT_MAIN_LOOP_LOGGER_MODULE_OBJECT.write(MODULE_NAME, "[ERROR] run -> loop -> startProcessFramework -> onFinished -> Unhandled custom response received. -> err = " + err.message); - TS.projects.superalgos.globals.taskVariables.FATAL_ERROR_MESSAGE = err.message - processStopped() + TS.projects.superalgos.globals.processVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).UNEXPECTED_ERROR = err + TS.projects.superalgos.functionLibraries.processFunctions.stopProcess(processIndex, callBackFunction, nextLoopTimeoutHandle) return } } @@ -471,24 +471,24 @@ "[ERROR] run -> loop -> startProcessFramework -> onFinished -> Unhandled err.result received. -> err.result = " + err.result); TS.projects.superalgos.globals.loggerVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).BOT_MAIN_LOOP_LOGGER_MODULE_OBJECT.write(MODULE_NAME, "[ERROR] run -> loop -> startProcessFramework -> onFinished -> Unhandled err.result received. -> err = " + err.message); - TS.projects.superalgos.globals.taskVariables.FATAL_ERROR_MESSAGE = err.message - processStopped() + TS.projects.superalgos.globals.processVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).UNEXPECTED_ERROR = err + TS.projects.superalgos.functionLibraries.processFunctions.stopProcess(processIndex, callBackFunction, nextLoopTimeoutHandle) return } } } catch (err) { TS.projects.superalgos.globals.loggerVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).BOT_MAIN_LOOP_LOGGER_MODULE_OBJECT.write(MODULE_NAME, "[ERROR] run -> loop -> startProcessFramework -> onFinished -> err = " + err.stack); - TS.projects.superalgos.globals.taskVariables.FATAL_ERROR_MESSAGE = err.message - processStopped() + TS.projects.superalgos.globals.processVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).UNEXPECTED_ERROR = err + TS.projects.superalgos.functionLibraries.processFunctions.stopProcess(processIndex, callBackFunction, nextLoopTimeoutHandle) return } } } catch (err) { TS.projects.superalgos.globals.loggerVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).BOT_MAIN_LOOP_LOGGER_MODULE_OBJECT.write(MODULE_NAME, "[ERROR] run -> loop -> startProcessFramework -> err = " + err.stack); - TS.projects.superalgos.globals.taskVariables.FATAL_ERROR_MESSAGE = err.message - processStopped() + TS.projects.superalgos.globals.processVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).UNEXPECTED_ERROR = err + TS.projects.superalgos.functionLibraries.processFunctions.stopProcess(processIndex, callBackFunction, nextLoopTimeoutHandle) return } } @@ -520,8 +520,8 @@ case TS.projects.superalgos.globals.standardResponses.DEFAULT_FAIL_RESPONSE.result: { // This is an unexpected exception that we do not know how to handle. TS.projects.superalgos.globals.loggerVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).BOT_MAIN_LOOP_LOGGER_MODULE_OBJECT.write(MODULE_NAME, "[ERROR] run -> loop -> finishProcessExecutionEvents -> onFinished -> Operation Failed. Aborting the process."); - TS.projects.superalgos.globals.taskVariables.FATAL_ERROR_MESSAGE = err.message - processStopped() + TS.projects.superalgos.globals.processVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).UNEXPECTED_ERROR = err + TS.projects.superalgos.functionLibraries.processFunctions.stopProcess(processIndex, callBackFunction, nextLoopTimeoutHandle) return } default: { @@ -529,24 +529,24 @@ "[ERROR] run -> loop -> finishProcessExecutionEvents -> onFinished -> Unhandled err.result received. -> err.result = " + err.result); TS.projects.superalgos.globals.loggerVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).BOT_MAIN_LOOP_LOGGER_MODULE_OBJECT.write(MODULE_NAME, "[ERROR] run -> loop -> finishProcessExecutionEvents -> onFinished -> Unhandled err.result received. -> err = " + err.message); - TS.projects.superalgos.globals.taskVariables.FATAL_ERROR_MESSAGE = err.message - processStopped() + TS.projects.superalgos.globals.processVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).UNEXPECTED_ERROR = err + TS.projects.superalgos.functionLibraries.processFunctions.stopProcess(processIndex, callBackFunction, nextLoopTimeoutHandle) return } } } catch (err) { TS.projects.superalgos.globals.loggerVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).BOT_MAIN_LOOP_LOGGER_MODULE_OBJECT.write(MODULE_NAME, "[ERROR] run -> loop -> finishProcessExecutionEvents -> onFinished -> err = " + err.stack); - TS.projects.superalgos.globals.taskVariables.FATAL_ERROR_MESSAGE = err.message - processStopped() + TS.projects.superalgos.globals.processVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).UNEXPECTED_ERROR = err + TS.projects.superalgos.functionLibraries.processFunctions.stopProcess(processIndex, callBackFunction, nextLoopTimeoutHandle) return } } } catch (err) { TS.projects.superalgos.globals.loggerVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).BOT_MAIN_LOOP_LOGGER_MODULE_OBJECT.write(MODULE_NAME, "[ERROR] run -> loop -> finishProcessExecutionEvents -> err = " + err.stack); - TS.projects.superalgos.globals.taskVariables.FATAL_ERROR_MESSAGE = err.message - processStopped() + TS.projects.superalgos.globals.processVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).UNEXPECTED_ERROR = err + TS.projects.superalgos.functionLibraries.processFunctions.stopProcess(processIndex, callBackFunction, nextLoopTimeoutHandle) return } } @@ -567,7 +567,7 @@ TS.projects.superalgos.globals.loggerVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).BOT_MAIN_LOOP_LOGGER_MODULE_OBJECT.persist(); TS.projects.superalgos.globals.taskConstants.EVENT_SERVER_CLIENT_MODULE_OBJECT.raiseEvent(TS.projects.superalgos.globals.processVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).SESSION_KEY, 'Stopped') - processStopped() + TS.projects.superalgos.functionLibraries.processFunctions.stopProcess(processIndex, callBackFunction, nextLoopTimeoutHandle) return; } @@ -664,8 +664,8 @@ } catch (err) { TS.projects.superalgos.globals.loggerVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).BOT_MAIN_LOOP_LOGGER_MODULE_OBJECT.write(MODULE_NAME, "[ERROR] run -> loop -> shallWeStop -> err = " + err.stack); - TS.projects.superalgos.globals.taskVariables.FATAL_ERROR_MESSAGE = err.message - processStopped() + TS.projects.superalgos.globals.processVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).UNEXPECTED_ERROR = err + TS.projects.superalgos.functionLibraries.processFunctions.stopProcess(processIndex, callBackFunction, nextLoopTimeoutHandle) return } } @@ -673,38 +673,12 @@ } catch (err) { TS.projects.superalgos.globals.loggerVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).PROCESS_INSTANCE_LOGGER_MODULE_OBJECT.write(MODULE_NAME, "[ERROR] run -> loop -> err = " + err.stack); - TS.projects.superalgos.globals.taskVariables.FATAL_ERROR_MESSAGE = err.message - processStopped() + TS.projects.superalgos.globals.processVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).UNEXPECTED_ERROR = err + TS.projects.superalgos.functionLibraries.processFunctions.stopProcess(processIndex, callBackFunction, nextLoopTimeoutHandle) return } } - function processStopped() { - if (TS.projects.superalgos.globals.taskVariables.FATAL_ERROR_MESSAGE !== undefined) { - TS.projects.superalgos.functionLibraries.processFunctions.processError - ( - TS.projects.superalgos.globals.processVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).PROCESS_KEY, - undefined, - "An unexpected error caused the Process to stop.", - { - project: 'Superalgos', - category: 'Topic', - type: 'TS Process Error - Unexpected Error' - } - ) - } else { - TS.projects.superalgos.globals.taskConstants.EVENT_SERVER_CLIENT_MODULE_OBJECT.raiseEvent(TS.projects.superalgos.globals.processVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).PROCESS_KEY, 'Stopped') - } - sessionStopped() - TS.projects.superalgos.globals.loggerVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).BOT_MAIN_LOOP_LOGGER_MODULE_OBJECT.persist(); - clearTimeout(nextLoopTimeoutHandle); - if (TS.projects.superalgos.globals.taskVariables.FATAL_ERROR_MESSAGE !== undefined) { - callBackFunction(TS.projects.superalgos.globals.standardResponses.DEFAULT_FAIL_RESPONSE) - } else { - callBackFunction(TS.projects.superalgos.globals.standardResponses.DEFAULT_OK_RESPONSE) - } - } - function sessionStopped() { if (TS.projects.superalgos.globals.processVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).SESSION_STATUS === 'Running') { TS.projects.superalgos.globals.taskConstants.EVENT_SERVER_CLIENT_MODULE_OBJECT.raiseEvent(TS.projects.superalgos.globals.processVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).SESSION_KEY, 'Stopped') diff --git a/Projects/Superalgos/TS/Function-Libraries/ProcessFunctions.js b/Projects/Superalgos/TS/Function-Libraries/ProcessFunctions.js index 3c0547589..80e93d9e1 100644 --- a/Projects/Superalgos/TS/Function-Libraries/ProcessFunctions.js +++ b/Projects/Superalgos/TS/Function-Libraries/ProcessFunctions.js @@ -1,14 +1,81 @@ exports.newSuperalgosFunctionLibrariesProcessFunctions = function () { let thisObject = { - processHeartBeat: processHeartBeat, + processHeartBeat: processHeartBeat, processError: processError, processWarning: processWarning, - processInfo: processInfo + processInfo: processInfo, + stopProcess: stopProcess } return thisObject + function stopProcess(processIndex, callBackFunction, nextLoopTimeoutHandle) { + + /* Make sure that the logger associated to this process saves its cache */ + TS.projects.superalgos.globals.loggerVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).BOT_MAIN_LOOP_LOGGER_MODULE_OBJECT.persist() + + /* Cancell this process timouput */ + clearTimeout(nextLoopTimeoutHandle) + + let error = TS.projects.superalgos.globals.processVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).UNEXPECTED_ERROR + + if (error !== undefined) { + /* + If the process is finishing with an error, we report it to the UI + and return to the process caller with a FAIL. + */ + let docs = { + project: 'Superalgos', + category: 'Topic', + type: 'TS Process Error - Unexpected Error', + placeholder: {} + } + + if (error.message !== undefined) { + docs.placeholder.errorMessage = { + style: 'Error', + text: error.message + } + } + if (error.stack !== undefined) { + docs.placeholder.errorStack = { + style: 'Javascript', + text: error.stack + } + } + if (error.code !== undefined) { + docs.placeholder.errorCode = { + style: 'Json', + text: error.code + } + } + docs.placeholder.errorDetails = { + style: 'Json', + text: JSON.stringify(error, undefined, 4) + } + + TS.projects.superalgos.functionLibraries.processFunctions.processError + ( + TS.projects.superalgos.globals.processVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).PROCESS_KEY, + undefined, + "An unexpected error caused the Process to stop.", + docs + ) + + callBackFunction(TS.projects.superalgos.globals.standardResponses.DEFAULT_FAIL_RESPONSE) + } else { + /* + If the process did not finish with an error, we report to the UI that it stopped + and return to the caller with OK. + */ + TS.projects.superalgos.globals.taskConstants.EVENT_SERVER_CLIENT_MODULE_OBJECT.raiseEvent( + TS.projects.superalgos.globals.processVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).PROCESS_KEY, 'Stopped') + + callBackFunction(TS.projects.superalgos.globals.standardResponses.DEFAULT_OK_RESPONSE) + } + } + function processHeartBeat(processIndex, processingDate, percentage, status) { let event = { seconds: (new Date()).getSeconds(), @@ -19,7 +86,7 @@ exports.newSuperalgosFunctionLibrariesProcessFunctions = function () { TS.projects.superalgos.globals.taskConstants.EVENT_SERVER_CLIENT_MODULE_OBJECT.raiseEvent(TS.projects.superalgos.globals.processVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).PROCESS_KEY, 'Heartbeat', event) } - function processError (processKey, node, errorMessage, docs) { + function processError(processKey, node, errorMessage, docs) { let event if (node !== undefined) { event = { @@ -38,7 +105,7 @@ exports.newSuperalgosFunctionLibrariesProcessFunctions = function () { TS.projects.superalgos.globals.taskConstants.EVENT_SERVER_CLIENT_MODULE_OBJECT.raiseEvent(processKey, 'Error', event) } - function processWarning (processKey, node, warningMessage, docs) { + function processWarning(processKey, node, warningMessage, docs) { let event if (node !== undefined) { event = { @@ -57,7 +124,7 @@ exports.newSuperalgosFunctionLibrariesProcessFunctions = function () { TS.projects.superalgos.globals.taskConstants.EVENT_SERVER_CLIENT_MODULE_OBJECT.raiseEvent(processKey, 'Warning', event) } - function processInfo (processKey, node, infoMessage, docs) { + function processInfo(processKey, node, infoMessage, docs) { let event if (node !== undefined) { event = { diff --git a/Projects/Superalgos/TS/Globals/ProcessVariables.js b/Projects/Superalgos/TS/Globals/ProcessVariables.js index f58dba5ba..2438cc927 100644 --- a/Projects/Superalgos/TS/Globals/ProcessVariables.js +++ b/Projects/Superalgos/TS/Globals/ProcessVariables.js @@ -31,6 +31,8 @@ exports.newSuperalgosGlobalsProcessVariables = function () { TRADING_PROCESSING_DAILY_FILES When in a trading process, this tell us if we are processing Daily Files or not. FILE_PATH_ROOT Stores the prefix of the path of any data or log file. WAIT_FOR_EXECUTION_FINISHED_EVENT This boolean flag tell us if the process waits for an event to continue. + UNEXPECTED_ERROR: When we encounter an error that will produce the Process to be stopped, we store the err object here so that is properties can be extracted for logging purposes. + */ return thisObject } \ No newline at end of file diff --git a/Projects/Superalgos/TS/Globals/TaskVariables.js b/Projects/Superalgos/TS/Globals/TaskVariables.js index caf9039d5..829434a11 100644 --- a/Projects/Superalgos/TS/Globals/TaskVariables.js +++ b/Projects/Superalgos/TS/Globals/TaskVariables.js @@ -8,7 +8,7 @@ exports.newSuperalgosGlobalsTaskVariables = function () { LOGGER_MAP: new Map(), // We will put all the loggers in a map, so that we can eventually finalize them. SESSION_MAP: new Map(), // We will put all the sessions in a map, so that we can eventually finalize them. FATAL_ERROR_MESSAGE: undefined, - UNEXPECTED_ERROR: undefined, // This is where we store the latest unexpected task error. + UNEXPECTED_ERROR: undefined, // When we encounter an error that will produce the Task to be stopped, we store the err object here so that is properties can be extracted for logging purposes. } return thisObject From 9f42d6bc1162f9d51b12266d834ab6c7bec35cc9 Mon Sep 17 00:00:00 2001 From: Luis Fernando Molina Date: Fri, 22 Jan 2021 10:50:10 +0100 Subject: [PATCH 13/16] Function not used --- .../TS/Bot-Modules/Trading-Bot/SingleMarketTradingBot.js | 7 ------- 1 file changed, 7 deletions(-) diff --git a/Projects/Superalgos/TS/Bot-Modules/Trading-Bot/SingleMarketTradingBot.js b/Projects/Superalgos/TS/Bot-Modules/Trading-Bot/SingleMarketTradingBot.js index cefebca19..4118a8170 100644 --- a/Projects/Superalgos/TS/Bot-Modules/Trading-Bot/SingleMarketTradingBot.js +++ b/Projects/Superalgos/TS/Bot-Modules/Trading-Bot/SingleMarketTradingBot.js @@ -679,13 +679,6 @@ } } - function sessionStopped() { - if (TS.projects.superalgos.globals.processVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).SESSION_STATUS === 'Running') { - TS.projects.superalgos.globals.taskConstants.EVENT_SERVER_CLIENT_MODULE_OBJECT.raiseEvent(TS.projects.superalgos.globals.processVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).SESSION_KEY, 'Stopped') - TS.projects.superalgos.globals.processVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).SESSION_STATUS = 'Stopped' - } - } - } catch (err) { TS.projects.superalgos.globals.taskVariables.UNEXPECTED_ERROR = err From 31bb098ff66c5ee042cb41e6bb790469fbcda744 Mon Sep 17 00:00:00 2001 From: Luis Fernando Molina Date: Fri, 22 Jan 2021 11:53:57 +0100 Subject: [PATCH 14/16] Bug Fixed on repositioning at chart in charting space while zoomed if --- .../Superalgos/UI/Spaces/Tutorial-Space/TutorialSpace.js | 8 +++++--- 1 file changed, 5 insertions(+), 3 deletions(-) diff --git a/Projects/Superalgos/UI/Spaces/Tutorial-Space/TutorialSpace.js b/Projects/Superalgos/UI/Spaces/Tutorial-Space/TutorialSpace.js index 4fa6497b2..df45fc80d 100644 --- a/Projects/Superalgos/UI/Spaces/Tutorial-Space/TutorialSpace.js +++ b/Projects/Superalgos/UI/Spaces/Tutorial-Space/TutorialSpace.js @@ -341,7 +341,7 @@ function newSuperalgosTutorialSpace() { return } sliderCounter++ - if (sliderCounter === 10 || sliderCounter === 100) { + if (sliderCounter === 1 || sliderCounter === 100) { switch (config.slider) { case "toTop": { @@ -579,11 +579,13 @@ function newSuperalgosTutorialSpace() { if (timeMachine !== undefined) { repositionAtTimeMachineCounter++ switch (true) { - case (repositionAtTimeMachineCounter > 0 && repositionAtTimeMachineCounter < 20): { + case (repositionAtTimeMachineCounter > 1 && repositionAtTimeMachineCounter < 20): { let event = { delta: -1 } - UI.projects.superalgos.spaces.chartingSpace.viewport.onMouseWheel(event) + for (let i = 0; i < 100; i++) { + UI.projects.superalgos.spaces.chartingSpace.viewport.onMouseWheel(event) + } break } case (repositionAtTimeMachineCounter === 30): { From d11f08ea334c4a189fd267413a0ca1070bb104ce Mon Sep 17 00:00:00 2001 From: Julian Molina Date: Fri, 22 Jan 2021 12:21:02 +0100 Subject: [PATCH 15/16] This is my contribution to Superalgos --- ...uperalgos-019-tutorial-step-warp-speed-zooming.json | 10 ++++++---- 1 file changed, 6 insertions(+), 4 deletions(-) diff --git a/Projects/Superalgos/Schemas/Docs-Tutorials/welcome-to-superalgos-019-tutorial-step-warp-speed-zooming.json b/Projects/Superalgos/Schemas/Docs-Tutorials/welcome-to-superalgos-019-tutorial-step-warp-speed-zooming.json index 4a51a07f8..d3c802c5e 100644 --- a/Projects/Superalgos/Schemas/Docs-Tutorials/welcome-to-superalgos-019-tutorial-step-warp-speed-zooming.json +++ b/Projects/Superalgos/Schemas/Docs-Tutorials/welcome-to-superalgos-019-tutorial-step-warp-speed-zooming.json @@ -12,12 +12,13 @@ "paragraphs": [ { "style": "Text", - "text": "Sometimes you may wish to visualize larger sections of hierarchies than your screen allows." + "text": "Sometimes you may wish to visualize larger sections of the Design Space than your screen allows.", + "updated": 1611314074367 }, { "style": "Callout", - "text": "Hit Ctrl and scroll the mouse wheel!", - "updated": 1611076507997 + "text": "Hit Ctrl and scroll the mouse wheel on Windows or ⌘ and - or + in Mac.", + "updated": 1611314352825 }, { "style": "Text", @@ -25,7 +26,8 @@ }, { "style": "Success", - "text": "Chrome indicates the level of zoom on the top-right corner. When zooming in or out, the design space gets centered on the screen. After applying the desired level of zoom, use the design space map to go back where you were." + "text": "Chrome indicates the level of zoom on the top-right corner. When zooming in or out, the design space gets centered on the screen. Use the design space map to go back where you were.", + "updated": 1611314381796 } ] } \ No newline at end of file From d4a811a4491c5a4105e87b5b9d556c4549f4751a Mon Sep 17 00:00:00 2001 From: Luis Fernando Molina Date: Fri, 22 Jan 2021 12:28:47 +0100 Subject: [PATCH 16/16] Bug Fixed, Workspace tab not showing anything --- Client/WebServer/css/docs.css | 9 ++------- 1 file changed, 2 insertions(+), 7 deletions(-) diff --git a/Client/WebServer/css/docs.css b/Client/WebServer/css/docs.css index 3c378553e..15dedac71 100644 --- a/Client/WebServer/css/docs.css +++ b/Client/WebServer/css/docs.css @@ -62,11 +62,6 @@ margin-bottom: 0px; margin-top: 0px; border: 0px solid #cdcdcd; padding: 5px; - -/* DELETE candidate -margin: auto; -margin-right: 20px; -*/ } .docs-table-cell{ @@ -817,7 +812,6 @@ padding-left: 180px; margin-top: 20px; } - .docs-search-results-header-tabs-container > input { display: none; } @@ -858,7 +852,8 @@ display: none; #tab4:checked ~ .docs-search-result-content #content4, #tab5:checked ~ .docs-search-result-content #content5, #tab6:checked ~ .docs-search-result-content #content6, -#tab7:checked ~ .docs-search-result-content #content7 { +#tab7:checked ~ .docs-search-result-content #content7, +#tab8:checked ~ .docs-search-result-content #content8 { display: block; }