forked from GNUsocial/gnu-social
44bcc942b8
Rearchitect (again!) notice stream code to delegate different functionality up and down the stack. Now, different classes implement NoticeStream.
101 lines
2.9 KiB
PHP
101 lines
2.9 KiB
PHP
<?php
|
|
/**
|
|
* StatusNet - the distributed open-source microblogging tool
|
|
* Copyright (C) 2011, StatusNet, Inc.
|
|
*
|
|
* A stream of notices
|
|
*
|
|
* PHP version 5
|
|
*
|
|
* This program is free software: you can redistribute it and/or modify
|
|
* it under the terms of the GNU Affero General Public License as published by
|
|
* the Free Software Foundation, either version 3 of the License, or
|
|
* (at your option) any later version.
|
|
*
|
|
* This program is distributed in the hope that it will be useful,
|
|
* but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
|
* GNU Affero General Public License for more details.
|
|
*
|
|
* You should have received a copy of the GNU Affero General Public License
|
|
* along with this program. If not, see <http://www.gnu.org/licenses/>.
|
|
*
|
|
* @category Stream
|
|
* @package StatusNet
|
|
* @author Evan Prodromou <evan@status.net>
|
|
* @copyright 2011 StatusNet, Inc.
|
|
* @license http://www.fsf.org/licensing/licenses/agpl-3.0.html AGPL 3.0
|
|
* @link http://status.net/
|
|
*/
|
|
|
|
if (!defined('STATUSNET')) {
|
|
// This check helps protect against security problems;
|
|
// your code file can't be executed directly from the web.
|
|
exit(1);
|
|
}
|
|
|
|
/**
|
|
* Class for notice streams
|
|
*
|
|
* @category Stream
|
|
* @package StatusNet
|
|
* @author Evan Prodromou <evan@status.net>
|
|
* @copyright 2011 StatusNet, Inc.
|
|
* @license http://www.fsf.org/licensing/licenses/agpl-3.0.html AGPL 3.0
|
|
* @link http://status.net/
|
|
*/
|
|
abstract class NoticeStream
|
|
{
|
|
abstract function getNoticeIds($offset, $limit, $sinceId, $maxId);
|
|
|
|
function getNotices($offset=0, $limit=20, $sinceId=0, $maxId=0)
|
|
{
|
|
$ids = $this->getNoticeIds($offset, $limit, $sinceId, $maxId);
|
|
|
|
$notices = self::getStreamByIds($ids);
|
|
|
|
return $notices;
|
|
}
|
|
|
|
static function getStreamByIds($ids)
|
|
{
|
|
$cache = Cache::instance();
|
|
|
|
if (!empty($cache)) {
|
|
$notices = array();
|
|
foreach ($ids as $id) {
|
|
$n = Notice::staticGet('id', $id);
|
|
if (!empty($n)) {
|
|
$notices[] = $n;
|
|
}
|
|
}
|
|
return new ArrayWrapper($notices);
|
|
} else {
|
|
$notice = new Notice();
|
|
if (empty($ids)) {
|
|
//if no IDs requested, just return the notice object
|
|
return $notice;
|
|
}
|
|
$notice->whereAdd('id in (' . implode(', ', $ids) . ')');
|
|
|
|
$notice->find();
|
|
|
|
$temp = array();
|
|
|
|
while ($notice->fetch()) {
|
|
$temp[$notice->id] = clone($notice);
|
|
}
|
|
|
|
$wrapped = array();
|
|
|
|
foreach ($ids as $id) {
|
|
if (array_key_exists($id, $temp)) {
|
|
$wrapped[] = $temp[$id];
|
|
}
|
|
}
|
|
|
|
return new ArrayWrapper($wrapped);
|
|
}
|
|
}
|
|
}
|