diff --git a/api/api-core/src/main/kotlin/co/nilin/opex/api/core/spi/ConfigProxy.kt b/api/api-core/src/main/kotlin/co/nilin/opex/api/core/spi/ConfigProxy.kt index af2969e65..7d9753344 100644 --- a/api/api-core/src/main/kotlin/co/nilin/opex/api/core/spi/ConfigProxy.kt +++ b/api/api-core/src/main/kotlin/co/nilin/opex/api/core/spi/ConfigProxy.kt @@ -15,7 +15,7 @@ interface ConfigProxy { suspend fun getUserConfig(token: String): UserWebConfig suspend fun updateUserConfig(token: String, request: UpdateUserConfigRequest): UserWebConfig suspend fun getUserFavoritePair(token: String): Set - suspend fun addUserFavoritePair(token: String, pairs: Set): Set - suspend fun removeUserFavoritePair(token: String, pairs: Set): Set + suspend fun addUserFavoritePair(token: String, pair: String): Set + suspend fun removeUserFavoritePair(token: String, pair: String): Set } diff --git a/api/api-ports/api-opex-rest/src/main/kotlin/co/nilin/opex/api/ports/opex/controller/ConfigController.kt b/api/api-ports/api-opex-rest/src/main/kotlin/co/nilin/opex/api/ports/opex/controller/ConfigController.kt index 1c32859a9..c61b07fd2 100644 --- a/api/api-ports/api-opex-rest/src/main/kotlin/co/nilin/opex/api/ports/opex/controller/ConfigController.kt +++ b/api/api-ports/api-opex-rest/src/main/kotlin/co/nilin/opex/api/ports/opex/controller/ConfigController.kt @@ -69,19 +69,19 @@ class ConfigController(private val configProxy: ConfigProxy) { return configProxy.getUserFavoritePair(securityContext.jwtAuthentication().tokenValue()) } - @PostMapping("/user/config/pair") + @PostMapping("/user/config/pair/{pair}") suspend fun addUserFavoritePair( @CurrentSecurityContext securityContext: SecurityContext, - @RequestBody pairs: Set + @PathVariable pair: String ): Set { - return configProxy.addUserFavoritePair(securityContext.jwtAuthentication().tokenValue(), pairs) + return configProxy.addUserFavoritePair(securityContext.jwtAuthentication().tokenValue(), pair) } - @DeleteMapping("/user/config/pair") + @DeleteMapping("/user/config/pair/{pair}") suspend fun removeUserFavoritePair( @CurrentSecurityContext securityContext: SecurityContext, - @RequestBody pairs: Set + @PathVariable pair: String ): Set { - return configProxy.removeUserFavoritePair(securityContext.jwtAuthentication().tokenValue(), pairs) + return configProxy.removeUserFavoritePair(securityContext.jwtAuthentication().tokenValue(), pair) } } \ No newline at end of file diff --git a/api/api-ports/api-proxy-rest/src/main/kotlin/co/nilin/opex/api/ports/proxy/impl/ConfigProxyImpl.kt b/api/api-ports/api-proxy-rest/src/main/kotlin/co/nilin/opex/api/ports/proxy/impl/ConfigProxyImpl.kt index a6a15f512..7d3e19192 100644 --- a/api/api-ports/api-proxy-rest/src/main/kotlin/co/nilin/opex/api/ports/proxy/impl/ConfigProxyImpl.kt +++ b/api/api-ports/api-proxy-rest/src/main/kotlin/co/nilin/opex/api/ports/proxy/impl/ConfigProxyImpl.kt @@ -140,13 +140,12 @@ class ConfigProxyImpl(@Qualifier("generalWebClient") private val webClient: WebC override suspend fun addUserFavoritePair( token: String, - pairs: Set + pair: String ): Set { return webClient.post() - .uri("$baseUrl/user/v1/pair") + .uri("$baseUrl/user/v1/pair/${pair}") .accept(MediaType.APPLICATION_JSON) .header(HttpHeaders.AUTHORIZATION, "Bearer $token") - .body(Mono.just(pairs)) .retrieve() .onStatus({ t -> t.isError }, { it.createException() }) .bodyToMono>() @@ -155,14 +154,13 @@ class ConfigProxyImpl(@Qualifier("generalWebClient") private val webClient: WebC override suspend fun removeUserFavoritePair( token: String, - pairs: Set + pair: String ): Set { return webClient.method(HttpMethod.DELETE) - .uri("$baseUrl/user/v1/pair") + .uri("$baseUrl/user/v1/pair/${pair}") .contentType(MediaType.APPLICATION_JSON) .accept(MediaType.APPLICATION_JSON) .header(HttpHeaders.AUTHORIZATION, "Bearer $token") - .bodyValue(pairs) .retrieve() .onStatus({ it.isError }) { it.createException() } .bodyToMono>()