Load streams with pagination

Signed-off-by: Julius Härtl <jus@bitgrid.net>

1 files changed, 4 insertions, 2 deletions

diff --git a/lib/Db/NotesRequest.php b/lib/Db/NotesRequest.php
index c8795d6a..715a722a 100644
--- a/lib/Db/NotesRequest.php
+++ b/lib/Db/NotesRequest.php
@@ -142,11 +142,12 @@ class NotesRequest extends NotesRequestBuilder {
 	 *
 	 * @return array
 	 */
-	public function getHomeNotesForActorId(string $actorId): array {
+	public function getHomeNotesForActorId(string $actorId, $since, $limit): array {
 		$qb = $this->getNotesSelectSql();
 
 		$this->rightJoinFollowing($qb);
 		$this->limitToActorId($qb, $actorId, 'f');
+		$this->limitPaginate($qb, $since, $limit);
 //		$this->leftJoinCacheActors($qb, 'attributed_to');
 
 		$notes = [];
@@ -192,9 +193,10 @@ class NotesRequest extends NotesRequestBuilder {
 	 *
 	 * @return array
 	 */
-	public function getDirectNotesForActorId(string $actorId): array {
+	public function getDirectNotesForActorId(string $actorId, $since, $limit): array {
 		$qb = $this->getNotesSelectSql();
 		$this->limitToRecipient($qb, $actorId);
+		$this->limitPaginate($qb, $since, $limit);
 		$this->leftJoinCacheActors($qb, 'attributed_to');
 
 		$notes = [];