fix double parsing

vendelieu · Dec 14, 2024 · ab1565b · ab1565b
1 parent e74c952
commit ab1565b
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/src/commonMain/kotlin/eu/vendeli/rethis/commands/GeospatialCommands.kt b/src/commonMain/kotlin/eu/vendeli/rethis/commands/GeospatialCommands.kt
@@ -55,7 +55,7 @@ suspend fun ReThis.geoPos(key: String, vararg members: String): List<List<GeoPos
     ),
 ).unwrapList<RType>().map { entry ->
     entry.safeCast<RArray>()?.value?.chunked(2) {
-        GeoPosition(it.first().unwrap<Double>()!!, it.last().unwrap()!!)
+        GeoPosition(it.first().unwrap()!!, it.last().unwrap()!!)
     }
 }
 

diff --git a/src/commonMain/kotlin/eu/vendeli/rethis/utils/ResponseUtils.kt b/src/commonMain/kotlin/eu/vendeli/rethis/utils/ResponseUtils.kt
@@ -13,7 +13,7 @@ import io.ktor.utils.io.charsets.*
 import io.ktor.utils.io.core.*
 import kotlinx.io.Buffer
 import kotlinx.io.readDecimalLong
-import kotlinx.io.readDouble
+import kotlinx.io.readString
 
 internal suspend fun ByteReadChannel.readRedisMessage(charset: Charset, rawOnly: Boolean = false): RType {
     val type = RespCode.fromCode(readByte()) // Read the type byte (e.g., +, -, :, $, *)
@@ -52,7 +52,7 @@ internal suspend fun ByteReadChannel.readRedisMessage(charset: Charset, rawOnly:
             else -> exception { "Invalid boolean format: $line" }
         }
 
-        RespCode.DOUBLE -> F64(line.readDouble())
+        RespCode.DOUBLE -> F64(line.readString().toDouble())
 
         RespCode.BIG_NUMBER -> try {
             BigNumber(BigInteger.parseString(line.readText(charset)))
@@ -134,7 +134,7 @@ internal suspend fun <T> ByteReadChannel.processRedisSimpleResponse(
             else -> exception { "Invalid boolean format: $line" }
         }
 
-        RespCode.DOUBLE -> line.readDouble()
+        RespCode.DOUBLE -> line.readString().toDouble()
 
         RespCode.BIG_NUMBER -> try {
             BigInteger.parseString(line.readText(charset))