AuthorizedClientsAuthProvider.js

class AuthorizedClientsAuthProvider(
    private val config: Config
): AuthenticationProvider(config), KoinComponent {
    private val authorizedClientsRepository by inject<AuthorizedClientsRepository>()
    override suspend fun onAuthenticate(context: AuthenticationContext) {
        context.call.request.headers[config.headerName]?.let { clientId ->
            if(authorizedClientsRepository.exists(clientId)) {
                context.principal(UserIdPrincipal(clientId))
            } else {
                throw UnauthorizedClientException("Authorization Failed")
            }
        } ?: throw UnauthorizedClientException("Authorization Request must be provided")
    }
    class Config internal constructor(name: String?) : AuthenticationProvider.Config(name) {
        var headerName: String = "ClientId"
    }
}