123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234 |
- <?php
- defined('STATUSNET') || die();
- class RSSCloudNotifier
- {
- const MAX_FAILURES = 3;
-
- public function challenge($endpoint, $feed)
- {
- $code = common_confirmation_code(128);
- $params = array('url' => $feed, 'challenge' => $code);
- $url = $endpoint . '?' . http_build_query($params);
- try {
- $client = new HTTPClient();
- $response = $client->get($url);
- } catch (Exception $e) {
- common_log(
- LOG_INFO,
- 'RSSCloud plugin - failure testing notify handler '
- . $endpoint . ' - ' . $e->getMessage()
- );
- return false;
- }
-
- $status = $response->getStatus();
- $body = $response->getBody();
- if ($status >= 200 && $status < 300) {
-
-
-
-
- if (strpos($body, $code) !== false) {
- common_log(LOG_INFO, 'RSSCloud plugin - ' .
- "success testing notify handler: $endpoint");
- return true;
- } else {
- common_log(LOG_INFO, 'RSSCloud plugin - ' .
- 'challenge/repsonse failed for notify handler ' .
- $endpoint);
- common_debug('body = ' . var_export($body, true));
- return false;
- }
- } else {
- common_log(LOG_INFO, 'RSSCloud plugin - ' .
- "failure testing notify handler: $endpoint " .
- ' - got HTTP ' . $status);
- common_debug('body = ' . var_export($body, true));
- return false;
- }
- }
-
- public function postUpdate($endpoint, $feed)
- {
- $headers = array();
- $postdata = array('url' => $feed);
- try {
- $client = new HTTPClient();
- $response = $client->post($endpoint, $headers, $postdata);
- } catch (Exception $e) {
- common_log(LOG_INFO, 'RSSCloud plugin - failure notifying ' .
- $endpoint . ' that feed ' . $feed .
- ' has changed: ' . $e->getMessage());
- return false;
- }
- $status = $response->getStatus();
- if ($status >= 200 && $status < 300) {
- common_log(LOG_INFO, 'RSSCloud plugin - success notifying ' .
- $endpoint . ' that feed ' . $feed . ' has changed.');
- return true;
- } else {
- common_log(LOG_INFO, 'RSSCloud plugin - failure notifying ' .
- $endpoint . ' that feed ' . $feed .
- ' has changed: got HTTP ' . $status);
- return false;
- }
- }
-
- public function notify($profile)
- {
- $feed = common_path('api/statuses/user_timeline/') .
- $profile->id . '.rss';
- $cloudSub = new RSSCloudSubscription();
- $cloudSub->subscribed = $profile->id;
- if ($cloudSub->find()) {
- while ($cloudSub->fetch()) {
- $result = $this->postUpdate($cloudSub->url, $feed);
- if ($result == false) {
- $this->handleFailure($cloudSub);
- }
- }
- }
- return true;
- }
-
- public function handleFailure($cloudSub)
- {
- $failCnt = $cloudSub->failures + 1;
- if ($failCnt == self::MAX_FAILURES) {
- common_log(
- LOG_INFO,
- 'Deleting RSSCloud subcription (max failure count reached), '
- . "profile: {$cloudSub->subscribed} handler: {$cloudSub->url}"
- );
-
-
-
- $qry = 'DELETE from rsscloud_subscription' .
- ' WHERE subscribed = ' . $cloudSub->subscribed .
- ' AND url = \'' . $cloudSub->url . '\'';
- $result = $cloudSub->query($qry);
- if (!$result) {
- common_log_db_error($cloudSub, 'DELETE', __FILE__);
- common_log(LOG_ERR, 'Could not delete RSSCloud subscription.');
- }
- } else {
- common_debug('Updating failure count on RSSCloud subscription. ' .
- $failCnt);
- $failCnt = $cloudSub->failures + 1;
-
- $result = $cloudSub->query(sprintf(
- <<<'END'
- UPDATE rsscloud_subscription
- SET failures = %1$d, modified = CURRENT_TIMESTAMP
- WHERE subscribed = %2$d AND url = %3$s
- END,
- $failCnt,
- $cloudSub->subscribed,
- $cloudSub->_quote($cloudSub->url)
- ));
- if (!$result) {
- common_log_db_error($cloudsub, 'UPDATE', __FILE__);
- common_log(
- LOG_ERR,
- 'Could not update failure count on RSSCloud subscription'
- );
- }
- }
- }
- }
|