From af80bd56ff5f23399b1f53a4b51da0f068bbfd2f Mon Sep 17 00:00:00 2001
From: einhorn_b <dariofrodo@gmx.de>
Date: Wed, 30 Aug 2023 15:24:54 +0200
Subject: [PATCH] add invalid transaction table

---
 dlt-database/entity/0001-init_db/Account.ts            |  3 +--
 dlt-database/entity/0001-init_db/InvalidTransaction.ts | 10 ++++++++++
 dlt-database/entity/InvalidTransaction.ts              |  1 +
 dlt-database/migrations/0001-init_db.ts                |  9 +++++++++
 4 files changed, 21 insertions(+), 2 deletions(-)
 create mode 100644 dlt-database/entity/0001-init_db/InvalidTransaction.ts
 create mode 100644 dlt-database/entity/InvalidTransaction.ts

diff --git a/dlt-database/entity/0001-init_db/Account.ts b/dlt-database/entity/0001-init_db/Account.ts
index ae7e8c8ec..81abb5ba7 100644
--- a/dlt-database/entity/0001-init_db/Account.ts
+++ b/dlt-database/entity/0001-init_db/Account.ts
@@ -5,7 +5,6 @@ import {
   CreateDateColumn,
   ManyToOne,
   JoinColumn,
-  OneToOne,
   OneToMany,
   ManyToMany,
   JoinTable,
@@ -15,7 +14,7 @@ import { Community } from './Community'
 import { TransactionRecipe } from './TransactionRecipe'
 import { ConfirmedTransaction } from './ConfirmedTransaction'
 import { DecimalTransformer } from '../../src/typeorm/DecimalTransformer'
-import Decimal from 'decimal.js-light'
+import { Decimal } from 'decimal.js-light'
 
 @Entity('accounts')
 export class Account {
diff --git a/dlt-database/entity/0001-init_db/InvalidTransaction.ts b/dlt-database/entity/0001-init_db/InvalidTransaction.ts
new file mode 100644
index 000000000..cfea858a1
--- /dev/null
+++ b/dlt-database/entity/0001-init_db/InvalidTransaction.ts
@@ -0,0 +1,10 @@
+import { Entity, PrimaryGeneratedColumn, Column } from 'typeorm'
+
+@Entity('invalid_transactions')
+export class InvalidTransaction {
+  @PrimaryGeneratedColumn('increment', { unsigned: true, type: 'bigint' })
+  id: number
+
+  @Column({ name: 'iota_message_id', type: 'binary', length: 32, nullable: true })
+  iotaMessageId?: Buffer
+}
diff --git a/dlt-database/entity/InvalidTransaction.ts b/dlt-database/entity/InvalidTransaction.ts
new file mode 100644
index 000000000..8042e74b4
--- /dev/null
+++ b/dlt-database/entity/InvalidTransaction.ts
@@ -0,0 +1 @@
+export { InvalidTransaction } from './0001-init_db/InvalidTransaction'
diff --git a/dlt-database/migrations/0001-init_db.ts b/dlt-database/migrations/0001-init_db.ts
index a7f31ac9b..245e3b95c 100644
--- a/dlt-database/migrations/0001-init_db.ts
+++ b/dlt-database/migrations/0001-init_db.ts
@@ -108,6 +108,14 @@ export async function upgrade(queryFn: (query: string, values?: any[]) => Promis
       FOREIGN KEY (\`transaction_recipe_id\`) REFERENCES transaction_recipes(id),
       FOREIGN KEY (\`account_id\`) REFERENCES accounts(id)
     ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_unicode_ci;`)
+
+  await queryFn(`
+    CREATE TABLE IF NOT EXISTS \`invalid_transactions\` (
+      \`id\` bigint unsigned NOT NULL AUTO_INCREMENT,
+      \`iota_message_id\` binary(32) DEFAULT NULL,
+      PRIMARY KEY (\`id\`),
+      INDEX (\`iota_message_id\`)
+    ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_unicode_ci;`)
 }
 
 export async function downgrade(queryFn: (query: string, values?: any[]) => Promise<Array<any>>) {
@@ -118,4 +126,5 @@ export async function downgrade(queryFn: (query: string, values?: any[]) => Prom
   await queryFn(`DROP TABLE IF EXISTS \`transaction_recipes\`;`)
   await queryFn(`DROP TABLE IF EXISTS \`confirmed_transactions\`;`)
   await queryFn(`DROP TABLE IF EXISTS \`community\`;`)
+  await queryFn(`DROP TABLE IF EXISTS \`invalid_transactions\`;`)
 }