2 files changed, 8 insertions, 0 deletions
diff --git a/src/queue/processors/http/deliver.ts b/src/queue/processors/http/deliver.ts
index 82dcf06ad4..6d24cd2634 100644
--- a/src/queue/processors/http/deliver.ts
+++ b/src/queue/processors/http/deliver.ts
@@ -4,6 +4,7 @@ import request from '../../../remote/activitypub/request';
 import { queueLogger } from '../../logger';
 import { registerOrFetchInstanceDoc } from '../../../services/register-or-fetch-instance-doc';
 import Instance from '../../../models/instance';
+import instanceChart from '../../../services/chart/instance';
 
 export default async (job: bq.Job, done: any): Promise<void> => {
 	const { host } = new URL(job.data.to);
@@ -19,6 +20,8 @@ export default async (job: bq.Job, done: any): Promise<void> => {
 					latestStatus: 200
 				}
 			});
+
+			instanceChart.requestSent(i.host, true);
 		});
 
 		done();
@@ -31,6 +34,8 @@ export default async (job: bq.Job, done: any): Promise<void> => {
 					latestStatus: res != null && res.hasOwnProperty('statusCode') ? res.statusCode : null
 				}
 			});
+
+			instanceChart.requestSent(i.host, false);
 		});
 
 		if (res != null && res.hasOwnProperty('statusCode')) {
diff --git a/src/queue/processors/http/process-inbox.ts b/src/queue/processors/http/process-inbox.ts
index 583e255136..07d4b5ba71 100644
--- a/src/queue/processors/http/process-inbox.ts
+++ b/src/queue/processors/http/process-inbox.ts
@@ -10,6 +10,7 @@ import { publishApLogStream } from '../../../services/stream';
 import Logger from '../../../misc/logger';
 import { registerOrFetchInstanceDoc } from '../../../services/register-or-fetch-instance-doc';
 import Instance from '../../../models/instance';
+import instanceChart from '../../../services/chart/instance';
 
 const logger = new Logger('inbox');
 
@@ -128,6 +129,8 @@ export default async (job: bq.Job, done: any): Promise<void> => {
 				latestRequestReceivedAt: new Date()
 			}
 		});
+
+		instanceChart.requestReceived(i.host);
 	});
 
 	// アクティビティを処理