diff options
Diffstat (limited to 'src/queue/processors')
| -rw-r--r-- | src/queue/processors/http/deliver.ts | 5 |
1 files changed, 5 insertions, 0 deletions
diff --git a/src/queue/processors/http/deliver.ts b/src/queue/processors/http/deliver.ts index 1ba582a284..96f6cc07ce 100644 --- a/src/queue/processors/http/deliver.ts +++ b/src/queue/processors/http/deliver.ts @@ -6,10 +6,15 @@ import { registerOrFetchInstanceDoc } from '../../../services/register-or-fetch- import Instance from '../../../models/instance'; import instanceChart from '../../../services/chart/instance'; +let latest: string = null; + export default async (job: bq.Job, done: any): Promise<void> => { const { host } = new URL(job.data.to); try { + if (latest !== (latest = JSON.stringify(job.data.content, null, 2))) + queueLogger.debug(`delivering ${latest}`); + await request(job.data.user, job.data.to, job.data.content); // Update stats |