Swordsteel
14e7971f73
- add link in to edit a user in users.html - change to AccountController - update getCreateAccount for change to AccountForm - add getEditAccount - add edit.html - change to Mapping.kt - update AccountForm toAccountRequest to throw exception if password null - add Account Response toAccountForm - change password and passwordConfirm to be null in AccountForm - add PasswordException - add getAccount to AccountRegistryService - add accountRegistryAccount to WebClientCalls.kt
82 lines
3.2 KiB
Kotlin
82 lines
3.2 KiB
Kotlin
package ltd.hlaeja.service
|
|
|
|
import io.github.oshai.kotlinlogging.KotlinLogging
|
|
import java.util.UUID
|
|
import ltd.hlaeja.exception.AccountRegistryException
|
|
import ltd.hlaeja.library.accountRegistry.Account
|
|
import ltd.hlaeja.library.accountRegistry.Authentication
|
|
import ltd.hlaeja.property.AccountRegistryProperty
|
|
import ltd.hlaeja.util.accountRegistryAccount
|
|
import ltd.hlaeja.util.accountRegistryAccounts
|
|
import ltd.hlaeja.util.accountRegistryAuthenticate
|
|
import ltd.hlaeja.util.accountRegistryCreate
|
|
import org.springframework.http.HttpStatus.BAD_REQUEST
|
|
import org.springframework.security.authentication.AuthenticationServiceException
|
|
import org.springframework.security.core.AuthenticationException
|
|
import org.springframework.stereotype.Service
|
|
import org.springframework.web.reactive.function.client.WebClient
|
|
import org.springframework.web.reactive.function.client.WebClientRequestException
|
|
import org.springframework.web.reactive.function.client.WebClientResponseException
|
|
import org.springframework.web.server.ResponseStatusException
|
|
import reactor.core.publisher.Flux
|
|
import reactor.core.publisher.Mono
|
|
|
|
private val log = KotlinLogging.logger {}
|
|
|
|
@Service
|
|
class AccountRegistryService(
|
|
private val webClient: WebClient,
|
|
private val property: AccountRegistryProperty,
|
|
) {
|
|
|
|
fun authenticate(
|
|
request: Authentication.Request,
|
|
): Mono<Authentication.Response> = webClient.accountRegistryAuthenticate(request, property)
|
|
.onErrorResume { error ->
|
|
when (error) {
|
|
is AuthenticationException -> Mono.error(error)
|
|
|
|
is WebClientResponseException -> "WebClient response exception: ${error.message}".let {
|
|
log.error(error) { it }
|
|
Mono.error(AuthenticationServiceException(it, error))
|
|
}
|
|
|
|
is WebClientRequestException -> "An error occurred while making a request: ${error.message}".let {
|
|
log.error(error) { it }
|
|
Mono.error(AuthenticationServiceException(it, error))
|
|
}
|
|
|
|
else -> "An unexpected error occurred: ${error.message}".let {
|
|
log.error(error) { it }
|
|
Mono.error(AuthenticationServiceException(it, error))
|
|
}
|
|
}
|
|
}
|
|
|
|
fun getAccounts(
|
|
page: Int,
|
|
size: Int,
|
|
): Flux<Account.Response> = webClient.accountRegistryAccounts(page, size, property)
|
|
.onErrorResume { error -> Flux.error(ResponseStatusException(BAD_REQUEST, error.message, error)) }
|
|
|
|
fun addAccount(
|
|
request: Account.Request,
|
|
): Mono<Account.Response> = webClient.accountRegistryCreate(request, property)
|
|
.onErrorResume { error ->
|
|
when (error) {
|
|
is AccountRegistryException -> Mono.error(error)
|
|
else -> Mono.error(ResponseStatusException(BAD_REQUEST, error.message))
|
|
}
|
|
}
|
|
|
|
fun getAccount(
|
|
account: UUID,
|
|
): Mono<Account.Response> = webClient.accountRegistryAccount(account, property)
|
|
.onErrorResume { error ->
|
|
when (error) {
|
|
is ResponseStatusException -> Mono.error(error)
|
|
else -> Mono.error(ResponseStatusException(BAD_REQUEST, error.message))
|
|
}
|
|
}
|
|
}
|