KTor Gson DataConversion с интерфейсом - PullRequest
Новая
       10

KTor Gson DataConversion с интерфейсом

0 голосов
/ 17 ноября 2018

Я пытаюсь зарегистрировать интерфейс PubicKey для преобразования данных в KTor, чтобы я мог легко получить открытый ключ, подобный этому: 

data class StoreRequest(
    val publicKey: PublicKey
)
...
val publicKey: PublicKey = call.receive<StoreRequest>().publicKey

Для этого я использовал эту страницу: https://ktor.io/servers/features/data-conversion.html
Я зарегистрировал этот конвертер данных: 

convert<PublicKey> {
    decode { values, _ ->
        // When I add a breakpoint here it won't be reached.
        values.singleOrNull()?.let { key ->
            val encryptedKey = Base64.getDecoder().decode(key.split(" ")[1])
            val inputStream = DataInputStream(ByteArrayInputStream(encryptedKey))

            val format = String(ByteArray(inputStream.readInt()).also(inputStream::readFully))

            if (format != "ssh-rsa") throw RuntimeException("Unsupported format")

            val publicExponent = ByteArray(inputStream.readInt()).also(inputStream::readFully)
            val modulus = ByteArray(inputStream.readInt()).also(inputStream::readFully)

            val spec = RSAPublicKeySpec(BigInteger(modulus), BigInteger(publicExponent))
            val keyFactory = KeyFactory.getInstance("RSA")

            keyFactory.generatePublic(spec)
        }
    }
}

Но по какой-то причине Gson жалуется, потому что я использую интерфейс: 

java.lang.RuntimeException: Unable to invoke no-args constructor for interface java.security.PublicKey. Register an InstanceCreator with Gson for this type may fix this problem`

Итак, я предполагаю, что мне нужно создать InstanceCreator для начального значения. Это начальный класс PublicKey, который я создал: 

class PkTest : PublicKey {
    override fun getAlgorithm(): String = ""
    override fun getEncoded(): ByteArray = ByteArray(0)
    override fun getFormat(): String = ""
}
...
install(ContentNegotiation) {
    gson {
        setPrettyPrinting()
        registerTypeAdapter(PublicKey::class.java, InstanceCreator<PublicKey> { PkTest() // This is called when I add a breakpoint })
    }
}

Но это тоже не работает! Это исключение, которое я получаю: 

com.google.gson.JsonSyntaxException: java.lang.IllegalStateException: Expected BEGIN_OBJECT but was STRING at line 2 column 16 path $.publicKey

По какой-то причине он ожидает, что предоставленный ключ будет объектом JSON, в то время как я предоставляю следующее: 

{
    "publicKey": "ssh-rsa AAAAB3NzaC1yc2EABAADAQABAAACAQDBPL2s+25Ank3zS6iHUoVk0tS63dZM0LzAaniiDon0tdWwq4vcL4+fV8BsAEcpMeijS92JhDDc9FccXlHbdDcmd6c4ITOt9h9xxhIefGsi1FTVJ/EjVtbqF5m0bu7ruIMGvuP1p5s004roHx9y0UdHvD/yNWLISMhy4nio6jLailIj3FS53Emj1WRNsOrpja3LzPXzhuuj6YnD9yfByT7iGZipxkmleaXrknChPClLI9uhcqtAzBLdd0NVTJLOt/3+d1cSNwdBw9e53wJvpEmH+P8UOZd+oV/y7cHIej4jQpBXVvpJR1Yaluh5RuxY90B0hSescUAj5g/3HVPpR/gE7op6i9Ab//0iXF15uWGlGzipI4lA2/wYEtv8swTjmdCTMNcTDw/1huTDEzZjghIKVpskHde/Lj416c7eSByLqsMg2OhlZGChKznpIjhuNRXz93DwqKuIKvJKSnhqaJDxmDGfG7nlQ/eTwGeAZ6VR50yMPiRTIpuYd767+Nsg486z7p0pnKoBlL6ffTbfeolUX2b6Nb9ZIOxJdpCSNTQRKQ50p4Y3S580cUM1Y2EfjlfIQG1JdmTQYB75AZXi/cB2PvScmF0bXRoj7iHg4lCnSUvRprWA0xbwzCW/wjNqw6MyRX42FFlvSRrmfaxGZxKYbmk3TzBv+Fp+CADPqQm3OQ== dynmem@memmen.frl"
}

Как я могу «обмануть» GSON, приняв строку для PublicKey? Или я что-то еще не так делаю?

Я думаю, GSON хочет сериализовать объект JSON в PublicKey. Но я хочу, чтобы он принял String. Я думаю, что это должно быть возможно, потому что такие классы, как UUID и Date работают очень хорошо ...

1 Ответ

0 голосов
/ 17 ноября 2018

Я решил это!Вместо InstanceCreator я использовал JsonDeserializer: 

install(ContentNegotiation) {
    gson {
        setPrettyPrinting()
        registerTypeAdapter(PublicKey::class.java, JsonDeserializer<PublicKey> { json, _, _ ->
            // TODO some type checking.
            val key = json.asString
            val encryptedKey = Base64.getDecoder().decode(key.split(" ")[1])
            val inputStream = DataInputStream(ByteArrayInputStream(encryptedKey))

            val format = String(ByteArray(inputStream.readInt()).also(inputStream::readFully))

            if (format != "ssh-rsa") throw RuntimeException("Unsupported format")

            val publicExponent = ByteArray(inputStream.readInt()).also(inputStream::readFully)
            val modulus = ByteArray(inputStream.readInt()).also(inputStream::readFully)

            val spec = RSAPublicKeySpec(BigInteger(modulus), BigInteger(publicExponent))
            val keyFactory = KeyFactory.getInstance("RSA")

            keyFactory.generatePublic(spec)
        })
    }
}

Эта часть может быть полностью удалена: 

convert<PublicKey> {
    decode { values, _ ->
        ...
    }
}
...