. */ /** * Process a feed distribution POST from a PuSH hub. * @package FeedSub * @author Brion Vibber */ class PushInQueueHandler extends QueueHandler { function transport() { return 'pushin'; } function handle($data) { assert(is_array($data)); $feedsub_id = $data['feedsub_id']; $post = $data['post']; $hmac = $data['hmac']; $feedsub = FeedSub::staticGet('id', $feedsub_id); if ($feedsub) { $feedsub->receive($post, $hmac); } else { common_log(LOG_ERR, "Discarding POST to unknown feed subscription id $feedsub_id"); } return true; } }