chore: automatic integrations table backups

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

Author: themarolt

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

@@ -0,0 +1,10 @@
+create table "integrationsHistory" as
+select *
+from "integrations"
+where 1 = 2;
+
+alter table "integrationsHistory"
+    add column "historyCreatedAt" 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");

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

@@ -0,0 +1,21 @@
+import CronTime from 'cron-time-generator'
+
+import { IS_PROD_ENV } from '@crowd/common'
+import { WRITE_DB_CONFIG, getDbConnection } from '@crowd/data-access-layer/src/database'
+
+import { IJobDefinition } from '../types'
+
+const job: IJobDefinition = {
+  name: 'integrations-backup',
+  cronTime: CronTime.every(1).minutes(),
+  timeout: 60 * 60, // 1 hour = 60 * 60 seconds
+  enabled: async () => true,
+  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";`)
+    ctx.log.info('Integrations backup job completed!')
+  },
+}
+
+export default job