インスタンスモデレーションのキャッシュを自動処理でも即時反映するように

mei23 · Mar 21, 2021 · e1f1a1a · e1f1a1a
1 parent cd97123
commit e1f1a1a
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 2 deletions.
diff --git a/src/queue/processors/deliver.ts b/src/queue/processors/deliver.ts
@@ -7,6 +7,7 @@ import Logger from '../../services/logger';
 import { UpdateInstanceinfo } from '../../services/update-instanceinfo';
 import { isBlockedHost, isClosedHost } from '../../misc/instance-info';
 import { DeliverJobData } from '../type';
+import { publishInstanceModUpdated } from '../../services/server-event';
 
 const logger = new Logger('deliver');
 
@@ -79,7 +80,9 @@ export default async (job: Bull.Job<DeliverJobData>) => {
 							$set: {
 								isMarkedAsClosed: true
 							}
-						});
+						}).then(() => {
+							publishInstanceModUpdated();
+						})
 					});
 				}
 

diff --git a/src/queue/processors/inbox.ts b/src/queue/processors/inbox.ts
@@ -19,6 +19,7 @@ import { extractApHost } from '../../misc/convert-host';
 import { LdSignature } from '../../remote/activitypub/misc/ld-signature';
 import resolveUser from '../../remote/resolve-user';
 import config from '../../config';
+import { publishInstanceModUpdated } from '../../services/server-event';
 
 const logger = new Logger('inbox');
 
@@ -139,7 +140,9 @@ export default async (job: Bull.Job<InboxJobData>): Promise<string> => {
 
 		Instance.update({ _id: i._id }, {
 			$set: set
-		});
+		}).then(() => {
+			publishInstanceModUpdated();
+		})
 
 		UpdateInstanceinfo(i, job.data.request);