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

update stream details 

Signed-off-by: Maxence Lange <maxence@artificial-owl.com>
pull/1781/head
Maxence Lange 2023-06-14 00:32:33 -01:00
rodzic 0f2c5816e0
commit 2150774b9d
4 zmienionych plików z 12 dodań i 8 usunięć
Pokaż statystyki Ściągnij plik aktualizacji Ściągnij plik porównania Expand all files Collapse all files

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

@ -105,7 +105,6 @@ class StreamRequest extends StreamRequestBuilder {
public function update(Stream $stream, bool $generateDest = false): void {
$qb = $this->getStreamUpdateSql();
$qb->set('details', $qb->createNamedParameter(json_encode($stream->getDetailsAll())));
$qb->set('to', $qb->createNamedParameter($stream->getTo()));
$qb->set(
'cc', $qb->createNamedParameter(json_encode($stream->getCcArray(), JSON_UNESCAPED_SLASHES))
@ -121,6 +120,15 @@ class StreamRequest extends StreamRequestBuilder {
}
}
public function updateDetails(Stream $stream): void {
$qb = $this->getStreamUpdateSql();
$qb->set('details', $qb->createNamedParameter(json_encode($stream->getDetailsAll())));
$qb->limitToIdPrim($qb->prim($stream->getId()));
$qb->executeStatement();
}
public function updateCache(Stream $stream, Cache $cache): void {
$qb = $this->getStreamUpdateSql();
$qb->set('cache', $qb->createNamedParameter(json_encode($cache, JSON_UNESCAPED_SLASHES)));

2
lib/Interfaces/Object/AnnounceInterface.php
Wyświetl plik

@ -305,7 +305,7 @@ class AnnounceInterface extends AbstractActivityPubInterface implements IActivit
'boosts', $this->actionsRequest->countActions($post->getId(), Announce::TYPE)
);
$this->streamRequest->update($post, true);
$this->streamRequest->updateDetails($post);
}
/**

6
lib/Interfaces/Object/LikeInterface.php
Wyświetl plik

@ -172,15 +172,11 @@ class LikeInterface extends AbstractActivityPubInterface implements IActivityPub
}
private function updateDetails(Stream $post): void {
// if (!$post->isLocal()) {
// return;
// }
$post->setDetailInt(
'likes', $this->actionsRequest->countActions($post->getId(), Like::TYPE)
);
$this->streamRequest->update($post, true);
$this->streamRequest->updateDetails($post);
}

2
lib/Interfaces/Object/NoteInterface.php
Wyświetl plik

@ -127,7 +127,7 @@ class NoteInterface extends AbstractActivityPubInterface implements IActivityPub
$count = $this->streamRequest->countRepliesTo($stream->getInReplyTo());
$orig->setDetailInt('replies', $count);
$this->streamRequest->update($orig);
$this->streamRequest->updateDetails($orig);
} catch (StreamNotFoundException $e) {
}
}