tmp delete then insert, removing after testing

provenance-io · Oct 30, 2023 · f05ef89 · f05ef89
1 parent cdf6c47
commit f05ef89
Show file tree

Hide file tree

Showing 2 changed files with 10 additions and 1 deletion.
diff --git a/service/src/main/kotlin/io/provenance/explorer/domain/entities/ExplorerCache.kt b/service/src/main/kotlin/io/provenance/explorer/domain/entities/ExplorerCache.kt
@@ -2,6 +2,7 @@ package io.provenance.explorer.domain.entities
 
 import io.provenance.explorer.OBJECT_MAPPER
 import io.provenance.explorer.domain.core.sql.jsonb
+import io.provenance.explorer.domain.extensions.startOfDay
 import io.provenance.explorer.model.ChainAum
 import io.provenance.explorer.model.ChainMarketRate
 import io.provenance.explorer.model.CmcHistoricalQuote
@@ -281,6 +282,10 @@ class TokenHistoricalDailyRecord(id: EntityID<DateTime>) : Entity<DateTime>(id)
                 .limit(1)
                 .firstOrNull()
         }
+
+        fun deleteByDate(date: DateTime) = transaction {
+            TokenHistoricalDailyTable.deleteWhere { TokenHistoricalDailyTable.timestamp eq date.startOfDay() }
+        }
     }
 
     var timestamp by TokenHistoricalDailyTable.timestamp

diff --git a/service/src/main/kotlin/io/provenance/explorer/service/async/AsyncService.kt b/service/src/main/kotlin/io/provenance/explorer/service/async/AsyncService.kt
@@ -307,6 +307,8 @@ class AsyncService(
             .map { it to emptyList<DlobHistorical>() }.toMap().toMutableMap()
         var prevPrice = TokenHistoricalDailyRecord.lastKnownPriceForDate(startDate)
 
+        TokenHistoricalDailyRecord
+
         baseMap.putAll(
             dlobRes.buy
                 .filter { DateTime(it.trade_timestamp * 1000).startOfDay() != today }
@@ -339,7 +341,9 @@ class AsyncService(
                         )
                 )
             ).also { prevPrice = close }
-            TokenHistoricalDailyRecord.save(record.time_open.startOfDay(), record)
+            TokenHistoricalDailyRecord.deleteByDate(record.time_open.startOfDay())
+            val id = TokenHistoricalDailyRecord.save(record.time_open.startOfDay(), record)
+            logger.info("saving record ${record.time_open.startOfDay()} $record insert count ${id.insertedCount}")
         }
     }