remove unnecessary joins

packages/backend/src/core/AccountMoveService.ts

@@ -141,24 +141,22 @@ export class AccountMoveService {
 
 		// follow the new account and unfollow the old one
 		const proxy = await this.proxyAccountService.fetch();
-		const followings = await this.followingsRepository.find({
+		const followings = await this.followingsRepository.findBy({
-			relations: {
-				follower: true,
-			},
-			where: {
 				followeeId: src.id,
 				followerHost: IsNull(), // follower is local
 				followerId: proxy ? Not(proxy.id) : undefined,
-			},
 		});
 		const followJobs: RelationshipJobData[] = [];
 		for (const following of followings) {
-			if (!following.follower) continue;
+			followJobs.push({ from: { id: following.followerId }, to: { id: dst.id } });
-			followJobs.push({ from: { id: following.follower.id }, to: { id: dst.id } });
 		}
 
 		// Decrease following count instead of unfollowing.
+		try {
 			await this.adjustFollowingCounts(followJobs.map(job => job.from.id), src);
+		} catch {
+			/* skip if any error happens */
+		}
 
 		// Should be queued because this can cause a number of follow per one move.
 		this.queueService.createFollowJob(followJobs);
@@ -168,19 +166,14 @@ export class AccountMoveService {
 	public async copyBlocking(src: ThinUser, dst: ThinUser): Promise<void> {
 		// Followers shouldn't overlap with blockers, but the destination account, different from the blockee (i.e., old account), may have followed the local user before moving.
 		// So block the destination account here.
-		const blockings = await this.blockingsRepository.find({ // FIXME: might be expensive
+		const srcBlockings = await this.blockingsRepository.findBy({ blockeeId: src.id });
-			relations: {
+		const dstBlockings = await this.blockingsRepository.findBy({ blockeeId: dst.id });
-				blocker: true
+		const blockerIds = dstBlockings.map(blocking => blocking.blockerId);
-			},
-			where: {
-				blockeeId: src.id
-			}
-		});
 		// reblock the destination account
 		const blockJobs: RelationshipJobData[] = [];
-		for (const blocking of blockings) {
+		for (const blocking of srcBlockings) {
-			if (!blocking.blocker) continue;
+			if (blockerIds.includes(blocking.blockerId)) continue; // skip if already blocked
-			blockJobs.push({ from: { id: blocking.blocker.id }, to: { id: dst.id } });
+			blockJobs.push({ from: { id: blocking.blockerId }, to: { id: dst.id } });
 		}
 		// no need to unblock the old account because it may be still functional
 		this.queueService.createBlockJob(blockJobs);

packages/backend/src/core/activitypub/ApInboxService.ts

@@ -765,8 +765,10 @@ export class ApInboxService {
 		}
 
 		// add target uri to movedToUri in order to indicate that the user has moved
+		if (oldAccount.movedToUri !== targetUri) {
 			await this.usersRepository.update(oldAccount.id, { movedToUri: targetUri });
 			oldAccount.movedToUri = targetUri;
+		}
 
 		// Move!
 		await this.accountMoveService.move(oldAccount, newAccount);