awatertrevi/infisical
1
0
Fork 0
mirror of https://github.com/awatertrevi/infisical.git synced 2026-10-07 17:27:40 +00:00
Code Issues Packages Projects Releases Wiki Activity

update log format to make it easier to query for in cloud watch

Browse Source
This commit is contained in:
Maidul Islam
2024-01-31 13:02:09 -05:00
parent 4b3e4f6a1e
commit cb27cfdd84
1 changed files with 5 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files
backend/src/ee/services/audit-log/audit-log-queue.ts
+5 -9
View File
@@ -44,7 +44,7 @@ export const auditLogQueueServiceFactory = ({
const plan = await licenseService.getPlan(orgId); const plan = await licenseService.getPlan(orgId);
const ttl = plan.auditLogsRetentionDays * MS_IN_DAY; const ttl = plan.auditLogsRetentionDays * MS_IN_DAY;
// skip inserting if audit log retension is 0 meaning its not supported // skip inserting if audit log retention is 0 meaning its not supported
if (ttl === 0) return; if (ttl === 0) return;
await auditLogDAL.create({ await auditLogDAL.create({
actor: actor.type, actor: actor.type,
@@ -61,12 +61,9 @@ export const auditLogQueueServiceFactory = ({
}); });
queueService.start(QueueName.AuditLogPrune, async () => { queueService.start(QueueName.AuditLogPrune, async () => {
logger.info("Started audit log pruning"); logger.info(`${QueueName.AuditLogPrune}: queue task started`);
await auditLogDAL.pruneAuditLog(); await auditLogDAL.pruneAuditLog();
// calculate next utc time delay logger.info(`${QueueName.AuditLogPrune}: queue task competed`);
// const nextPruneTime = getTimeDiffForNextAuditLogPrune();
// await queueService.stopJobById(QueueName.AuditLogPrune, "audit-log-prune");
logger.info("Finished audit log pruning");
}); });
// we do a repeat cron job in utc timezone at 12 Midnight each day // we do a repeat cron job in utc timezone at 12 Midnight each day
@@ -86,9 +83,8 @@ export const auditLogQueueServiceFactory = ({
}); });
}; };
queueService.listen(QueueName.AuditLogPrune, "error", (err) => { queueService.listen(QueueName.AuditLogPrune, "failed", (err) => {
logger.error("Audit log pruning failed"); logger.error(err?.failedReason, `${QueueName.AuditLogPrune}: log pruning failed`);
logger.error(err);
}); });
return { return {