frodovdr/node-red
1
0
Fork 0
mirror of https://github.com/node-red/node-red.git synced 2023-10-10 13:36:53 +02:00
Code Issues Releases Wiki Activity

Let Twitter node save place as a location property rather than text.

Browse Source
This commit is contained in:
Dave C-J 2014-11-14 23:42:35 +00:00
parent 9863b6e178
commit 7b14e753cd
1 changed files with 27 additions and 22 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

37
nodes/core/social/27-twitter.js
View File

@ -40,21 +40,19 @@ module.exports = function(RED) {
if(msg.tweet) { if(msg.tweet) {
if(msg.tweet.geo) { // if geo is set, always set location from geo if(msg.tweet.geo) { // if geo is set, always set location from geo
if(msg.tweet.geo.coordinates && msg.tweet.geo.coordinates.length === 2) { if(msg.tweet.geo.coordinates && msg.tweet.geo.coordinates.length === 2) {
if(!msg.location) { if (!msg.location) { msg.location = {}; }
msg.location = {};
}
// coordinates[0] is lat, coordinates[1] is lon // coordinates[0] is lat, coordinates[1] is lon
msg.location.lat = msg.tweet.geo.coordinates[0]; msg.location.lat = msg.tweet.geo.coordinates[0];
msg.location.lon = msg.tweet.geo.coordinates[1]; msg.location.lon = msg.tweet.geo.coordinates[1];
msg.location.icon = "twitter";
} }
} else if(msg.tweet.coordinates) { // otherwise attempt go get it from coordinates } else if(msg.tweet.coordinates) { // otherwise attempt go get it from coordinates
if(msg.tweet.coordinates.coordinates && msg.tweet.coordinates.coordinates.length === 2) { if(msg.tweet.coordinates.coordinates && msg.tweet.coordinates.coordinates.length === 2) {
if(!msg.location) { if (!msg.location) { msg.location = {}; }
msg.location = {};
}
// WARNING! coordinates[1] is lat, coordinates[0] is lon!!! // WARNING! coordinates[1] is lat, coordinates[0] is lon!!!
msg.location.lat = msg.tweet.coordinates.coordinates[1]; msg.location.lat = msg.tweet.coordinates.coordinates[1];
msg.location.lon = msg.tweet.coordinates.coordinates[0]; msg.location.lon = msg.tweet.coordinates.coordinates[0];
msg.location.icon = "twitter";
} }
} // if none of these found then just do nothing } // if none of these found then just do nothing
} // if no msg.tweet then just do nothing } // if no msg.tweet then just do nothing
@ -79,7 +77,6 @@ module.exports = function(RED) {
access_token_secret: credentials.access_token_secret access_token_secret: credentials.access_token_secret
}); });
//setInterval(function() { //setInterval(function() {
// twit.get("/application/rate_limit_status.json",null,function(err,cb) { // twit.get("/application/rate_limit_status.json",null,function(err,cb) {
// console.log("direct_messages:",cb["resources"]["direct_messages"]); // console.log("direct_messages:",cb["resources"]["direct_messages"]);
@ -119,11 +116,13 @@ module.exports = function(RED) {
if (cb) { if (cb) {
for (var t=cb.length-1;t>=0;t-=1) { for (var t=cb.length-1;t>=0;t-=1) {
var tweet = cb[t]; var tweet = cb[t];
var where = tweet.user.location||""; var where = tweet.user.location;
var la = tweet.lang || tweet.user.lang; 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, lang:la, tweet:tweet };
var msg = { topic:node.topic+"/"+tweet.user.screen_name, payload:tweet.text, location:where, lang:la, tweet:tweet }; if (where) {
msg.location = {place:where};
addLocationToTweet(msg); addLocationToTweet(msg);
}
node.send(msg); node.send(msg);
if (t == 0) { if (t == 0) {
node.since_ids[u] = tweet.id_str; node.since_ids[u] = tweet.id_str;
@ -163,8 +162,13 @@ module.exports = function(RED) {
if (cb) { if (cb) {
for (var t=cb.length-1;t>=0;t-=1) { for (var t=cb.length-1;t>=0;t-=1) {
var tweet = cb[t]; var tweet = cb[t];
var msg = { topic:node.topic+"/"+tweet.sender.screen_name, payload:tweet.text, tweet:tweet }; var where = tweet.sender.location;
var la = tweet.lang || tweet.sender.lang;
var msg = { topic:node.topic+"/"+tweet.sender.screen_name, payload:tweet.text, lang:la, tweet:tweet };
if (where) {
msg.location = {place:where};
addLocationToTweet(msg); addLocationToTweet(msg);
}
node.send(msg); node.send(msg);
if (t == 0) { if (t == 0) {
node.since_id = tweet.id_str; node.since_id = tweet.id_str;
@ -184,7 +188,7 @@ module.exports = function(RED) {
if (this.user === "true") { thing = 'user'; } if (this.user === "true") { thing = 'user'; }
var st = { track: [node.tags] }; var st = { track: [node.tags] };
var bits = node.tags.split(","); var bits = node.tags.split(",");
if ((bits.length > 0) && (bits.length % 4 == 0)) { if (bits.length == 4) {
if ((Number(bits[0]) < Number(bits[2])) && (Number(bits[1]) < Number(bits[3]))) { if ((Number(bits[0]) < Number(bits[2])) && (Number(bits[1]) < Number(bits[3]))) {
st = { locations: node.tags }; st = { locations: node.tags };
} }
@ -202,13 +206,14 @@ module.exports = function(RED) {
//twit.stream('statuses/filter', { track: [node.tags] }, function(stream) { //twit.stream('statuses/filter', { track: [node.tags] }, function(stream) {
node.stream = stream; node.stream = stream;
stream.on('data', function(tweet) { stream.on('data', function(tweet) {
//console.log(tweet.user);
if (tweet.user !== undefined) { if (tweet.user !== undefined) {
var where = tweet.user.location||""; var where = tweet.user.location;
var la = tweet.lang || tweet.user.lang; 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, lang:la, tweet:tweet };
var msg = { topic:node.topic+"/"+tweet.user.screen_name, payload:tweet.text, location:where, lang:la, tweet:tweet }; if (where) {
msg.location = {place:where};
addLocationToTweet(msg); addLocationToTweet(msg);
}
node.send(msg); node.send(msg);
} }
}); });