summaryrefslogtreecommitdiff
path: root/src/queue
diff options
context:
space:
mode:
Diffstat (limited to 'src/queue')
-rw-r--r--src/queue/processors/deliver.ts3
-rw-r--r--src/queue/processors/inbox.ts3
2 files changed, 6 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);
});
diff --git a/src/queue/processors/inbox.ts b/src/queue/processors/inbox.ts
index e71181ee73..1a583ec865 100644
--- a/src/queue/processors/inbox.ts
+++ b/src/queue/processors/inbox.ts
@@ -13,6 +13,7 @@ import { fetchMeta } from '../../misc/fetch-meta';
import { toPuny } from '../../misc/convert-host';
import { validActor } from '../../remote/activitypub/type';
import { ensure } from '../../prelude/ensure';
+import { fetchNodeinfo } from '../../services/fetch-nodeinfo';
const logger = new Logger('inbox');
@@ -105,6 +106,8 @@ export default async (job: Bull.Job): Promise<void> => {
isNotResponding: false
});
+ fetchNodeinfo(i);
+
instanceChart.requestReceived(i.host);
});