summaryrefslogtreecommitdiff
path: root/bank/src/main/kotlin/tech/libeufin/bank/db/TanDAO.kt
diff options
context:
space:
mode:
authorAntoine A <>2024-03-16 02:23:06 +0100
committerAntoine A <>2024-03-16 02:23:06 +0100
commite292fa357724df8695b6110eec6e4a60c7986363 (patch)
tree417196f539625eeb8b805f8b8d9dc0c5783caf97 /bank/src/main/kotlin/tech/libeufin/bank/db/TanDAO.kt
parente5e718622da88f8eff5474a3c7092ee51360977e (diff)
downloadlibeufin-e292fa357724df8695b6110eec6e4a60c7986363.tar.gz
libeufin-e292fa357724df8695b6110eec6e4a60c7986363.tar.bz2
libeufin-e292fa357724df8695b6110eec6e4a60c7986363.zip
Simplify error handling for microsecond overflows that never occur in practice
Diffstat (limited to 'bank/src/main/kotlin/tech/libeufin/bank/db/TanDAO.kt')
-rw-r--r--bank/src/main/kotlin/tech/libeufin/bank/db/TanDAO.kt10
1 files changed, 5 insertions, 5 deletions
diff --git a/bank/src/main/kotlin/tech/libeufin/bank/db/TanDAO.kt b/bank/src/main/kotlin/tech/libeufin/bank/db/TanDAO.kt
index 66771c93..c7328d65 100644
--- a/bank/src/main/kotlin/tech/libeufin/bank/db/TanDAO.kt
+++ b/bank/src/main/kotlin/tech/libeufin/bank/db/TanDAO.kt
@@ -23,7 +23,7 @@ import tech.libeufin.bank.Operation
import tech.libeufin.bank.TanChannel
import tech.libeufin.bank.internalServerError
import tech.libeufin.common.oneOrNull
-import tech.libeufin.common.toDbMicros
+import tech.libeufin.common.micros
import java.time.Duration
import java.time.Instant
import java.util.concurrent.TimeUnit
@@ -46,7 +46,7 @@ class TanDAO(private val db: Database) {
stmt.setString(1, body)
stmt.setString(2, op.name)
stmt.setString(3, code)
- stmt.setLong(4, now.toDbMicros() ?: throw faultyTimestampByBank())
+ stmt.setLong(4, now.micros())
stmt.setLong(5, TimeUnit.MICROSECONDS.convert(validityPeriod))
stmt.setInt(6, retryCounter)
stmt.setString(7, login)
@@ -76,7 +76,7 @@ class TanDAO(private val db: Database) {
stmt.setLong(1, id)
stmt.setString(2, login)
stmt.setString(3, code)
- stmt.setLong(4, now.toDbMicros() ?: throw faultyTimestampByBank())
+ stmt.setLong(4, now.micros())
stmt.setLong(5, TimeUnit.MICROSECONDS.convert(validityPeriod))
stmt.setInt(6, retryCounter)
stmt.executeQuery().use {
@@ -100,7 +100,7 @@ class TanDAO(private val db: Database) {
) = db.serializable { conn ->
val stmt = conn.prepareStatement("SELECT tan_challenge_mark_sent(?,?,?)")
stmt.setLong(1, id)
- stmt.setLong(2, now.toDbMicros() ?: throw faultyTimestampByBank())
+ stmt.setLong(2, now.micros())
stmt.setLong(3, TimeUnit.MICROSECONDS.convert(retransmissionPeriod))
stmt.executeQuery()
}
@@ -129,7 +129,7 @@ class TanDAO(private val db: Database) {
stmt.setLong(1, id)
stmt.setString(2, login)
stmt.setString(3, code)
- stmt.setLong(4, now.toDbMicros() ?: throw faultyTimestampByBank())
+ stmt.setLong(4, now.micros())
stmt.executeQuery().use {
when {
!it.next() -> throw internalServerError("TAN try returned nothing")