diff --git a/src/main/kotlin/com/api/admin/service/TransferService.kt b/src/main/kotlin/com/api/admin/service/TransferService.kt index e313e24..bfff3b9 100644 --- a/src/main/kotlin/com/api/admin/service/TransferService.kt +++ b/src/main/kotlin/com/api/admin/service/TransferService.kt @@ -44,8 +44,6 @@ class TransferService( Mono.error(IllegalStateException("Transaction already exists")) } else { Mono.defer { saveTransfer(wallet, chainType, transactionHash, accountType,accountLogId).then() } - .subscribeOn(Schedulers.boundedElastic()) - .then(Mono.empty()) } } } @@ -68,6 +66,7 @@ class TransferService( } .flatMap { transfer -> transferRepository.save(transfer).doOnNext { println("having ?") } .doOnSuccess {transfer -> + println("transfer : " + transfer.toString() ) eventPublisher.publishEvent(AdminTransferCreatedEvent(this, transfer.toResponse(accountId))) }.then() } diff --git a/src/main/kotlin/com/api/admin/service/dto/NftResponse.kt b/src/main/kotlin/com/api/admin/service/dto/NftResponse.kt index ac25b25..1f1752c 100644 --- a/src/main/kotlin/com/api/admin/service/dto/NftResponse.kt +++ b/src/main/kotlin/com/api/admin/service/dto/NftResponse.kt @@ -8,6 +8,7 @@ data class NftResponse( val tokenId: String, val tokenAddress: String, val chainType: ChainType, + val collectionName: String, ){ companion object{ fun NftResponse.toEntity() = Nft(