123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990 |
- <?php
- if (!defined('GNUSOCIAL')) { exit(1); }
- class HubOutQueueHandler extends QueueHandler
- {
- function transport()
- {
- return 'hubout';
- }
- function handle($data)
- {
- assert(array_key_exists('atom', $data));
- assert(is_string($data['atom']));
- $atom = $data['atom'];
- assert(array_key_exists('retries', $data));
- $retries = intval($data['retries']);
- if (array_key_exists('topic', $data) && array_key_exists('callback', $data)) {
- assert(is_string($data['topic']));
- assert(is_string($data['callback']));
- $sub = HubSub::getByHashkey($data['topic'], $data['callback']);
- } elseif (array_key_exists('sub', $data)) {
-
- common_debug('Legacy behaviour of storing HubSub objects found, this should go away when all objects are handled...');
- $sub = $data['sub'];
- } else {
- throw new ServerException('No HubSub object available with queue item data.');
- }
- assert($sub instanceof HubSub);
- try {
- $success = $sub->push($atom);
-
- if ($success) {
- common_debug('WebSub push completed successfully!');
- } else {
- common_debug('WebSub push failed with an HTTP error.');
- }
- if ($sub->getErrors()>0) {
- common_debug('Resetting WebSub push error count following successful reset.');
- $sub->resetErrors();
- }
- } catch (AlreadyFulfilledException $e) {
-
- common_log(LOG_INFO, "Failed WebSub push to $sub->callback for $sub->topic (".get_class($e)."): " . $e->getMessage());
- } catch (Exception $e) {
- $retries--;
- $msg = "Failed WebSub push to $sub->callback for $sub->topic (".get_class($e)."): " . $e->getMessage();
- if ($retries > 0) {
- common_log(LOG_INFO, "$msg; scheduling for $retries more tries");
-
-
- $sub->distribute($atom, $retries);
- } else {
- $sub->incrementErrors($e->getMessage());
- common_log(LOG_ERR, "$msg; discarding");
- }
- }
- return true;
- }
- }
|