123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235 |
- <?php
- if (!defined('STATUSNET')) {
- exit(1);
- }
- class RSSCloudNotifier
- {
- const MAX_FAILURES = 3;
-
- 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;
- }
- }
-
- 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;
- }
- }
-
- 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;
- }
-
- 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;
-
- $qry = 'UPDATE rsscloud_subscription' .
- ' SET failures = ' . $failCnt .
- ' WHERE subscribed = ' . $cloudSub->subscribed .
- ' AND url = \'' . $cloudSub->url . '\'';
- $result = $cloudSub->query($qry);
- if (!$result) {
- common_log_db_error($cloudsub, 'UPDATE', __FILE__);
- common_log(LOG_ERR,
- 'Could not update failure ' .
- 'count on RSSCloud subscription');
- }
- }
- }
- }
|