diff options
Diffstat (limited to 'src/queue')
| -rw-r--r-- | src/queue/processors/deliver.ts | 3 | ||||
| -rw-r--r-- | src/queue/processors/inbox.ts | 3 |
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); }); |