mirror
/
social
kopia lustrzana https://github.com/nextcloud/social
1
0
Forkuj 0
Kod Zgłoszenia Packages Projekty Wydania Wiki Aktywność

filter DM 

Signed-off-by: Maxence Lange <maxence@artificial-owl.com>
pull/768/head
Maxence Lange 2019-09-30 18:39:44 +02:00
rodzic 741a49f09b
commit 9a554f72be
2 zmienionych plików z 17 dodań i 5 usunięć
Pokaż statystyki Ściągnij plik aktualizacji Ściągnij plik porównania Expand all files Collapse all files

10
lib/Db/SocialLimitsQueryBuilder.php
Wyświetl plik

@ -310,6 +310,16 @@ class SocialLimitsQueryBuilder extends SocialCrossQueryBuilder {
}
/**
* @param string $recipient
*/
public function filterDest(string $recipient) {
$expr = $this->expr();
$this->andWhere($expr->neq('actor_id', $this->createNamedParameter($this->prim($recipient))));
}
/**
* @param string $actorId
* @param string $type

12
lib/Db/StreamRequest.php
Wyświetl plik

@ -454,17 +454,19 @@ class StreamRequest extends StreamRequestBuilder {
*/
public function getTimelineDirect(Person $actor, int $since = 0, int $limit = 5): array {
$qb = $this->getStreamSelectSql();
$qb->filterType(SocialAppNotification::TYPE);
$qb->limitPaginate($since, $limit);
$qb->innerJoinCacheActors('ca', 's.attributed_to_prim');
$qb->selectDestFollowing('sd', '');
$qb->innerJoinDest('recipient', 'id_prim', 'sd', 's');
$qb->limitToDest($actor->getId(), 'recipient', '', 'sd');
$this->filterRecipient($qb, ACore::CONTEXT_PUBLIC);
$this->filterRecipient($qb, $actor->getFollowers());
$qb->filterType(SocialAppNotification::TYPE);
$qb->innerJoinCacheActors('ca', 's.attributed_to_prim');
$qb->filterDest(ACore::CONTEXT_PUBLIC);
$qb->filterDest($actor->getFollowers());
$qb->andWhere($qb->exprLimitToDBFieldInt('hidden_on_timeline', 1, 's'));
return $this->getStreamsFromRequest($qb);
}