-import { logger } from '../../../helpers'
-import { doRequest } from '../../../helpers/requests'
-import { ACTIVITY_PUB } from '../../../initializers/constants'
-import { processActivities } from '../../activitypub/process/process'
+import { doRequest, logger } from '../../../helpers'
+import { ACTIVITY_PUB } from '../../../initializers'
+import { processActivities } from '../../activitypub/process'
import { ActivityPubHttpPayload } from './activitypub-http-job-scheduler'
async function process (payload: ActivityPubHttpPayload, jobId: number) {
}
function onError (err: Error, jobId: number) {
- logger.error('Error when broadcasting ActivityPub request in job %d.', jobId, err)
+ logger.error('Error when fetcher ActivityPub request in job %d.', jobId, err)
return Promise.resolve()
}