diff --git a/workers/archiver/src/index.ts b/workers/archiver/src/index.ts index 39d07e41..d45c863f 100644 --- a/workers/archiver/src/index.ts +++ b/workers/archiver/src/index.ts @@ -103,13 +103,18 @@ export default class ArchiverWorker extends Worker { const finishDate = new Date(); const dbSizeOnFinish = (await this.eventsDbConnection.stats()).dataSize; - await this.sendReport({ - dbSizeOnFinish, - dbSizeOnStart, - startDate, - projectsData, - finishDate, - }); + try { + await this.sendReport({ + dbSizeOnFinish, + dbSizeOnStart, + startDate, + projectsData, + finishDate, + }); + } catch (error) { + this.logger.error('Error sending report:', error); + } + this.logger.info(`Finish archiving at ${finishDate}.`); this.logger.info(`Database size on start: ${prettysize(dbSizeOnStart)}, on finish: ${prettysize(dbSizeOnFinish)}, delta: ${prettysize(dbSizeOnStart - dbSizeOnFinish)}`); } @@ -148,11 +153,11 @@ export default class ArchiverWorker extends Worker { await this.projectCollection.updateOne({ _id: project._id, }, - { - $inc: { - archivedEventsCount: deletedCount, - }, - }); + { + $inc: { + archivedEventsCount: deletedCount, + }, + }); } /** @@ -335,11 +340,17 @@ export default class ArchiverWorker extends Worker { report += `\n\n${totalArchivedEventsCount} events and ${totalRemovedReleasesCount} releases archived in ${archivingTimeInMinutes.toFixed(DIGITS_AFTER_POINT)} min`; report += `\nDatabase size changed from ${prettysize(reportData.dbSizeOnStart)} to ${prettysize(reportData.dbSizeOnFinish)} (–${prettysize(reportData.dbSizeOnStart - reportData.dbSizeOnFinish)})`; - await axios({ + const response = await axios({ method: 'post', url: process.env.REPORT_NOTIFY_URL, data: 'message=' + report + '&parse_mode=HTML', }); + + this.logger.info('Report notification response:', { + status: response.status, + statusText: response.statusText, + data: response.data + }); } /**