From 3d245dc3af1cad73eeb49b0e2e7abb37516c3192 Mon Sep 17 00:00:00 2001
From: einhorn_b <dariofrodo@gmx.de>
Date: Fri, 15 Dec 2023 19:21:52 +0100
Subject: [PATCH] add error message column for invalid transaction

---
 .../InvalidTransaction.ts                           | 13 +++++++++++++
 dlt-database/entity/InvalidTransaction.ts           |  2 +-
 .../migrations/0003-refactor_transaction_recipe.ts  |  5 +++++
 3 files changed, 19 insertions(+), 1 deletion(-)
 create mode 100644 dlt-database/entity/0003-refactor_transaction_recipe/InvalidTransaction.ts

diff --git a/dlt-database/entity/0003-refactor_transaction_recipe/InvalidTransaction.ts b/dlt-database/entity/0003-refactor_transaction_recipe/InvalidTransaction.ts
new file mode 100644
index 000000000..e103e253f
--- /dev/null
+++ b/dlt-database/entity/0003-refactor_transaction_recipe/InvalidTransaction.ts
@@ -0,0 +1,13 @@
+import { Entity, PrimaryGeneratedColumn, Column, BaseEntity } from 'typeorm'
+
+@Entity('invalid_transactions')
+export class InvalidTransaction extends BaseEntity {
+  @PrimaryGeneratedColumn('increment', { unsigned: true, type: 'bigint' })
+  id: number
+
+  @Column({ name: 'iota_message_id', type: 'binary', length: 32 })
+  iotaMessageId: Buffer
+
+  @Column({ name: 'error_message', type: 'varchar', length: 255 })
+  errorMessage: string
+}
diff --git a/dlt-database/entity/InvalidTransaction.ts b/dlt-database/entity/InvalidTransaction.ts
index 8042e74b4..166b13adf 100644
--- a/dlt-database/entity/InvalidTransaction.ts
+++ b/dlt-database/entity/InvalidTransaction.ts
@@ -1 +1 @@
-export { InvalidTransaction } from './0001-init_db/InvalidTransaction'
+export { InvalidTransaction } from './0003-refactor_transaction_recipe/InvalidTransaction'
diff --git a/dlt-database/migrations/0003-refactor_transaction_recipe.ts b/dlt-database/migrations/0003-refactor_transaction_recipe.ts
index f51f277fd..2d3d92a23 100644
--- a/dlt-database/migrations/0003-refactor_transaction_recipe.ts
+++ b/dlt-database/migrations/0003-refactor_transaction_recipe.ts
@@ -26,6 +26,10 @@ export async function upgrade(queryFn: (query: string, values?: any[]) => Promis
     `ALTER TABLE \`accounts\` MODIFY COLUMN \`balance_confirmed_at_date\` datetime NULL DEFAULT NULL;`,
   )
 
+  await queryFn(
+    `ALTER TABLE \`invalid_transactions\` ADD COLUMN \`error_message\` varchar(255) NOT NULL;`,
+  )
+
   await queryFn(
     `CREATE TABLE \`transactions\` (
         \`id\` bigint unsigned NOT NULL AUTO_INCREMENT,
@@ -121,6 +125,7 @@ export async function downgrade(queryFn: (query: string, values?: any[]) => Prom
   )
   await queryFn(`ALTER TABLE \`accounts\` DROP COLUMN \`balance_created_at\`;`)
   await queryFn(`ALTER TABLE \`accounts\` DROP COLUMN \`balance_created_at_date\`;`)
+  await queryFn(`ALTER TABLE \`invalid_transactions\` DROP COLUMN \`error_message\`;`)
   await queryFn(`DROP TABLE \`transactions\`;`)
 
   await queryFn(