summaryrefslogtreecommitdiff
path: root/packages/backend/src/server/api/stream/channels/channel.ts
diff options
context:
space:
mode:
authorsyuilo <Syuilotan@yahoo.co.jp>2023-10-15 10:36:22 +0900
committerGitHub <noreply@github.com>2023-10-15 10:36:22 +0900
commit3f4ee9840560d8c423111f1ab93b2e36218a1314 (patch)
treea133afad107362fea5ac00ec8e30704d62a357b9 /packages/backend/src/server/api/stream/channels/channel.ts
parentperf(backend): tweak populateMyReaction (diff)
downloadsharkey-3f4ee9840560d8c423111f1ab93b2e36218a1314.tar.gz
sharkey-3f4ee9840560d8c423111f1ab93b2e36218a1314.tar.bz2
sharkey-3f4ee9840560d8c423111f1ab93b2e36218a1314.zip
perf(backend): improve streaming api performance (#12033)
* wip * Update NoteEntityService.ts * wip * wip * wip * wip
Diffstat (limited to 'packages/backend/src/server/api/stream/channels/channel.ts')
-rw-r--r--packages/backend/src/server/api/stream/channels/channel.ts18
1 files changed, 5 insertions, 13 deletions
diff --git a/packages/backend/src/server/api/stream/channels/channel.ts b/packages/backend/src/server/api/stream/channels/channel.ts
index a01714e76d..e4c34e00ce 100644
--- a/packages/backend/src/server/api/stream/channels/channel.ts
+++ b/packages/backend/src/server/api/stream/channels/channel.ts
@@ -38,19 +38,6 @@ class ChannelChannel extends Channel {
private async onNote(note: Packed<'Note'>) {
if (note.channelId !== this.channelId) return;
- // リプライなら再pack
- if (note.replyId != null) {
- note.reply = await this.noteEntityService.pack(note.replyId, this.user, {
- detail: true,
- });
- }
- // Renoteなら再pack
- if (note.renoteId != null) {
- note.renote = await this.noteEntityService.pack(note.renoteId, this.user, {
- detail: true,
- });
- }
-
// 流れてきたNoteがミュートしているユーザーが関わるものだったら無視する
if (isUserRelated(note, this.userIdsWhoMeMuting)) return;
// 流れてきたNoteがブロックされているユーザーが関わるものだったら無視する
@@ -58,6 +45,11 @@ class ChannelChannel extends Channel {
if (note.renote && !note.text && isUserRelated(note, this.userIdsWhoMeMutingRenotes)) return;
+ if (this.user && note.renoteId && !note.text) {
+ const myRenoteReaction = await this.noteEntityService.populateMyReaction(note.renoteId, this.user.id);
+ note.renote!.myReaction = myRenoteReaction;
+ }
+
this.connection.cacheNote(note);
this.send('note', note);