Function cleanupExpiredRuns

server/modules/updateAudit.js:583–632

(retentionDays)

}

async function cleanupExpiredRuns(retentionDays) {
  if (!db.UpdateRun || !db.UpdateRunEvent) {
    return { deletedRuns: 0, deletedEvents: 0 };
  }

  const parsedRetentionDays = Number.parseInt(retentionDays, 10);
  const effectiveRetentionDays = Number.isInteger(parsedRetentionDays) && parsedRetentionDays > 0
    ? parsedRetentionDays
    : 30;
  const cutoff = new Date(Date.now() - (effectiveRetentionDays * 24 * 60 * 60 * 1000));

  try {
    const expiredRuns = await db.UpdateRun.findAll({
      where: {
        startedAt: {
          [Op.lt]: cutoff,
        },
      },
      attributes: ["id"],
    });
    const runIds = expiredRuns.map((run) => run.id);

    if (runIds.length === 0) {
      return { deletedRuns: 0, deletedEvents: 0 };
    }

    const deletedEvents = await db.UpdateRunEvent.destroy({
      where: {
        runId: runIds,
      },
    });
    const deletedRuns = await db.UpdateRun.destroy({
      where: {
        id: runIds,
      },
    });

    emitStructuredAuditLog("cleanup_completed", {
      cutoff: cutoff.toISOString(),
      retentionDays: effectiveRetentionDays,
      deletedRuns,
      deletedEvents,
    });

    return { deletedRuns, deletedEvents };
  } catch (error) {
    emitAuditInternalError("[updateAudit] failed to cleanup expired runs", error);
    return { deletedRuns: 0, deletedEvents: 0 };
  }
}

module.exports = {
  createHash,