node-red/nodes/social/27-twitter.js

/**
 * Copyright 2013 IBM Corp.
 *
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 * http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 **/

var RED = require("../../red/red");
var ntwitter = require('ntwitter');
var OAuth= require('oauth').OAuth;

function TwitterNode(n) {
    RED.nodes.createNode(this,n);
    this.screen_name = n.screen_name;
}
RED.nodes.registerType("twitter-credentials",TwitterNode);

function TwitterInNode(n) {
    RED.nodes.createNode(this,n);
    this.active = true;
    this.user = n.user;
    this.tags = n.tags.replace(/ /g,'');
    this.twitter = n.twitter;
    this.topic = n.topic;
    this.twitterConfig = RED.nodes.getNode(this.twitter);
    var credentials = RED.nodes.getCredentials(this.twitter);

    if (credentials && credentials.screen_name == this.twitterConfig.screen_name) {
        var twit = new ntwitter({
                consumer_key: "OKjYEd1ef2bfFolV25G5nQ",
                consumer_secret: "meRsltCktVMUI8gmggpXett7WBLd1k0qidYazoML6g",
                access_token_key: credentials.access_token,
                access_token_secret: credentials.access_token_secret
        });

        var node = this;
        if (this.tags !== "") {
            try {
                var thing = 'statuses/filter';
                if (this.user == "true") { thing = 'user'; }
                function setupStream() {
                    if (node.active) {
                        twit.stream(thing, { track: [node.tags] }, function(stream) {
                                //twit.stream('user', { track: [node.tags] }, function(stream) {
                                //twit.stream('site', { track: [node.tags] }, function(stream) {
                                //twit.stream('statuses/filter', { track: [node.tags] }, function(stream) {
                                node.stream = stream;
                                stream.on('data', function(tweet) {
                                        //console.log(tweet.user);
                                        if (tweet.user !== undefined) {
                                            var where = tweet.user.location||"";
                                            var la = tweet.lang || tweet.user.lang;
                                            //console.log(tweet.user.location,"=>",tweet.user.screen_name,"=>",pay);
                                            var msg = { topic:node.topic+"/"+tweet.user.screen_name, payload:tweet.text, location:where, lang:la, tweet:tweet };
                                            node.send(msg);
                                        }
                                });
                                stream.on('error', function(tweet) {
                                        node.warn(tweet);
                                        setTimeout(setupStream,5000);
                                });
                                stream.on('destroy', function (response) {
                                        if (this.active) {
                                            node.warn("twitter ended unexpectedly");
                                            setTimeout(setupStream,5000);
                                        }
                                });
                        });
                    }
                }
                setupStream();
            }
            catch (err) {
                node.error(err);
            }
        } else {
            this.error("Invalid tag property");
        }


    } else {
        this.error("missing twitter credentials");
    }
}

RED.nodes.registerType("twitter in",TwitterInNode);

TwitterInNode.prototype.close = function() {
    if (this.stream) {
        this.active = false;
		this.stream.destroy();
	}
}

function TwitterOutNode(n) {
	RED.nodes.createNode(this,n);
	this.topic = n.topic;
	this.twitter = n.twitter;
	this.twitterConfig = RED.nodes.getNode(this.twitter);
    var credentials = RED.nodes.getCredentials(this.twitter);
    var node = this;

    if (credentials && credentials.screen_name == this.twitterConfig.screen_name) {
        var twit = new ntwitter({
                consumer_key: "OKjYEd1ef2bfFolV25G5nQ",
                consumer_secret: "meRsltCktVMUI8gmggpXett7WBLd1k0qidYazoML6g",
                access_token_key: credentials.access_token,
                access_token_secret: credentials.access_token_secret
        }).verifyCredentials(function (err, data) {
                if (err) {
                    node.error("Error verifying credentials: " + err);
                } else {
                    node.on("input", function(msg) {
                            if (msg != null) {
                                if (msg.payload.length > 140) {
                                    msg.payload = msg.payload.slice(0,139);
                                    node.warn("Tweet greater than 140 : truncated");
                                }
                                twit.updateStatus(msg.payload, function (err, data) {
                                        if (err) node.error(err);
                                });
                            }
                    });
                }
        });
    }
}

RED.nodes.registerType("twitter out",TwitterOutNode);



var oa = new OAuth(
	"https://api.twitter.com/oauth/request_token",
	"https://api.twitter.com/oauth/access_token",
	"OKjYEd1ef2bfFolV25G5nQ",
	"meRsltCktVMUI8gmggpXett7WBLd1k0qidYazoML6g",
	"1.0",
	null,
	"HMAC-SHA1"
);

var credentials = {};

RED.app.get('/twitter/:id', function(req,res) {
        var credentials = RED.nodes.getCredentials(req.params.id);
        if (credentials) {
            res.send(JSON.stringify({sn:credentials.screen_name}));
        } else {
            res.send(JSON.stringify({}));
        }
});

RED.app.delete('/twitter/:id', function(req,res) {
        RED.nodes.deleteCredentials(req.params.id);
        res.send(200);
});

RED.app.get('/twitter/:id/auth', function(req, res){
        var credentials = {};
        oa.getOAuthRequestToken({
                oauth_callback: req.query.callback
        },function(error, oauth_token, oauth_token_secret, results){
            if (error) {
                console.log(error);
                res.send("yeah no. didn't work.")
            }
            else {
                credentials.oauth_token = oauth_token;
                credentials.oauth_token_secret = oauth_token_secret;
                res.redirect('https://twitter.com/oauth/authorize?oauth_token='+oauth_token)
                RED.nodes.addCredentials(req.params.id,credentials);
            }
        });
});

RED.app.get('/twitter/:id/auth/callback', function(req, res, next){

        var credentials = RED.nodes.getCredentials(req.params.id);
		credentials.oauth_verifier = req.query.oauth_verifier;

		oa.getOAuthAccessToken(
		    credentials.oauth_token,
		    credentials.token_secret,
		    credentials.oauth_verifier,
            function(error, oauth_access_token, oauth_access_token_secret, results){
                if (error){
                    console.log(error);
                    res.send("yeah something broke.");
                } else {
                    credentials = {};
                    credentials.access_token = oauth_access_token;
                    credentials.access_token_secret = oauth_access_token_secret;
                    credentials.screen_name = "@"+results.screen_name;
                    RED.nodes.addCredentials(req.params.id,credentials);
                    res.send("<html><head></head><body>Authorised - you can close this window and return to Node-RED</body></html>");
                }
            }
		);
});