Improve instance stats

This commit is contained in:
syuilo 2019-02-07 16:05:29 +09:00
parent dfb69030df
commit e5841a2c9a
2 changed files with 18 additions and 2 deletions

View file

@ -44,12 +44,17 @@ export interface IInstance {
followersCount: number; followersCount: number;
/** /**
* *
*/ */
latestRequestSentAt?: Date; latestRequestSentAt?: Date;
/** /**
* HTTPステータス * HTTPステータスコード
*/ */
latestStatus?: number; latestStatus?: number;
/**
*
*/
latestRequestReceivedAt?: Date;
} }

View file

@ -8,6 +8,8 @@ import { toUnicode } from 'punycode';
import { URL } from 'url'; import { URL } from 'url';
import { publishApLogStream } from '../../../services/stream'; import { publishApLogStream } from '../../../services/stream';
import Logger from '../../../misc/logger'; import Logger from '../../../misc/logger';
import { registerOrFetchInstanceDoc } from '../../../services/register-or-fetch-instance-doc';
import Instance from '../../../models/instance';
const logger = new Logger('inbox'); const logger = new Logger('inbox');
@ -101,6 +103,15 @@ export default async (job: bq.Job, done: any): Promise<void> => {
}); });
//#endregion //#endregion
// Update stats
registerOrFetchInstanceDoc(user.host).then(i => {
Instance.update({ _id: i._id }, {
$set: {
latestRequestReceivedAt: new Date()
}
});
});
// アクティビティを処理 // アクティビティを処理
try { try {
await perform(user, activity); await perform(user, activity);