Skip to content

Commit

Permalink
Merge pull request #13 from NTF-marketplace/develop
Browse files Browse the repository at this point in the history
fix nftResponse
  • Loading branch information
min-96 authored Oct 18, 2024
2 parents bd72148 + ce2533b commit 0b37f97
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 2 deletions.
3 changes: 1 addition & 2 deletions src/main/kotlin/com/api/admin/service/TransferService.kt
Original file line number Diff line number Diff line change
Expand Up @@ -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())
}
}
}
Expand All @@ -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()
}
Expand Down
1 change: 1 addition & 0 deletions src/main/kotlin/com/api/admin/service/dto/NftResponse.kt
Original file line number Diff line number Diff line change
Expand Up @@ -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(
Expand Down

0 comments on commit 0b37f97

Please sign in to comment.