mirror of
https://github.com/InsanusMokrassar/MicroUtils.git
synced 2024-11-25 03:28:46 +00:00
Compare commits
15 Commits
333f91477c
...
52a38daae1
Author | SHA1 | Date | |
---|---|---|---|
|
52a38daae1 | ||
1dca5ea00d | |||
f03d1d788c | |||
fcac6f9fa8 | |||
ca0cd433c9 | |||
39589fdbd0 | |||
605fc3cff9 | |||
12cd6f48f8 | |||
1f57478d10 | |||
7ef4c5d282 | |||
25391609b9 | |||
f0b7b9c5e5 | |||
301cdaa2c2 | |||
fce7ec8912 | |||
24bd403549 |
4
.github/workflows/build.yml
vendored
4
.github/workflows/build.yml
vendored
@ -17,8 +17,8 @@ jobs:
|
|||||||
mv gradle.properties.tmp gradle.properties
|
mv gradle.properties.tmp gradle.properties
|
||||||
- name: Build
|
- name: Build
|
||||||
run: ./gradlew build
|
run: ./gradlew build
|
||||||
- name: Publish
|
- name: Publish to InmoNexus
|
||||||
continue-on-error: true
|
continue-on-error: true
|
||||||
run: ./gradlew publishAllPublicationsToGiteaRepository
|
run: ./gradlew publishAllPublicationsToInmoNexusRepository
|
||||||
env:
|
env:
|
||||||
GITEA_TOKEN: ${{ secrets.GITEA_TOKEN }}
|
GITEA_TOKEN: ${{ secrets.GITEA_TOKEN }}
|
||||||
|
24
CHANGELOG.md
24
CHANGELOG.md
@ -1,5 +1,29 @@
|
|||||||
# Changelog
|
# Changelog
|
||||||
|
|
||||||
|
## 0.23.0
|
||||||
|
|
||||||
|
**THIS UPDATE MAY CONTAINS SOME BREAKING CHANGES (INCLUDING BREAKING CHANGES IN BYTECODE LAYER) RELATED TO UPDATE OF
|
||||||
|
KTOR DEPENDENCY**
|
||||||
|
|
||||||
|
**THIS UPDATE CONTAINS CHANGES ACCORDING TO MIGRATION [GUIDE FROM KTOR](https://ktor.io/docs/migrating-3.html)**
|
||||||
|
|
||||||
|
* `Versions`:
|
||||||
|
* `Ktor`: `2.3.12` -> `3.0.1`
|
||||||
|
* `Ktor`:
|
||||||
|
* `Common`:
|
||||||
|
* Extension `Input.downloadToTempFile` has changed its receiver to `Source`. Its API can be broken
|
||||||
|
* `Client`:
|
||||||
|
* Extension `HttpClient.tempUpload` has changed type of `onUpload` argument from `OnUploadCallback` to `ProgressListener`
|
||||||
|
* All extensions `HttpClient.uniUpload` have changed type of `onUpload` argument from `OnUploadCallback` to `ProgressListener`
|
||||||
|
* `Server`:
|
||||||
|
* Remove redundant `ApplicationCall.respond` extension due to its presence in the ktor library
|
||||||
|
|
||||||
|
## 0.22.9
|
||||||
|
|
||||||
|
* `Repos`:
|
||||||
|
* `Cache`:
|
||||||
|
* Add direct caching repos
|
||||||
|
|
||||||
## 0.22.8
|
## 0.22.8
|
||||||
|
|
||||||
* `Common`:
|
* `Common`:
|
||||||
|
@ -15,5 +15,5 @@ crypto_js_version=4.1.1
|
|||||||
# Project data
|
# Project data
|
||||||
|
|
||||||
group=dev.inmo
|
group=dev.inmo
|
||||||
version=0.22.8
|
version=0.23.0
|
||||||
android_code_version=274
|
android_code_version=276
|
||||||
|
@ -6,7 +6,7 @@ kt-coroutines = "1.9.0"
|
|||||||
|
|
||||||
kslog = "1.3.6"
|
kslog = "1.3.6"
|
||||||
|
|
||||||
jb-compose = "1.7.1+build1894-release-1.7.1"
|
jb-compose = "1.7.1+build1910-release-1.7.1"
|
||||||
jb-exposed = "0.55.0"
|
jb-exposed = "0.55.0"
|
||||||
jb-dokka = "1.9.20"
|
jb-dokka = "1.9.20"
|
||||||
|
|
||||||
@ -15,7 +15,7 @@ sqlite = "3.46.1.3"
|
|||||||
korlibs = "5.4.0"
|
korlibs = "5.4.0"
|
||||||
uuid = "0.8.4"
|
uuid = "0.8.4"
|
||||||
|
|
||||||
ktor = "2.3.12"
|
ktor = "3.0.1"
|
||||||
|
|
||||||
gh-release = "2.5.2"
|
gh-release = "2.5.2"
|
||||||
|
|
||||||
@ -23,7 +23,7 @@ koin = "4.0.0"
|
|||||||
|
|
||||||
okio = "3.9.1"
|
okio = "3.9.1"
|
||||||
|
|
||||||
ksp = "2.0.21-1.0.25"
|
ksp = "2.0.21-1.0.26"
|
||||||
kotlin-poet = "1.18.1"
|
kotlin-poet = "1.18.1"
|
||||||
|
|
||||||
versions = "0.51.0"
|
versions = "0.51.0"
|
||||||
|
@ -3,9 +3,10 @@ package dev.inmo.micro_utils.ktor.client
|
|||||||
import dev.inmo.micro_utils.common.MPPFile
|
import dev.inmo.micro_utils.common.MPPFile
|
||||||
import dev.inmo.micro_utils.ktor.common.*
|
import dev.inmo.micro_utils.ktor.common.*
|
||||||
import io.ktor.client.HttpClient
|
import io.ktor.client.HttpClient
|
||||||
|
import io.ktor.client.content.*
|
||||||
|
|
||||||
expect suspend fun HttpClient.tempUpload(
|
expect suspend fun HttpClient.tempUpload(
|
||||||
fullTempUploadDraftPath: String,
|
fullTempUploadDraftPath: String,
|
||||||
file: MPPFile,
|
file: MPPFile,
|
||||||
onUpload: OnUploadCallback = { _, _ -> }
|
onUpload: ProgressListener = ProgressListener { _, _ -> }
|
||||||
): TemporalFileId
|
): TemporalFileId
|
||||||
|
@ -4,8 +4,8 @@ import dev.inmo.micro_utils.common.FileName
|
|||||||
import dev.inmo.micro_utils.common.MPPFile
|
import dev.inmo.micro_utils.common.MPPFile
|
||||||
import dev.inmo.micro_utils.ktor.common.LambdaInputProvider
|
import dev.inmo.micro_utils.ktor.common.LambdaInputProvider
|
||||||
import io.ktor.client.HttpClient
|
import io.ktor.client.HttpClient
|
||||||
|
import io.ktor.client.content.*
|
||||||
import io.ktor.http.Headers
|
import io.ktor.http.Headers
|
||||||
import io.ktor.utils.io.core.Input
|
|
||||||
import kotlinx.serialization.DeserializationStrategy
|
import kotlinx.serialization.DeserializationStrategy
|
||||||
import kotlinx.serialization.StringFormat
|
import kotlinx.serialization.StringFormat
|
||||||
import kotlinx.serialization.json.Json
|
import kotlinx.serialization.json.Json
|
||||||
@ -31,7 +31,7 @@ expect suspend fun <T> HttpClient.uniUpload(
|
|||||||
resultDeserializer: DeserializationStrategy<T>,
|
resultDeserializer: DeserializationStrategy<T>,
|
||||||
headers: Headers = Headers.Empty,
|
headers: Headers = Headers.Empty,
|
||||||
stringFormat: StringFormat = Json,
|
stringFormat: StringFormat = Json,
|
||||||
onUpload: OnUploadCallback = { _, _ -> }
|
onUpload: ProgressListener = ProgressListener { _, _ -> }
|
||||||
): T?
|
): T?
|
||||||
|
|
||||||
/**
|
/**
|
||||||
@ -46,7 +46,7 @@ suspend fun <T> HttpClient.uniUpload(
|
|||||||
additionalData: Map<String, Any> = emptyMap(),
|
additionalData: Map<String, Any> = emptyMap(),
|
||||||
headers: Headers = Headers.Empty,
|
headers: Headers = Headers.Empty,
|
||||||
stringFormat: StringFormat = Json,
|
stringFormat: StringFormat = Json,
|
||||||
onUpload: OnUploadCallback = { _, _ -> }
|
onUpload: ProgressListener = ProgressListener { _, _ -> }
|
||||||
): T? = uniUpload(
|
): T? = uniUpload(
|
||||||
url,
|
url,
|
||||||
additionalData + ("bytes" to file),
|
additionalData + ("bytes" to file),
|
||||||
@ -68,7 +68,7 @@ suspend fun <T> HttpClient.uniUpload(
|
|||||||
additionalData: Map<String, Any> = emptyMap(),
|
additionalData: Map<String, Any> = emptyMap(),
|
||||||
headers: Headers = Headers.Empty,
|
headers: Headers = Headers.Empty,
|
||||||
stringFormat: StringFormat = Json,
|
stringFormat: StringFormat = Json,
|
||||||
onUpload: OnUploadCallback = { _, _ -> }
|
onUpload: ProgressListener = ProgressListener { _, _ -> }
|
||||||
): T? = uniUpload(
|
): T? = uniUpload(
|
||||||
url,
|
url,
|
||||||
additionalData + ("bytes" to info),
|
additionalData + ("bytes" to info),
|
||||||
@ -93,7 +93,7 @@ suspend fun <T> HttpClient.uniUpload(
|
|||||||
additionalData: Map<String, Any> = emptyMap(),
|
additionalData: Map<String, Any> = emptyMap(),
|
||||||
headers: Headers = Headers.Empty,
|
headers: Headers = Headers.Empty,
|
||||||
stringFormat: StringFormat = Json,
|
stringFormat: StringFormat = Json,
|
||||||
onUpload: OnUploadCallback = { _, _ -> }
|
onUpload: ProgressListener = ProgressListener { _, _ -> }
|
||||||
): T? = uniUpload(
|
): T? = uniUpload(
|
||||||
url,
|
url,
|
||||||
UniUploadFileInfo(fileName, mimeType, inputAllocator),
|
UniUploadFileInfo(fileName, mimeType, inputAllocator),
|
||||||
|
@ -5,16 +5,15 @@ import dev.inmo.micro_utils.coroutines.LinkedSupervisorJob
|
|||||||
import dev.inmo.micro_utils.coroutines.launchSafelyWithoutExceptions
|
import dev.inmo.micro_utils.coroutines.launchSafelyWithoutExceptions
|
||||||
import dev.inmo.micro_utils.ktor.common.TemporalFileId
|
import dev.inmo.micro_utils.ktor.common.TemporalFileId
|
||||||
import io.ktor.client.HttpClient
|
import io.ktor.client.HttpClient
|
||||||
|
import io.ktor.client.content.*
|
||||||
import kotlinx.coroutines.*
|
import kotlinx.coroutines.*
|
||||||
import org.w3c.dom.mediasource.ENDED
|
|
||||||
import org.w3c.dom.mediasource.ReadyState
|
|
||||||
import org.w3c.xhr.*
|
import org.w3c.xhr.*
|
||||||
import org.w3c.xhr.XMLHttpRequest.Companion.DONE
|
import org.w3c.xhr.XMLHttpRequest.Companion.DONE
|
||||||
|
|
||||||
suspend fun tempUpload(
|
suspend fun tempUpload(
|
||||||
fullTempUploadDraftPath: String,
|
fullTempUploadDraftPath: String,
|
||||||
file: MPPFile,
|
file: MPPFile,
|
||||||
onUpload: OnUploadCallback
|
onUpload: ProgressListener
|
||||||
): TemporalFileId {
|
): TemporalFileId {
|
||||||
val formData = FormData()
|
val formData = FormData()
|
||||||
val answer = CompletableDeferred<TemporalFileId>(currentCoroutineContext().job)
|
val answer = CompletableDeferred<TemporalFileId>(currentCoroutineContext().job)
|
||||||
@ -28,7 +27,7 @@ suspend fun tempUpload(
|
|||||||
val request = XMLHttpRequest()
|
val request = XMLHttpRequest()
|
||||||
request.responseType = XMLHttpRequestResponseType.TEXT
|
request.responseType = XMLHttpRequestResponseType.TEXT
|
||||||
request.upload.onprogress = {
|
request.upload.onprogress = {
|
||||||
subscope.launchSafelyWithoutExceptions { onUpload(it.loaded.toLong(), it.total.toLong()) }
|
subscope.launchSafelyWithoutExceptions { onUpload.onProgress(it.loaded.toLong(), it.total.toLong()) }
|
||||||
}
|
}
|
||||||
request.onload = {
|
request.onload = {
|
||||||
if (request.status == 200.toShort()) {
|
if (request.status == 200.toShort()) {
|
||||||
@ -60,5 +59,5 @@ suspend fun tempUpload(
|
|||||||
actual suspend fun HttpClient.tempUpload(
|
actual suspend fun HttpClient.tempUpload(
|
||||||
fullTempUploadDraftPath: String,
|
fullTempUploadDraftPath: String,
|
||||||
file: MPPFile,
|
file: MPPFile,
|
||||||
onUpload: OnUploadCallback
|
onUpload: ProgressListener
|
||||||
): TemporalFileId = dev.inmo.micro_utils.ktor.client.tempUpload(fullTempUploadDraftPath, file, onUpload)
|
): TemporalFileId = dev.inmo.micro_utils.ktor.client.tempUpload(fullTempUploadDraftPath, file, onUpload)
|
||||||
|
@ -1,10 +1,10 @@
|
|||||||
package dev.inmo.micro_utils.ktor.client
|
package dev.inmo.micro_utils.ktor.client
|
||||||
|
|
||||||
import dev.inmo.micro_utils.common.MPPFile
|
import dev.inmo.micro_utils.common.MPPFile
|
||||||
import dev.inmo.micro_utils.common.Progress
|
|
||||||
import dev.inmo.micro_utils.coroutines.LinkedSupervisorJob
|
import dev.inmo.micro_utils.coroutines.LinkedSupervisorJob
|
||||||
import dev.inmo.micro_utils.coroutines.launchSafelyWithoutExceptions
|
import dev.inmo.micro_utils.coroutines.launchSafelyWithoutExceptions
|
||||||
import io.ktor.client.HttpClient
|
import io.ktor.client.HttpClient
|
||||||
|
import io.ktor.client.content.*
|
||||||
import io.ktor.http.Headers
|
import io.ktor.http.Headers
|
||||||
import io.ktor.utils.io.core.readBytes
|
import io.ktor.utils.io.core.readBytes
|
||||||
import kotlinx.coroutines.CompletableDeferred
|
import kotlinx.coroutines.CompletableDeferred
|
||||||
@ -36,7 +36,7 @@ actual suspend fun <T> HttpClient.uniUpload(
|
|||||||
resultDeserializer: DeserializationStrategy<T>,
|
resultDeserializer: DeserializationStrategy<T>,
|
||||||
headers: Headers,
|
headers: Headers,
|
||||||
stringFormat: StringFormat,
|
stringFormat: StringFormat,
|
||||||
onUpload: OnUploadCallback
|
onUpload: ProgressListener
|
||||||
): T? {
|
): T? {
|
||||||
val formData = FormData()
|
val formData = FormData()
|
||||||
val answer = CompletableDeferred<T?>(currentCoroutineContext().job)
|
val answer = CompletableDeferred<T?>(currentCoroutineContext().job)
|
||||||
@ -66,7 +66,7 @@ actual suspend fun <T> HttpClient.uniUpload(
|
|||||||
}
|
}
|
||||||
request.responseType = XMLHttpRequestResponseType.TEXT
|
request.responseType = XMLHttpRequestResponseType.TEXT
|
||||||
request.upload.onprogress = {
|
request.upload.onprogress = {
|
||||||
subscope.launchSafelyWithoutExceptions { onUpload(it.loaded.toLong(), it.total.toLong()) }
|
subscope.launchSafelyWithoutExceptions { onUpload.onProgress(it.loaded.toLong(), it.total.toLong()) }
|
||||||
}
|
}
|
||||||
request.onload = {
|
request.onload = {
|
||||||
if (request.status == 200.toShort()) {
|
if (request.status == 200.toShort()) {
|
||||||
|
@ -4,6 +4,7 @@ import dev.inmo.micro_utils.common.MPPFile
|
|||||||
import dev.inmo.micro_utils.common.filename
|
import dev.inmo.micro_utils.common.filename
|
||||||
import dev.inmo.micro_utils.ktor.common.TemporalFileId
|
import dev.inmo.micro_utils.ktor.common.TemporalFileId
|
||||||
import io.ktor.client.HttpClient
|
import io.ktor.client.HttpClient
|
||||||
|
import io.ktor.client.content.*
|
||||||
import io.ktor.client.plugins.onUpload
|
import io.ktor.client.plugins.onUpload
|
||||||
import io.ktor.client.request.forms.formData
|
import io.ktor.client.request.forms.formData
|
||||||
import io.ktor.client.request.forms.submitFormWithBinaryData
|
import io.ktor.client.request.forms.submitFormWithBinaryData
|
||||||
@ -18,7 +19,7 @@ internal val MPPFile.mimeType: String
|
|||||||
actual suspend fun HttpClient.tempUpload(
|
actual suspend fun HttpClient.tempUpload(
|
||||||
fullTempUploadDraftPath: String,
|
fullTempUploadDraftPath: String,
|
||||||
file: MPPFile,
|
file: MPPFile,
|
||||||
onUpload: OnUploadCallback
|
onUpload: ProgressListener
|
||||||
): TemporalFileId {
|
): TemporalFileId {
|
||||||
val inputProvider = file.inputProvider()
|
val inputProvider = file.inputProvider()
|
||||||
val fileId = submitFormWithBinaryData(
|
val fileId = submitFormWithBinaryData(
|
||||||
|
@ -1,8 +1,7 @@
|
|||||||
package dev.inmo.micro_utils.ktor.client
|
package dev.inmo.micro_utils.ktor.client
|
||||||
|
|
||||||
import dev.inmo.micro_utils.common.Progress
|
|
||||||
import io.ktor.client.HttpClient
|
import io.ktor.client.HttpClient
|
||||||
import io.ktor.client.engine.mergeHeaders
|
import io.ktor.client.content.*
|
||||||
import io.ktor.client.plugins.onUpload
|
import io.ktor.client.plugins.onUpload
|
||||||
import io.ktor.client.request.HttpRequestBuilder
|
import io.ktor.client.request.HttpRequestBuilder
|
||||||
import io.ktor.client.request.forms.InputProvider
|
import io.ktor.client.request.forms.InputProvider
|
||||||
@ -20,7 +19,6 @@ import kotlinx.serialization.DeserializationStrategy
|
|||||||
import kotlinx.serialization.InternalSerializationApi
|
import kotlinx.serialization.InternalSerializationApi
|
||||||
import kotlinx.serialization.SerializationStrategy
|
import kotlinx.serialization.SerializationStrategy
|
||||||
import kotlinx.serialization.StringFormat
|
import kotlinx.serialization.StringFormat
|
||||||
import kotlinx.serialization.encodeToString
|
|
||||||
import kotlinx.serialization.serializer
|
import kotlinx.serialization.serializer
|
||||||
import java.io.File
|
import java.io.File
|
||||||
|
|
||||||
@ -39,7 +37,7 @@ actual suspend fun <T> HttpClient.uniUpload(
|
|||||||
resultDeserializer: DeserializationStrategy<T>,
|
resultDeserializer: DeserializationStrategy<T>,
|
||||||
headers: Headers,
|
headers: Headers,
|
||||||
stringFormat: StringFormat,
|
stringFormat: StringFormat,
|
||||||
onUpload: OnUploadCallback
|
onUpload: ProgressListener
|
||||||
): T? {
|
): T? {
|
||||||
val withBinary = data.values.any { it is File || it is UniUploadFileInfo }
|
val withBinary = data.values.any { it is File || it is UniUploadFileInfo }
|
||||||
|
|
||||||
@ -76,7 +74,7 @@ actual suspend fun <T> HttpClient.uniUpload(
|
|||||||
appendAll(headers)
|
appendAll(headers)
|
||||||
}
|
}
|
||||||
onUpload { bytesSentTotal, contentLength ->
|
onUpload { bytesSentTotal, contentLength ->
|
||||||
onUpload(bytesSentTotal, contentLength)
|
onUpload.onProgress(bytesSentTotal, contentLength)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -5,6 +5,7 @@ import dev.inmo.micro_utils.common.filename
|
|||||||
import dev.inmo.micro_utils.ktor.common.TemporalFileId
|
import dev.inmo.micro_utils.ktor.common.TemporalFileId
|
||||||
import dev.inmo.micro_utils.mime_types.getMimeTypeOrAny
|
import dev.inmo.micro_utils.mime_types.getMimeTypeOrAny
|
||||||
import io.ktor.client.HttpClient
|
import io.ktor.client.HttpClient
|
||||||
|
import io.ktor.client.content.*
|
||||||
import io.ktor.client.plugins.onUpload
|
import io.ktor.client.plugins.onUpload
|
||||||
import io.ktor.client.request.forms.formData
|
import io.ktor.client.request.forms.formData
|
||||||
import io.ktor.client.request.forms.submitFormWithBinaryData
|
import io.ktor.client.request.forms.submitFormWithBinaryData
|
||||||
@ -18,7 +19,7 @@ internal val MPPFile.mimeType: String
|
|||||||
actual suspend fun HttpClient.tempUpload(
|
actual suspend fun HttpClient.tempUpload(
|
||||||
fullTempUploadDraftPath: String,
|
fullTempUploadDraftPath: String,
|
||||||
file: MPPFile,
|
file: MPPFile,
|
||||||
onUpload: OnUploadCallback
|
onUpload: ProgressListener
|
||||||
): TemporalFileId {
|
): TemporalFileId {
|
||||||
val inputProvider = file.inputProvider()
|
val inputProvider = file.inputProvider()
|
||||||
val fileId = submitFormWithBinaryData(
|
val fileId = submitFormWithBinaryData(
|
||||||
|
@ -1,9 +1,8 @@
|
|||||||
package dev.inmo.micro_utils.ktor.client
|
package dev.inmo.micro_utils.ktor.client
|
||||||
|
|
||||||
import dev.inmo.micro_utils.common.MPPFile
|
import dev.inmo.micro_utils.common.MPPFile
|
||||||
import dev.inmo.micro_utils.common.Progress
|
|
||||||
import io.ktor.client.HttpClient
|
import io.ktor.client.HttpClient
|
||||||
import io.ktor.client.engine.mergeHeaders
|
import io.ktor.client.content.*
|
||||||
import io.ktor.client.plugins.onUpload
|
import io.ktor.client.plugins.onUpload
|
||||||
import io.ktor.client.request.HttpRequestBuilder
|
import io.ktor.client.request.HttpRequestBuilder
|
||||||
import io.ktor.client.request.forms.InputProvider
|
import io.ktor.client.request.forms.InputProvider
|
||||||
@ -21,7 +20,6 @@ import kotlinx.serialization.DeserializationStrategy
|
|||||||
import kotlinx.serialization.InternalSerializationApi
|
import kotlinx.serialization.InternalSerializationApi
|
||||||
import kotlinx.serialization.SerializationStrategy
|
import kotlinx.serialization.SerializationStrategy
|
||||||
import kotlinx.serialization.StringFormat
|
import kotlinx.serialization.StringFormat
|
||||||
import kotlinx.serialization.encodeToString
|
|
||||||
import kotlinx.serialization.serializer
|
import kotlinx.serialization.serializer
|
||||||
|
|
||||||
/**
|
/**
|
||||||
@ -39,7 +37,7 @@ actual suspend fun <T> HttpClient.uniUpload(
|
|||||||
resultDeserializer: DeserializationStrategy<T>,
|
resultDeserializer: DeserializationStrategy<T>,
|
||||||
headers: Headers,
|
headers: Headers,
|
||||||
stringFormat: StringFormat,
|
stringFormat: StringFormat,
|
||||||
onUpload: OnUploadCallback
|
onUpload: ProgressListener
|
||||||
): T? {
|
): T? {
|
||||||
val withBinary = data.values.any { it is MPPFile || it is UniUploadFileInfo }
|
val withBinary = data.values.any { it is MPPFile || it is UniUploadFileInfo }
|
||||||
|
|
||||||
@ -75,9 +73,7 @@ actual suspend fun <T> HttpClient.uniUpload(
|
|||||||
headers {
|
headers {
|
||||||
appendAll(headers)
|
appendAll(headers)
|
||||||
}
|
}
|
||||||
onUpload { bytesSentTotal, contentLength ->
|
onUpload(onUpload)
|
||||||
onUpload(bytesSentTotal, contentLength)
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
|
||||||
val response = if (withBinary) {
|
val response = if (withBinary) {
|
||||||
|
@ -5,6 +5,7 @@ import dev.inmo.micro_utils.common.filename
|
|||||||
import dev.inmo.micro_utils.ktor.common.TemporalFileId
|
import dev.inmo.micro_utils.ktor.common.TemporalFileId
|
||||||
import dev.inmo.micro_utils.mime_types.getMimeTypeOrAny
|
import dev.inmo.micro_utils.mime_types.getMimeTypeOrAny
|
||||||
import io.ktor.client.HttpClient
|
import io.ktor.client.HttpClient
|
||||||
|
import io.ktor.client.content.*
|
||||||
import io.ktor.client.plugins.onUpload
|
import io.ktor.client.plugins.onUpload
|
||||||
import io.ktor.client.request.forms.formData
|
import io.ktor.client.request.forms.formData
|
||||||
import io.ktor.client.request.forms.submitFormWithBinaryData
|
import io.ktor.client.request.forms.submitFormWithBinaryData
|
||||||
@ -18,7 +19,7 @@ internal val MPPFile.mimeType: String
|
|||||||
actual suspend fun HttpClient.tempUpload(
|
actual suspend fun HttpClient.tempUpload(
|
||||||
fullTempUploadDraftPath: String,
|
fullTempUploadDraftPath: String,
|
||||||
file: MPPFile,
|
file: MPPFile,
|
||||||
onUpload: OnUploadCallback
|
onUpload: ProgressListener
|
||||||
): TemporalFileId {
|
): TemporalFileId {
|
||||||
val inputProvider = file.inputProvider()
|
val inputProvider = file.inputProvider()
|
||||||
val fileId = submitFormWithBinaryData(
|
val fileId = submitFormWithBinaryData(
|
||||||
|
@ -1,9 +1,8 @@
|
|||||||
package dev.inmo.micro_utils.ktor.client
|
package dev.inmo.micro_utils.ktor.client
|
||||||
|
|
||||||
import dev.inmo.micro_utils.common.MPPFile
|
import dev.inmo.micro_utils.common.MPPFile
|
||||||
import dev.inmo.micro_utils.common.Progress
|
|
||||||
import io.ktor.client.HttpClient
|
import io.ktor.client.HttpClient
|
||||||
import io.ktor.client.engine.mergeHeaders
|
import io.ktor.client.content.*
|
||||||
import io.ktor.client.plugins.onUpload
|
import io.ktor.client.plugins.onUpload
|
||||||
import io.ktor.client.request.HttpRequestBuilder
|
import io.ktor.client.request.HttpRequestBuilder
|
||||||
import io.ktor.client.request.forms.InputProvider
|
import io.ktor.client.request.forms.InputProvider
|
||||||
@ -21,7 +20,6 @@ import kotlinx.serialization.DeserializationStrategy
|
|||||||
import kotlinx.serialization.InternalSerializationApi
|
import kotlinx.serialization.InternalSerializationApi
|
||||||
import kotlinx.serialization.SerializationStrategy
|
import kotlinx.serialization.SerializationStrategy
|
||||||
import kotlinx.serialization.StringFormat
|
import kotlinx.serialization.StringFormat
|
||||||
import kotlinx.serialization.encodeToString
|
|
||||||
import kotlinx.serialization.serializer
|
import kotlinx.serialization.serializer
|
||||||
|
|
||||||
/**
|
/**
|
||||||
@ -39,7 +37,7 @@ actual suspend fun <T> HttpClient.uniUpload(
|
|||||||
resultDeserializer: DeserializationStrategy<T>,
|
resultDeserializer: DeserializationStrategy<T>,
|
||||||
headers: Headers,
|
headers: Headers,
|
||||||
stringFormat: StringFormat,
|
stringFormat: StringFormat,
|
||||||
onUpload: OnUploadCallback
|
onUpload: ProgressListener
|
||||||
): T? {
|
): T? {
|
||||||
val withBinary = data.values.any { it is MPPFile || it is UniUploadFileInfo }
|
val withBinary = data.values.any { it is MPPFile || it is UniUploadFileInfo }
|
||||||
|
|
||||||
@ -75,9 +73,7 @@ actual suspend fun <T> HttpClient.uniUpload(
|
|||||||
headers {
|
headers {
|
||||||
appendAll(headers)
|
appendAll(headers)
|
||||||
}
|
}
|
||||||
onUpload { bytesSentTotal, contentLength ->
|
onUpload(onUpload)
|
||||||
onUpload(bytesSentTotal, contentLength)
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
|
||||||
val response = if (withBinary) {
|
val response = if (withBinary) {
|
||||||
|
@ -5,6 +5,7 @@ import dev.inmo.micro_utils.common.filename
|
|||||||
import dev.inmo.micro_utils.ktor.common.TemporalFileId
|
import dev.inmo.micro_utils.ktor.common.TemporalFileId
|
||||||
import dev.inmo.micro_utils.mime_types.getMimeTypeOrAny
|
import dev.inmo.micro_utils.mime_types.getMimeTypeOrAny
|
||||||
import io.ktor.client.HttpClient
|
import io.ktor.client.HttpClient
|
||||||
|
import io.ktor.client.content.*
|
||||||
import io.ktor.client.plugins.onUpload
|
import io.ktor.client.plugins.onUpload
|
||||||
import io.ktor.client.request.forms.formData
|
import io.ktor.client.request.forms.formData
|
||||||
import io.ktor.client.request.forms.submitFormWithBinaryData
|
import io.ktor.client.request.forms.submitFormWithBinaryData
|
||||||
@ -18,7 +19,7 @@ internal val MPPFile.mimeType: String
|
|||||||
actual suspend fun HttpClient.tempUpload(
|
actual suspend fun HttpClient.tempUpload(
|
||||||
fullTempUploadDraftPath: String,
|
fullTempUploadDraftPath: String,
|
||||||
file: MPPFile,
|
file: MPPFile,
|
||||||
onUpload: OnUploadCallback
|
onUpload: ProgressListener
|
||||||
): TemporalFileId {
|
): TemporalFileId {
|
||||||
val inputProvider = file.inputProvider()
|
val inputProvider = file.inputProvider()
|
||||||
val fileId = submitFormWithBinaryData(
|
val fileId = submitFormWithBinaryData(
|
||||||
|
@ -1,9 +1,8 @@
|
|||||||
package dev.inmo.micro_utils.ktor.client
|
package dev.inmo.micro_utils.ktor.client
|
||||||
|
|
||||||
import dev.inmo.micro_utils.common.MPPFile
|
import dev.inmo.micro_utils.common.MPPFile
|
||||||
import dev.inmo.micro_utils.common.Progress
|
|
||||||
import io.ktor.client.HttpClient
|
import io.ktor.client.HttpClient
|
||||||
import io.ktor.client.engine.mergeHeaders
|
import io.ktor.client.content.*
|
||||||
import io.ktor.client.plugins.onUpload
|
import io.ktor.client.plugins.onUpload
|
||||||
import io.ktor.client.request.HttpRequestBuilder
|
import io.ktor.client.request.HttpRequestBuilder
|
||||||
import io.ktor.client.request.forms.InputProvider
|
import io.ktor.client.request.forms.InputProvider
|
||||||
@ -21,7 +20,6 @@ import kotlinx.serialization.DeserializationStrategy
|
|||||||
import kotlinx.serialization.InternalSerializationApi
|
import kotlinx.serialization.InternalSerializationApi
|
||||||
import kotlinx.serialization.SerializationStrategy
|
import kotlinx.serialization.SerializationStrategy
|
||||||
import kotlinx.serialization.StringFormat
|
import kotlinx.serialization.StringFormat
|
||||||
import kotlinx.serialization.encodeToString
|
|
||||||
import kotlinx.serialization.serializer
|
import kotlinx.serialization.serializer
|
||||||
|
|
||||||
/**
|
/**
|
||||||
@ -39,7 +37,7 @@ actual suspend fun <T> HttpClient.uniUpload(
|
|||||||
resultDeserializer: DeserializationStrategy<T>,
|
resultDeserializer: DeserializationStrategy<T>,
|
||||||
headers: Headers,
|
headers: Headers,
|
||||||
stringFormat: StringFormat,
|
stringFormat: StringFormat,
|
||||||
onUpload: OnUploadCallback
|
onUpload: ProgressListener
|
||||||
): T? {
|
): T? {
|
||||||
val withBinary = data.values.any { it is MPPFile || it is UniUploadFileInfo }
|
val withBinary = data.values.any { it is MPPFile || it is UniUploadFileInfo }
|
||||||
|
|
||||||
@ -75,9 +73,7 @@ actual suspend fun <T> HttpClient.uniUpload(
|
|||||||
headers {
|
headers {
|
||||||
appendAll(headers)
|
appendAll(headers)
|
||||||
}
|
}
|
||||||
onUpload { bytesSentTotal, contentLength ->
|
onUpload(onUpload)
|
||||||
onUpload(bytesSentTotal, contentLength)
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
|
||||||
val response = if (withBinary) {
|
val response = if (withBinary) {
|
||||||
|
@ -1,13 +1,12 @@
|
|||||||
package dev.inmo.micro_utils.ktor.common
|
package dev.inmo.micro_utils.ktor.common
|
||||||
|
|
||||||
import io.ktor.utils.io.core.Input
|
import io.ktor.utils.io.streams.*
|
||||||
import io.ktor.utils.io.core.copyTo
|
import kotlinx.io.Source
|
||||||
import io.ktor.utils.io.streams.asOutput
|
import kotlinx.io.readTo
|
||||||
import java.io.File
|
import java.io.File
|
||||||
import java.io.InputStream
|
|
||||||
import java.util.UUID
|
import java.util.UUID
|
||||||
|
|
||||||
fun Input.downloadToTempFile(
|
fun Source.downloadToTempFile(
|
||||||
fileName: String = UUID.randomUUID().toString(),
|
fileName: String = UUID.randomUUID().toString(),
|
||||||
fileExtension: String? = ".temp",
|
fileExtension: String? = ".temp",
|
||||||
folder: File? = null
|
folder: File? = null
|
||||||
@ -17,7 +16,7 @@ fun Input.downloadToTempFile(
|
|||||||
folder
|
folder
|
||||||
).apply {
|
).apply {
|
||||||
outputStream().use {
|
outputStream().use {
|
||||||
copyTo(it.asOutput())
|
it.writePacket(this@downloadToTempFile)
|
||||||
}
|
}
|
||||||
deleteOnExit()
|
deleteOnExit()
|
||||||
}
|
}
|
||||||
|
@ -1,15 +0,0 @@
|
|||||||
package dev.inmo.micro_utils.ktor.server
|
|
||||||
|
|
||||||
import io.ktor.server.application.ApplicationCall
|
|
||||||
import io.ktor.server.response.responseType
|
|
||||||
import io.ktor.util.InternalAPI
|
|
||||||
import io.ktor.util.reflect.TypeInfo
|
|
||||||
|
|
||||||
@InternalAPI
|
|
||||||
suspend fun <T : Any> ApplicationCall.respond(
|
|
||||||
message: T,
|
|
||||||
typeInfo: TypeInfo
|
|
||||||
) {
|
|
||||||
response.responseType = typeInfo
|
|
||||||
response.pipeline.execute(this, message as Any)
|
|
||||||
}
|
|
@ -4,13 +4,13 @@ import com.benasher44.uuid.uuid4
|
|||||||
import io.ktor.http.content.PartData
|
import io.ktor.http.content.PartData
|
||||||
import io.ktor.utils.io.copyTo
|
import io.ktor.utils.io.copyTo
|
||||||
import io.ktor.utils.io.core.copyTo
|
import io.ktor.utils.io.core.copyTo
|
||||||
import io.ktor.utils.io.jvm.javaio.copyTo
|
import io.ktor.utils.io.jvm.javaio.*
|
||||||
import io.ktor.utils.io.streams.asOutput
|
import io.ktor.utils.io.streams.*
|
||||||
import java.io.File
|
import java.io.File
|
||||||
|
|
||||||
fun PartData.FileItem.download(target: File) {
|
fun PartData.FileItem.download(target: File) {
|
||||||
provider().use { input ->
|
provider().toInputStream().use { input ->
|
||||||
target.outputStream().asOutput().use {
|
target.outputStream().use {
|
||||||
input.copyTo(it)
|
input.copyTo(it)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@ -25,9 +25,9 @@ fun PartData.FileItem.downloadToTemporalFile(): File {
|
|||||||
}
|
}
|
||||||
|
|
||||||
fun PartData.BinaryItem.download(target: File) {
|
fun PartData.BinaryItem.download(target: File) {
|
||||||
provider().use { input ->
|
provider().inputStream().use { input ->
|
||||||
target.outputStream().use {
|
target.outputStream().use {
|
||||||
input.copyTo(it.asOutput())
|
input.copyTo(it)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
@ -1,7 +1,7 @@
|
|||||||
package dev.inmo.micro_utils.ktor.server
|
package dev.inmo.micro_utils.ktor.server
|
||||||
|
|
||||||
import dev.inmo.micro_utils.ktor.server.configurators.KtorApplicationConfigurator
|
import dev.inmo.micro_utils.ktor.server.configurators.KtorApplicationConfigurator
|
||||||
import io.ktor.server.application.Application
|
import io.ktor.server.application.*
|
||||||
import io.ktor.server.cio.CIO
|
import io.ktor.server.cio.CIO
|
||||||
import io.ktor.server.cio.CIOApplicationEngine
|
import io.ktor.server.cio.CIOApplicationEngine
|
||||||
import io.ktor.server.engine.*
|
import io.ktor.server.engine.*
|
||||||
@ -11,20 +11,22 @@ fun <TEngine : ApplicationEngine, TConfiguration : ApplicationEngine.Configurati
|
|||||||
engine: ApplicationEngineFactory<TEngine, TConfiguration>,
|
engine: ApplicationEngineFactory<TEngine, TConfiguration>,
|
||||||
host: String = "localhost",
|
host: String = "localhost",
|
||||||
port: Int = Random.nextInt(1024, 65535),
|
port: Int = Random.nextInt(1024, 65535),
|
||||||
additionalEngineEnvironmentConfigurator: ApplicationEngineEnvironmentBuilder.() -> Unit = {},
|
additionalEngineEnvironmentConfigurator: EngineConnectorBuilder.() -> Unit = {},
|
||||||
additionalConfigurationConfigurator: TConfiguration.() -> Unit = {},
|
additionalConfigurationConfigurator: TConfiguration.() -> Unit = {},
|
||||||
|
environment: ApplicationEnvironment = applicationEnvironment(),
|
||||||
block: Application.() -> Unit
|
block: Application.() -> Unit
|
||||||
): TEngine = embeddedServer(
|
): EmbeddedServer<TEngine, TConfiguration> = embeddedServer<TEngine, TConfiguration>(
|
||||||
engine,
|
engine,
|
||||||
applicationEngineEnvironment {
|
environment,
|
||||||
module(block)
|
{
|
||||||
connector {
|
connector {
|
||||||
this.host = host
|
this.host = host
|
||||||
this.port = port
|
this.port = port
|
||||||
|
additionalEngineEnvironmentConfigurator()
|
||||||
}
|
}
|
||||||
additionalEngineEnvironmentConfigurator()
|
additionalConfigurationConfigurator()
|
||||||
},
|
},
|
||||||
additionalConfigurationConfigurator
|
module = block
|
||||||
)
|
)
|
||||||
|
|
||||||
/**
|
/**
|
||||||
@ -35,15 +37,17 @@ fun <TEngine : ApplicationEngine, TConfiguration : ApplicationEngine.Configurati
|
|||||||
fun createKtorServer(
|
fun createKtorServer(
|
||||||
host: String = "localhost",
|
host: String = "localhost",
|
||||||
port: Int = Random.nextInt(1024, 65535),
|
port: Int = Random.nextInt(1024, 65535),
|
||||||
additionalEngineEnvironmentConfigurator: ApplicationEngineEnvironmentBuilder.() -> Unit = {},
|
additionalEngineEnvironmentConfigurator: EngineConnectorBuilder.() -> Unit = {},
|
||||||
additionalConfigurationConfigurator: CIOApplicationEngine.Configuration.() -> Unit = {},
|
additionalConfigurationConfigurator: CIOApplicationEngine.Configuration.() -> Unit = {},
|
||||||
|
environment: ApplicationEnvironment = applicationEnvironment(),
|
||||||
block: Application.() -> Unit
|
block: Application.() -> Unit
|
||||||
): CIOApplicationEngine = createKtorServer(
|
): EmbeddedServer<CIOApplicationEngine, CIOApplicationEngine.Configuration> = createKtorServer(
|
||||||
CIO,
|
CIO,
|
||||||
host,
|
host,
|
||||||
port,
|
port,
|
||||||
additionalEngineEnvironmentConfigurator,
|
additionalEngineEnvironmentConfigurator,
|
||||||
additionalConfigurationConfigurator,
|
additionalConfigurationConfigurator,
|
||||||
|
environment,
|
||||||
block
|
block
|
||||||
)
|
)
|
||||||
|
|
||||||
@ -51,15 +55,17 @@ fun <TEngine : ApplicationEngine, TConfiguration : ApplicationEngine.Configurati
|
|||||||
engine: ApplicationEngineFactory<TEngine, TConfiguration>,
|
engine: ApplicationEngineFactory<TEngine, TConfiguration>,
|
||||||
host: String = "localhost",
|
host: String = "localhost",
|
||||||
port: Int = Random.nextInt(1024, 65535),
|
port: Int = Random.nextInt(1024, 65535),
|
||||||
additionalEngineEnvironmentConfigurator: ApplicationEngineEnvironmentBuilder.() -> Unit = {},
|
additionalEngineEnvironmentConfigurator: EngineConnectorBuilder.() -> Unit = {},
|
||||||
additionalConfigurationConfigurator: TConfiguration.() -> Unit = {},
|
additionalConfigurationConfigurator: TConfiguration.() -> Unit = {},
|
||||||
|
environment: ApplicationEnvironment = applicationEnvironment(),
|
||||||
configurators: List<KtorApplicationConfigurator>
|
configurators: List<KtorApplicationConfigurator>
|
||||||
): TEngine = createKtorServer(
|
): EmbeddedServer<TEngine, TConfiguration> = createKtorServer(
|
||||||
engine,
|
engine,
|
||||||
host,
|
host,
|
||||||
port,
|
port,
|
||||||
additionalEngineEnvironmentConfigurator,
|
additionalEngineEnvironmentConfigurator,
|
||||||
additionalConfigurationConfigurator
|
additionalConfigurationConfigurator,
|
||||||
|
environment,
|
||||||
) {
|
) {
|
||||||
configurators.forEach { it.apply { configure() } }
|
configurators.forEach { it.apply { configure() } }
|
||||||
}
|
}
|
||||||
@ -73,6 +79,7 @@ fun createKtorServer(
|
|||||||
host: String = "localhost",
|
host: String = "localhost",
|
||||||
port: Int = Random.nextInt(1024, 65535),
|
port: Int = Random.nextInt(1024, 65535),
|
||||||
configurators: List<KtorApplicationConfigurator>,
|
configurators: List<KtorApplicationConfigurator>,
|
||||||
additionalEngineEnvironmentConfigurator: ApplicationEngineEnvironmentBuilder.() -> Unit = {},
|
additionalEngineEnvironmentConfigurator: EngineConnectorBuilder.() -> Unit = {},
|
||||||
additionalConfigurationConfigurator: CIOApplicationEngine.Configuration.() -> Unit = {},
|
additionalConfigurationConfigurator: CIOApplicationEngine.Configuration.() -> Unit = {},
|
||||||
): ApplicationEngine = createKtorServer(CIO, host, port, additionalEngineEnvironmentConfigurator, additionalConfigurationConfigurator, configurators)
|
environment: ApplicationEnvironment = applicationEnvironment(),
|
||||||
|
): EmbeddedServer<CIOApplicationEngine, CIOApplicationEngine.Configuration> = createKtorServer(CIO, host, port, additionalEngineEnvironmentConfigurator, additionalConfigurationConfigurator, environment, configurators)
|
||||||
|
@ -17,6 +17,7 @@ import io.ktor.server.response.respondText
|
|||||||
import io.ktor.server.routing.Route
|
import io.ktor.server.routing.Route
|
||||||
import io.ktor.server.routing.post
|
import io.ktor.server.routing.post
|
||||||
import kotlinx.coroutines.*
|
import kotlinx.coroutines.*
|
||||||
|
import kotlinx.coroutines.channels.BufferOverflow
|
||||||
import kotlinx.coroutines.flow.*
|
import kotlinx.coroutines.flow.*
|
||||||
import kotlinx.coroutines.sync.Mutex
|
import kotlinx.coroutines.sync.Mutex
|
||||||
import kotlinx.coroutines.sync.withLock
|
import kotlinx.coroutines.sync.withLock
|
||||||
@ -26,7 +27,10 @@ import java.nio.file.attribute.FileTime
|
|||||||
|
|
||||||
class TemporalFilesRoutingConfigurator(
|
class TemporalFilesRoutingConfigurator(
|
||||||
private val subpath: String = DefaultTemporalFilesSubPath,
|
private val subpath: String = DefaultTemporalFilesSubPath,
|
||||||
private val temporalFilesUtilizer: TemporalFilesUtilizer = TemporalFilesUtilizer
|
private val temporalFilesUtilizer: TemporalFilesUtilizer = TemporalFilesUtilizer,
|
||||||
|
filesFlowReplay: Int = 0,
|
||||||
|
filesFlowExtraBufferCapacity: Int = Int.MAX_VALUE,
|
||||||
|
filesFlowOnBufferOverflow: BufferOverflow = BufferOverflow.SUSPEND
|
||||||
) : ApplicationRoutingConfigurator.Element {
|
) : ApplicationRoutingConfigurator.Element {
|
||||||
interface TemporalFilesUtilizer {
|
interface TemporalFilesUtilizer {
|
||||||
fun start(filesMap: MutableMap<TemporalFileId, MPPFile>, filesMutex: Mutex, onNewFileFlow: Flow<TemporalFileId>): Job
|
fun start(filesMap: MutableMap<TemporalFileId, MPPFile>, filesMutex: Mutex, onNewFileFlow: Flow<TemporalFileId>): Job
|
||||||
@ -74,7 +78,11 @@ class TemporalFilesRoutingConfigurator(
|
|||||||
|
|
||||||
private val temporalFilesMap = mutableMapOf<TemporalFileId, MPPFile>()
|
private val temporalFilesMap = mutableMapOf<TemporalFileId, MPPFile>()
|
||||||
private val temporalFilesMutex = Mutex()
|
private val temporalFilesMutex = Mutex()
|
||||||
private val filesFlow = MutableSharedFlow<TemporalFileId>()
|
private val filesFlow = MutableSharedFlow<TemporalFileId>(
|
||||||
|
replay = filesFlowReplay,
|
||||||
|
extraBufferCapacity = filesFlowExtraBufferCapacity,
|
||||||
|
onBufferOverflow = filesFlowOnBufferOverflow
|
||||||
|
)
|
||||||
val utilizerJob = temporalFilesUtilizer.start(temporalFilesMap, temporalFilesMutex, filesFlow.asSharedFlow())
|
val utilizerJob = temporalFilesUtilizer.start(temporalFilesMap, temporalFilesMutex, filesFlow.asSharedFlow())
|
||||||
|
|
||||||
override fun Route.invoke() {
|
override fun Route.invoke() {
|
||||||
@ -111,7 +119,7 @@ class TemporalFilesRoutingConfigurator(
|
|||||||
temporalFilesMap[fileId] = file
|
temporalFilesMap[fileId] = file
|
||||||
}
|
}
|
||||||
call.respondText(fileId.string)
|
call.respondText(fileId.string)
|
||||||
launchSafelyWithoutExceptions { filesFlow.emit(fileId) }
|
filesFlow.emit(fileId)
|
||||||
} ?: call.respond(HttpStatusCode.BadRequest)
|
} ?: call.respond(HttpStatusCode.BadRequest)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
@ -6,6 +6,7 @@ import dev.inmo.micro_utils.ktor.common.downloadToTempFile
|
|||||||
import io.ktor.http.content.*
|
import io.ktor.http.content.*
|
||||||
import io.ktor.server.application.ApplicationCall
|
import io.ktor.server.application.ApplicationCall
|
||||||
import io.ktor.server.request.receiveMultipart
|
import io.ktor.server.request.receiveMultipart
|
||||||
|
import io.ktor.utils.io.*
|
||||||
import io.ktor.utils.io.core.*
|
import io.ktor.utils.io.core.*
|
||||||
import kotlinx.coroutines.currentCoroutineContext
|
import kotlinx.coroutines.currentCoroutineContext
|
||||||
import kotlinx.coroutines.isActive
|
import kotlinx.coroutines.isActive
|
||||||
@ -47,7 +48,7 @@ suspend fun ApplicationCall.uniloadMultipart(
|
|||||||
onBinaryChannelItem
|
onBinaryChannelItem
|
||||||
) {
|
) {
|
||||||
when (it.name) {
|
when (it.name) {
|
||||||
"bytes" -> resultInput = it.provider()
|
"bytes" -> resultInput = it.provider().readBuffer()
|
||||||
else -> onCustomFileItem(it)
|
else -> onCustomFileItem(it)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
@ -2,8 +2,7 @@ package dev.inmo.micro_utils.ktor.server.configurators
|
|||||||
|
|
||||||
import dev.inmo.micro_utils.ktor.server.configurators.ApplicationRoutingConfigurator.Element
|
import dev.inmo.micro_utils.ktor.server.configurators.ApplicationRoutingConfigurator.Element
|
||||||
import io.ktor.server.application.*
|
import io.ktor.server.application.*
|
||||||
import io.ktor.server.routing.Route
|
import io.ktor.server.routing.*
|
||||||
import io.ktor.server.routing.Routing
|
|
||||||
import kotlinx.serialization.Contextual
|
import kotlinx.serialization.Contextual
|
||||||
import kotlinx.serialization.Serializable
|
import kotlinx.serialization.Serializable
|
||||||
|
|
||||||
@ -19,9 +18,7 @@ class ApplicationRoutingConfigurator(
|
|||||||
}
|
}
|
||||||
|
|
||||||
override fun Application.configure() {
|
override fun Application.configure() {
|
||||||
pluginOrNull(Routing) ?.apply {
|
routing {
|
||||||
rootInstaller.apply { invoke() }
|
|
||||||
} ?: install(Routing) {
|
|
||||||
rootInstaller.apply { invoke() }
|
rootInstaller.apply { invoke() }
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
@ -23,9 +23,7 @@ interface KtorApplicationConfigurator {
|
|||||||
}
|
}
|
||||||
|
|
||||||
override fun Application.configure() {
|
override fun Application.configure() {
|
||||||
pluginOrNull(io.ktor.server.routing.Routing) ?.apply {
|
routing {
|
||||||
rootInstaller.apply { invoke() }
|
|
||||||
} ?: install(io.ktor.server.routing.Routing) {
|
|
||||||
rootInstaller.apply { invoke() }
|
rootInstaller.apply { invoke() }
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
@ -0,0 +1,113 @@
|
|||||||
|
package dev.inmo.micro_utils.repos.cache.full.direct
|
||||||
|
|
||||||
|
import dev.inmo.micro_utils.common.*
|
||||||
|
import dev.inmo.micro_utils.coroutines.SmartRWLocker
|
||||||
|
import dev.inmo.micro_utils.coroutines.launchSafelyWithoutExceptions
|
||||||
|
import dev.inmo.micro_utils.coroutines.withReadAcquire
|
||||||
|
import dev.inmo.micro_utils.coroutines.withWriteLock
|
||||||
|
import dev.inmo.micro_utils.pagination.Pagination
|
||||||
|
import dev.inmo.micro_utils.pagination.PaginationResult
|
||||||
|
import dev.inmo.micro_utils.repos.*
|
||||||
|
import dev.inmo.micro_utils.repos.cache.*
|
||||||
|
import dev.inmo.micro_utils.repos.cache.util.ActualizeAllClearMode
|
||||||
|
import dev.inmo.micro_utils.repos.cache.util.actualizeAll
|
||||||
|
import kotlinx.coroutines.CoroutineScope
|
||||||
|
import kotlinx.coroutines.Dispatchers
|
||||||
|
|
||||||
|
open class DirectFullReadCRUDCacheRepo<ObjectType, IdType>(
|
||||||
|
protected open val parentRepo: ReadCRUDRepo<ObjectType, IdType>,
|
||||||
|
protected open val kvCache: KeyValueRepo<IdType, ObjectType>,
|
||||||
|
protected val locker: SmartRWLocker = SmartRWLocker(),
|
||||||
|
protected open val idGetter: (ObjectType) -> IdType
|
||||||
|
) : ReadCRUDRepo<ObjectType, IdType>, DirectFullCacheRepo {
|
||||||
|
protected open suspend fun actualizeAll() {
|
||||||
|
kvCache.actualizeAll(parentRepo, locker = locker)
|
||||||
|
}
|
||||||
|
|
||||||
|
override suspend fun getByPagination(pagination: Pagination): PaginationResult<ObjectType> = locker.withReadAcquire {
|
||||||
|
kvCache.values(pagination)
|
||||||
|
}
|
||||||
|
|
||||||
|
override suspend fun getIdsByPagination(pagination: Pagination): PaginationResult<IdType> = locker.withReadAcquire {
|
||||||
|
kvCache.keys(pagination)
|
||||||
|
}
|
||||||
|
|
||||||
|
override suspend fun count(): Long = locker.withReadAcquire {
|
||||||
|
kvCache.count()
|
||||||
|
}
|
||||||
|
|
||||||
|
override suspend fun contains(id: IdType): Boolean = locker.withReadAcquire {
|
||||||
|
kvCache.contains(id)
|
||||||
|
}
|
||||||
|
|
||||||
|
override suspend fun getAll(): Map<IdType, ObjectType> = locker.withReadAcquire {
|
||||||
|
kvCache.getAll()
|
||||||
|
}
|
||||||
|
|
||||||
|
override suspend fun getById(id: IdType): ObjectType? = locker.withReadAcquire {
|
||||||
|
kvCache.get(id)
|
||||||
|
}
|
||||||
|
|
||||||
|
override suspend fun invalidate() {
|
||||||
|
actualizeAll()
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
fun <ObjectType, IdType> ReadCRUDRepo<ObjectType, IdType>.directlyCached(
|
||||||
|
kvCache: KeyValueRepo<IdType, ObjectType>,
|
||||||
|
locker: SmartRWLocker = SmartRWLocker(),
|
||||||
|
idGetter: (ObjectType) -> IdType
|
||||||
|
) = DirectFullReadCRUDCacheRepo(this, kvCache, locker, idGetter)
|
||||||
|
|
||||||
|
open class DirectFullCRUDCacheRepo<ObjectType, IdType, InputValueType>(
|
||||||
|
override val parentRepo: CRUDRepo<ObjectType, IdType, InputValueType>,
|
||||||
|
kvCache: KeyValueRepo<IdType, ObjectType>,
|
||||||
|
scope: CoroutineScope = CoroutineScope(Dispatchers.Default),
|
||||||
|
skipStartInvalidate: Boolean = false,
|
||||||
|
locker: SmartRWLocker = SmartRWLocker(writeIsLocked = !skipStartInvalidate),
|
||||||
|
idGetter: (ObjectType) -> IdType
|
||||||
|
) : DirectFullReadCRUDCacheRepo<ObjectType, IdType>(
|
||||||
|
parentRepo,
|
||||||
|
kvCache,
|
||||||
|
locker,
|
||||||
|
idGetter
|
||||||
|
),
|
||||||
|
WriteCRUDRepo<ObjectType, IdType, InputValueType> by WriteCRUDCacheRepo(
|
||||||
|
parentRepo,
|
||||||
|
kvCache,
|
||||||
|
scope,
|
||||||
|
locker,
|
||||||
|
idGetter
|
||||||
|
),
|
||||||
|
CRUDRepo<ObjectType, IdType, InputValueType> {
|
||||||
|
init {
|
||||||
|
if (!skipStartInvalidate) {
|
||||||
|
scope.launchSafelyWithoutExceptions {
|
||||||
|
if (locker.writeMutex.isLocked) {
|
||||||
|
initialInvalidate()
|
||||||
|
} else {
|
||||||
|
invalidate()
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
protected open suspend fun initialInvalidate() {
|
||||||
|
try {
|
||||||
|
kvCache.actualizeAll(parentRepo, locker = null)
|
||||||
|
} finally {
|
||||||
|
locker.unlockWrite()
|
||||||
|
}
|
||||||
|
}
|
||||||
|
override suspend fun invalidate() {
|
||||||
|
actualizeAll()
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
fun <ObjectType, IdType, InputType> CRUDRepo<ObjectType, IdType, InputType>.directFullyCached(
|
||||||
|
kvCache: KeyValueRepo<IdType, ObjectType> = MapKeyValueRepo(),
|
||||||
|
scope: CoroutineScope = CoroutineScope(Dispatchers.Default),
|
||||||
|
skipStartInvalidate: Boolean = false,
|
||||||
|
locker: SmartRWLocker = SmartRWLocker(),
|
||||||
|
idGetter: (ObjectType) -> IdType
|
||||||
|
) = DirectFullCRUDCacheRepo(this, kvCache, scope, skipStartInvalidate, locker, idGetter)
|
@ -0,0 +1,13 @@
|
|||||||
|
package dev.inmo.micro_utils.repos.cache.full.direct
|
||||||
|
|
||||||
|
import dev.inmo.micro_utils.repos.cache.full.FullCacheRepo
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Repos-inheritors MUST realize their methods via next logic:
|
||||||
|
*
|
||||||
|
* * Reloading of data in cache must be reactive (e.g. via Flow) or direct mutation methods usage (override set and
|
||||||
|
* mutate cache inside, for example)
|
||||||
|
* * All reading methods must take data from cache via synchronization with [dev.inmo.micro_utils.coroutines.SmartRWLocker]
|
||||||
|
*/
|
||||||
|
interface DirectFullCacheRepo : FullCacheRepo {
|
||||||
|
}
|
@ -0,0 +1,177 @@
|
|||||||
|
package dev.inmo.micro_utils.repos.cache.full.direct
|
||||||
|
|
||||||
|
import dev.inmo.micro_utils.coroutines.SmartRWLocker
|
||||||
|
import dev.inmo.micro_utils.coroutines.launchSafelyWithoutExceptions
|
||||||
|
import dev.inmo.micro_utils.coroutines.withReadAcquire
|
||||||
|
import dev.inmo.micro_utils.coroutines.withWriteLock
|
||||||
|
import dev.inmo.micro_utils.pagination.Pagination
|
||||||
|
import dev.inmo.micro_utils.pagination.PaginationResult
|
||||||
|
import dev.inmo.micro_utils.repos.*
|
||||||
|
import dev.inmo.micro_utils.repos.cache.full.FullKeyValueCacheRepo
|
||||||
|
import dev.inmo.micro_utils.repos.cache.full.FullReadKeyValueCacheRepo
|
||||||
|
import dev.inmo.micro_utils.repos.cache.full.FullWriteKeyValueCacheRepo
|
||||||
|
import dev.inmo.micro_utils.repos.cache.util.actualizeAll
|
||||||
|
import kotlinx.coroutines.CoroutineScope
|
||||||
|
import kotlinx.coroutines.Dispatchers
|
||||||
|
import kotlinx.coroutines.flow.Flow
|
||||||
|
import kotlinx.coroutines.flow.launchIn
|
||||||
|
import kotlinx.coroutines.flow.onEach
|
||||||
|
|
||||||
|
open class DirectFullReadKeyValueCacheRepo<Key, Value>(
|
||||||
|
protected open val parentRepo: ReadKeyValueRepo<Key, Value>,
|
||||||
|
protected open val kvCache: KeyValueRepo<Key, Value>,
|
||||||
|
protected val locker: SmartRWLocker = SmartRWLocker()
|
||||||
|
) : DirectFullCacheRepo, ReadKeyValueRepo<Key, Value> {
|
||||||
|
protected open suspend fun actualizeAll() {
|
||||||
|
kvCache.actualizeAll(parentRepo, locker)
|
||||||
|
}
|
||||||
|
|
||||||
|
override suspend fun get(k: Key): Value? = locker.withReadAcquire {
|
||||||
|
kvCache.get(k)
|
||||||
|
}
|
||||||
|
|
||||||
|
override suspend fun values(pagination: Pagination, reversed: Boolean): PaginationResult<Value> = locker.withReadAcquire {
|
||||||
|
kvCache.values(pagination, reversed)
|
||||||
|
}
|
||||||
|
|
||||||
|
override suspend fun count(): Long = locker.withReadAcquire {
|
||||||
|
kvCache.count()
|
||||||
|
}
|
||||||
|
|
||||||
|
override suspend fun contains(key: Key): Boolean = locker.withReadAcquire {
|
||||||
|
kvCache.contains(key)
|
||||||
|
}
|
||||||
|
|
||||||
|
override suspend fun getAll(): Map<Key, Value> = locker.withReadAcquire {
|
||||||
|
kvCache.getAll()
|
||||||
|
}
|
||||||
|
|
||||||
|
override suspend fun keys(pagination: Pagination, reversed: Boolean): PaginationResult<Key> = locker.withReadAcquire {
|
||||||
|
kvCache.keys(pagination, reversed)
|
||||||
|
}
|
||||||
|
|
||||||
|
override suspend fun keys(v: Value, pagination: Pagination, reversed: Boolean): PaginationResult<Key> = locker.withReadAcquire {
|
||||||
|
kvCache.keys(v, pagination, reversed)
|
||||||
|
}
|
||||||
|
|
||||||
|
override suspend fun invalidate() {
|
||||||
|
actualizeAll()
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
fun <Key, Value> ReadKeyValueRepo<Key, Value>.directlyCached(
|
||||||
|
kvCache: KeyValueRepo<Key, Value>,
|
||||||
|
locker: SmartRWLocker = SmartRWLocker()
|
||||||
|
) = DirectFullReadKeyValueCacheRepo(this, kvCache, locker)
|
||||||
|
|
||||||
|
open class DirectFullWriteKeyValueCacheRepo<Key, Value>(
|
||||||
|
protected open val parentRepo: WriteKeyValueRepo<Key, Value>,
|
||||||
|
protected open val kvCache: KeyValueRepo<Key, Value>,
|
||||||
|
protected val locker: SmartRWLocker = SmartRWLocker(),
|
||||||
|
scope: CoroutineScope = CoroutineScope(Dispatchers.Default),
|
||||||
|
) : DirectFullCacheRepo, WriteKeyValueRepo<Key, Value> by parentRepo {
|
||||||
|
override val onNewValue: Flow<Pair<Key, Value>>
|
||||||
|
get() = parentRepo.onNewValue
|
||||||
|
override val onValueRemoved: Flow<Key>
|
||||||
|
get() = parentRepo.onValueRemoved
|
||||||
|
|
||||||
|
protected val onNewJob = parentRepo.onNewValue.onEach {
|
||||||
|
locker.withWriteLock {
|
||||||
|
kvCache.set(it.first, it.second)
|
||||||
|
}
|
||||||
|
}.launchIn(scope)
|
||||||
|
protected val onRemoveJob = parentRepo.onValueRemoved.onEach {
|
||||||
|
locker.withWriteLock {
|
||||||
|
kvCache.unset(it)
|
||||||
|
}
|
||||||
|
}.launchIn(scope)
|
||||||
|
|
||||||
|
override suspend fun invalidate() {
|
||||||
|
locker.withWriteLock {
|
||||||
|
kvCache.clear()
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
override suspend fun unsetWithValues(toUnset: List<Value>) = parentRepo.unsetWithValues(toUnset)
|
||||||
|
}
|
||||||
|
|
||||||
|
fun <Key, Value> WriteKeyValueRepo<Key, Value>.directlyCached(
|
||||||
|
kvCache: KeyValueRepo<Key, Value>,
|
||||||
|
scope: CoroutineScope = CoroutineScope(Dispatchers.Default)
|
||||||
|
) = DirectFullWriteKeyValueCacheRepo(this, kvCache, scope = scope)
|
||||||
|
|
||||||
|
open class DirectFullKeyValueCacheRepo<Key, Value>(
|
||||||
|
override val parentRepo: KeyValueRepo<Key, Value>,
|
||||||
|
kvCache: KeyValueRepo<Key, Value>,
|
||||||
|
scope: CoroutineScope = CoroutineScope(Dispatchers.Default),
|
||||||
|
skipStartInvalidate: Boolean = false,
|
||||||
|
locker: SmartRWLocker = SmartRWLocker(writeIsLocked = !skipStartInvalidate),
|
||||||
|
) : DirectFullCacheRepo,
|
||||||
|
KeyValueRepo<Key, Value> ,
|
||||||
|
WriteKeyValueRepo<Key, Value> by DirectFullWriteKeyValueCacheRepo(
|
||||||
|
parentRepo,
|
||||||
|
kvCache,
|
||||||
|
locker,
|
||||||
|
scope
|
||||||
|
),
|
||||||
|
DirectFullReadKeyValueCacheRepo<Key, Value>(parentRepo, kvCache, locker) {
|
||||||
|
init {
|
||||||
|
if (!skipStartInvalidate) {
|
||||||
|
scope.launchSafelyWithoutExceptions {
|
||||||
|
if (locker.writeMutex.isLocked) {
|
||||||
|
initialInvalidate()
|
||||||
|
} else {
|
||||||
|
invalidate()
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
protected open suspend fun initialInvalidate() {
|
||||||
|
try {
|
||||||
|
kvCache.actualizeAll(parentRepo, locker = null)
|
||||||
|
} finally {
|
||||||
|
locker.unlockWrite()
|
||||||
|
}
|
||||||
|
}
|
||||||
|
override suspend fun invalidate() {
|
||||||
|
kvCache.actualizeAll(parentRepo, locker)
|
||||||
|
}
|
||||||
|
|
||||||
|
override suspend fun clear() {
|
||||||
|
parentRepo.clear()
|
||||||
|
kvCache.clear()
|
||||||
|
}
|
||||||
|
|
||||||
|
override suspend fun unsetWithValues(toUnset: List<Value>) = parentRepo.unsetWithValues(toUnset)
|
||||||
|
|
||||||
|
override suspend fun set(toSet: Map<Key, Value>) {
|
||||||
|
locker.withWriteLock {
|
||||||
|
parentRepo.set(toSet)
|
||||||
|
kvCache.set(
|
||||||
|
toSet.filter {
|
||||||
|
parentRepo.contains(it.key)
|
||||||
|
}
|
||||||
|
)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
override suspend fun unset(toUnset: List<Key>) {
|
||||||
|
locker.withWriteLock {
|
||||||
|
parentRepo.unset(toUnset)
|
||||||
|
kvCache.unset(
|
||||||
|
toUnset.filter {
|
||||||
|
!parentRepo.contains(it)
|
||||||
|
}
|
||||||
|
)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
fun <Key, Value> KeyValueRepo<Key, Value>.directlyFullyCached(
|
||||||
|
kvCache: KeyValueRepo<Key, Value> = MapKeyValueRepo(),
|
||||||
|
scope: CoroutineScope = CoroutineScope(Dispatchers.Default),
|
||||||
|
skipStartInvalidate: Boolean = false,
|
||||||
|
locker: SmartRWLocker = SmartRWLocker()
|
||||||
|
) = DirectFullKeyValueCacheRepo(this, kvCache, scope, skipStartInvalidate, locker)
|
@ -0,0 +1,243 @@
|
|||||||
|
package dev.inmo.micro_utils.repos.cache.full.direct
|
||||||
|
|
||||||
|
import dev.inmo.micro_utils.common.*
|
||||||
|
import dev.inmo.micro_utils.coroutines.SmartRWLocker
|
||||||
|
import dev.inmo.micro_utils.coroutines.launchSafelyWithoutExceptions
|
||||||
|
import dev.inmo.micro_utils.coroutines.withReadAcquire
|
||||||
|
import dev.inmo.micro_utils.coroutines.withWriteLock
|
||||||
|
import dev.inmo.micro_utils.pagination.*
|
||||||
|
import dev.inmo.micro_utils.pagination.utils.*
|
||||||
|
import dev.inmo.micro_utils.repos.*
|
||||||
|
import dev.inmo.micro_utils.repos.cache.util.ActualizeAllClearMode
|
||||||
|
import dev.inmo.micro_utils.repos.cache.util.actualizeAll
|
||||||
|
import kotlinx.coroutines.CoroutineScope
|
||||||
|
import kotlinx.coroutines.Dispatchers
|
||||||
|
import kotlinx.coroutines.flow.*
|
||||||
|
|
||||||
|
open class DirectFullReadKeyValuesCacheRepo<Key,Value>(
|
||||||
|
protected open val parentRepo: ReadKeyValuesRepo<Key, Value>,
|
||||||
|
protected open val kvCache: KeyValueRepo<Key, List<Value>>,
|
||||||
|
protected val locker: SmartRWLocker = SmartRWLocker(),
|
||||||
|
) : ReadKeyValuesRepo<Key, Value>, DirectFullCacheRepo {
|
||||||
|
protected open suspend fun actualizeKey(k: Key) {
|
||||||
|
kvCache.actualizeAll(locker = locker, clearMode = ActualizeAllClearMode.Never) {
|
||||||
|
mapOf(k to parentRepo.getAll(k))
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
protected open suspend fun actualizeAll() {
|
||||||
|
kvCache.actualizeAll(parentRepo, locker = locker)
|
||||||
|
}
|
||||||
|
|
||||||
|
override suspend fun get(k: Key, pagination: Pagination, reversed: Boolean): PaginationResult<Value> {
|
||||||
|
return locker.withReadAcquire {
|
||||||
|
kvCache.get(k) ?.paginate(
|
||||||
|
pagination.let { if (reversed) it.reverse(count(k)) else it }
|
||||||
|
) ?.let {
|
||||||
|
if (reversed) it.copy(results = it.results.reversed()) else it
|
||||||
|
}
|
||||||
|
} ?: emptyPaginationResult()
|
||||||
|
}
|
||||||
|
|
||||||
|
override suspend fun getAll(k: Key, reversed: Boolean): List<Value> {
|
||||||
|
return locker.withReadAcquire {
|
||||||
|
kvCache.get(k) ?.optionallyReverse(reversed)
|
||||||
|
} ?: emptyList()
|
||||||
|
}
|
||||||
|
|
||||||
|
override suspend fun getAll(reverseLists: Boolean): Map<Key, List<Value>> {
|
||||||
|
return locker.withReadAcquire {
|
||||||
|
kvCache.getAll().takeIf { it.isNotEmpty() } ?.let {
|
||||||
|
if (reverseLists) {
|
||||||
|
it.mapValues { it.value.reversed() }
|
||||||
|
} else {
|
||||||
|
it
|
||||||
|
}
|
||||||
|
}
|
||||||
|
} ?: emptyMap()
|
||||||
|
}
|
||||||
|
override suspend fun keys(pagination: Pagination, reversed: Boolean): PaginationResult<Key> {
|
||||||
|
return locker.withReadAcquire {
|
||||||
|
kvCache.keys(pagination, reversed).takeIf { it.results.isNotEmpty() }
|
||||||
|
} ?: emptyPaginationResult()
|
||||||
|
}
|
||||||
|
|
||||||
|
override suspend fun count(): Long = locker.withReadAcquire { kvCache.count() }
|
||||||
|
|
||||||
|
override suspend fun count(k: Key): Long = locker.withReadAcquire { kvCache.get(k) ?.size } ?.toLong() ?: 0L
|
||||||
|
|
||||||
|
override suspend fun contains(k: Key, v: Value): Boolean = locker.withReadAcquire { kvCache.get(k) ?.contains(v) } == true
|
||||||
|
|
||||||
|
override suspend fun contains(k: Key): Boolean = locker.withReadAcquire { kvCache.contains(k) }
|
||||||
|
|
||||||
|
override suspend fun keys(
|
||||||
|
v: Value,
|
||||||
|
pagination: Pagination,
|
||||||
|
reversed: Boolean
|
||||||
|
): PaginationResult<Key> {
|
||||||
|
val keys = locker.withReadAcquire {
|
||||||
|
getAllWithNextPaging { kvCache.keys(it) }.filter { kvCache.get(it)?.contains(v) == true }
|
||||||
|
.optionallyReverse(reversed)
|
||||||
|
}
|
||||||
|
val result = if (keys.isNotEmpty()) {
|
||||||
|
keys.paginate(pagination.optionallyReverse(keys.size, reversed)).takeIf { it.results.isNotEmpty() }
|
||||||
|
} else {
|
||||||
|
null
|
||||||
|
}
|
||||||
|
|
||||||
|
return result ?: emptyPaginationResult()
|
||||||
|
}
|
||||||
|
|
||||||
|
override suspend fun invalidate() {
|
||||||
|
actualizeAll()
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
fun <Key, Value> ReadKeyValuesRepo<Key, Value>.directlyCached(
|
||||||
|
kvCache: KeyValueRepo<Key, List<Value>>,
|
||||||
|
locker: SmartRWLocker = SmartRWLocker(),
|
||||||
|
) = DirectFullReadKeyValuesCacheRepo(this, kvCache, locker)
|
||||||
|
|
||||||
|
open class DirectFullWriteKeyValuesCacheRepo<Key,Value>(
|
||||||
|
parentRepo: WriteKeyValuesRepo<Key, Value>,
|
||||||
|
protected open val kvCache: KeyValueRepo<Key, List<Value>>,
|
||||||
|
scope: CoroutineScope = CoroutineScope(Dispatchers.Default),
|
||||||
|
protected val locker: SmartRWLocker = SmartRWLocker(),
|
||||||
|
) : WriteKeyValuesRepo<Key, Value> by parentRepo, DirectFullCacheRepo {
|
||||||
|
protected val onNewJob = parentRepo.onNewValue.onEach {
|
||||||
|
locker.withWriteLock {
|
||||||
|
kvCache.set(
|
||||||
|
it.first,
|
||||||
|
kvCache.get(it.first) ?.plus(it.second) ?: listOf(it.second)
|
||||||
|
)
|
||||||
|
}
|
||||||
|
}.launchIn(scope)
|
||||||
|
protected val onRemoveJob = parentRepo.onValueRemoved.onEach {
|
||||||
|
locker.withWriteLock {
|
||||||
|
kvCache.set(
|
||||||
|
it.first,
|
||||||
|
kvCache.get(it.first)?.minus(it.second) ?: return@onEach
|
||||||
|
)
|
||||||
|
}
|
||||||
|
}.launchIn(scope)
|
||||||
|
|
||||||
|
override suspend fun invalidate() {
|
||||||
|
locker.withWriteLock {
|
||||||
|
kvCache.clear()
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
fun <Key, Value> WriteKeyValuesRepo<Key, Value>.directlyCached(
|
||||||
|
kvCache: KeyValueRepo<Key, List<Value>>,
|
||||||
|
scope: CoroutineScope = CoroutineScope(Dispatchers.Default),
|
||||||
|
locker: SmartRWLocker = SmartRWLocker(),
|
||||||
|
) = DirectFullWriteKeyValuesCacheRepo(this, kvCache, scope, locker)
|
||||||
|
|
||||||
|
open class DirectFullKeyValuesCacheRepo<Key,Value>(
|
||||||
|
override val parentRepo: KeyValuesRepo<Key, Value>,
|
||||||
|
kvCache: KeyValueRepo<Key, List<Value>>,
|
||||||
|
scope: CoroutineScope = CoroutineScope(Dispatchers.Default),
|
||||||
|
skipStartInvalidate: Boolean = false,
|
||||||
|
locker: SmartRWLocker = SmartRWLocker(writeIsLocked = !skipStartInvalidate),
|
||||||
|
) : KeyValuesRepo<Key, Value>,
|
||||||
|
DirectFullReadKeyValuesCacheRepo<Key, Value>(parentRepo, kvCache, locker),
|
||||||
|
WriteKeyValuesRepo<Key, Value> by parentRepo {
|
||||||
|
init {
|
||||||
|
if (!skipStartInvalidate) {
|
||||||
|
scope.launchSafelyWithoutExceptions {
|
||||||
|
if (locker.writeMutex.isLocked) {
|
||||||
|
initialInvalidate()
|
||||||
|
} else {
|
||||||
|
invalidate()
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
override suspend fun clearWithValue(v: Value) {
|
||||||
|
doAllWithCurrentPaging {
|
||||||
|
keys(v, it).also {
|
||||||
|
remove(it.results.associateWith { listOf(v) })
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
protected open suspend fun initialInvalidate() {
|
||||||
|
try {
|
||||||
|
kvCache.actualizeAll(parentRepo, locker = null)
|
||||||
|
} finally {
|
||||||
|
locker.unlockWrite()
|
||||||
|
}
|
||||||
|
}
|
||||||
|
override suspend fun invalidate() {
|
||||||
|
kvCache.actualizeAll(parentRepo, locker = locker)
|
||||||
|
}
|
||||||
|
|
||||||
|
override suspend fun set(toSet: Map<Key, List<Value>>) {
|
||||||
|
locker.withWriteLock {
|
||||||
|
parentRepo.set(toSet)
|
||||||
|
kvCache.set(
|
||||||
|
toSet.filter {
|
||||||
|
parentRepo.contains(it.key)
|
||||||
|
}
|
||||||
|
)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
override suspend fun add(toAdd: Map<Key, List<Value>>) {
|
||||||
|
locker.withWriteLock {
|
||||||
|
parentRepo.add(toAdd)
|
||||||
|
toAdd.forEach {
|
||||||
|
val filtered = it.value.filter { v ->
|
||||||
|
parentRepo.contains(it.key, v)
|
||||||
|
}.ifEmpty {
|
||||||
|
return@forEach
|
||||||
|
}
|
||||||
|
kvCache.set(
|
||||||
|
it.key,
|
||||||
|
(kvCache.get(it.key) ?: emptyList()) + filtered
|
||||||
|
)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
override suspend fun remove(toRemove: Map<Key, List<Value>>) {
|
||||||
|
locker.withWriteLock {
|
||||||
|
parentRepo.remove(toRemove)
|
||||||
|
toRemove.forEach {
|
||||||
|
val filtered = it.value.filter { v ->
|
||||||
|
!parentRepo.contains(it.key, v)
|
||||||
|
}.ifEmpty {
|
||||||
|
return@forEach
|
||||||
|
}.toSet()
|
||||||
|
val resultList = (kvCache.get(it.key) ?: emptyList()) - filtered
|
||||||
|
if (resultList.isEmpty()) {
|
||||||
|
kvCache.unset(it.key)
|
||||||
|
} else {
|
||||||
|
kvCache.set(
|
||||||
|
it.key,
|
||||||
|
resultList
|
||||||
|
)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
override suspend fun clear(k: Key) {
|
||||||
|
locker.withWriteLock {
|
||||||
|
parentRepo.clear(k)
|
||||||
|
if (parentRepo.contains(k)) {
|
||||||
|
return@withWriteLock
|
||||||
|
}
|
||||||
|
kvCache.unset(k)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
fun <Key, Value> KeyValuesRepo<Key, Value>.directlyFullyCached(
|
||||||
|
kvCache: KeyValueRepo<Key, List<Value>> = MapKeyValueRepo(),
|
||||||
|
scope: CoroutineScope = CoroutineScope(Dispatchers.Default),
|
||||||
|
skipStartInvalidate: Boolean = false,
|
||||||
|
locker: SmartRWLocker = SmartRWLocker(),
|
||||||
|
) = DirectFullKeyValuesCacheRepo(this, kvCache, scope, skipStartInvalidate, locker)
|
@ -8,7 +8,7 @@ import dev.inmo.micro_utils.repos.ktor.common.key_value.*
|
|||||||
import io.ktor.client.HttpClient
|
import io.ktor.client.HttpClient
|
||||||
import io.ktor.client.request.post
|
import io.ktor.client.request.post
|
||||||
import io.ktor.http.*
|
import io.ktor.http.*
|
||||||
import io.ktor.util.InternalAPI
|
import io.ktor.utils.io.InternalAPI
|
||||||
import io.ktor.util.reflect.TypeInfo
|
import io.ktor.util.reflect.TypeInfo
|
||||||
import io.ktor.util.reflect.typeInfo
|
import io.ktor.util.reflect.typeInfo
|
||||||
import kotlinx.coroutines.flow.Flow
|
import kotlinx.coroutines.flow.Flow
|
||||||
|
@ -8,7 +8,7 @@ import dev.inmo.micro_utils.repos.ktor.common.one_to_many.*
|
|||||||
import io.ktor.client.HttpClient
|
import io.ktor.client.HttpClient
|
||||||
import io.ktor.client.request.post
|
import io.ktor.client.request.post
|
||||||
import io.ktor.http.*
|
import io.ktor.http.*
|
||||||
import io.ktor.util.InternalAPI
|
import io.ktor.utils.io.InternalAPI
|
||||||
import io.ktor.util.reflect.TypeInfo
|
import io.ktor.util.reflect.TypeInfo
|
||||||
import io.ktor.util.reflect.typeInfo
|
import io.ktor.util.reflect.typeInfo
|
||||||
import kotlinx.coroutines.flow.Flow
|
import kotlinx.coroutines.flow.Flow
|
||||||
|
@ -25,7 +25,7 @@ import kotlin.test.Test
|
|||||||
import kotlin.test.assertEquals
|
import kotlin.test.assertEquals
|
||||||
|
|
||||||
class KtorCRUDRepoTests : CommonCRUDRepoTests() {
|
class KtorCRUDRepoTests : CommonCRUDRepoTests() {
|
||||||
private var engine: ApplicationEngine? = null
|
private var engine: EmbeddedServer<*, *>? = null
|
||||||
|
|
||||||
@BeforeTest
|
@BeforeTest
|
||||||
fun beforeTest() {
|
fun beforeTest() {
|
||||||
|
@ -27,7 +27,7 @@ import kotlinx.serialization.json.Json
|
|||||||
import kotlin.test.*
|
import kotlin.test.*
|
||||||
|
|
||||||
class KtorKeyValueRepoTests : CommonKeyValueRepoTests() {
|
class KtorKeyValueRepoTests : CommonKeyValueRepoTests() {
|
||||||
private var engine: ApplicationEngine? = null
|
private var engine: EmbeddedServer<*, *>? = null
|
||||||
|
|
||||||
override val repoCreator: suspend () -> KeyValueRepo<String, String> = {
|
override val repoCreator: suspend () -> KeyValueRepo<String, String> = {
|
||||||
KtorKeyValueRepoClient(
|
KtorKeyValueRepoClient(
|
||||||
@ -77,7 +77,7 @@ class KtorKeyValueRepoTests : CommonKeyValueRepoTests() {
|
|||||||
repo,
|
repo,
|
||||||
Int.serializer(),
|
Int.serializer(),
|
||||||
ComplexData.serializer(),
|
ComplexData.serializer(),
|
||||||
Json {}
|
Json
|
||||||
)
|
)
|
||||||
}
|
}
|
||||||
}.start(false)
|
}.start(false)
|
||||||
|
@ -23,7 +23,7 @@ import kotlinx.serialization.json.Json
|
|||||||
import kotlin.test.*
|
import kotlin.test.*
|
||||||
|
|
||||||
class KtorKeyValuesRepoTests : CommonKeyValuesRepoTests() {
|
class KtorKeyValuesRepoTests : CommonKeyValuesRepoTests() {
|
||||||
private var engine: ApplicationEngine? = null
|
private var engine: EmbeddedServer<*, *>? = null
|
||||||
override val testSequencesSize: Int
|
override val testSequencesSize: Int
|
||||||
get() = 100
|
get() = 100
|
||||||
|
|
||||||
|
@ -13,7 +13,7 @@ import io.ktor.server.websocket.*
|
|||||||
import kotlinx.serialization.json.Json
|
import kotlinx.serialization.json.Json
|
||||||
|
|
||||||
object KtorRepoTestsHelper {
|
object KtorRepoTestsHelper {
|
||||||
fun beforeTest(routingConfigurator: Routing.() -> Unit): ApplicationEngine {
|
fun beforeTest(routingConfigurator: Routing.() -> Unit): EmbeddedServer<CIOApplicationEngine, CIOApplicationEngine.Configuration> {
|
||||||
return embeddedServer(
|
return embeddedServer(
|
||||||
CIO,
|
CIO,
|
||||||
23456,
|
23456,
|
||||||
@ -28,7 +28,7 @@ object KtorRepoTestsHelper {
|
|||||||
routing(routingConfigurator)
|
routing(routingConfigurator)
|
||||||
}.start(false)
|
}.start(false)
|
||||||
}
|
}
|
||||||
fun afterTest(engine: ApplicationEngine) {
|
fun afterTest(engine: EmbeddedServer<*, *>) {
|
||||||
engine.stop()
|
engine.stop()
|
||||||
}
|
}
|
||||||
fun client(): HttpClient = HttpClient {
|
fun client(): HttpClient = HttpClient {
|
||||||
|
@ -16,7 +16,7 @@ import io.ktor.server.application.call
|
|||||||
import io.ktor.server.response.respond
|
import io.ktor.server.response.respond
|
||||||
import io.ktor.server.routing.Route
|
import io.ktor.server.routing.Route
|
||||||
import io.ktor.server.routing.get
|
import io.ktor.server.routing.get
|
||||||
import io.ktor.util.InternalAPI
|
import io.ktor.utils.io.InternalAPI
|
||||||
import io.ktor.util.reflect.typeInfo
|
import io.ktor.util.reflect.typeInfo
|
||||||
import kotlinx.serialization.*
|
import kotlinx.serialization.*
|
||||||
|
|
||||||
|
@ -14,7 +14,7 @@ import io.ktor.server.application.call
|
|||||||
import io.ktor.server.response.respond
|
import io.ktor.server.response.respond
|
||||||
import io.ktor.server.routing.Route
|
import io.ktor.server.routing.Route
|
||||||
import io.ktor.server.routing.get
|
import io.ktor.server.routing.get
|
||||||
import io.ktor.util.InternalAPI
|
import io.ktor.utils.io.InternalAPI
|
||||||
import io.ktor.util.reflect.typeInfo
|
import io.ktor.util.reflect.typeInfo
|
||||||
import kotlinx.serialization.*
|
import kotlinx.serialization.*
|
||||||
|
|
||||||
|
@ -11,7 +11,7 @@ class TypedSerializerTests {
|
|||||||
interface Example {
|
interface Example {
|
||||||
val number: Number
|
val number: Number
|
||||||
}
|
}
|
||||||
val serialFormat = Json { }
|
val serialFormat = Json
|
||||||
|
|
||||||
@Serializable
|
@Serializable
|
||||||
data class Example1(override val number: Long) : Example
|
data class Example1(override val number: Long) : Example
|
||||||
|
Loading…
Reference in New Issue
Block a user