summaryrefslogtreecommitdiff
path: root/src/queue/processors
diff options
context:
space:
mode:
Diffstat (limited to 'src/queue/processors')
-rw-r--r--src/queue/processors/deliver.ts4
-rw-r--r--src/queue/processors/inbox.ts4
2 files changed, 4 insertions, 4 deletions
diff --git a/src/queue/processors/deliver.ts b/src/queue/processors/deliver.ts
index 16b2f6e29a..cb7587ef81 100644
--- a/src/queue/processors/deliver.ts
+++ b/src/queue/processors/deliver.ts
@@ -4,7 +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';
+import { fetchInstanceMetadata } from '../../services/fetch-instance-metadata';
import { fetchMeta } from '../../misc/fetch-meta';
import { toPuny } from '../../misc/convert-host';
@@ -48,7 +48,7 @@ export default async (job: Bull.Job) => {
isNotResponding: false
});
- fetchNodeinfo(i);
+ fetchInstanceMetadata(i);
instanceChart.requestSent(i.host, true);
});
diff --git a/src/queue/processors/inbox.ts b/src/queue/processors/inbox.ts
index 1d35079e9d..b4e8b85a46 100644
--- a/src/queue/processors/inbox.ts
+++ b/src/queue/processors/inbox.ts
@@ -8,7 +8,7 @@ import { instanceChart } from '../../services/chart';
import { fetchMeta } from '../../misc/fetch-meta';
import { toPuny, extractDbHost } from '../../misc/convert-host';
import { getApId } from '../../remote/activitypub/type';
-import { fetchNodeinfo } from '../../services/fetch-nodeinfo';
+import { fetchInstanceMetadata } from '../../services/fetch-instance-metadata';
import { InboxJobData } from '..';
import DbResolver from '../../remote/activitypub/db-resolver';
import { resolvePerson } from '../../remote/activitypub/models/person';
@@ -126,7 +126,7 @@ export default async (job: Bull.Job<InboxJobData>): Promise<string> => {
isNotResponding: false
});
- fetchNodeinfo(i);
+ fetchInstanceMetadata(i);
instanceChart.requestReceived(i.host);
});