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
  28 class PushCallbackAction extends Action
  29 {
  30     function handle()
  31     {
  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('Empty or invalid feed id', 400);
  49         }
  50
  51         $feedinfo = Feedinfo::staticGet('id', $feedid);
  52         if (!$feedinfo) {
  53             throw new ServerException('Unknown feed id ' . $feedid, 400);
  54         }
  55
  56         $hmac = '';
  57         if (isset($_SERVER['HTTP_X_HUB_SIGNATURE'])) {
  58             $hmac = $_SERVER['HTTP_X_HUB_SIGNATURE'];
  59         }
  60
  61         $post = file_get_contents('php://input');
  62         $feedinfo->postUpdates($post, $hmac);
  63     }
  64
  65     /**
  66      * Handler for GET verification requests from the hub
  67      */
  68     function handleGet()
  69     {
  70         $mode = $this->arg('hub_mode');
  71         $topic = $this->arg('hub_topic');
  72         $challenge = $this->arg('hub_challenge');
  73         $lease_seconds = $this->arg('hub_lease_seconds');
  74         $verify_token = $this->arg('hub_verify_token');
  75
  76         if ($mode != 'subscribe' && $mode != 'unsubscribe') {
  77             common_log(LOG_WARNING, __METHOD__ . ": bogus hub callback with mode \"$mode\"");
  78             throw new ServerException("Bogus hub callback: bad mode", 404);
  79         }
  80
  81         $feedinfo = Feedinfo::staticGet('feeduri', $topic);
  82         if (!$feedinfo) {
  83             common_log(LOG_WARNING, __METHOD__ . ": bogus hub callback for unknown feed $topic");
  84             throw new ServerException("Bogus hub callback: unknown feed", 404);
  85         }
  86
  87         # Can't currently set the token in our sub api
  88         #if ($feedinfo->verify_token !== $verify_token) {
  89         #    common_log(LOG_WARNING, __METHOD__ . ": bogus hub callback with bad token \"$verify_token\" for feed $topic");
  90         #    throw new ServerError("Bogus hub callback: bad token", 404);
  91         #}
  92
  93         // OK!
  94         common_log(LOG_INFO, __METHOD__ . ': sub confirmed');
  95         $feedinfo->sub_start = common_sql_date(time());
  96         if ($lease_seconds > 0) {
  97             $feedinfo->sub_end = common_sql_date(time() + $lease_seconds);
  98         } else {
  99             $feedinfo->sub_end = null;
 100         }
 101         $feedinfo->update();
 102
 103         print $challenge;
 104     }
 105 }