フォローインポートで自分をスキップするように (#4614)
* skip myself in import-following * skip owner in publishToFollowers
This commit is contained in:
		
							parent
							
								
									deaadc33db
								
							
						
					
					
						commit
						59dc929431
					
				
					 2 changed files with 5 additions and 1 deletions
				
			
		| 
						 | 
					@ -45,6 +45,9 @@ export async function importFollowing(job: Bull.Job, done: any): Promise<void> {
 | 
				
			||||||
			target = await resolveUser(username, host);
 | 
								target = await resolveUser(username, host);
 | 
				
			||||||
		}
 | 
							}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
							// skip myself
 | 
				
			||||||
 | 
							if (target._id.equals(job.data.user._id)) continue;
 | 
				
			||||||
 | 
					
 | 
				
			||||||
		logger.info(`Follow ${target._id} ...`);
 | 
							logger.info(`Follow ${target._id} ...`);
 | 
				
			||||||
 | 
					
 | 
				
			||||||
		follow(user, target);
 | 
							follow(user, target);
 | 
				
			||||||
| 
						 | 
					
 | 
				
			||||||
| 
						 | 
					@ -568,7 +568,8 @@ async function publishToFollowers(note: INote, user: IUser, noteActivity: any) {
 | 
				
			||||||
	});
 | 
						});
 | 
				
			||||||
 | 
					
 | 
				
			||||||
	const followers = await Following.find({
 | 
						const followers = await Following.find({
 | 
				
			||||||
		followeeId: note.userId
 | 
							followeeId: note.userId,
 | 
				
			||||||
 | 
							followerId: { $ne: note.userId }	// バグでフォロワーに自分がいることがあるため
 | 
				
			||||||
	});
 | 
						});
 | 
				
			||||||
 | 
					
 | 
				
			||||||
	const queue: string[] = [];
 | 
						const queue: string[] = [];
 | 
				
			||||||
| 
						 | 
					
 | 
				
			||||||
		Loading…
	
	Add table
		Add a link
		
	
		Reference in a new issue