summaryrefslogtreecommitdiff
path: root/src/queue/processors/http/process-inbox.ts
diff options
context:
space:
mode:
Diffstat (limited to 'src/queue/processors/http/process-inbox.ts')
-rw-r--r--src/queue/processors/http/process-inbox.ts11
1 files changed, 11 insertions, 0 deletions
diff --git a/src/queue/processors/http/process-inbox.ts b/src/queue/processors/http/process-inbox.ts
index 3cc13cbdaa..d88f00a098 100644
--- a/src/queue/processors/http/process-inbox.ts
+++ b/src/queue/processors/http/process-inbox.ts
@@ -8,6 +8,8 @@ import { toUnicode } from 'punycode';
import { URL } from 'url';
import { publishApLogStream } from '../../../services/stream';
import Logger from '../../../misc/logger';
+import { registerOrFetchInstanceDoc } from '../../../services/register-or-fetch-instance-doc';
+import Instance from '../../../models/instance';
const logger = new Logger('inbox');
@@ -101,6 +103,15 @@ export default async (job: bq.Job, done: any): Promise<void> => {
});
//#endregion
+ // Update stats
+ registerOrFetchInstanceDoc(user.host).then(i => {
+ Instance.update({ _id: i._id }, {
+ $set: {
+ latestRequestReceivedAt: new Date()
+ }
+ });
+ });
+
// アクティビティを処理
try {
await perform(user, activity);