summaryrefslogtreecommitdiff
path: root/src/queue
diff options
context:
space:
mode:
authorsyuilo <syuilotan@yahoo.co.jp>2019-02-07 16:05:29 +0900
committersyuilo <syuilotan@yahoo.co.jp>2019-02-07 16:05:29 +0900
commit7275bc6d3b356f3aa8ff7aef92f5abf52a18a13e (patch)
treebe1da9c8198f48ff18403dfa9e2bc2a8501d9ab0 /src/queue
parentMerge branch 'develop' of https://github.com/syuilo/misskey into develop (diff)
downloadsharkey-7275bc6d3b356f3aa8ff7aef92f5abf52a18a13e.tar.gz
sharkey-7275bc6d3b356f3aa8ff7aef92f5abf52a18a13e.tar.bz2
sharkey-7275bc6d3b356f3aa8ff7aef92f5abf52a18a13e.zip
Improve instance stats
Diffstat (limited to 'src/queue')
-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);