|
|
|
@@ -15,30 +15,21 @@ class UnifiedRequester(
|
|
|
|
|
suspend fun <ResultType> uniget(
|
|
|
|
|
url: String,
|
|
|
|
|
resultDeserializer: DeserializationStrategy<ResultType>
|
|
|
|
|
): ResultType = client.get<StandardKtorSerialInputData>(
|
|
|
|
|
url
|
|
|
|
|
).let {
|
|
|
|
|
serialFormat.decodeDefault(resultDeserializer, it)
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
): ResultType = client.uniget(url, resultDeserializer, serialFormat)
|
|
|
|
|
|
|
|
|
|
fun <T> encodeUrlQueryValue(
|
|
|
|
|
serializationStrategy: SerializationStrategy<T>,
|
|
|
|
|
value: T
|
|
|
|
|
) = serialFormat.encodeHex(
|
|
|
|
|
serializationStrategy,
|
|
|
|
|
value
|
|
|
|
|
) = serializationStrategy.encodeUrlQueryValue(
|
|
|
|
|
value,
|
|
|
|
|
serialFormat
|
|
|
|
|
)
|
|
|
|
|
|
|
|
|
|
suspend fun <BodyType, ResultType> unipost(
|
|
|
|
|
url: String,
|
|
|
|
|
bodyInfo: BodyPair<BodyType>,
|
|
|
|
|
resultDeserializer: DeserializationStrategy<ResultType>
|
|
|
|
|
) = client.post<StandardKtorSerialInputData>(url) {
|
|
|
|
|
body = serialFormat.encodeDefault(bodyInfo.first, bodyInfo.second)
|
|
|
|
|
}.let {
|
|
|
|
|
serialFormat.decodeDefault(resultDeserializer, it)
|
|
|
|
|
}
|
|
|
|
|
) = client.unipost(url, bodyInfo, resultDeserializer, serialFormat)
|
|
|
|
|
|
|
|
|
|
fun <T> createStandardWebsocketFlow(
|
|
|
|
|
url: String,
|
|
|
|
@@ -51,14 +42,30 @@ val defaultRequester = UnifiedRequester()
|
|
|
|
|
|
|
|
|
|
suspend fun <ResultType> HttpClient.uniget(
|
|
|
|
|
url: String,
|
|
|
|
|
resultDeserializer: DeserializationStrategy<ResultType>
|
|
|
|
|
) = defaultRequester.uniget(url, resultDeserializer)
|
|
|
|
|
resultDeserializer: DeserializationStrategy<ResultType>,
|
|
|
|
|
serialFormat: StandardKtorSerialFormat = standardKtorSerialFormat
|
|
|
|
|
) = get<StandardKtorSerialInputData>(
|
|
|
|
|
url
|
|
|
|
|
).let {
|
|
|
|
|
serialFormat.decodeDefault(resultDeserializer, it)
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
fun <T> SerializationStrategy<T>.encodeUrlQueryValue(value: T) = defaultRequester.encodeUrlQueryValue(this, value)
|
|
|
|
|
fun <T> SerializationStrategy<T>.encodeUrlQueryValue(
|
|
|
|
|
value: T,
|
|
|
|
|
serialFormat: StandardKtorSerialFormat = standardKtorSerialFormat
|
|
|
|
|
) = serialFormat.encodeHex(
|
|
|
|
|
this,
|
|
|
|
|
value
|
|
|
|
|
)
|
|
|
|
|
|
|
|
|
|
suspend fun <BodyType, ResultType> HttpClient.unipost(
|
|
|
|
|
url: String,
|
|
|
|
|
bodyInfo: BodyPair<BodyType>,
|
|
|
|
|
resultDeserializer: DeserializationStrategy<ResultType>
|
|
|
|
|
) = defaultRequester.unipost(url, bodyInfo, resultDeserializer)
|
|
|
|
|
resultDeserializer: DeserializationStrategy<ResultType>,
|
|
|
|
|
serialFormat: StandardKtorSerialFormat = standardKtorSerialFormat
|
|
|
|
|
) = post<StandardKtorSerialInputData>(url) {
|
|
|
|
|
body = serialFormat.encodeDefault(bodyInfo.first, bodyInfo.second)
|
|
|
|
|
}.let {
|
|
|
|
|
serialFormat.decodeDefault(resultDeserializer, it)
|
|
|
|
|
}
|
|
|
|
|