Changeset 1674:00146501e490

Timestamp:

09/01/13 03:16:29 (12 years ago)

Author:

Florent Cotton <florent.cotton@…>

Branch:

pingbacks

Children:

1675:23613441b822, 1676:ae97601883d2

Message:

Support des pingbacks : après le support de la détection et de l'envoi de pingbacks, au tour du support en réception.
Dans le détail (ou presque) :

• Ajout d'un endpoint "pingback.ping" XML-RPC, mais le tout le gros du traitement est dans le fichier class.dc.trackback.php
• Ajout d'une méthode "receive_pb" dans la classe dcTrackback pour la prise en charge quasi-complète de la réception et enregistrement d'un pingback.
• Ajout d'une balise template {{tpl:BlogXMLRPCURL}} pour retourner l'URL du serveur XML-RPC du blog courant
• Ajout d'un bloc au niveau des en-têtes dans les templates par défaut post.html et page.html pour la mise en oeuvre si besoin d'un <link rel="pingback" ../>
• Ajout de l'envoi d'un en-tête HTTP supplémentaire "X-Pingback" dans les gestionnaires d'URLs pour les types "post" et "pages"

Reste plus qu'à tester en conditions réelles et à polir au besoin.

Files:

• inc/core/class.dc.trackback.php (modified) (1 diff)
• inc/core/class.dc.xmlrpc.php (modified) (4 diffs)
• inc/public/class.dc.template.php (modified) (2 diffs)
• inc/public/default-templates/post.html (modified) (1 diff)
• inc/public/lib.urlhandlers.php (modified) (1 diff)
• plugins/pages/_public.php (modified) (1 diff)
• plugins/pages/default-templates/page.html (modified) (1 diff)

inc/core/class.dc.trackback.php

@@ -309 +309 @@
      }
      //@}
+
+     /// @name Receive pingbacks
+     //@{
+     /**
+     Receives a pingback and insert it as a comment of given post.
+     
+     @param    from_url       <b>string</b>       Source URL
+     @param    to_url              <b>string</b>       Target URL
+     */
+     public function receive_pb($from_url, $to_url)
+     {
+          $reg = '!^'.preg_quote($this->core->blog->url).'(.*)!';
+          $type = $args = $next = '';
+          
+          # Are you dumb?
+          if (!preg_match($reg, $to_url, $m)) {
+               throw new Exception(__('Any chance you ping one of my contents? No? Really?'), 0);
+          }
+          
+          # Does the targeted URL look like a registered post type? 
+          $url_part = $m[1];
+          $p_type = '';
+          $post_types = $this->core->getPostTypes();
+          foreach ($post_types as $k => $v) {
+               $reg = '!^'.preg_quote(str_replace('%s', '', $v['public_url'])).'(.*)!';
+               if (preg_match($reg, $url_part, $n)) {
+                    $p_type = $k;
+                    $post_url = $n[1];
+                    break;
+               }
+          }
+          
+          if (empty($p_type)) {
+               throw new Exception(__('Sorry but you can not ping this type of content.'), 33);
+          }
+
+          # Time to see if we've got a winner...
+          $params = array(
+               'post_type' => $p_type,
+               'post_url' => $post_url,
+          );
+          $posts = $this->core->blog->getPosts($params);
+          
+          # Missed! 
+          if ($posts->isEmpty()) {
+               throw new Exception(__('Oops. Kinda "not found" stuff. Please check the target URL twice.'), 33);
+          }
+          
+          # Nice try. But, sorry, no.
+          if (!$posts->trackbacksActive()) {
+               throw new Exception(__('Sorry, dude. This entry does not accept pingback at the moment.'), 33);
+          }
+
+          # OK. We've found our champion. Time to check the remote part.
+          try {
+               $http = self::initHttp($from_url, $from_path);
+               
+               # First round : just to be sure the ping comes from an acceptable resource type.
+               $http->setHeadersOnly(true);
+               $http->get($from_path);
+               $c_type = explode(';', $http->getHeader('content-type'));
+
+               # Bad luck. Bye, bye...
+               if (!in_array($c_type[0],array('text/html', 'application/xhtml+xml'))) {
+                    throw new Exception(__('Your source URL does not look like a supported content type. Sorry. Bye, bye!'), 0);
+               }
+               
+               # Second round : let's go fetch and parse the remote content
+               $http->setHeadersOnly(false);
+               $http->get($from_path);
+               $remote_content = $http->getContent();
+
+               $charset = mb_detect_encoding($remote_content,
+                    'UTF-8,ISO-8859-1,ISO-8859-2,ISO-8859-3,'.
+                    'ISO-8859-4,ISO-8859-5,ISO-8859-6,ISO-8859-7,ISO-8859-8,'.
+                    'ISO-8859-9,ISO-8859-10,ISO-8859-13,ISO-8859-14,ISO-8859-15');
+
+               if (strtolower($charset) != 'utf-8') {
+                    $remote_content = iconv($charset,'UTF-8',$remote_content);
+               }
+               
+               # We want a title...
+               if (!preg_match('!<title>([^<].*?)</title>!mis', $remote_content, $m)) {
+                    throw new Exception(__('Where\'s your title?'), 0);
+               }
+               $title = trim(html::clean($m[1]));
+               $title = html::decodeEntities($title);
+               $title = html::escapeHTML($title);
+               $title = text::cutString($title,60);
+               
+               preg_match('!<body[^>]*?>(.*)?</body>!msi', $remote_content, $m);
+               $source = $m[1];
+               $source = preg_replace('![\r\n\s]+!ms',' ',$source);
+               $source = preg_replace( "/<\/*(h\d|p|th|td|li|dt|dd|pre|caption|input|textarea|button)[^>]*>/", "\n\n", $source );
+               $source = strip_tags($source, '<a>');
+               $source = explode("\n\n",$source);
+               
+               $excerpt = '';
+               foreach ($source as $line) {
+                    if (strpos($line, $to_url) !== false) {
+                         if (preg_match("!<a[^>]+?".$to_url."[^>]*>([^>]+?)</a>!", $line, $m)) {
+                              $excerpt = strip_tags($line);
+                              break;
+                         }
+                    }
+               }
+               if ($excerpt) {
+                    $excerpt = '(&#8230;) '.text::cutString(html::escapeHTML($excerpt),255).' (&#8230;)';
+               }
+               else {
+                    $excerpt = '(??)';
+               }
+
+               $comment =
+               "<!-- TB -->\n".
+               '<p><strong>'.$title."</strong></p>\n".
+               '<p>'.$excerpt.'</p>';
+               
+               $cur = $this->core->con->openCursor($this->core->prefix.'comment');
+               $cur->comment_author = 'Anonymous blog';
+               $cur->comment_site = (string) $from_url;
+               $cur->comment_content = (string) $comment;
+               $cur->post_id = $posts->post_id;
+               $cur->comment_trackback = 1;
+               $cur->comment_status = $this->core->blog->settings->system->trackbacks_pub ? 1 : -1;
+               $cur->comment_ip = http::realIP();
+               
+               # --BEHAVIOR-- publicBeforeTrackbackCreate
+               $this->core->callBehavior('publicBeforeTrackbackCreate',$cur);
+               if ($cur->post_id) {
+                    $comment_id = $this->core->blog->addComment($cur);
+                    
+                    # --BEHAVIOR-- publicAfterTrackbackCreate
+                    $this->core->callBehavior('publicAfterTrackbackCreate',$cur,$comment_id);
+               }
+          }
+          catch (Exception $e) {
+               throw new Exception(__('Sorry, an internal problem has occured.'), 0);
+          }
+          
+          return __('Thanks, mate. It was a pleasure.');
+     }
+     //@}
      
      private static function initHttp($url,&$path)

inc/core/class.dc.xmlrpc.php

@@ -214 +214 @@
                array('array','integer','string','string'),
                'Retrieve all of the comment statuses.');
+               
+          # Pingback support
+          $this->addCallback('pingback.ping',array($this,'pingback_ping'),
+               array('string', 'string', 'string'),
+               'Notify a link to a post.');
      }
      
@@ -270 +275 @@
      }
      
-     private function setBlog()
+     private function setBlog($bypass = false)
      {
           if (!$this->blog_id) {
@@ -288 +293 @@
           }
           
-          if (!$this->core->blog->settings->system->enable_xmlrpc ||
-          !$this->core->auth->check('usage,contentadmin',$this->core->blog->id)) {
+          if (!$bypass &&
+               (!$this->core->blog->settings->system->enable_xmlrpc ||
+               !$this->core->auth->check('usage,contentadmin',$this->core->blog->id))) {
                $this->core->blog = null;
                throw new Exception('Not enough permissions on this blog.');
@@ -1629 +1635 @@
           );
      }
+
+     /* Pingback support
+     --------------------------------------------------- */
+     public function pingback_ping($from_url, $to_url)
+     {
+          # Come on, buddy! Don't make me waste time with this kind of silliness...
+          if (!(filter_var($from_url, FILTER_VALIDATE_URL) && preg_match('!^https?://!',$from_url))) {
+               throw new Exception(__('No valid source URL provided? Try again!'), 0);
+          }
+          
+          $this->setBlog(true);
+          $tb = new dcTrackback($this->core);
+          return $tb->receive_pb($from_url, $to_url);
+     }
 }
 ?>

inc/public/class.dc.template.php

@@ -70 +70 @@
           $this->addValue('BlogID',array($this,'BlogID'));
           $this->addValue('BlogURL',array($this,'BlogURL'));
+          $this->addValue('BlogXMLRPCURL',array($this,'BlogXMLRPCURL'));
           $this->addValue('BlogPublicURL',array($this,'BlogPublicURL'));
           $this->addValue('BlogQmarkURL',array($this,'BlogQmarkURL'));
@@ -906 +907 @@
      
      /*dtd
+     <!ELEMENT tpl:BlogXMLRPCURL - O -- Blog XML-RPC URL -->
+     */
+     public function BlogXMLRPCURL($attr)
+     {
+          $f = $this->getFilters($attr);
+          return '<?php echo '.sprintf($f,'$core->blog->url.$core->url->getURLFor(\'xmlrpc\',$core->blog->id)').'; ?>';
+     }
+     
+     /*dtd
      <!ELEMENT tpl:BlogURL - O -- Blog URL -->
      */

inc/public/default-templates/post.html

@@ -25 +25 @@
   <link rel="top" href="{{tpl:BlogURL}}" title="{{tpl:lang Home}}" />
   <link rel="contents" href="{{tpl:BlogArchiveURL}}" title="{{tpl:lang Archives}}" />
+  <tpl:EntryIf pings_active="1"><link rel="pingback" href="{{tpl:BlogXMLRPCURL}}" /></tpl:EntryIf>
   
   <tpl:EntryNext><link rel="next" href="{{tpl:EntryURL}}"

inc/public/lib.urlhandlers.php

@@ -480 +480 @@
                     
                     # The entry
+                    if ($_ctx->posts->trackbacksActive()) {
+                         header('X-Pingback: '.$core->blog->url.$core->url->getURLFor("xmlrpc",$core->blog->id));
+                    }
                     self::serveDocument('post.html');
                }

plugins/pages/_public.php

@@ -181 +181 @@
                     
                     # The entry
+                    if ($_ctx->posts->trackbacksActive()) {
+                         header('X-Pingback: '.$core->blog->url.$core->url->getURLFor("xmlrpc",$core->blog->id));
+                    }
                     $core->tpl->setPath($core->tpl->getPath(), dirname(__FILE__).'/default-templates');
                     self::serveDocument('page.html');

plugins/pages/default-templates/page.html

@@ -25 +25 @@
   <link rel="top" href="{{tpl:BlogURL}}" title="{{tpl:lang Home}}" />
   <link rel="contents" href="{{tpl:BlogArchiveURL}}" title="{{tpl:lang Archives}}" />
+  <tpl:EntryIf pings_active="1"><link rel="pingback" href="{{tpl:BlogXMLRPCURL}}" /></tpl:EntryIf>
   
   <link rel="alternate" type="application/atom+xml" title="Atom 1.0" href="{{tpl:BlogFeedURL type="atom"}}" />