diff --git a/server.js b/server.js index 22b9eb9..92620f0 100644 --- a/server.js +++ b/server.js @@ -15,6 +15,7 @@ const favicon = require('serve-favicon'); const bodyParser = require('body-parser'); const bcrypt = require('bcrypt'); const passport = require('passport'); +const twitter = require('twitter'); const uuidv4 = require('uuid/v4'); const turf = require('@turf/turf'); @@ -33,7 +34,8 @@ app.use(bodyParser.urlencoded({ var app_cfg = require('./server/app_cfg.js'); var sql_cfg = require('./server/sql_cfg')(fs, bcrypt, app_cfg); var sql = require('./server/sql_qry')(sql_cfg, uuidv4, turf, app_cfg); -var waip = require('./server/waip')(io, sql, async, app_cfg); +var tw = require('./server/twitter')(twitter, uuidv4, app_cfg); +var waip = require('./server/waip')(io, sql, tw, async, app_cfg); var socket = require('./server/socket')(io, sql, app_cfg, waip); var udp = require('./server/udp')(app_cfg, waip, sql); var auth = require('./server/auth')(app, app_cfg, sql_cfg, async, bcrypt, passport, io); diff --git a/server/twitter.js b/server/twitter.js new file mode 100755 index 0000000..ec3938a --- /dev/null +++ b/server/twitter.js @@ -0,0 +1,24 @@ +module.exports = function(twitter, uuidv4, app_cfg) { + + function alert_twitter_list(twitter_data, err, callback) { + // tw.tw_screen_name, tw_consumer_key, tw.tw_consumer_secret, tw.tw_access_token_key, tw.tw_access_token_secret, we.uuid, we.einsatzart, wa.name_wache + + var client = new twitter({ + consumer_key: twitter_data.tw_consumer_key, + consumer_secret: twitter_data.tw_consumer_secret, + access_token_key: twitter_data.tw_access_token_key, + access_token_secret: twitter_data.tw_access_token_secret + }); + + var params = {screen_name: 'nodejs', slug: twitter_data.list, count: 50}; + client.get('lists/members', params, function(error, members, response) { + if (!error) { + console.log(members); + }; + }); + }; + + return { + alert_twitter_list: alert_twitter_list + }; +};