r2t.php

<?php

class r2t {
    
    public $debug = true;
    protected $feeds = array();
    /**
    *
    */
    function __construct() {
        $this->init();
    }
    
    protected function init() {
        include_once ("sfYaml/sfYaml.class.php");
        define('R2T_TEMP_DIR', R2T_PROJECT_DIR . "/tmp/");
        if (!file_Exists(R2T_TEMP_DIR)) {
            if (!mkdir(R2T_TEMP_DIR)) {
                die("Could not create " . R2T_TEMP_DIR);
            }
        }
        $yaml = file_get_contents(R2T_PROJECT_DIR . '/conf/defaults.yml');
        $yaml .= file_get_contents(R2T_PROJECT_DIR . '/conf/feeds.yml');
        $f = sfYAML::Load($yaml);
        if ($f['feeds']) {
            $this->feeds = $f['feeds'];
        }
        $this->defaults = $f['defaults'];
    }
    
    public function process() {
        
        foreach ($this->feeds as $feedname => $options) {
            $options = $this->mergeOptionsWithDefaults($options);
            $newentries = $this->getNewEntries($feedname, $options['url']);
            $cnt = 1;
            foreach ($newentries as $guid => $entry) {
                try {
                    $options = $this->twit($entry, $options);
                } catch (Exception $e) {
                    $entries = sfYAML::Load(R2T_TEMP_DIR . "/$feedname");
                    
                    print "Couldn't post " . $entry['title'] . " " . $entry['link'] . " due to " . $e->getMessage() . "\n";
                    unset ($entries[$guid]);
                    unset ($newentries[$guid]);
                    file_put_contents(R2T_TEMP_DIR . "/$feedname", sfYaml::dump($entries));
                    chmod(R2T_TEMP_DIR . "/$feedname",0666);
                    continue;
                }
                $cnt++;
                if ($cnt > $options['maxposts']) {
                    break;
                }
            }
        }
        return $newentries;
    }
    
    protected function mergeOptionsWithDefaults($options) {
        
      
        
        foreach ($this->defaults as $name => $value) {
            if (!isset($options[$name])) {
                $options[$name] = $value;
            }
        }
        return $options;
        
    }
    protected function twit($entry, $options) {
        
        if (isset($options['shortener']) && $options['shortener'] && strlen($entry['link']) > $options['maxurllength']) {
            if (!isset($options['shortenerObject'])) {
                $this->debug("create " . $options['shortener'] . " class");
                include_once ("r2t/shortener/" . $options['shortener'] . ".php");
                $classname = "r2t_shortener_" . $options['shortener'];
                $options['shortenerObject'] = new $classname();
            }
            $this->debug("shorten " . $entry['link'] . " to ");
            $res = $options['shortenerObject']->shorten($entry['link'],$entry['title']);
            if (is_array($res)) {
                $entry['link'] = $res['url'];
                $entry['title'] = $res['text'];
            } else {
                $entry['link'] = $res;
            }
             
            $this->debug("    " . $entry['link']);
        }
        
        // check if something was posted with that link already
        include_once("HTTP/Request.php");
        if (isset($options['twitter']['user'])) {
            $req = new HTTP_Request('http://api.twitter.com/1/statuses/user_timeline.json?screen_name=' . $options['twitter']['user'] );
            if ($req->sendRequest()) {        
                $tweets = json_decode($req->getResponseBody());
                foreach($tweets as $tw) {
                    if (isset($tw->text)) {
                        if (strpos($tw->text,$entry['link']) !== false) {
                            $this->debug("  already tweeted link " . $entry['link']); 
                            return $options; 
                        }
                    } else {
                        continue;
                    }
                }
            }
        }
        
        $msg = $entry['title'];

        if ($options['addAuthor'] ) {
            $msg .= " - " . preg_replace("/[^\s]+@[^\s]+/","",$entry['author']);
        }
        $msg .= " " . $entry['link'];
        $msg = preg_replace("/[\s]{2,}/"," ",$msg);
        if (isset($options['prefix'])) {
            $msg = $options['prefix'] . " " . $msg;
        }
        $msg = trim($msg);
        $this->debug("twit " . $msg);
        /* oauth */
        
        if ($options['twitter']['token'] && class_exists("OAuth")) {
            $req_url = 'http://twitter.com/oauth/request_token';
            $acc_url = 'http://twitter.com/oauth/access_token';
            $authurl = 'http://twitter.com/oauth/authorize';
            $api_url = 'http://twitter.com/statuses/update.json';
            $conskey = 'DyhAb4DLlFmc5Wn29QvL9g';
            $conssec = 'wgaBiC9YJx38sqBLklUqpkWB1Cq1ztAemp5lkfwQ';
            
            $oauth = new OAuth($conskey,$conssec,OAUTH_SIG_METHOD_HMACSHA1,OAUTH_AUTH_TYPE_URI);
            $oauth->debug = 1;
            $oauth->setToken($options['twitter']['token'], $options['twitter']['secret']);
            
            $api_args = array("status" => $msg, "empty_param" => NULL);
            if (isset($entry['lat'])) {
                $api_args['lat'] = $entry['lat'];
                $api_args['long'] = $entry['long'];
            }
            $oauth->fetch($api_url, $api_args, OAUTH_HTTP_METHOD_POST, array("User-Agent" => "pecl/oauth"));
            /* end oauth */
        } else {
            include_once 'Services/Twitter.php';
            $service = new Services_Twitter($options['twitter']['user'], $options['twitter']['pass']);
            $service->statuses->update($msg);
        }
        $this->debug("prowlApiKey: " . (isset($options['prowlApiKey']) ? $options['prowlApiKey'] : 'unset'));
        if (!empty($options['prowlApiKey'])) {
            include_once('ProwlPHP/ProwlPHP.php');
            $prowl = new Prowl($options['prowlApiKey']);
            $prowl->push(array(
            'application'=>'rss2twi.php',
            'event'=>'New Post',
            'description'=> $msg,
            'priority'=>0,
            //'apikey'=>'APIKEY'	// Not required if already set during object construction.
            //'providerkey'=>"PROVIDERKEY'
            ),true);
        }
        return $options;
        
    }
    
    protected function getNewEntries($feedname, $url) {
        $oldentries = $this->getOldEntries($feedname);
        $onlineentries = $this->getOnlineEntries($feedname,$url);
        if (count($onlineentries) > 0) {
            //keep some old entries, so that they don't get repostet if the show up later
            $z = 0;
            $max = count($onlineentries);
            
            foreach($oldentries as $k => $v) {
                if(!isset($onlineentries[$k])) { 
                    $onlineentries[$k] = $v;
                    $z++;
                    if ($z > $max) {
                        break;
                    }
                }
            }
            
            file_put_contents(R2T_TEMP_DIR . "/$feedname", sfYaml::dump($onlineentries));
            chmod(R2T_TEMP_DIR . "/$feedname",0666);
        }
        $newentries = $onlineentries;
        foreach ($onlineentries as $guid => $a) {
            if (isset($oldentries[$guid])) {
                unset($newentries[$guid]);
            } else {
                $this->debug("   New Entry: " . $a['link'] . " " . $a['title']);
            }
            
        }
        return $newentries;
    }
    
    protected function getOldEntries($feed) {
        $file = R2T_TEMP_DIR . "/$feed";
        $oldentries = array();
        if (file_exists($file)) {
            $oldentries = sfYAML::Load($file);
        }
        return $oldentries;
        
    }
    
    protected function getOnlineEntries($feedname,$url) {
        $feed = $this->readFeed($feedname,$url);
        $this->debug("Loop through entries");
        $entries = array();
        foreach ($feed as $entry) {
            //$this->debug("  " . $entry->link . ": " . $entry->guid . " " . $entry->title);
            if (isset($entry->guid)) {
                $entry->guid = $entry->link;
            }
            $e = array(
            "link" => $entry->link,
            "title" => $entry->title,
            "author" => $entry->author
            );
            if(!$entry->guid) {
                $entry->guid = $entry->link;
            }
            
            if ($entry->lat) {
                $e['lat'] = $entry->lat;
                $e['long'] = $entry->long;
            }
            $entries[$entry->guid] = $e;
        }
        return $entries;
    }
    
    protected function readFeed($feedname,$url) {
        require_once ("XML/Feed/Parser.php");
        
        $this->debug("readFeed for $url");
        $body = $this->httpRequest($feedname,$url);
        if ($body) {
            $this->debug("parse Feed");
            return new XML_Feed_Parser($body);
            
        } else {
            $this->debug("Feed for $url was empty");
            return array();
        }
        
    }
    
    protected function httpRequest($feedname,$url) {
        require_once ("HTTP/Request.php");
        $this->debug("httpRequest for $url");
        
        $req = new HTTP_Request($url);
        if (!PEAR::isError($req->sendRequest())) {
            return $req->getResponseBody();
        }
        return null;
        
    }
    protected function debug($msg) {
        
        if ($this->debug) {
            if (is_string($msg)) {
                print $msg . "\n";
            } else {
                var_dump($msg);
            }
        }
    }
}