12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758 |
- <?php
- if (!defined('STATUSNET')) {
- exit(1);
- }
- class HubConfQueueHandler extends QueueHandler
- {
- function transport()
- {
- return 'hubconf';
- }
- function handle($data)
- {
- $sub = $data['sub'];
- $mode = $data['mode'];
- $token = $data['token'];
- assert($sub instanceof HubSub);
- assert($mode === 'subscribe' || $mode === 'unsubscribe');
- common_log(LOG_INFO, __METHOD__ . ": $mode $sub->callback $sub->topic");
- try {
- $sub->verify($mode, $token);
- } catch (Exception $e) {
- common_log(LOG_ERR, "Failed WebSub $mode verify to $sub->callback for $sub->topic: " .
- $e->getMessage());
-
-
- }
- return true;
- }
- }
|