chore: rename

Signed-off-by: Uroš Marolt <uros@marolt.me>

Author: themarolt

backend/src/database/migrations/V1762773409__integrations-backup.sql

@@ -1,10 +1,10 @@
-create table "integrationsHistory" as
+create table "integrationsBackup" as
 select *
 from "integrations"
 where 1 = 2;
 
-alter table "integrationsHistory"
-    add column "historyCreatedAt" timestamptz not null default now();
+alter table "integrationsBackup"
+    add column "backupCreatedAt" timestamptz not null default now();
 
-create index if not exists ix_integration_history_integration_id on "integrationsHistory" ("id");
-create index if not exists ix_integration_history_history_created_at on "integrationsHistory" ("historyCreatedAt");
+create index if not exists ix_integration_history_integration_id on "integrationsBackup" ("id");
+create index if not exists ix_integration_history_history_created_at on "integrationsBackup" ("backupCreatedAt");

services/apps/cron_service/src/jobs/integrationsBackup.job.ts

@@ -7,13 +7,16 @@ import { IJobDefinition } from '../types'
 
 const job: IJobDefinition = {
   name: 'integrations-backup',
-  cronTime: CronTime.every(1).minutes(),
+  cronTime: CronTime.every(1).days(),
   timeout: 60 * 60, // 1 hour = 60 * 60 seconds
-  enabled: async () => true,
+  enabled: async () => IS_PROD_ENV,
   process: async (ctx) => {
     ctx.log.info('Starting integrations backup job!')
     const dbConnection = await getDbConnection(WRITE_DB_CONFIG(), 1, 0)
-    await dbConnection.query(`insert into "integrationsHistory" select * from "integrations";`)
+    await dbConnection.query(`insert into "integrationsBackup" select * from "integrations";`)
+    await dbConnection.query(
+      `delete from "integrationsBackup" where "backupCreatedAt" < now() - interval '2 months'`,
+    )
     ctx.log.info('Integrations backup job completed!')
   },
 }