summaryrefslogtreecommitdiff
path: root/src/queue/processors/deliver.ts
diff options
context:
space:
mode:
authorsyuilo <Syuilotan@yahoo.co.jp>2019-11-05 22:14:42 +0900
committerGitHub <noreply@github.com>2019-11-05 22:14:42 +0900
commit77c9b90e6d72e8d1ca5038611fa967d789bacf69 (patch)
treec60e3f8f86bb407d6836c632d2f3c69ff360913a /src/queue/processors/deliver.ts
parentFix bug (diff)
downloadsharkey-77c9b90e6d72e8d1ca5038611fa967d789bacf69.tar.gz
sharkey-77c9b90e6d72e8d1ca5038611fa967d789bacf69.tar.bz2
sharkey-77c9b90e6d72e8d1ca5038611fa967d789bacf69.zip
Store nodeinfo per federated instances (#5578)
* Store nodeinfo per federated instances * Update fetch-nodeinfo.ts * Update fetch-nodeinfo.ts * update
Diffstat (limited to 'src/queue/processors/deliver.ts')
-rw-r--r--src/queue/processors/deliver.ts3
1 files changed, 3 insertions, 0 deletions
diff --git a/src/queue/processors/deliver.ts b/src/queue/processors/deliver.ts
index 8837c80d87..b252c20163 100644
--- a/src/queue/processors/deliver.ts
+++ b/src/queue/processors/deliver.ts
@@ -4,6 +4,7 @@ import { registerOrFetchInstanceDoc } from '../../services/register-or-fetch-ins
import Logger from '../../services/logger';
import { Instances } from '../../models';
import { instanceChart } from '../../services/chart';
+import { fetchNodeinfo } from '../../services/fetch-nodeinfo';
const logger = new Logger('deliver');
@@ -28,6 +29,8 @@ export default async (job: Bull.Job) => {
isNotResponding: false
});
+ fetchNodeinfo(i);
+
instanceChart.requestSent(i.host, true);
});