Skip to content

Commit 2e27f56

Browse files
chore: added try-catch for sending report (#457) (#458)
* chore: added try-catch for sending report * added res log Co-authored-by: Vyacheslav Chernyshev <81693471+slaveeks@users.noreply.github.com>
1 parent 688da24 commit 2e27f56

File tree

1 file changed

+24
-13
lines changed

1 file changed

+24
-13
lines changed

workers/archiver/src/index.ts

Lines changed: 24 additions & 13 deletions
Original file line numberDiff line numberDiff line change
@@ -103,13 +103,18 @@ export default class ArchiverWorker extends Worker {
103103
const finishDate = new Date();
104104
const dbSizeOnFinish = (await this.eventsDbConnection.stats()).dataSize;
105105

106-
await this.sendReport({
107-
dbSizeOnFinish,
108-
dbSizeOnStart,
109-
startDate,
110-
projectsData,
111-
finishDate,
112-
});
106+
try {
107+
await this.sendReport({
108+
dbSizeOnFinish,
109+
dbSizeOnStart,
110+
startDate,
111+
projectsData,
112+
finishDate,
113+
});
114+
} catch (error) {
115+
this.logger.error('Error sending report:', error);
116+
}
117+
113118
this.logger.info(`Finish archiving at ${finishDate}.`);
114119
this.logger.info(`Database size on start: ${prettysize(dbSizeOnStart)}, on finish: ${prettysize(dbSizeOnFinish)}, delta: ${prettysize(dbSizeOnStart - dbSizeOnFinish)}`);
115120
}
@@ -148,11 +153,11 @@ export default class ArchiverWorker extends Worker {
148153
await this.projectCollection.updateOne({
149154
_id: project._id,
150155
},
151-
{
152-
$inc: {
153-
archivedEventsCount: deletedCount,
154-
},
155-
});
156+
{
157+
$inc: {
158+
archivedEventsCount: deletedCount,
159+
},
160+
});
156161
}
157162

158163
/**
@@ -335,11 +340,17 @@ export default class ArchiverWorker extends Worker {
335340
report += `\n\n<b>${totalArchivedEventsCount}</b> events and <b>${totalRemovedReleasesCount}</b> releases archived in ${archivingTimeInMinutes.toFixed(DIGITS_AFTER_POINT)} min`;
336341
report += `\nDatabase size changed from ${prettysize(reportData.dbSizeOnStart)} to ${prettysize(reportData.dbSizeOnFinish)} (–${prettysize(reportData.dbSizeOnStart - reportData.dbSizeOnFinish)})`;
337342

338-
await axios({
343+
const response = await axios({
339344
method: 'post',
340345
url: process.env.REPORT_NOTIFY_URL,
341346
data: 'message=' + report + '&parse_mode=HTML',
342347
});
348+
349+
this.logger.info('Report notification response:', {
350+
status: response.status,
351+
statusText: response.statusText,
352+
data: response.data
353+
});
343354
}
344355

345356
/**

0 commit comments

Comments
 (0)