@@ -2,13 +2,13 @@ NabazTwit is a script which try to provide a better way to combine twitter and t h1. Why? -The Violet twitter modules takes all your friends twits, and send them in TTS (Text to speech) to your Nabaztag. +The Violet twitter modules takes all your friends twits and send them in TTS (Text to speech) to your Nabaztag. It can be really too much noise as you can have a lot of friends, and also, the nabaztag is not good at reading urls or smileys h1. What do this script do? -This script can read only the replies made to you (i.e. with a @your_nickname in the text) +This script can read only the replies made to you (i.e. with a @your_nickname in the text) and private message received Before sending thoses twits to your nabaztag, the script remove all smileys and urls. And the script also check if your nabaztag is awake (otherwise it don't send message to prevent mailbox overload) At the end you receive less noise and more undestandable TTS messages @@ -37,6 +37,10 @@ You can activate debug mode, by changing $debug to true near the top of the scri Feel free to enhance, adapt, evolve it for your own needs. +REMARK: + +This script consume 2 API request per run (1 to retrieve your replies and 1 to retrieve your direct messages) + h1. known issues README.textile @@ -6,7 +6,7 @@ Retrieve your twitter replies of friends timeline and process it to be more "Nabaztag" compatible, by removing some stuff that the rabbit can't read properly -Version:0.1 +Version:0.2 Author: Olivier Ruffin (http://www.veilleperso.com) Remarks: @@ -25,12 +25,15 @@ header('Content-type: text/xml; charset=UTF-8'); $params = @parse_ini_file("config.ini", TRUE); if (empty($params)) die("Unable to find conf.ini file\n"); -$twitter_url = "http://".$params["twitter"]["login"].":".$params["twitter"]["password"]."@twitter.com/statuses/".$params["twitter"]["check"].".xml?count=10"; +$status_url = "http://".$params["twitter"]["login"].":".$params["twitter"]["password"] ."@twitter.com/statuses/".$params["twitter"]["check"].".xml"; +$private_url = "http://".$params["twitter"]["login"].":".$params["twitter"]["password"] ."@twitter.com/direct_messages.xml"; + + $api_url = "http://api.nabaztag.com/vl/FR/api.jsp?sn=".$params["violet"]["sn"]."&token=".$params["violet"]["token"]; if (empty($params["twitter"]["cache"])) $localfile = "/tmp/last_read.twitter"; else $localfile = $params["twitter"]["cache"]; -$debug = false; +$debug = true; $sleep = 10; //time to sleep beetween 2 messages to make sure each message is delivered //$debug_with = "/tmp/twitter.debug"; // a twitter XML file to allow local debug @@ -44,6 +47,7 @@ function debug_log($msg) { // EMOTICONS $smileys = array( ':-)', +'xD', ':)', ':-D', ':D', // very happy @@ -127,7 +131,11 @@ $smileys = array( $translate = array( 'lol' => 'ha ha ha ha', 'ptdr' => 'ha ha ha ha', - 'pr' => 'pour' + 'pr' => 'pour', + 'rt' => 'retwit', + 'tx' => 'merci', + 'thx' => 'merci', + 'slt' => 'salut' ); // ------------------------------------------------------------------- @@ -144,32 +152,67 @@ function delete_emoticons($txt) { $short_smiley = str_replace(":-", ";", $smiley); if ($short_smiley != $smiley) $txt = str_replace($short_smiley, "", $txt); } + + $txt = "$txt "; foreach ($translate as $key => $value) { - $txt = str_replace(" $key ", $value, $txt); + $txt = preg_replace("| $key |is", " $value ", $txt); } - return $txt; + return trim($txt); } // ------------------------------------------------------------------- -// Process message and send new messages to nabztag +// What is the last twit id retrieved? +// ------------------------------------------------------------------- +function previous_id($type) { + return (int) @file_get_contents(cache_filename($type)); +} + +// ------------------------------------------------------------------- +// What is the file cache ? +// ------------------------------------------------------------------- +function cache_filename($type) { + global $localfile; + return "${localfile}.${type}"; +} + // ------------------------------------------------------------------- -function send_twits_to_nabaztag($str) { - global $api_url, $localfile, $sleep, $params; - $previous_id = (int) @file_get_contents($localfile); +// What is the url to check ? +// ------------------------------------------------------------------- +function url_for($type) { + global $status_url, $private_url; + if ($type == 'status') $url = $status_url; + else $url = $private_url; + $since_id = previous_id($type); + if ($since_id>0) { + if (strpos($url, "?")) $url .= "&since_id=${since_id}"; + else $url .= "?since_id=${since_id}"; + } + return $url; +} +// ------------------------------------------------------------------- +// Process message and send new messages to nabztag +// ------------------------------------------------------------------- +function send_twits_to_nabaztag($str, $type) { + global $api_url, $sleep, $params; + $previous_id = previous_id($type); debug_log("SINCE: $previous_id\n"); debug_log("XML: $str"); $xml = simplexml_load_string($str); $last_id = 0; - foreach ($xml->status as $item) { + if ($type == 'status') $list = $xml->status; + else $list = $xml->direct_message; + + foreach ($list as $item) { if ($item->id > $last_id) $last_id = $item->id; } + // memorise the new last id - save_last_id($last_id); + save_last_id($last_id, $type); $to_send = array(); - foreach ($xml->status as $item) { + foreach ($list as $item) { $id = (int)$item->id; if ($id>$previous_id) { $txt = preg_replace("/http(s)*:\/\/[^\s]+/is", "", html_entity_decode(utf8_decode($item->text), ENT_QUOTES)); @@ -179,7 +222,9 @@ function send_twits_to_nabaztag($str) { $txt = trim(preg_replace("/([\s\_\/-]+)/is", " ", $txt)); if ($txt != "") { - $from = preg_replace("/([\s\_-]+)/is", " ", $item->user->name); + if ($type == 'status') $from = $item->user->name; + else $from = $item->sender->name; + $from = preg_replace("/([\s\_-]+)/is", " ", $from); $txt = $params["violet"]["from"]." $from , ".utf8_encode($txt); $to_send["$id"] = $txt; } @@ -187,9 +232,8 @@ function send_twits_to_nabaztag($str) { else { debug_log("Skipping $id - Already sent"); } - } - + if (sizeof($to_send)>0) { ksort($to_send, SORT_NUMERIC); foreach ($to_send as $id => $txt) { @@ -199,6 +243,7 @@ function send_twits_to_nabaztag($str) { sleep($sleep); // prevent spam-like attitude ! } } + return ""; } @@ -206,10 +251,10 @@ function send_twits_to_nabaztag($str) { // get the lasts message from twitter friends timeline // ------------------------------------------------------------------- -function fetch_xml(){ - global $twitter_url, $localfile, $debug_with; - if ($debug_with) $twitter_url = $debug_with; - $content = @file_get_contents($twitter_url); +function fetch_xml($url){ + global $debug_with; + if ($debug_with) $url = $debug_with; + $content = @file_get_contents($url); return $content; } @@ -228,27 +273,38 @@ function is_sleeping() { // ------------------------------------------------------------------- // memorise the id of the last message read // ------------------------------------------------------------------- -function save_last_id($last_id) { - global $localfile; - debug_log("SAVE LAST ID : $last_id"); - $fp=fopen($localfile, "w"); - fwrite($fp, $last_id); //write contents of feed to cache file - fclose($fp); +function save_last_id($last_id, $type) { + if ((int)$last_id>0) { + debug_log("SAVE LAST ID : $last_id"); + $fp = fopen(cache_filename($type), "w"); + fwrite($fp, $last_id); //write contents of feed to cache file + fclose($fp); + } } // ------------------------------------------------------------------- -// process new twits +// memorise the id of the last message read // ------------------------------------------------------------------- -function process_incoming_twits(){ - global $localfile; - if (!file_exists($localfile)) { // if cache file doesn't exist - touch($localfile); //create it - chmod($localfile, 0666); +function process_incoming_twits_for($type) { + $file = cache_filename($type); + if (!file_exists($file)) { // if cache file doesn't exist + touch($file); //create it + chmod($file, 0666); } - $xml = fetch_xml(); //then populate cache file with contents of RSS feed - if ($xml != "") send_twits_to_nabaztag($xml); + $url = url_for($type); + debug_log("URL: ${url}"); + $xml = fetch_xml($url); //then populate cache file with contents of RSS feed + if ($xml != "") send_twits_to_nabaztag($xml, $type); else debug_log("EMPTY XML!"); + +} +// ------------------------------------------------------------------- +// process new twits +// ------------------------------------------------------------------- +function process_incoming_twits(){ + process_incoming_twits_for('status'); + process_incoming_twits_for('private'); } if (!is_sleeping()) process_incoming_twits(); nabaztag.php 1b34de58f0d04cca2ce0bf71484f18ab47789b87 Olivier Ruffin olivier@veilleperso.com http://github.com/veilleperso/nabaztwit/commit/e344a312c7398a153a30518e83fecb0a55c0c45b e344a312c7398a153a30518e83fecb0a55c0c45b 2009-03-05T06:55:01-08:00 2009-03-05T06:55:01-08:00 The script now retrieve public twits but also direct messages in TTS fbffaf046f88f888bd04d7ba8c6a3eb145942164 Olivier Ruffin olivier@veilleperso.com