diff options
| author | Johann150 <johann.galle@protonmail.com> | 2022-04-19 11:46:41 +0200 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2022-04-19 18:46:41 +0900 |
| commit | 3cf226d534d10261c693ed51ba3db440fe8e8be9 (patch) | |
| tree | e8171065095b919e94d95d466c404600220a6fb2 /packages/backend/src/services | |
| parent | fix ogp rendering and refactor (diff) | |
| download | misskey-3cf226d534d10261c693ed51ba3db440fe8e8be9.tar.gz misskey-3cf226d534d10261c693ed51ba3db440fe8e8be9.tar.bz2 misskey-3cf226d534d10261c693ed51ba3db440fe8e8be9.zip | |
await promises (#8519)
Diffstat (limited to 'packages/backend/src/services')
| -rw-r--r-- | packages/backend/src/services/blocking/create.ts | 17 | ||||
| -rw-r--r-- | packages/backend/src/services/following/create.ts | 6 | ||||
| -rw-r--r-- | packages/backend/src/services/following/delete.ts | 11 |
3 files changed, 15 insertions, 19 deletions
diff --git a/packages/backend/src/services/blocking/create.ts b/packages/backend/src/services/blocking/create.ts index 5e96e5037f..d4b28d8d77 100644 --- a/packages/backend/src/services/blocking/create.ts +++ b/packages/backend/src/services/blocking/create.ts @@ -95,17 +95,12 @@ async function unFollow(follower: User, followee: User) { return; } - Followings.delete(following.id); - - //#region Decrement following count - Users.decrement({ id: follower.id }, 'followingCount', 1); - //#endregion - - //#region Decrement followers count - Users.decrement({ id: followee.id }, 'followersCount', 1); - //#endregion - - perUserFollowingChart.update(follower, followee, false); + await Promises.all([ + Followings.delete(following.id), + Users.decrement({ id: follower.id }, 'followingCount', 1), + Users.decrement({ id: followee.id }, 'followersCount', 1), + perUserFollowingChart.update(follower, followee, false), + ]); // Publish unfollow event if (Users.isLocalUser(follower)) { diff --git a/packages/backend/src/services/following/create.ts b/packages/backend/src/services/following/create.ts index 7491c44f83..f521118d48 100644 --- a/packages/backend/src/services/following/create.ts +++ b/packages/backend/src/services/following/create.ts @@ -67,8 +67,10 @@ export async function insertFollowingDoc(followee: { id: User['id']; host: User[ if (alreadyFollowed) return; //#region Increment counts - Users.increment({ id: follower.id }, 'followingCount', 1); - Users.increment({ id: followee.id }, 'followersCount', 1); + await Promises.all([ + Users.increment({ id: follower.id }, 'followingCount', 1), + Users.increment({ id: followee.id }, 'followersCount', 1), + ]); //#endregion //#region Update instance stats diff --git a/packages/backend/src/services/following/delete.ts b/packages/backend/src/services/following/delete.ts index 241f9606e5..1e425c2689 100644 --- a/packages/backend/src/services/following/delete.ts +++ b/packages/backend/src/services/following/delete.ts @@ -58,12 +58,11 @@ export default async function(follower: { id: User['id']; host: User['host']; ur } export async function decrementFollowing(follower: { id: User['id']; host: User['host']; }, followee: { id: User['id']; host: User['host']; }) { - //#region Decrement following count - Users.decrement({ id: follower.id }, 'followingCount', 1); - //#endregion - - //#region Decrement followers count - Users.decrement({ id: followee.id }, 'followersCount', 1); + //#region Decrement following / followers counts + await Promises.all([ + Users.decrement({ id: follower.id }, 'followingCount', 1), + Users.decrement({ id: followee.id }, 'followersCount', 1), + ]); //#endregion //#region Update instance stats |