sup.php 2.9 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192
  1. <?php
  2. /*
  3. * StatusNet - the distributed open-source microblogging tool
  4. * Copyright (C) 2008, 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. if (!defined('STATUSNET') && !defined('LACONICA')) { exit(1); }
  20. // @todo FIXME: documentation needed.
  21. class SupAction extends Action
  22. {
  23. function handle($args)
  24. {
  25. parent::handle($args);
  26. $seconds = $this->trimmed('seconds');
  27. if (!$seconds) {
  28. $seconds = 15;
  29. }
  30. $updates = $this->getUpdates($seconds);
  31. header('Content-Type: application/json; charset=utf-8');
  32. print json_encode(array('updated_time' => date('c'),
  33. 'since_time' => date('c', time() - $seconds),
  34. 'available_periods' => $this->availablePeriods(),
  35. 'period' => $seconds,
  36. 'updates' => $updates));
  37. }
  38. function availablePeriods()
  39. {
  40. static $periods = array(86400, 43200, 21600, 7200,
  41. 3600, 1800, 600, 300, 120,
  42. 60, 30, 15);
  43. $available = array();
  44. foreach ($periods as $period) {
  45. $available[$period] = common_local_url('sup',
  46. array('seconds' => $period));
  47. }
  48. return $available;
  49. }
  50. function getUpdates($seconds)
  51. {
  52. $notice = new Notice();
  53. // XXX: cache this. Depends on how big this protocol becomes;
  54. // Re-doing this query every 15 seconds isn't the end of the world.
  55. $divider = common_sql_date(time() - $seconds);
  56. $notice->query('SELECT profile_id, max(id) AS max_id ' .
  57. 'FROM ( ' .
  58. 'SELECT profile_id, id FROM notice ' .
  59. ((common_config('db','type') == 'pgsql') ?
  60. 'WHERE extract(epoch from created) > (extract(epoch from now()) - ' . $seconds . ') ' :
  61. 'WHERE created > "'.$divider.'" ' ) .
  62. ') AS latest ' .
  63. 'GROUP BY profile_id');
  64. $updates = array();
  65. while ($notice->fetch()) {
  66. $updates[] = array($notice->profile_id, $notice->max_id);
  67. }
  68. return $updates;
  69. }
  70. function isReadOnly($args)
  71. {
  72. return true;
  73. }
  74. }