From 56275bcfcbd1366b0e96b79915e810baed0548bb Mon Sep 17 00:00:00 2001
From: syuilo <Syuilotan@yahoo.co.jp>
Date: Fri, 8 Feb 2019 16:58:57 +0900
Subject: Introduce per-instance chart (#4183)

* Introduce per-instance chart

* Implement chart view in client

* Handle note deleting

* More chart srcs

* Add drive stats

* Improve drive stats

* Fix bug

* Add icon
---
 src/queue/processors/http/deliver.ts       | 5 +++++
 src/queue/processors/http/process-inbox.ts | 3 +++
 2 files changed, 8 insertions(+)

(limited to 'src/queue/processors')

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);
 	});
 
 	// アクティビティを処理
-- 
cgit v1.2.3-freya