Changeset 1338

Timestamp:

03/25/11 22:12:13 (2 years ago)

Author:

Torben Brodt

Message:

retweet update

Files:

• twitter.retweet/files/lib/system/event/listener/TwitterRetweetListener.class.php (modified) (5 diffs)
• twitter.retweet/install.sql (modified) (1 diff)
• wavethread (deleted)

twitter.retweet/files/lib/system/event/listener/TwitterRetweetListener.class.php

@@ -3 +3 @@
 
 /**
- * 
- * 
+ * link retweet to trackback
+ *
  * @author      Torben Brodt
  * @url         http://trac.easy-coding.de/trac/wcf/wiki/twitter
@@ -15 +15 @@
          */
         public function execute($eventObj, $className, $eventName) {
+
+                switch($className) {
+                        case 'TwitterMessageEditor':
+                                $this->messageEditor($eventObj);
+                        break;
+                        case 'AbstractPage':
+                                //TODO: display retweets
+                        break;
+                }
+        }
         
-                //TODO: display retweets
-        
+        /**
+         * @param       TwitterMessageEditor    $eventObj
+         */
+        protected function messageEditor($eventObj) {
                 foreach($eventObj->links as $link) {
-                
-        
                         $link = $this->rdfAutoDiscover($link);
-                
-                        if($this->isHomeLink($link)) {
-                                $query = parse_url($link, PHP_URL_QUERY);
-                                parse_str($query, $output);
-                                
-                                $this->link($eventObj, $output['action'], $output['objectID'], $output['objectType'], $output['packageID']);
+
+                        // skip foreign links
+                        if(!$this->isHomeLink($link)) {
+                                continue;
                         }
+                        $query = parse_url($link, PHP_URL_QUERY);
+                        parse_str($query, $output);
+                        
+                        // skip strange links
+                        if(!isset($output['objectType'], $output['packageID'], $output['objectID'])) {
+                                continue;
+                        }
+
+                        $adapterID = $this->getAdapterID($output['objectType'], intval($output['packageID']));
+
+                        $sql = 'INSERT IGNORE INTO
+                                        wcf'.WCF_N.'_twitter_message_retweet
+                                        (messageID, adapterID, objectID, time)
+                                VALUES ('.intval($eventObj->messageID).', '.intval($adapterID).', 
+                                        '.intval($output['objectID']).', '.TIME_NOW.')';
+
+                        WCF::getDB()->sendQuery($sql);
                 }
         }
 
         /**
-         *
+         * @return boolean
          */
         protected function isHomeLink($link) {
@@ -40 +65 @@
                 }
 
-                // TODO: does this link point to PAGE_URL ?
-
-                return true;
+                return preg_match('/^'.preg_quote(PAGE_URL, '/').'/', $link);
         }
 
-        protected function link() {
-                // TODO: insert wcf1_twitter_message_retweet
+        /**
+         * @return integer
+         */
+        protected function getAdapterID() {
+                // get cache
+                WCF::getCache()->addResource(
+                        'trackback-adapter',
+                        WCF_DIR.'cache/cache.trackback-adapter.php',
+                        WCF_DIR.'lib/system/cache/CacheBuilderTrackbackAdapter.class.php'
+                );
+                $cache = WCF::getCache()->get('trackback-adapter');
+
+                // try to find a matching trackback adapter
+                if (isset($cache[$objectType])) {
+                        foreach ($cache[$objectType] as $adapter) {
+                                if ($adapter['packageID'] == $packageID) {
+                                        return $adapter['adapterID'];
+                                }
+                        }
+                }
+                return 0;
         }
-        
+
         /**
          * @return string
@@ -56 +98 @@
                 $pageContent = @file_get_contents($trackbackURL);
                 $didDiscover = false;
-                
+
                 if ($pageContent !== false) {
                         // search for RDF instructions
@@ -64 +106 @@
                                                 // get pingback URL
                                                 if (preg_match('/trackback\:ping\=\"([^"]+)\"/isU', $rdfInstructions, $pingbackURL)) {
-                                                        
                                                         return $pingbackURL[1];
                                                 }

twitter.retweet/install.sql

@@ -5 +5 @@
         adapterID INT(10) unsigned NOT NULL,
         objectID INT(10) unsigned NOT NULL,
+        time INT(10) NOT NULL DEFAULT 0,
         PRIMARY KEY (messageID),
         INDEX (adapterID, objectID)