improved tipbot

This commit is contained in:
Niko Storni 2018-04-13 17:02:41 -04:00
parent b320075799
commit 15d89cb581
No known key found for this signature in database
GPG key ID: F37FE63398800368

View file

@ -1,7 +1,7 @@
var winston = require('winston'), const winston = require('winston'),
fs = require('fs'), fs = require('fs'),
yaml = require('js-yaml'), yaml = require('js-yaml'),
coin = require('node-gameunits'); coind = require('node-gameunits');
const Twitter = require('twitter'); const Twitter = require('twitter');
// check if the config file exists // check if the config file exists
@ -22,7 +22,7 @@ if (settings.log.file) {
} }
// connect to coin json-rpc // connect to coin json-rpc
winston.info('Connecting to coind...'); winston.info('Connecting to coind...');
var coin = coin({ let coin = coind({
host: settings.rpc.host, host: settings.rpc.host,
port: settings.rpc.port, port: settings.rpc.port,
user: settings.rpc.user, user: settings.rpc.user,
@ -105,14 +105,16 @@ String.prototype.expand = function (values) {
}; };
client.stream('statuses/filter', {track: settings.twitter.twitterkeyword}, function (stream) { client.stream('statuses/filter', {track: settings.twitter.twitterkeyword}, function (stream) {
stream.on('error', function (error) { stream.on('error', function (error) {
winston.error('Something went wrong with the twitter streaming api. '); winston.error('Something went wrong with the twitter streaming api.');
winston.error(error);
}); });
stream.on('end', function (reason) { stream.on('end', function (reason) {
winston.error('Twitter streaming api throws end'); winston.error('Twitter streaming api failed with');
winston.error(reason);
}); });
stream.on('data', function (tweet) { stream.on('data', function (tweet) {
console.log('@' + tweet.user.screen_name + '|' + tweet.text); console.log('@' + tweet.user.screen_name + '|' + tweet.text);
if (tweet.text.substring(0, 2) == 'RT') { if (tweet.text.substring(0, 2) === 'RT') {
console.log('Retweet Ingrored'); console.log('Retweet Ingrored');
return; return;
} }