use pre-configured http_request2 instance

[stapibas.git] / src / stapibas / Feed / PingUrls.php

diff --git a/src/stapibas/Feed/PingUrls.php b/src/stapibas/Feed/PingUrls.php
index 17fff7918a6d721b0b0daabca0cd1ab825a2f4c0..7c16223156873c176b00516f6a142e80ea45f6aa 100644 (file)
--- a/src/stapibas/Feed/PingUrls.php
+++ b/src/stapibas/Feed/PingUrls.php
@@ -10,18 +10,23 @@ class Feed_PingUrls
     public $log;
     public $pbc;
 
-    public function __construct()
+    public function __construct(Dependencies $deps)
     {
-        $this->pbc = new \PEAR2\Services\Pingback\Client();
+        $this->deps = $deps;
+        $this->db   = $deps->db;
+        $this->log  = $deps->log;
 
-        $req = new \HTTP_Request2();
+        $this->pbc = new \PEAR2\Services\Linkback\Client();
+        $req = $this->pbc->getRequest();
         $req->setConfig(
             array(
                 'ssl_verify_peer' => false,
                 'ssl_verify_host' => false
             )
         );
-        $this->pbc->setRequest($req);
+        $headers = $req->getHeaders();
+        $req->setHeader('user-agent', 'stapibas / ' . $headers['user-agent']);
+
         $this->pbc->setDebug(true);
     }
 
@@ -29,18 +34,49 @@ class Feed_PingUrls
     {
         $this->log->info('Pinging all URLs..');
         $res = $this->db->query(
-            'SELECT fe_url, feu_id, feu_url FROM feedentries, feedentryurls'
-            . ' WHERE fe_id = feu_fe_id AND feu_active = 1 AND feu_pinged = 0'
+            'SELECT fe_url, feu_id, feu_url, feu_tries'
+            . ' FROM feedentries, feedentryurls'
+            . ' WHERE fe_id = feu_fe_id' . $this->sqlNeedsUpdate()
+        );
+        $items = 0;
+        while ($row = $res->fetch(\PDO::FETCH_OBJ)) {
+            $this->log->info(
+                'Pinging URL #%d: %s', $row->feu_id, $row->feu_url
+            );
+            $this->ping($row);
+            ++$items;
+        }
+        $this->log->info('Finished pinging %d URLs.', $items);
+    }
+
+    public function pingSome($urlOrIds)
+    {
+        $options = array();
+        foreach ($urlOrIds as $urlOrId) {
+            if (is_numeric($urlOrId)) {
+                $options[] = 'feu_id = ' . intval($urlOrId);
+            } else {
+                $options[] = 'feu_url = ' . $this->db->quote($urlOrId);
+            }
+        }
+
+        $this->log->info('Pinging %d URLs..', count($options));
+        $res = $this->db->query(
+            'SELECT fe_url, feu_id, feu_url, feu_tries'
+            . ' FROM feedentries, feedentryurls'
+            . ' WHERE fe_id = feu_fe_id'
+            . $this->sqlNeedsUpdate()
+            . ' AND (' . implode(' OR ', $options) . ')'
         );
         $items = 0;
         while ($row = $res->fetch(\PDO::FETCH_OBJ)) {
             $this->log->info(
-                sprintf('Pinging URL #%d: %s', $row->feu_id, $row->feu_url)
+                'Pinging URL #%d: %s', $row->feu_id, $row->feu_url
             );
             $this->ping($row);
             ++$items;
         }
-        $this->log->info(sprintf('Finished pinging %d URLs.', $items));
+        $this->log->info('Finished pinging %d URLs.', $items);
     }
 
     public function ping($row)
@@ -56,7 +92,11 @@ class Feed_PingUrls
                 'UPDATE feedentryurls SET'
                 . '  feu_pinged = 1'
                 . ', feu_updated = NOW()'
-                . ', feu_error = ' . $this->db->quote($e->getMessage())
+                . ', feu_error = 1'
+                . ', feu_error_code = ' . $this->db->quote($e->getCode())
+                . ', feu_error_message = ' . $this->db->quote($e->getMessage())
+                . ', feu_tries = ' . $this->db->quote($row->feu_tries + 1)
+                . ', feu_retry = ' . $this->sqlRetry($e)
                 . ' WHERE feu_id = ' . $this->db->quote($row->feu_id)
             );
             return;
@@ -69,26 +109,75 @@ class Feed_PingUrls
                 'UPDATE feedentryurls SET'
                 . '  feu_pinged = 1'
                 . ', feu_updated = NOW()'
-                . ', feu_error = ""'
+                . ', feu_error = 0'
+                . ', feu_error_code = ""'
+                . ', feu_error_message = ""'
+                . ', feu_tries = ' . $this->db->quote($row->feu_tries + 1)
+                . ', feu_retry = 0'
                 . ' WHERE feu_id = ' . $this->db->quote($row->feu_id)
             );
         } else {
             //error
-            $this->log->err('Error: ' . $res->getCode() . ': ' . $res->getMessage());
-            $this->log->info(
-                'Pingback response: Status code ' . $res->getResponse()->getStatus()
-                . ', headers: ' . print_r($res->getResponse()->getHeader(), true)
-                . ', body: ' . $res->getResponse()->getBody()
-            );
+            $code = $res->getCode();
+            $this->log->err('Error: ' . $code . ': ' . $res->getMessage());
+            $httpRes = $res->getResponse();
+            if ($httpRes) {
+                $this->log->info(
+                    'Pingback response: Status code ' . $httpRes->getStatus()
+                    . ', headers: ' . print_r($httpRes->getHeader(), true)
+                );
+                if ($code == 100 || $code == 101 || $code == -32600) {
+                    $this->log->info('HTTP body: ' . $httpRes->getBody());
+                }
+            }
             $this->db->exec(
                 'UPDATE feedentryurls SET'
                 . '  feu_pinged = 1'
                 . ', feu_updated = NOW()'
-                . ', feu_error = '
-                . $this->db->quote($res->getCode() . ': ' . $res->getMessage())
+                . ', feu_error = 1'
+                . ', feu_error_code = ' . $this->db->quote($res->getCode())
+                . ', feu_error_message = ' . $this->db->quote($res->getMessage())
+                . ', feu_tries = ' . $this->db->quote($row->feu_tries + 1)
+                . ', feu_retry = ' . $this->sqlRetry($res)
                 . ' WHERE feu_id = ' . $this->db->quote($row->feu_id)
             );
         }
     }
+
+    protected function sqlNeedsUpdate()
+    {
+        if ($this->deps->options['force']) {
+            return '';
+        }
+        $sqlRetry = '(feu_retry = 1 AND feu_tries < 5)';
+        //FIXME: wait at least 1 hour before retrying
+
+        return ' AND feu_active = 1 AND (feu_pinged = 0 OR ' . $sqlRetry . ')';
+    }
+
+    /**
+     * Determines if it should be retried to pingback the URL after some time
+     *
+     * @param $obj mixed Exception or Pingback response
+     */
+    protected function sqlRetry($obj)
+    {
+        if ($obj instanceof \Exception) {
+            return '1';
+        }
+
+        switch ($obj->getCode()) {
+        case -32601:  //they have xmp-rpc, but do not support pingback
+        case 17:  //they think we don't link to them
+        case 18:  //they think we send out pingback spam
+        case 48:  //already registered
+        case 49:  //access denied
+        case 200: //pingback not supported
+        case 201: //Unvalid target URI
+            return '0';
+        }
+
+        return '1';
+    }
 }
 ?>