From e1f1a1af0945cbf4c0fbfda5c90c06b5d2bf3f39 Mon Sep 17 00:00:00 2001
From: mei23 <m@m544.net>
Date: Sun, 21 Mar 2021 10:43:49 +0900
Subject: [PATCH] =?UTF-8?q?=E3=82=A4=E3=83=B3=E3=82=B9=E3=82=BF=E3=83=B3?=
 =?UTF-8?q?=E3=82=B9=E3=83=A2=E3=83=87=E3=83=AC=E3=83=BC=E3=82=B7=E3=83=A7?=
 =?UTF-8?q?=E3=83=B3=E3=81=AE=E3=82=AD=E3=83=A3=E3=83=83=E3=82=B7=E3=83=A5?=
 =?UTF-8?q?=E3=82=92=E8=87=AA=E5=8B=95=E5=87=A6=E7=90=86=E3=81=A7=E3=82=82?=
 =?UTF-8?q?=E5=8D=B3=E6=99=82=E5=8F=8D=E6=98=A0=E3=81=99=E3=82=8B=E3=82=88?=
 =?UTF-8?q?=E3=81=86=E3=81=AB?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 src/queue/processors/deliver.ts | 5 ++++-
 src/queue/processors/inbox.ts   | 5 ++++-
 2 files changed, 8 insertions(+), 2 deletions(-)

diff --git a/src/queue/processors/deliver.ts b/src/queue/processors/deliver.ts
index 9c974210147d..02dafa8ca6d8 100644
--- 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
index a6ef90aaacbc..5eba0713fc4d 100644
--- 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);