X-Git-Url: https://git.mxchange.org/?a=blobdiff_plain;f=lib%2Finboxnoticestream.php;h=2b19461c5763d7bc542cac96ce956fbf9fcdda4b;hb=b4271a3533bdf12329f27dd75452c1ef2a6ee3d1;hp=496fe0d05d5425f6c784a0cf448b4fe34e4bb52d;hpb=e4a1dff98d6a15c8f513bdb2ef55c699f8e70bcd;p=quix0rs-gnu-social.git diff --git a/lib/inboxnoticestream.php b/lib/inboxnoticestream.php index 496fe0d05d..2b19461c57 100644 --- a/lib/inboxnoticestream.php +++ b/lib/inboxnoticestream.php @@ -30,7 +30,7 @@ * @link http://status.net/ */ -if (!defined('GNUSOCIAL') && !defined('STATUSNET')) { exit(1); } +if (!defined('GNUSOCIAL')) { exit(1); } /** * Stream of notices for a profile's "all" feed @@ -54,9 +54,6 @@ class InboxNoticeStream extends ScopingNoticeStream */ function __construct(Profile $target, Profile $scoped=null) { - if ($scoped === null) { - $scoped = Profile::current(); - } // FIXME: we don't use CachingNoticeStream - but maybe we should? parent::__construct(new CachingNoticeStream(new RawInboxNoticeStream($target), 'profileall'), $scoped); } @@ -72,7 +69,7 @@ class InboxNoticeStream extends ScopingNoticeStream * @license http://www.fsf.org/licensing/licenses/agpl-3.0.html AGPL 3.0 * @link http://status.net/ */ -class RawInboxNoticeStream extends NoticeStream +class RawInboxNoticeStream extends FullNoticeStream { protected $target = null; protected $inbox = null; @@ -84,8 +81,8 @@ class RawInboxNoticeStream extends NoticeStream */ function __construct(Profile $target) { + parent::__construct(); $this->target = $target; - $this->unselectVerbs = array(ActivityVerb::DELETE); } /** @@ -119,12 +116,9 @@ class RawInboxNoticeStream extends NoticeStream if (!empty($max_id)) { $notice->whereAdd(sprintf('notice.id <= %d', $max_id)); } - if (!empty($this->selectVerbs)) { - $notice->whereAddIn('verb', $this->selectVerbs, $notice->columnType('verb')); - } - if (!empty($this->unselectVerbs)) { - $notice->whereAddIn('!verb', $this->unselectVerbs, $notice->columnType('verb')); - } + + self::filterVerbs($notice, $this->selectVerbs); + $notice->limit($offset, $limit); // notice.id will give us even really old posts, which were // recently imported. For example if a remote instance had