[DEV-3493] userData in transaction

src/shared/services/process.service.ts

@@ -53,6 +53,7 @@ export enum Process {
   PAYMENT_CONFIRMATIONS = 'PaymentConfirmations',
   FIAT_OUTPUT_COMPLETE = 'FiatOutputComplete',
   BLOCKCHAIN_FEE_UPDATE = 'BlockchainFeeUpdate',
+  TRANSACTION_USER_SYNC = 'TransactionUserSync',
 }
 
 type ProcessMap = { [p in Process]?: boolean };

src/subdomains/supporting/payment/entities/transaction.entity.ts

@@ -116,6 +116,9 @@ export class Transaction extends IEntity {
   @ManyToOne(() => User, (user) => user.transactions, { nullable: true, eager: true })
   user?: User;
 
+  @ManyToOne(() => UserData, (userData) => userData.kycSteps, { nullable: true })
+  userData: UserData;
+
   @OneToOne(() => TransactionRequest, { nullable: true })
   @JoinColumn()
   request?: TransactionRequest;
@@ -160,8 +163,4 @@ export class Transaction extends IEntity {
   get targetEntity(): BuyCrypto | BuyFiat | RefReward | BankTxReturn | undefined {
     return this.buyCrypto ?? this.buyFiat ?? this.refReward ?? this.bankTxReturn ?? undefined;
   }
-
-  get userData(): UserData {
-    return this.user?.userData;
-  }
 }

src/subdomains/supporting/payment/services/transaction.service.ts

@@ -1,4 +1,8 @@
 import { Injectable } from '@nestjs/common';
+import { Cron, CronExpression } from '@nestjs/schedule';
+import { DfxLogger } from 'src/shared/services/dfx-logger';
+import { DisabledProcess, Process } from 'src/shared/services/process.service';
+import { Lock } from 'src/shared/utils/lock';
 import { Util } from 'src/shared/utils/util';
 import { UpdateTransactionDto } from 'src/subdomains/core/history/dto/update-transaction.dto';
 import { Between, FindOptionsRelations, IsNull, LessThanOrEqual, Not } from 'typeorm';
@@ -9,8 +13,30 @@ import { TransactionRepository } from '../repositories/transaction.repository';
 
 @Injectable()
 export class TransactionService {
+  private readonly logger = new DfxLogger(TransactionService);
+
   constructor(private readonly repo: TransactionRepository) {}
 
+  @Cron(CronExpression.EVERY_MINUTE)
+  @Lock()
+  async syncUserData(): Promise<void> {
+    if (DisabledProcess(Process.TRANSACTION_USER_SYNC)) return;
+
+    const entities = await this.repo.find({
+      where: { user: { id: Not(IsNull()) }, userData: { id: IsNull() } },
+      relations: { user: { userData: true }, userData: true },
+      take: 10000,
+    });
+
+    for (const entity of entities) {
+      try {
+        await this.repo.update(entity.id, { userData: entity.user.userData });
+      } catch (e) {
+        this.logger.error(`Failed to sync transaction userData ${entity.id}:`, e);
+      }
+    }
+  }
+
   async create(dto: CreateTransactionDto): Promise<Transaction | undefined> {
     const entity = this.repo.create(dto);