plugins/OStatus/actions/pushcallback.php

   1 <?php
   2 /*
   3  * StatusNet - the distributed open-source microblogging tool
   4  * Copyright (C) 2009, StatusNet, Inc.
   5  *
   6  * This program is free software: you can redistribute it and/or modify
   7  * it under the terms of the GNU Affero General Public License as published by
   8  * the Free Software Foundation, either version 3 of the License, or
   9  * (at your option) any later version.
  10  *
  11  * This program is distributed in the hope that it will be useful,
  12  * but WITHOUT ANY WARRANTY; without even the implied warranty of
  13  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  14  * GNU Affero General Public License for more details.
  15  *
  16  * You should have received a copy of the GNU Affero General Public License
  17  * along with this program.  If not, see <http://www.gnu.org/licenses/>.
  18  */
  19
  20 /**
  21  * @package FeedSubPlugin
  22  * @maintainer Brion Vibber <brion@status.net>
  23  */
  24
  25 if (!defined('STATUSNET') && !defined('LACONICA')) { exit(1); }
  26
  27 class PushCallbackAction extends Action
  28 {
  29     function handle()
  30     {
  31         StatusNet::setApi(true); // Minimize error messages to aid in debugging
  32         parent::handle();
  33         if ($_SERVER['REQUEST_METHOD'] == 'POST') {
  34             $this->handlePost();
  35         } else {
  36             $this->handleGet();
  37         }
  38     }
  39
  40     /**
  41      * Handler for POST content updates from the hub
  42      */
  43     function handlePost()
  44     {
  45         $feedid = $this->arg('feed');
  46         common_log(LOG_INFO, "POST for feed id $feedid");
  47         if (!$feedid) {
  48             throw new ServerException(_m('Empty or invalid feed id.'), 400);
  49         }
  50
  51         $feedsub = FeedSub::staticGet('id', $feedid);
  52         if (!$feedsub) {
  53             // TRANS: Server exception. %s is a feed ID.
  54             throw new ServerException(sprintf(_m('Unknown PuSH feed id %s'),$feedid), 400);
  55         }
  56
  57         $hmac = '';
  58         if (isset($_SERVER['HTTP_X_HUB_SIGNATURE'])) {
  59             $hmac = $_SERVER['HTTP_X_HUB_SIGNATURE'];
  60         }
  61
  62         $post = file_get_contents('php://input');
  63
  64         // Queue this to a background process; we should return
  65         // as quickly as possible from a distribution POST.
  66         // If queues are disabled this'll process immediately.
  67         $data = array('feedsub_id' => $feedsub->id,
  68                       'post' => $post,
  69                       'hmac' => $hmac);
  70         $qm = QueueManager::get();
  71         $qm->enqueue($data, 'pushin');
  72     }
  73
  74     /**
  75      * Handler for GET verification requests from the hub.
  76      */
  77     function handleGet()
  78     {
  79         $mode = $this->arg('hub_mode');
  80         $topic = $this->arg('hub_topic');
  81         $challenge = $this->arg('hub_challenge');
  82         $lease_seconds = $this->arg('hub_lease_seconds');
  83         $verify_token = $this->arg('hub_verify_token');
  84         common_log(LOG_INFO, __METHOD__ . ": sub verification mode: $mode topic: $topic challenge: $challenge lease_seconds: $lease_seconds verify_token: $verify_token");
  85
  86         if ($mode != 'subscribe' && $mode != 'unsubscribe') {
  87             // TRANS: Client exception. %s is an invalid value for hub.mode.
  88             throw new ClientException(sprintf(_m('Bad hub.mode "$s".',$mode)), 404);
  89         }
  90
  91         $feedsub = FeedSub::staticGet('uri', $topic);
  92         if (!$feedsub) {
  93             // TRANS: Client exception. %s is an invalid feed name.
  94             throw new ClientException(sprintf(_m('Bad hub.topic feed "%s".'),$topic), 404);
  95         }
  96
  97         if ($feedsub->verify_token !== $verify_token) {
  98             // TRANS: Client exception. %1$s the invalid token, %2$s is the topic for which the invalid token was given.
  99             throw new ClientException(sprintf(_m('Bad hub.verify_token %1$s for %2$s.'),$token,$topic), 404);
 100         }
 101
 102         if ($mode == 'subscribe') {
 103             // We may get re-sub requests legitimately.
 104             if ($feedsub->sub_state != 'subscribe' && $feedsub->sub_state != 'active') {
 105                 // TRANS: Client exception. %s is an invalid topic.
 106                 throw new ClientException(sprintf(_m('Unexpected subscribe request for %s.'),$topic), 404);
 107             }
 108         } else {
 109             if ($feedsub->sub_state != 'unsubscribe') {
 110                 // TRANS: Client exception. %s is an invalid topic.
 111                 throw new ClientException(sprintf(_m('Unexpected unsubscribe request for %s.'),$topic), 404);
 112             }
 113         }
 114
 115         if ($mode == 'subscribe') {
 116             if ($feedsub->sub_state == 'active') {
 117                 common_log(LOG_INFO, __METHOD__ . ': sub update confirmed');
 118             } else {
 119                 common_log(LOG_INFO, __METHOD__ . ': sub confirmed');
 120             }
 121             $feedsub->confirmSubscribe($lease_seconds);
 122         } else {
 123             common_log(LOG_INFO, __METHOD__ . ": unsub confirmed; deleting sub record for $topic");
 124             $feedsub->confirmUnsubscribe();
 125         }
 126         print $challenge;
 127     }
 128 }