add hash to transaction

Author: alexey-kadach

src/main/kotlin/io/openfuture/api/component/web3/TransactionHandler.kt

@@ -29,9 +29,10 @@ class TransactionHandler(
     @Transactional
     fun handle(transactionLog: Log) {
         val contract = repository.findByAddressIgnoreCase(transactionLog.address) ?: return
+        if (null != service.find(transactionLog.transactionHash)) return
+        val transaction = service.save(Transaction.of(contract, transactionLog))
 
         try {
-            val transaction = service.save(Transaction.of(contract, transactionLog))
             val event = eventDecoder.getEvent(contract.address, transaction.data)
             val transactionDto = TransactionDto(transaction, event)
             contract.webHook?.let { RestTemplate().postForLocation(it, transactionDto) }

src/main/kotlin/io/openfuture/api/entity/scaffold/Transaction.kt

@@ -9,6 +9,9 @@ import javax.persistence.*
 @Table(name = "transactions")
 class Transaction(
 
+        @Column(name = "hash", nullable = false, unique = true)
+        val hash: String,
+
         @ManyToOne
         @JoinColumn(name = "scaffold_id", nullable = false)
         val scaffold: Scaffold,
@@ -22,7 +25,7 @@ class Transaction(
 ) : BaseModel() {
 
     companion object {
-        fun of(scaffold: Scaffold, log: Log): Transaction = Transaction(scaffold, log.data)
+        fun of(scaffold: Scaffold, log: Log): Transaction = Transaction(log.transactionHash, scaffold, log.data)
     }
 
 }

src/main/kotlin/io/openfuture/api/repository/Repository.kt

@@ -51,6 +51,8 @@ interface TransactionRepository : BaseRepository<Transaction> {
 
     fun findAllByScaffoldOrderByDateDesc(scaffold: Scaffold, pageable: Pageable): Page<Transaction>
 
+    fun findByHash(hash: String): Transaction?
+
 }
 
 @Repository

src/main/kotlin/io/openfuture/api/service/DefaultTransactionService.kt

@@ -17,6 +17,9 @@ class DefaultTransactionService(
     override fun getAll(scaffold: Scaffold, pageRequest: Pageable): Page<Transaction> =
             repository.findAllByScaffoldOrderByDateDesc(scaffold, pageRequest)
 
+    @Transactional(readOnly = true)
+    override fun find(hash: String): Transaction? = repository.findByHash(hash)
+
     @Transactional
     override fun save(transaction: Transaction): Transaction = repository.save(transaction)
 

src/main/kotlin/io/openfuture/api/service/Service.kt

@@ -83,6 +83,8 @@ interface TransactionService {
 
     fun getAll(scaffold: Scaffold, pageRequest: Pageable): Page<Transaction>
 
+    fun find(hash: String): Transaction?
+
     fun save(transaction: Transaction): Transaction
 
 }

src/main/resources/db/migration/V1_15__add_hash_to_transaction.sql

@@ -0,0 +1,3 @@
+TRUNCATE transactions;
+
+ALTER TABLE transactions ADD COLUMN hash VARCHAR NOT NULL UNIQUE;