3 * StatusNet - the distributed open-source microblogging tool
4 * Copyright (C) 2011, StatusNet, Inc.
6 * Stream of notices for a list
10 * This program is free software: you can redistribute it and/or modify
11 * it under the terms of the GNU Affero General Public License as published by
12 * the Free Software Foundation, either version 3 of the License, or
13 * (at your option) any later version.
15 * This program is distributed in the hope that it will be useful,
16 * but WITHOUT ANY WARRANTY; without even the implied warranty of
17 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
18 * GNU Affero General Public License for more details.
20 * You should have received a copy of the GNU Affero General Public License
21 * along with this program. If not, see <http://www.gnu.org/licenses/>.
25 * @author Evan Prodromou <evan@status.net>
26 * @copyright 2011 StatusNet, Inc.
27 * @license http://www.fsf.org/licensing/licenses/agpl-3.0.html AGPL 3.0
28 * @link http://status.net/
31 if (!defined('STATUSNET')) {
32 // This check helps protect against security problems;
33 // your code file can't be executed directly from the web.
38 * Stream of notices for a list
42 * @author Evan Prodromou <evan@status.net>
43 * @author Shashi Gowda <connect2shashi@gmail.com>
44 * @copyright 2011 StatusNet, Inc.
45 * @license http://www.fsf.org/licensing/licenses/agpl-3.0.html AGPL 3.0
46 * @link http://status.net/
48 class PeopletagNoticeStream extends ScopingNoticeStream
50 function __construct($plist, $profile = -1)
52 if (is_int($profile) && $profile == -1) {
53 $profile = Profile::current();
55 parent::__construct(new CachingNoticeStream(new RawPeopletagNoticeStream($plist),
56 'profile_list:notice_ids:' . $plist->id),
62 * Stream of notices for a list
66 * @author Evan Prodromou <evan@status.net>
67 * @author Shashi Gowda <connect2shashi@gmail.com>
68 * @copyright 2011 StatusNet, Inc.
69 * @license http://www.fsf.org/licensing/licenses/agpl-3.0.html AGPL 3.0
70 * @link http://status.net/
72 class RawPeopletagNoticeStream extends NoticeStream
74 protected $profile_list;
76 function __construct($profile_list)
78 $this->profile_list = $profile_list;
82 * Query notices by users associated with this tag from the database.
84 * @param integer $offset offset
85 * @param integer $limit maximum no of results
86 * @param integer $since_id=null since this id
87 * @param integer $max_id=null maximum id in result
89 * @return array array of notice ids.
92 function getNoticeIds($offset, $limit, $since_id, $max_id)
94 $notice = new Notice();
97 $notice->selectAdd('notice.id');
99 $notice->joinAdd(array('profile_id', 'profile_tag:tagged'));
101 $notice->whereAdd(sprintf('profile_tag.tag = "%s"', $this->profile_list->tag));
102 $notice->whereAdd(sprintf('profile_tag.tagger = %d', $this->profile_list->tagger));
104 if ($since_id != 0) {
105 $notice->whereAdd('notice.id > ' . $since_id);
109 $notice->whereAdd('notice.id <= ' . $max_id);
112 $notice->orderBy('notice.id DESC');
114 if (!is_null($offset)) {
115 $notice->limit($offset, $limit);
119 if ($notice->find()) {
120 while ($notice->fetch()) {
121 $ids[] = $notice->id;