[DEV-839] add bankTxRepeat Tabel + migration

migration/1664968683394-addBankTxRepeatTable.js

@@ -0,0 +1,17 @@
+const { MigrationInterface, QueryRunner } = require("typeorm");
+
+module.exports = class addBankTxRepeatTable1664968683394 {
+    name = 'addBankTxRepeatTable1664968683394'
+
+    async up(queryRunner) {
+        await queryRunner.query(`CREATE TABLE "bank_tx_repeat" ("id" int NOT NULL IDENTITY(1,1), "updated" datetime2 NOT NULL CONSTRAINT "DF_0e12daa90f36e01e4fde706a574" DEFAULT getdate(), "created" datetime2 NOT NULL CONSTRAINT "DF_c015290f9f9cb210694f0de26a5" DEFAULT getdate(), "bankTxId" int NOT NULL, CONSTRAINT "PK_1007a7041835ff298a818999556" PRIMARY KEY ("id"))`);
+        await queryRunner.query(`CREATE UNIQUE INDEX "REL_9265a19ab44e83ee134738735f" ON "bank_tx_repeat" ("bankTxId") WHERE "bankTxId" IS NOT NULL`);
+        await queryRunner.query(`ALTER TABLE "bank_tx_repeat" ADD CONSTRAINT "FK_9265a19ab44e83ee134738735f3" FOREIGN KEY ("bankTxId") REFERENCES "bank_tx"("id") ON DELETE NO ACTION ON UPDATE NO ACTION`);
+    }
+
+    async down(queryRunner) {
+        await queryRunner.query(`ALTER TABLE "bank_tx_repeat" DROP CONSTRAINT "FK_9265a19ab44e83ee134738735f3"`);
+        await queryRunner.query(`DROP INDEX "REL_9265a19ab44e83ee134738735f" ON "bank_tx_repeat"`);
+        await queryRunner.query(`DROP TABLE "bank_tx_repeat"`);
+    }
+}

src/payment/models/bank-tx-repeat/bank-tx-repeat.entity.ts

@@ -0,0 +1,10 @@
+import { Entity, OneToOne, JoinColumn } from 'typeorm';
+import { IEntity } from 'src/shared/models/entity';
+import { BankTx } from '../bank-tx/bank-tx.entity';
+
+@Entity()
+export class BankTxRepeat extends IEntity {
+  @OneToOne(() => BankTx, { nullable: false })
+  @JoinColumn()
+  bankTx: BankTx;
+}

src/payment/models/bank-tx-repeat/bank-tx-repeat.repository.ts

@@ -0,0 +1,5 @@
+import { EntityRepository, Repository } from 'typeorm';
+import { BankTxRepeat } from './bank-tx-repeat.entity';
+
+@EntityRepository(BankTxRepeat)
+export class BankTxRepeatRepository extends Repository<BankTxRepeat> {}

src/payment/models/bank-tx-repeat/bank-tx-repeat.service.ts

@@ -0,0 +1,15 @@
+import { Injectable } from '@nestjs/common';
+import { BankTx } from '../bank-tx/bank-tx.entity';
+import { BankTxRepeat } from './bank-tx-repeat.entity';
+import { BankTxRepeatRepository } from './bank-tx-repeat.repository';
+
+@Injectable()
+export class BankTxRepeatService {
+  constructor(private readonly bankTxRepeatRepo: BankTxRepeatRepository) {}
+
+  async create(bankTx: BankTx): Promise<BankTxRepeat> {
+    const entity = this.bankTxRepeatRepo.create({ bankTx });
+
+    return await this.bankTxRepeatRepo.save(entity);
+  }
+}

src/payment/models/bank-tx/bank-tx.service.ts

@@ -13,6 +13,7 @@ import { SettingService } from 'src/shared/models/setting/setting.service';
 import { FrickService } from './frick.service';
 import { OlkypayService } from './olkypay.service';
 import { BankTxReturnService } from '../bank-tx-return/bank-tx-return.service';
+import { BankTxRepeatService } from '../bank-tx-repeat/bank-tx-repeat.service';
 
 @Injectable()
 export class BankTxService {
@@ -25,6 +26,7 @@ export class BankTxService {
     private readonly frickService: FrickService,
     private readonly olkyService: OlkypayService,
     private readonly bankTxReturnService: BankTxReturnService,
+    private readonly bankTxRepeatService: BankTxRepeatService,
   ) {}
 
   // --- TRANSACTION HANDLING --- //
@@ -82,6 +84,9 @@ export class BankTxService {
       case BankTxType.BANK_TX_RETURN:
         await this.bankTxReturnService.create(bankTx);
         break;
+      case BankTxType.BANK_TX_REPEAT:
+        await this.bankTxRepeatService.create(bankTx);
+        break;
     }
 
     return await this.bankTxRepo.save(bankTx);

src/payment/payment.module.ts

@@ -69,6 +69,8 @@ import { ExchangeModule } from './models/exchange/exchange.module';
 import { PricingModule } from './models/pricing/pricing.module';
 import { BankTxReturnRepository } from './models/bank-tx-return/bank-tx-return.repository';
 import { BankTxReturnService } from './models/bank-tx-return/bank-tx-return.service';
+import { BankTxRepeatRepository } from './models/bank-tx-repeat/bank-tx-repeat.repository';
+import { BankTxRepeatService } from './models/bank-tx-repeat/bank-tx-repeat.service';
 
 @Module({
   imports: [
@@ -92,6 +94,7 @@ import { BankTxReturnService } from './models/bank-tx-return/bank-tx-return.serv
       BankAccountRepository,
       CryptoRouteRepository,
       BankTxReturnRepository,
+      BankTxRepeatRepository,
     ]),
     SharedModule,
     AinModule,
@@ -153,6 +156,7 @@ import { BankTxReturnService } from './models/bank-tx-return/bank-tx-return.serv
     CryptoRouteService,
     ChainalysisService,
     BankTxReturnService,
+    BankTxRepeatService,
   ],
   exports: [
     BuyService,