Added caching in get request with default value of false (#27)

* Added caching in get request with default value of false * Updated publish workflow
HRV-Mart · Jun 17, 2023 · dbdd1e2 · dbdd1e2
1 parent 0f98454
commit dbdd1e2
Show file tree

Hide file tree

Showing 2 changed files with 11 additions and 2 deletions.
diff --git a/.github/workflows/publish.yml b/.github/workflows/publish.yml
@@ -36,4 +36,4 @@ jobs:
         env:
           MAVEN_USERNAME: ${{ secrets.OSSRH_USERNAME }}
           MAVEN_PASSWORD: ${{ secrets.OSSRH_TOKEN }}
-          VERSION: ${{ github.ref_name }}
+          VERSION: ${{ github.event.release.name }}
diff --git a/src/main/kotlin/com/hrv/mart/apicall/APICaller.kt b/src/main/kotlin/com/hrv/mart/apicall/APICaller.kt
@@ -8,6 +8,8 @@ import org.springframework.stereotype.Service
 import org.springframework.web.reactive.function.client.WebClient.Builder
 import org.springframework.web.reactive.function.client.WebClientResponseException
 import reactor.core.publisher.Mono
+import java.time.Duration
+import java.time.temporal.ChronoUnit
 import kotlin.reflect.full.findAnnotation
 
 @Service
@@ -19,13 +21,20 @@ class APICaller(
     fun <T>getData(
         path: String,
         responseClassType: Class<T>,
-        response: ServerHttpResponse
+        response: ServerHttpResponse,
+        isCacheable: Boolean = false
     ): Mono<T> {
         val webClient = webClientBuilder.baseUrl(path)
             .build()
+        val duration =
+            if (isCacheable)
+                2L
+            else
+                0L
         return webClient.get()
             .retrieve()
             .bodyToMono(responseClassType)
+            .cache(Duration.of(duration, ChronoUnit.SECONDS))
             .onErrorResume {
                 setResponse(response, it as WebClientResponseException, responseClassType)
             }