use new linkback request template api
[stapibas.git] / src / stapibas / Feed / PingUrls.php
1 <?php
2 namespace stapibas;
3
4 /**
5  * Pings all URLs that have not been pinged yet
6  */
7 class Feed_PingUrls
8 {
9     public $db;
10     public $log;
11     public $pbc;
12
13     public function __construct(Dependencies $deps)
14     {
15         $this->deps = $deps;
16         $this->db   = $deps->db;
17         $this->log  = $deps->log;
18
19         $this->pbc = new \PEAR2\Services\Linkback\Client();
20         $req = $this->pbc->getRequest();
21         $req->setConfig(
22             array(
23                 'ssl_verify_peer' => false,
24                 'ssl_verify_host' => false
25             )
26         );
27         $this->pbc->setRequestTemplate($req);
28         $headers = $req->getHeaders();
29         $req->setHeader('user-agent', 'stapibas / ' . $headers['user-agent']);
30
31         $this->pbc->setDebug(true);
32     }
33
34     public function pingAll()
35     {
36         $this->log->info('Pinging all URLs..');
37         $res = $this->db->query(
38             'SELECT fe_url, feu_id, feu_url, feu_tries'
39             . ' FROM feedentries, feedentryurls'
40             . ' WHERE fe_id = feu_fe_id' . $this->sqlNeedsUpdate()
41         );
42         $items = 0;
43         while ($row = $res->fetch(\PDO::FETCH_OBJ)) {
44             $this->log->info(
45                 'Pinging URL #%d: %s', $row->feu_id, $row->feu_url
46             );
47             $this->ping($row);
48             ++$items;
49         }
50         $this->log->info('Finished pinging %d URLs.', $items);
51     }
52
53     public function pingSome($urlOrIds)
54     {
55         $options = array();
56         foreach ($urlOrIds as $urlOrId) {
57             if (is_numeric($urlOrId)) {
58                 $options[] = 'feu_id = ' . intval($urlOrId);
59             } else {
60                 $options[] = 'feu_url = ' . $this->db->quote($urlOrId);
61             }
62         }
63
64         $this->log->info('Pinging %d URLs..', count($options));
65         $res = $this->db->query(
66             'SELECT fe_url, feu_id, feu_url, feu_tries'
67             . ' FROM feedentries, feedentryurls'
68             . ' WHERE fe_id = feu_fe_id'
69             . $this->sqlNeedsUpdate()
70             . ' AND (' . implode(' OR ', $options) . ')'
71         );
72         $items = 0;
73         while ($row = $res->fetch(\PDO::FETCH_OBJ)) {
74             $this->log->info(
75                 'Pinging URL #%d: %s', $row->feu_id, $row->feu_url
76             );
77             $this->ping($row);
78             ++$items;
79         }
80         $this->log->info('Finished pinging %d URLs.', $items);
81     }
82
83     public function ping($row)
84     {
85         $from = $row->fe_url;
86         $to   = $row->feu_url;
87
88         try {
89             $res = $this->pbc->send($from, $to);
90         } catch (\Exception $e) {
91             $this->log->err('Exception: ' . $e->getMessage());
92             $this->db->exec(
93                 'UPDATE feedentryurls SET'
94                 . '  feu_pinged = 1'
95                 . ', feu_updated = NOW()'
96                 . ', feu_error = 1'
97                 . ', feu_error_code = ' . $this->db->quote($e->getCode())
98                 . ', feu_error_message = ' . $this->db->quote($e->getMessage())
99                 . ', feu_tries = ' . $this->db->quote($row->feu_tries + 1)
100                 . ', feu_retry = ' . $this->sqlRetry($e)
101                 . ' WHERE feu_id = ' . $this->db->quote($row->feu_id)
102             );
103             return;
104         }
105
106         if (!$res->isError()) {
107             //all fine
108             $this->log->info('ok');
109             $this->db->exec(
110                 'UPDATE feedentryurls SET'
111                 . '  feu_pinged = 1'
112                 . ', feu_updated = NOW()'
113                 . ', feu_error = 0'
114                 . ', feu_error_code = ""'
115                 . ', feu_error_message = ""'
116                 . ', feu_tries = ' . $this->db->quote($row->feu_tries + 1)
117                 . ', feu_retry = 0'
118                 . ' WHERE feu_id = ' . $this->db->quote($row->feu_id)
119             );
120         } else {
121             //error
122             $code = $res->getCode();
123             $this->log->err('Error: ' . $code . ': ' . $res->getMessage());
124             $httpRes = $res->getResponse();
125             if ($httpRes) {
126                 $this->log->info(
127                     'Pingback response: Status code ' . $httpRes->getStatus()
128                     . ', headers: ' . print_r($httpRes->getHeader(), true)
129                 );
130                 if ($code == 100 || $code == 101 || $code == -32600) {
131                     $this->log->info('HTTP body: ' . $httpRes->getBody());
132                 }
133             }
134             $this->db->exec(
135                 'UPDATE feedentryurls SET'
136                 . '  feu_pinged = 1'
137                 . ', feu_updated = NOW()'
138                 . ', feu_error = 1'
139                 . ', feu_error_code = ' . $this->db->quote($res->getCode())
140                 . ', feu_error_message = ' . $this->db->quote($res->getMessage())
141                 . ', feu_tries = ' . $this->db->quote($row->feu_tries + 1)
142                 . ', feu_retry = ' . $this->sqlRetry($res)
143                 . ' WHERE feu_id = ' . $this->db->quote($row->feu_id)
144             );
145         }
146     }
147
148     protected function sqlNeedsUpdate()
149     {
150         if ($this->deps->options['force']) {
151             return '';
152         }
153         $sqlRetry = '(feu_retry = 1 AND feu_tries < 5)';
154         //FIXME: wait at least 1 hour before retrying
155
156         return ' AND feu_active = 1 AND (feu_pinged = 0 OR ' . $sqlRetry . ')';
157     }
158
159     /**
160      * Determines if it should be retried to pingback the URL after some time
161      *
162      * @param $obj mixed Exception or Pingback response
163      */
164     protected function sqlRetry($obj)
165     {
166         if ($obj instanceof \Exception) {
167             return '1';
168         }
169
170         switch ($obj->getCode()) {
171         case -32601:  //they have xmp-rpc, but do not support pingback
172         case 17:  //they think we don't link to them
173         case 18:  //they think we send out pingback spam
174         case 48:  //already registered
175         case 49:  //access denied
176         case 200: //pingback not supported
177         case 201: //Unvalid target URI
178             return '0';
179         }
180
181         return '1';
182     }
183 }
184 ?>