From eb404cf8b3e0d106f18a12883a00bccb4e9dfc57 Mon Sep 17 00:00:00 2001
From: Moriz Wahl <moriz.wahl@gmx.de>
Date: Wed, 13 Jul 2022 14:30:46 +0200
Subject: [PATCH] add migrations to insert contributions to all transactions
 with type creation that do not have a contribution yet

---
 .../0043-insert_missing_contributions.ts      | 34 +++++++++++++++++++
 1 file changed, 34 insertions(+)
 create mode 100644 database/migrations/0043-insert_missing_contributions.ts

diff --git a/database/migrations/0043-insert_missing_contributions.ts b/database/migrations/0043-insert_missing_contributions.ts
new file mode 100644
index 000000000..a14141498
--- /dev/null
+++ b/database/migrations/0043-insert_missing_contributions.ts
@@ -0,0 +1,34 @@
+/* MIGRATION TO INSERT contributions for all transactions with type creation that do not have a contribution yet */
+
+/* eslint-disable @typescript-eslint/explicit-module-boundary-types */
+/* eslint-disable @typescript-eslint/no-explicit-any */
+
+export async function upgrade(queryFn: (query: string, values?: any[]) => Promise<Array<any>>) {
+  await queryFn(
+    `INSERT INTO gradido_community.contributions
+  (user_id, created_at, contribution_date, memo, amount, moderator_id, confirmed_by, confirmed_at, transaction_id)
+SELECT 
+  user_id,
+  balance_date,
+  creation_date AS contribution_date,
+  memo,
+  amount,
+  20 AS moderator_id,
+  502 AS confirmed_by,
+  balance_date AS confirmed_at,
+  id
+FROM
+  gradido_community.transactions
+WHERE
+  type_id = 1
+  AND NOT EXISTS(
+    SELECT * FROM gradido_community.contributions
+    WHERE gradido_community.contributions.transaction_id = gradido_community.transactions.id);`,
+  )
+}
+
+export async function downgrade(queryFn: (query: string, values?: any[]) => Promise<Array<any>>) {
+  await queryFn(
+    'DELETE FROM `contributions` WHERE `contributions`.`moderator_id` = 20 AND `contributions`.`confirmed_by` = 502 AND `contributions`.`created_at` = `contributions`.`confirmed_at`;',
+  )
+}