removed if

rodolfodpk · Nov 19, 2024 · 3cd56bd · 3cd56bd
1 parent 11fe78e
commit 3cd56bd
Showing 1 changed file with 8 additions and 12 deletions.
diff --git a/src/main/kotlin/crablet/postgres/CrabletEventsAppender.kt b/src/main/kotlin/crablet/postgres/CrabletEventsAppender.kt
@@ -34,21 +34,17 @@ class CrabletEventsAppender(private val client: Pool) : EventsAppender {
             // Execute the prepared query, it is in transaction due to the use of #withTransaction method.
             connection.preparedQuery(functionCall)
                 .execute(params)
-        }.onComplete { resultQuery ->
-            if (resultQuery.succeeded()) {
-                val resultSet = resultQuery.result()
-                // Extract the result (last_sequence_id) from the first row
-                val latestSequenceId = resultSet.firstOrNull()?.getLong("last_sequence_id")
-                if (latestSequenceId != null) {
-                    promise.complete(SequenceNumber(latestSequenceId))
-                } else {
-                    promise.fail("No last_sequence_id returned from append_events function")
-                }
+        }.onSuccess { rowSet ->
+            // Extract the result (last_sequence_id) from the first row
+            val latestSequenceId = rowSet.firstOrNull()?.getLong("last_sequence_id")
+            if (latestSequenceId != null) {
+                promise.complete(SequenceNumber(latestSequenceId))
             } else {
-                promise.fail(resultQuery.cause())
+                promise.fail("No last_sequence_id returned from append_events function")
             }
+        }.onFailure {
+            promise.fail(it)
         }
-
         return promise.future()
     }