BitKeeper beta release

Author: satiracode

build.gradle

@@ -20,8 +20,6 @@ repositories {
 }
 
 dependencies {
-    implementation("io.quarkus:quarkus-picocli")
-    implementation 'org.jline:jline:3.29.0'
     implementation 'io.quarkiverse.loggingsentry:quarkus-logging-sentry:2.1.3'
     implementation enforcedPlatform("${quarkusPlatformGroupId}:${quarkusPlatformArtifactId}:${quarkusPlatformVersion}")
     implementation 'io.quarkus:quarkus-rest'
@@ -38,10 +36,13 @@ dependencies {
 
     implementation 'com.fasterxml.jackson.module:jackson-module-kotlin:2.18.3'
 
-    implementation 'org.exploit.threshield:gg20:0.0.6'
-    implementation 'org.exploit.threshield:frost:0.0.6'
-    implementation 'org.exploit.threshield:ed25519:0.0.6'
-    implementation 'org.exploit.threshield:core:0.0.6'
+    implementation 'org.exploit.tss:gg20:0.0.1-patch1'
+    implementation 'org.exploit.tss:frost:0.0.1-patch1'
+
+    implementation 'org.exploit.tss:ed25519:0.0.1-patch1'
+    implementation 'org.exploit.tss:secp256k1:0.0.1-patch1'
+
+    implementation 'org.exploit.tss:core:0.0.1-patch1'
 
     implementation 'com.nimbusds:nimbus-jose-jwt:10.2'
 
@@ -76,6 +77,16 @@ allOpen {
     annotation("io.quarkus.test.junit.QuarkusTest")
 }
 
+configurations.configureEach {
+    resolutionStrategy {
+        force(
+                "net.java.dev.jna:jna:5.17.0",
+                "net.java.dev.jna:jna-platform:5.17.0",
+                "org.exploit:crypto:0.0.9-patch1",
+        )
+    }
+}
+
 compileKotlin {
     kotlinOptions.jvmTarget = JavaVersion.VERSION_17
     kotlinOptions.javaParameters = true

src/main/kotlin/org/exploit/keeper/api/CentralApi.kt

@@ -3,9 +3,10 @@ package org.exploit.keeper.api
 import org.eclipse.jetty.http.HttpMethod
 import org.exploit.jettyx.annotation.HttpRequest
 import org.exploit.jettyx.model.HttpResponse
+import org.exploit.keeper.model.health.ShortStatus
 import java.util.concurrent.CompletableFuture
 
 interface CentralApi {
     @HttpRequest(path = "/v1/keeper/ping", method = HttpMethod.GET)
-    fun health(): CompletableFuture<HttpResponse<Void>>
+    fun health(): CompletableFuture<HttpResponse<ShortStatus>>
 }

src/main/kotlin/org/exploit/keeper/api/FrostApi.kt

@@ -4,33 +4,34 @@ import org.eclipse.jetty.http.HttpMethod
 import org.exploit.jettyx.annotation.Body
 import org.exploit.jettyx.annotation.HttpRequest
 import org.exploit.jettyx.annotation.Query
+import org.exploit.jettyx.model.HttpResponse
 import org.exploit.keeper.model.common.InitSession
 import org.exploit.keeper.model.frost.ComputedZ
 import org.exploit.keeper.model.frost.FrostOperationCommitment
 import java.util.concurrent.CompletableFuture
 
 interface FrostApi {
     @HttpRequest(method = HttpMethod.POST, path = "/v1/frost/init")
-    fun init(@Body body: InitSession): CompletableFuture<Void>
+    fun init(@Body body: InitSession): CompletableFuture<HttpResponse<Void>>
 
     @HttpRequest(method = HttpMethod.POST, path = "/v1/frost/commitment")
     fun storeCommitment(
         @Query("sessionId") sessionId: String,
         @Body body: FrostOperationCommitment
-    ): CompletableFuture<Void>
+    ): CompletableFuture<HttpResponse<Void>>
 
     @HttpRequest(method = HttpMethod.POST, path = "/v1/frost/commitment/broadcast")
     fun broadcast(
         @Query("sessionId") sessionId: String
-    ): CompletableFuture<Void>
+    ): CompletableFuture<HttpResponse<Void>>
 
     @HttpRequest(method = HttpMethod.GET, path = "/v1/frost/signature/z")
     fun computeZ(
         @Query("sessionId") sessionId: String
-    ): CompletableFuture<ComputedZ>
+    ): CompletableFuture<HttpResponse<ComputedZ>>
 
     @HttpRequest(method = HttpMethod.GET, path = "/v1/frost/abort")
     fun abort(
         @Query("sessionId") sessionId: String
-    ): CompletableFuture<Void>
+    ): CompletableFuture<HttpResponse<Void>>
 }

src/main/kotlin/org/exploit/keeper/api/GG20Api.kt

@@ -1,66 +1,67 @@
 package org.exploit.keeper.api
 
 import org.eclipse.jetty.http.HttpMethod
+import org.exploit.gmp.BigInt
 import org.exploit.jettyx.annotation.Body
 import org.exploit.jettyx.annotation.ContentType
 import org.exploit.jettyx.annotation.HttpRequest
 import org.exploit.jettyx.annotation.Query
+import org.exploit.jettyx.model.HttpResponse
 import org.exploit.keeper.model.common.InitSession
 import org.exploit.keeper.model.common.Value
 import org.exploit.keeper.model.gg20.commitment.GG20GammaCommitmentDto
 import org.exploit.keeper.model.gg20.commitment.GG20OfflinePhaseData
 import org.exploit.keeper.model.gg20.mta.GG20MtAComputeRequest
 import org.exploit.keeper.model.gg20.mta.GG20MtAResult
-import java.math.BigInteger
 import java.util.concurrent.CompletableFuture
 
 interface GG20Api {
     @ContentType("application/json")
     @HttpRequest(method = HttpMethod.POST, path = "/v1/gg20/init")
-    fun init(@Body session: InitSession): CompletableFuture<Void>
+    fun init(@Body session: InitSession): CompletableFuture<HttpResponse<Void>>
 
     @ContentType("application/json")
     @HttpRequest(method = HttpMethod.POST, path = "/v1/gg20/commitment")
     fun storeCommitment(
         @Query("sessionId") sessionId: String,
         @Body body: GG20GammaCommitmentDto
-    ): CompletableFuture<Void>
+    ): CompletableFuture<HttpResponse<Void>>
 
     @HttpRequest(method = HttpMethod.POST, path = "/v1/gg20/commitment/broadcast")
     fun broadcastCommitment(
         @Query("sessionId") sessionId: String
-    ): CompletableFuture<Void>
+    ): CompletableFuture<HttpResponse<Void>>
 
     @HttpRequest(method = HttpMethod.POST, path = "/v1/gg20/mta/exchange")
     fun exchangeMta(
         @Query("sessionId") sessionId: String
-    ): CompletableFuture<Void>
+    ): CompletableFuture<HttpResponse<Void>>
 
     @ContentType("application/json")
     @HttpRequest(method = HttpMethod.POST, path = "/v1/gg20/mta/compute")
     fun computeMta(
         @Body request: GG20MtAComputeRequest
-    ): CompletableFuture<GG20MtAResult>
+    ): CompletableFuture<HttpResponse<GG20MtAResult>>
 
     @ContentType("application/json")
     @HttpRequest(method = HttpMethod.POST, path = "/v1/gg20/prephase")
     fun storeOfflinePhase(
         @Query("sessionId") sessionId: String,
         @Body data: GG20OfflinePhaseData
-    ): CompletableFuture<Void>
+    ): CompletableFuture<HttpResponse<Void>>
 
     @HttpRequest(method = HttpMethod.POST, path = "/v1/gg20/prephase/broadcast")
     fun broadcastOfflinePhase(
         @Query("sessionId") sessionId: String
-    ): CompletableFuture<Void>
+    ): CompletableFuture<HttpResponse<Void>>
 
     @HttpRequest(method = HttpMethod.GET, path = "/v1/gg20/signature/s")
     fun computeS(
         @Query("sessionId") sessionId: String
-    ): CompletableFuture<Value<BigInteger>>
+    ): CompletableFuture<HttpResponse<Value<BigInt>>>
 
     @HttpRequest(method = HttpMethod.POST, path = "/v1/gg20/abort")
     fun abort(
         @Query("sessionId") sessionId: String
-    ): CompletableFuture<Void>
+    ): CompletableFuture<HttpResponse<Void>>
 }

src/main/kotlin/org/exploit/keeper/api/KeyGenApi.kt

@@ -3,23 +3,24 @@ package org.exploit.keeper.api
 import org.eclipse.jetty.http.HttpMethod
 import org.exploit.jettyx.annotation.HttpRequest
 import org.exploit.jettyx.annotation.Query
+import org.exploit.jettyx.model.HttpResponse
 import org.exploit.keeper.constant.CurveName
 import org.exploit.keeper.model.keygen.ShamirShareDto
 import java.util.concurrent.CompletableFuture
 
 interface KeyGenApi {
     @HttpRequest(path = "/v1/keygen/init", method = HttpMethod.POST)
-    fun init(@Query("keyId") keyId: String, @Query("curve") curve: CurveName, @Query("overwrite") overwrite: Boolean): CompletableFuture<Void>
+    fun init(@Query("keyId") keyId: String, @Query("curve") curve: CurveName, @Query("overwrite") overwrite: Boolean): CompletableFuture<HttpResponse<Void>>
 
     @HttpRequest(path = "/v1/keygen/share", method = HttpMethod.GET)
-    fun share(@Query("keyId") keyId: String): CompletableFuture<ShamirShareDto>
+    fun share(@Query("keyId") keyId: String): CompletableFuture<HttpResponse<ShamirShareDto>>
 
     @HttpRequest(path = "/v1/keygen/collect", method = HttpMethod.POST)
-    fun collect(@Query("keyId") keyId: String): CompletableFuture<Void>
+    fun collect(@Query("keyId") keyId: String): CompletableFuture<HttpResponse<Void>>
 
     @HttpRequest(path = "/v1/keygen/compute", method = HttpMethod.POST)
-    fun compute(@Query("keyId") keyId: String): CompletableFuture<Void>
+    fun compute(@Query("keyId") keyId: String): CompletableFuture<HttpResponse<Void>>
 
     @HttpRequest(path = "/v1/keygen/abort", method = HttpMethod.POST)
-    fun abort(@Query("keyId") keyId: String): CompletableFuture<Void>
+    fun abort(@Query("keyId") keyId: String): CompletableFuture<HttpResponse<Void>>
 }

src/main/kotlin/org/exploit/keeper/api/PublicKeyApi.kt

@@ -3,10 +3,11 @@ package org.exploit.keeper.api
 import org.eclipse.jetty.http.HttpMethod
 import org.exploit.jettyx.annotation.HttpRequest
 import org.exploit.jettyx.annotation.Path
+import org.exploit.jettyx.model.HttpResponse
 import org.exploit.keeper.model.PublicKeyDto
 import java.util.concurrent.CompletableFuture
 
 interface PublicKeyApi {
     @HttpRequest(method = HttpMethod.GET, path = "/v1/publicKey/{keyId}")
-    fun getPublicKeyShare(@Path("keyId") keyId: String): CompletableFuture<PublicKeyDto>
+    fun getPublicKeyShare(@Path("keyId") keyId: String): CompletableFuture<HttpResponse<PublicKeyDto>>
 }

src/main/kotlin/org/exploit/keeper/api/client/BitKeeperClient.kt

@@ -8,7 +8,7 @@ import org.exploit.keeper.api.*
 import org.exploit.keeper.api.auth.KeeperAuthenticator
 import org.exploit.keeper.extension.decodeBase64
 import org.exploit.keeper.extension.toSchnorrSignature
-import org.exploit.threshield.exception.IdentifiableAbortException
+import org.exploit.tss.exception.IdentifiableAbortException
 
 class BitKeeperClient(val peerId: Int, private val publicKey: Ed25519PublicKey, auth: KeeperAuthenticator, url: String, jettyx: Jettyx) {
     val frost: FrostApi by lazy {

src/main/kotlin/org/exploit/keeper/component/BouncyCastleInit.kt

@@ -1,10 +1,16 @@
 package org.exploit.keeper.component
 
+import com.fasterxml.jackson.core.JsonGenerator
+import com.fasterxml.jackson.core.JsonParser
+import com.fasterxml.jackson.core.JsonToken
 import com.fasterxml.jackson.core.StreamReadConstraints
-import com.fasterxml.jackson.databind.ObjectMapper
+import com.fasterxml.jackson.databind.*
+import com.fasterxml.jackson.databind.module.SimpleModule
 import com.fasterxml.jackson.module.kotlin.registerKotlinModule
 import io.quarkus.jackson.ObjectMapperCustomizer
 import jakarta.inject.Singleton
+import org.exploit.gmp.BigInt
+
 
 @Singleton
 class JacksonCustomizer: ObjectMapperCustomizer {
@@ -16,6 +22,65 @@ class JacksonCustomizer: ObjectMapperCustomizer {
                     .build()
             )
 
+        objectMapper.registerModule(
+            SimpleModule()
+                .addSerializer(BigInt::class.java, BigIntHexSerializer())
+                .addDeserializer(BigInt::class.java, BigIntHexDeserializer())
+        )
+
         objectMapper.registerKotlinModule()
     }
+
+    class BigIntHexSerializer : JsonSerializer<BigInt>() {
+        override fun serialize(value: BigInt?, gen: JsonGenerator, serializers: SerializerProvider?) {
+            if (value == null) {
+                gen.writeNull()
+                return
+            }
+
+            var hex = value.toJavaInt().abs().toString(16)
+            if (value.signum() < 0) {
+                hex = "-$hex"
+            }
+            gen.writeString(hex)
+        }
+
+        override fun handledType(): Class<BigInt> {
+            return BigInt::class.java
+        }
+    }
+
+    class BigIntHexDeserializer : JsonDeserializer<BigInt>() {
+        override fun deserialize(p: JsonParser, ctxt: DeserializationContext): BigInt? {
+            if (p.currentToken() === JsonToken.VALUE_NULL) {
+                return null
+            }
+
+            var text: String
+            if (p.currentToken().isNumeric) {
+                text = p.numberValue.toString()
+                return BigInt(text, 10)
+            } else {
+                text = p.valueAsString.trim()
+            }
+
+            val negative = text.startsWith("-")
+            if (negative) {
+                text = text.substring(1)
+            }
+            if (text.startsWith("0x") || text.startsWith("0X")) {
+                text = text.substring(2)
+            }
+            if (text.isEmpty()) {
+                throw ctxt.weirdStringException(text, BigInt::class.java, "empty hexadecimal value")
+            }
+
+            val result = BigInt(text, 16)
+            return if (negative) result.negate() else result
+        }
+
+        override fun handledType(): Class<*> {
+            return BigInt::class.java
+        }
+    }
 }