From e881e1bfb3d1bf0e1a453235b5fe104f276c1392 Mon Sep 17 00:00:00 2001
From: syuilo <Syuilotan@yahoo.co.jp>
Date: Mon, 22 Mar 2021 10:45:07 +0900
Subject: [PATCH] perf(server): Reduce database query
---
src/services/note/create.ts | 26 +++++++++++++-------------
1 file changed, 13 insertions(+), 13 deletions(-)
diff --git a/src/services/note/create.ts b/src/services/note/create.ts
index 96177e9758..4a737e8516 100644
--- a/src/services/note/create.ts
+++ b/src/services/note/create.ts
@@ -259,21 +259,21 @@ export default async (user: User, data: Option, silent = false) => new Promise<N
});
// Antenna
- Antennas.find().then(async antennas => {
- const followings = await Followings.createQueryBuilder('following')
- .andWhere(`following.followeeId = :userId`, { userId: note.userId })
- .getMany();
-
- const followers = followings.map(f => f.followerId);
-
- for (const antenna of antennas) {
- checkHitAntenna(antenna, note, user, followers).then(hit => {
- if (hit) {
- addNoteToAntenna(antenna, note, user);
+ Followings.createQueryBuilder('following')
+ .andWhere(`following.followeeId = :userId`, { userId: note.userId })
+ .getMany()
+ .then(followings => {
+ const followers = followings.map(f => f.followerId);
+ Antennas.find().then(async antennas => {
+ for (const antenna of antennas) {
+ checkHitAntenna(antenna, note, user, followers).then(hit => {
+ if (hit) {
+ addNoteToAntenna(antenna, note, user);
+ }
+ });
}
});
- }
- });
+ });
// Channel
if (note.channelId) {