From e3c96463f1b618fa0231766337780e87694833fb Mon Sep 17 00:00:00 2001
From: Ulf Gebhardt <ulf.gebhardt@webcraft-media.de>
Date: Fri, 25 Feb 2022 20:48:03 +0100
Subject: [PATCH] clean transactions

---
 .../0028-clean_transaction_table.ts           | 81 +++++++++++++++++++
 1 file changed, 81 insertions(+)
 create mode 100644 database/migrations/0028-clean_transaction_table.ts

diff --git a/database/migrations/0028-clean_transaction_table.ts b/database/migrations/0028-clean_transaction_table.ts
new file mode 100644
index 000000000..82a5948f8
--- /dev/null
+++ b/database/migrations/0028-clean_transaction_table.ts
@@ -0,0 +1,81 @@
+/* MIGRATION TO CLEAN THE TRANSACTION TABLE
+ *
+ * This migration deletes and renames several
+ * columns of the `transactions` table.
+ *
+ * This migration has data loss
+ */
+
+/* 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>>) {
+  // Delete columns
+
+  // delete column `amount`
+  await queryFn('ALTER TABLE `transactions` DROP COLUMN `amount`;')
+  // delete column `send_sender_final_balance`
+  await queryFn('ALTER TABLE `transactions` DROP COLUMN `send_sender_final_balance`;')
+  // delete column `balance`
+  await queryFn('ALTER TABLE `transactions` DROP COLUMN `balance`;')
+  // delete column `temp_dec_send_sender_final_balance`
+  await queryFn('ALTER TABLE `transactions` DROP COLUMN `temp_dec_send_sender_final_balance`;')
+  // delete column `temp_dec_diff_send_sender_final_balance`
+  await queryFn('ALTER TABLE `transactions` DROP COLUMN `temp_dec_diff_send_sender_final_balance`;')
+  // delete column `temp_dec_old_balance`
+  await queryFn('ALTER TABLE `transactions` DROP COLUMN `temp_dec_old_balance`;')
+  // delete column `temp_dec_diff_balance`
+  await queryFn('ALTER TABLE `transactions` DROP COLUMN `temp_dec_diff_balance`;')
+
+  // Rename columns
+
+  // rename column `dec_amount` to `amount`
+  await queryFn('ALTER TABLE `transactions` RENAME COLUMN `dec_amount` to `amount`;')
+
+  // rename column `dec_balance` to `balance`
+  await queryFn('ALTER TABLE `transactions` RENAME COLUMN `dec_balance` to `balance`;')
+
+  // rename column `dec_decay` to `decay`
+  await queryFn('ALTER TABLE `transactions` RENAME COLUMN `dec_decay` to `decay`;')
+}
+
+export async function downgrade(queryFn: (query: string, values?: any[]) => Promise<Array<any>>) {
+  // Not all data is recoverable here, this data is simulated,
+  // We lose all incorrect balances and wrongly rounded amounts.
+  await queryFn('ALTER TABLE `transactions` RENAME COLUMN `decay` to `dec_decay`;')
+  await queryFn('ALTER TABLE `transactions` RENAME COLUMN `balance` to `dec_balance`;')
+  await queryFn('ALTER TABLE `transactions` RENAME COLUMN `amount` to `dec_amount`;')
+
+  await queryFn(
+    'ALTER TABLE `transactions` ADD COLUMN `temp_dec_diff_balance` decimal(40,20) DEFAULT NULL AFTER linked_transaction_id;',
+  )
+  await queryFn(
+    'ALTER TABLE `transactions` ADD COLUMN `temp_dec_old_balance` decimal(40,20) DEFAULT NULL AFTER linked_transaction_id;',
+  )
+  await queryFn(
+    'ALTER TABLE `transactions` ADD COLUMN `temp_dec_diff_send_sender_final_balance` decimal(40,20) DEFAULT NULL AFTER linked_transaction_id;',
+  )
+  await queryFn(
+    'ALTER TABLE `transactions` ADD COLUMN `temp_dec_send_sender_final_balance` decimal(40,20) DEFAULT NULL AFTER linked_transaction_id;',
+  )
+  await queryFn('ALTER TABLE `transactions` ADD COLUMN `balance` bigint(20) DEFAULT 0 AFTER memo;')
+  await queryFn(
+    'ALTER TABLE `transactions` ADD COLUMN `send_sender_final_balance` bigint(20) DEFAULT NULL memo;',
+  )
+  await queryFn(
+    'ALTER TABLE `transactions` ADD COLUMN `amount` bigint(20) DEFAULT NULL AFTER decay_start;',
+  )
+
+  await queryFn(`
+    UPDATE transaction SET
+      temp_dec_diff_balance = 0,
+      temp_dec_old_balance = dec_balance,
+      temp_dec_diff_send_sender_final_balance = 0,
+      temp_dec_send_sender_final_balance = dec_balance
+      balance = dec_balance * 10000
+      send_sender_final_balance = dec_balance * 10000
+      amount = dec_amount * 10000
+  `)
+
+  await queryFn('ALTER TABLE `transactions` MODIFY COLUMN `amount` bigint(20) NOT NULL AFTER;')
+}