Merge pull request #162 from InsanusMokrassar/0.11.1

0.11.1
This commit is contained in:
InsanusMokrassar 2022-06-12 16:32:05 +06:00 committed by GitHub
commit 04cf8c3d9a
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
8 changed files with 137 additions and 138 deletions

View File

@ -1,5 +1,11 @@
# Changelog # Changelog
## 0.11.1
* `Repos`
* `Ktor`
* In `configureReadKeyValueRepoRoutes` and `configureReadKeyValuesRepoRoutes` configurators fixed requiring of `reversed` property
## 0.11.0 ## 0.11.0
* `Versions` * `Versions`

View File

@ -14,5 +14,5 @@ crypto_js_version=4.1.1
# Project data # Project data
group=dev.inmo group=dev.inmo
version=0.11.0 version=0.11.1
android_code_version=124 android_code_version=125

View File

@ -13,6 +13,7 @@ import io.ktor.http.content.streamProvider
import io.ktor.server.application.call import io.ktor.server.application.call
import io.ktor.server.request.receiveMultipart import io.ktor.server.request.receiveMultipart
import io.ktor.server.response.respond import io.ktor.server.response.respond
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.*
@ -111,7 +112,7 @@ class TemporalFilesRoutingConfigurator(
temporalFilesMutex.withLock { temporalFilesMutex.withLock {
temporalFilesMap[fileId] = file temporalFilesMap[fileId] = file
} }
call.respond(fileId.string) call.respondText(fileId.string)
launchSafelyWithoutExceptions { filesFlow.emit(fileId) } launchSafelyWithoutExceptions { filesFlow.emit(fileId) }
} ?: call.respond(HttpStatusCode.BadRequest) } ?: call.respond(HttpStatusCode.BadRequest)
} }

View File

@ -1,6 +1,7 @@
package dev.inmo.micro_utils.repos.ktor.client.crud package dev.inmo.micro_utils.repos.ktor.client.crud
import dev.inmo.micro_utils.ktor.common.* import dev.inmo.micro_utils.ktor.common.*
import dev.inmo.micro_utils.pagination.PaginationResult
import dev.inmo.micro_utils.repos.* import dev.inmo.micro_utils.repos.*
import io.ktor.client.HttpClient import io.ktor.client.HttpClient
import io.ktor.http.ContentType import io.ktor.http.ContentType
@ -19,14 +20,14 @@ class KtorCRUDRepoClient<ObjectType, IdType, InputValue> (
inline operator fun <reified ObjectType, reified IdType, reified InputValue> invoke( inline operator fun <reified ObjectType, reified IdType, reified InputValue> invoke(
baseUrl: String, baseUrl: String,
httpClient: HttpClient, httpClient: HttpClient,
objectTypeInfo: TypeInfo,
contentType: ContentType, contentType: ContentType,
noinline idSerializer: suspend (IdType) -> String noinline idSerializer: suspend (IdType) -> String
) = KtorCRUDRepoClient( ) = KtorCRUDRepoClient(
KtorReadCRUDRepoClient( KtorReadCRUDRepoClient(
baseUrl, baseUrl,
httpClient, httpClient,
objectTypeInfo, typeInfo<ObjectType>(),
typeInfo<PaginationResult<ObjectType>>(),
contentType, contentType,
idSerializer idSerializer
), ),
@ -41,33 +42,17 @@ class KtorCRUDRepoClient<ObjectType, IdType, InputValue> (
baseUrl: String, baseUrl: String,
subpart: String, subpart: String,
httpClient: HttpClient, httpClient: HttpClient,
objectTypeInfo: TypeInfo,
contentType: ContentType, contentType: ContentType,
noinline idSerializer: suspend (IdType) -> String noinline idSerializer: suspend (IdType) -> String
) = KtorCRUDRepoClient<ObjectType, IdType, InputValue>( ) = KtorCRUDRepoClient<ObjectType, IdType, InputValue>(
buildStandardUrl(baseUrl, subpart), buildStandardUrl(baseUrl, subpart),
httpClient, httpClient,
objectTypeInfo,
contentType, contentType,
idSerializer idSerializer
) )
} }
} }
inline fun <reified ObjectType, reified IdType, reified InputValue> KtorCRUDRepoClient(
baseUrl: String,
httpClient: HttpClient,
contentType: ContentType,
noinline idSerializer: suspend (IdType) -> String
) = KtorCRUDRepoClient<ObjectType, IdType, InputValue>(
baseUrl,
httpClient,
typeInfo<ObjectType>(),
contentType,
idSerializer
)
inline fun <reified ObjectType, reified IdType, reified InputValue> KtorCRUDRepoClient( inline fun <reified ObjectType, reified IdType, reified InputValue> KtorCRUDRepoClient(
baseUrl: String, baseUrl: String,
httpClient: HttpClient, httpClient: HttpClient,

View File

@ -18,6 +18,7 @@ class KtorReadCRUDRepoClient<ObjectType, IdType> (
private val baseUrl: String, private val baseUrl: String,
private val httpClient: HttpClient, private val httpClient: HttpClient,
private val objectType: TypeInfo, private val objectType: TypeInfo,
private val paginationObjectType: TypeInfo,
private val contentType: ContentType, private val contentType: ContentType,
private val idSerializer: suspend (IdType) -> String private val idSerializer: suspend (IdType) -> String
) : ReadCRUDRepo<ObjectType, IdType> { ) : ReadCRUDRepo<ObjectType, IdType> {
@ -25,7 +26,7 @@ class KtorReadCRUDRepoClient<ObjectType, IdType> (
buildStandardUrl(baseUrl, getByPaginationRouting, pagination.asUrlQueryParts) buildStandardUrl(baseUrl, getByPaginationRouting, pagination.asUrlQueryParts)
) { ) {
contentType(contentType) contentType(contentType)
}.body() }.body(paginationObjectType)
override suspend fun getById(id: IdType): ObjectType? = httpClient.get( override suspend fun getById(id: IdType): ObjectType? = httpClient.get(
buildStandardUrl( buildStandardUrl(
@ -70,6 +71,7 @@ inline fun <reified ObjectType, IdType> KtorReadCRUDRepoClient(
baseUrl, baseUrl,
httpClient, httpClient,
typeInfo<ObjectType>(), typeInfo<ObjectType>(),
typeInfo<PaginationResult<ObjectType>>(),
contentType, contentType,
idSerializer idSerializer
) )

View File

@ -1,7 +1,7 @@
swagger: "2.0" openapi: "3.0.0"
info: info:
description: "This is a template for the KeyValue repositories from [microutils](https://github.com/InsanusMokrassar/MicroUtils/tree/master/repos/ktor/server/src/jvmMain/kotlin/dev/inmo/micro_utils/repos/ktor/server/key/value)" description: "This is a template for the KeyValue repositories from [microutils](https://github.com/InsanusMokrassar/MicroUtils/tree/master/repos/ktor/server/src/jvmMain/kotlin/dev/inmo/micro_utils/repos/ktor/server/key/value)"
version: "0.11.0" version: "0.11.1"
title: "KeyValue Repo" title: "KeyValue Repo"
contact: contact:
email: "ovsyannikov.alexey95@gmail.com" email: "ovsyannikov.alexey95@gmail.com"
@ -11,81 +11,63 @@ tags:
- name: "Write" - name: "Write"
description: "Operations with `post` request in most cases" description: "Operations with `post` request in most cases"
parameters: components:
KeyInQuery: parameters:
in: "query" KeyInQuery:
name: "key" in: "query"
allOf: name: "key"
- $ref: "#/definitions/Key" schema:
KeysInBody: $ref: "#/components/schemas/Key"
in: "body" PaginationInQueryPage:
name: "body" in: "query"
type: array name: "ppage"
items: description: "Page of pagination"
$ref: "#/definitions/Key" schema:
ValuesInBody:
in: "body"
name: "body"
type: array
items:
$ref: "#/definitions/Value"
PaginationInQueryPage:
in: "query"
type: integer
name: "ppage"
description: "Page of pagination"
required: false
PaginationInQuerySize:
in: "query"
type: integer
name: "psize"
description: "Size of each page in pagination"
required: false
ReversedInQuery:
in: "query"
type: boolean
name: "reversed"
description: "If passed, will tell to reverse the result pages"
required: false
ValueInQuery:
in: "query"
name: "value"
allOf:
- $ref: "#/definitions/Value"
MapInBody:
in: "body"
name: "body"
allOf:
- $ref: "#/definitions/Map"
definitions:
Key:
type: integer
description: "REWRITE THIS TYPE AS KEY IN SWAGGER FILE"
Value:
type: integer
description: "REWRITE THIS TYPE AS VALUE IN SWAGGER FILE"
Map:
type: object
description: "Map of objects"
PaginationResult:
type: object
properties:
page:
type: integer type: integer
description: "Page of pagination" required: false
pagesNumber: PaginationInQuerySize:
in: "query"
name: "psize"
description: "Size of each page in pagination"
schema:
type: integer type: integer
description: "Count of pages with the size from this pagination" required: false
size: ReversedInQuery:
type: integer in: "query"
description: "Size of each page in pagination" name: "reversed"
results: description: "If passed, will tell to reverse the result pages"
type: array schema:
description: "Array of all elements on that page. Size of pagination and size of array can be different and it can be interpreted like current page is the last one" type: boolean
items: required: false
type: object ValueInQuery:
in: "query"
name: "value"
schema:
$ref: "#/components/schemas/Value"
schemas:
Key:
type: integer
description: "REWRITE THIS TYPE AS KEY IN SWAGGER FILE"
Value:
type: integer
description: "REWRITE THIS TYPE AS VALUE IN SWAGGER FILE"
PaginationResult:
type: object
properties:
page:
type: integer
description: "Page of pagination"
pagesNumber:
type: integer
description: "Count of pages with the size from this pagination"
size:
type: integer
description: "Size of each page in pagination"
results:
type: array
description: "Array of all elements on that page. Size of pagination and size of array can be different and it can be interpreted like current page is the last one"
items:
type: object
paths: paths:
/get: /get:
@ -93,13 +75,16 @@ paths:
tags: tags:
- "Read" - "Read"
parameters: parameters:
- $ref: "#/parameters/KeyInQuery" - allOf:
required: true - $ref: "#/components/parameters/KeyInQuery"
- required: true
responses: responses:
"200": "200":
description: "Element by key" description: "Element by key"
schema: content:
$ref: "#/definitions/Value" "*/*":
schema:
$ref: "#/components/schemas/Value"
"204": "204":
description: "No value by id" description: "No value by id"
/values: /values:
@ -107,51 +92,57 @@ paths:
tags: tags:
- "Read" - "Read"
parameters: parameters:
- $ref: "#/parameters/PaginationInQueryPage" - $ref: "#/components/parameters/PaginationInQueryPage"
- $ref: "#/parameters/PaginationInQuerySize" - $ref: "#/components/parameters/PaginationInQuerySize"
- $ref: "#/parameters/ReversedInQuery" - $ref: "#/components/parameters/ReversedInQuery"
responses: responses:
"200": "200":
description: "Pagination with elements" description: "Pagination with elements"
schema: content:
allOf: "*/*":
- $ref: "#/definitions/PaginationResult" schema:
- properties: allOf:
results: - $ref: "#/components/schemas/PaginationResult"
items: - properties:
$ref: "#/definitions/Value" results:
items:
$ref: "#/components/schemas/Value"
/keys: /keys:
get: get:
tags: tags:
- "Read" - "Read"
parameters: parameters:
- $ref: "#/parameters/PaginationInQueryPage" - $ref: "#/components/parameters/PaginationInQueryPage"
- $ref: "#/parameters/PaginationInQuerySize" - $ref: "#/components/parameters/PaginationInQuerySize"
- $ref: "#/parameters/ReversedInQuery" - $ref: "#/components/parameters/ReversedInQuery"
- $ref: "#/parameters/ValueInQuery" - $ref: "#/components/parameters/ValueInQuery"
required: false required: false
responses: responses:
"200": "200":
description: "Pagination with elements" description: "Pagination with elements"
schema: content:
allOf: "*/*":
- $ref: "#/definitions/PaginationResult" schema:
- properties: allOf:
results: - $ref: "#/components/schemas/PaginationResult"
items: - properties:
$ref: "#/definitions/Key" results:
items:
$ref: "#/components/schemas/Key"
/contains: /contains:
get: get:
tags: tags:
- "Read" - "Read"
parameters: parameters:
- $ref: "#/parameters/KeyInQuery" - $ref: "#/components/parameters/KeyInQuery"
required: true required: true
responses: responses:
"200": "200":
description: "Object with id availability in repo" description: "Object with id availability in repo"
schema: content:
type: boolean "*/*":
schema:
type: boolean
/count: /count:
get: get:
tags: tags:
@ -159,19 +150,23 @@ paths:
responses: responses:
"200": "200":
description: "Amount of objects in repo" description: "Amount of objects in repo"
schema: content:
type: integer "*/*":
schema:
type: integer
/set: /set:
post: post:
tags: tags:
- "Write" - "Write"
parameters: requestBody:
- allOf: content:
- $ref: "#/parameters/MapInBody" "*/*":
- additionalProperties: schema:
$ref: "#/definitions/Value" type: object
additionalProperties:
$ref: "#/components/schemas/Value"
description: "Map with new elements to set. Use keys as a keys of this map" description: "Map with new elements to set. Use keys as a keys of this map"
responses: responses:
"200": "200":
@ -180,8 +175,13 @@ paths:
post: post:
tags: tags:
- "Write" - "Write"
parameters: requestBody:
- $ref: "#/parameters/KeysInBody" content:
"*/*":
schema:
type: array
items:
$ref: "#/components/schemas/Key"
responses: responses:
"200": "200":
description: "Objects with keys from body has been unset" description: "Objects with keys from body has been unset"
@ -189,8 +189,13 @@ paths:
post: post:
tags: tags:
- "Write" - "Write"
parameters: requestBody:
- $ref: "#/parameters/ValuesInBody" content:
"*/*":
schema:
type: array
items:
$ref: "#/components/schemas/Value"
responses: responses:
"200": "200":
description: "Objects with values from body has been unset" description: "Objects with values from body has been unset"

View File

@ -51,7 +51,7 @@ inline fun <reified Key, reified Value> Route.configureReadKeyValueRepoRoutes (
get(keysRoute) { get(keysRoute) {
val pagination = call.request.queryParameters.extractPagination val pagination = call.request.queryParameters.extractPagination
val reversed = call.getQueryParameterOrSendError(reversedParameterName) ?.toBoolean() ?: false val reversed = call.getQueryParameter(reversedParameterName) ?.toBoolean() ?: false
val value = call.getQueryParameter(valueParameterName) ?.let { val value = call.getQueryParameter(valueParameterName) ?.let {
valueDeserializer(it) valueDeserializer(it)
} }

View File

@ -42,7 +42,7 @@ inline fun <reified Key, reified Value> Route.configureReadKeyValuesRepoRoutes (
get(keysRoute) { get(keysRoute) {
val pagination = call.request.queryParameters.extractPagination val pagination = call.request.queryParameters.extractPagination
val reversed = call.getQueryParameterOrSendError(reversedParameterName) ?.toBoolean() ?: false val reversed = call.getQueryParameter(reversedParameterName) ?.toBoolean() ?: false
val value = call.getQueryParameter(valueParameterName) ?.let { val value = call.getQueryParameter(valueParameterName) ?.let {
valueDeserializer(it) valueDeserializer(it)
} }