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

Merge pull request #2099 from Luis-Fernando-Molina/develop

Browse Source 
Contribution: Twitter Bot Moved
This commit is contained in:
Luis Fernando Molina authored and GitHub committed 2021-10-10 06:44:40 -04:00
2 parents 956460df10 7d9971a1a6
commit 5380122b7f
1 file changed
-97
Download Patch File Download Diff File Expand all files Collapse all files
Projects/Foundations/TS/Bot-Modules/Trading-Bot/Announcements/TwitterBot.js
-97
View File
@@ -1,97 +0,0 @@
exports.newFoundationsBotModulesTwitterBot = function (processIndex) {
const MODULE_NAME = 'Twitter Bot'
let thisObject = {
taskParameters: undefined,
format: undefined,
twitterclient: undefined,
sendMessage: sendMessage,
initialize: initialize,
finalize: finalize
}
return thisObject
function initialize(config) {
/* Twitter Bot Initialization */
var Twitter = SA.nodeModules.twitter
let consumer_key = config.consumer_key
let consumer_secret = config.consumer_secret
let access_token_key = config.access_token_key
let access_token_secret = config.access_token_secret
if (process.env.TWITTER_CONSUMER_KEY) {
consumer_key = process.env.TWITTER_CONSUMER_KEY
}
if (process.env.TWITTER_CONSUMER_SECRET) {
consumer_secret = process.env.TWITTER_CONSUMER_SECRET
}
if (process.env.TWITTER_ACCESS_TOKEN_KEY) {
access_token_key = process.env.TWITTER_ACCESS_TOKEN_KEY
}
if (process.env.TWITTER_ACCESS_TOKEN_SECRET) {
access_token_secret = process.env.TWITTER_ACCESS_TOKEN_SECRET
}
var twitterclient = new Twitter({
consumer_key: consumer_key,
consumer_secret: consumer_secret,
access_token_key: access_token_key,
access_token_secret: access_token_secret
});
thisObject.twitterclient = twitterclient
try {
thisObject.taskParameters = {
exchange: TS.projects.foundations.globals.taskConstants.TASK_NODE.parentNode.parentNode.parentNode.referenceParent.parentNode.parentNode.name,
market: TS.projects.foundations.globals.taskConstants.TASK_NODE.parentNode.parentNode.parentNode.referenceParent.baseAsset.referenceParent.config.codeName +
'/' +
TS.projects.foundations.globals.taskConstants.TASK_NODE.parentNode.parentNode.parentNode.referenceParent.quotedAsset.referenceParent.config.codeName
}
if (config.format === undefined) {
thisObject.format = "%{MESSAGE}"
} else {
thisObject.format = config.format
}
} catch (err) {
logError("initialize -> err = " + err.stack);
}
}
function finalize() {}
function sendMessage(message) {
try {
message = formatMessage(message)
message = JSON.stringify({status: message})
} catch (err) {
logError("announce -> Twitter JSON message error -> err = " + err)
}
thisObject.twitterclient.post('statuses/update', message, function(error, tweet, response) {
if(error) throw error;
console.log(tweet); // Tweet body.
console.log(response); // Raw response object.
});
}
function formatMessage(message) {
formattedMessage = thisObject.format
formattedMessage = formattedMessage.replace('%{EXCHANGE}', thisObject.taskParameters.exchange)
formattedMessage = formattedMessage.replace('%{MARKET}', thisObject.taskParameters.market)
formattedMessage = formattedMessage.replace('%{MESSAGE}', message)
return formattedMessage
}
function logWarn(message) {
TS.projects.foundations.globals.loggerVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).BOT_MAIN_LOOP_LOGGER_MODULE_OBJECT.write(MODULE_NAME, '[WARN] ' + message)
}
function logError(message) {
TS.projects.foundations.globals.loggerVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).BOT_MAIN_LOOP_LOGGER_MODULE_OBJECT.write(MODULE_NAME, '[ERROR] ' + message)
}
}