feat: updated major version of algolia client library

libs/utils/algolia/build.gradle.kts

@@ -0,0 +1,14 @@
+plugins {
+    `java-library`
+    kotlin("jvm")
+    kotlin("plugin.serialization")
+}
+
+dependencies {
+    implementation(project(":libs:utils:config"))
+    implementation(project(":libs:utils:logging"))
+
+    implementation(Ktor.plugins.serialization.kotlinx.json)
+
+    implementation("com.algolia:algoliasearch-client-kotlin:_")
+}

libs/utils/algolia/src/main/kotlin/com/k33/platform/utils/algolia/AlgoliaRecommendClient.kt

@@ -0,0 +1,57 @@
+package com.k33.platform.utils.algolia
+
+import com.algolia.client.api.RecommendClient
+import com.algolia.client.model.recommend.GetRecommendationsParams
+import com.algolia.client.model.recommend.RecommendHit
+import com.algolia.client.model.recommend.RelatedModel
+import com.algolia.client.model.recommend.RelatedQuery
+
+class AlgoliaRecommendClient(
+    applicationId: Algolia.ApplicationId,
+    apiKey: Algolia.ApiKey,
+    private val index: Algolia.Index,
+) {
+    private val client by lazy {
+        RecommendClient(
+            appId = applicationId.value,
+            apiKey = apiKey.value,
+        )
+    }
+
+    suspend fun getRelated(
+        objectID: Algolia.ObjectID,
+    ): List<Algolia.ObjectID> {
+        return client
+            .getRecommendations(
+                getRecommendationsParams = GetRecommendationsParams(
+                    requests = listOf(
+                        RelatedQuery(
+                            indexName = index.name,
+                            maxRecommendations = 3,
+                            threshold = 40.0,
+                            model = RelatedModel.RelatedProducts,
+                            objectID = objectID.value,
+                        )
+                    )
+                )
+            )
+            .results
+            .flatMap { recommendationsResult ->
+                recommendationsResult.hits.map { hit ->
+                    Algolia.ObjectID((hit as RecommendHit).objectID)
+                }
+            }
+    }
+
+    companion object {
+        fun getInstance(
+            index: Algolia.Index,
+        ): AlgoliaRecommendClient {
+            return AlgoliaRecommendClient(
+                applicationId = algoliaConfig.applicationId,
+                apiKey = algoliaConfig.apiKey,
+                index = index,
+            )
+        }
+    }
+}

libs/utils/algolia/src/main/kotlin/com/k33/platform/utils/algolia/AlgoliaSearchClient.kt

@@ -0,0 +1,76 @@
+package com.k33.platform.utils.algolia
+
+import com.algolia.client.api.SearchClient
+import com.algolia.client.extensions.replaceAllObjects
+import com.algolia.client.model.search.BrowseParamsObject
+import kotlinx.serialization.json.JsonObject
+import kotlinx.serialization.json.jsonPrimitive
+
+class AlgoliaSearchClient(
+    applicationId: Algolia.ApplicationId,
+    apiKey: Algolia.ApiKey,
+    private val index: Algolia.Index,
+) {
+
+    private val client by lazy {
+        SearchClient(
+            appId = applicationId.value,
+            apiKey = apiKey.value,
+        )
+    }
+
+    suspend fun upsert(
+        objectID: Algolia.ObjectID,
+        record: JsonObject,
+    ) {
+        client.addOrUpdateObject(
+            indexName = index.name,
+            objectID = objectID.value,
+            body = record,
+        )
+    }
+
+    suspend fun batchUpsert(
+        records: List<JsonObject>
+    ) {
+        client.replaceAllObjects(
+            indexName = index.name,
+            objects = records,
+        )
+    }
+
+    suspend fun delete(
+        objectID: Algolia.ObjectID,
+    ) {
+        client.deleteObject(
+            indexName = index.name,
+            objectID = objectID.value,
+        )
+    }
+
+    suspend fun getAllIds(): Map<Algolia.ObjectID, String> {
+        return client
+            .browse(
+                indexName = index.name,
+                browseParams = BrowseParamsObject(
+                    attributesToRetrieve = listOf("publishedAt"),
+                )
+            )
+            .hits
+            .associate {
+                Algolia.ObjectID(it.objectID) to it.additionalProperties!!["publishedAt"]!!.jsonPrimitive.content
+            }
+    }
+
+    companion object {
+        fun getInstance(
+            index: Algolia.Index,
+        ): AlgoliaSearchClient {
+            return AlgoliaSearchClient(
+                applicationId = algoliaConfig.applicationId,
+                apiKey = algoliaConfig.apiKey,
+                index = index,
+            )
+        }
+    }
+}

libs/utils/algolia/src/main/kotlin/com/k33/platform/utils/algolia/Config.kt

@@ -0,0 +1,13 @@
+package com.k33.platform.utils.algolia
+
+data class AlgoliaConfig(
+    val applicationId: Algolia.ApplicationId,
+    val apiKey: Algolia.ApiKey,
+)
+
+val algoliaConfig: AlgoliaConfig by lazy {
+    AlgoliaConfig(
+        applicationId = Algolia.ApplicationId(System.getenv("ALGOLIA_APP_ID")),
+        apiKey = Algolia.ApiKey(System.getenv("ALGOLIA_API_KEY")),
+    )
+}

libs/utils/algolia/src/main/kotlin/com/k33/platform/utils/algolia/Model.kt

@@ -0,0 +1,22 @@
+package com.k33.platform.utils.algolia
+
+object Algolia {
+
+    object Key {
+        const val ObjectID = "objectID"
+    }
+
+    @JvmInline
+    value class ApplicationId(val value: String)
+
+    @JvmInline
+    value class ApiKey(val value: String)
+
+    @Suppress("EnumEntryName")
+    enum class Index {
+        articles,
+    }
+
+    @JvmInline
+    value class ObjectID(val value: String)
+}

libs/utils/cms/contentful/build.gradle.kts

@@ -5,6 +5,8 @@ plugins {
 }
 
 dependencies {
+    implementation(project(":libs:utils:algolia"))
+
     implementation(project(":libs:utils:config"))
     implementation(project(":libs:utils:logging"))
     implementation(project(":libs:utils:slack"))
@@ -27,8 +29,6 @@ dependencies {
     implementation("org.apache.logging.log4j:log4j-to-slf4j:_")
     implementation("org.apache.logging.log4j:log4j-core:_")
 
-    implementation("com.algolia:algoliasearch-client-kotlin:_")
-
     // test
     testImplementation("io.kotest:kotest-runner-junit5-jvm:_")
 }

libs/utils/cms/contentful/src/main/kotlin/com/k33/platform/cms/JsonObjectId.kt

@@ -1,10 +1,10 @@
 package com.k33.platform.cms
 
-import com.algolia.search.helper.toObjectID
-import com.k33.platform.cms.sync.Algolia
+import com.k33.platform.utils.algolia.Algolia
 import kotlinx.serialization.json.JsonObject
 import kotlinx.serialization.json.contentOrNull
 import kotlinx.serialization.json.jsonPrimitive
 
 val JsonObject.objectIDString get() = get(Algolia.Key.ObjectID)?.jsonPrimitive?.contentOrNull
-val JsonObject.objectID get() = objectIDString?.toObjectID()
+
+val JsonObject.objectID get() = objectIDString?.let(Algolia::ObjectID)

libs/utils/cms/contentful/src/main/kotlin/com/k33/platform/cms/config/Config.kt

@@ -2,28 +2,25 @@
 
 package com.k33.platform.cms.config
 
+import com.k33.platform.utils.algolia.Algolia
+
 @Suppress("EnumEntryName")
 enum class Sync(
     val config: SyncConfig,
 ) {
     researchArticles(
         SyncConfig(
             ContentfulSpace.research,
-            AlgoliaIndexName.articles,
+            Algolia.Index.articles,
         )
     ),
 }
 
 data class SyncConfig(
     val contentfulSpace: ContentfulSpace,
-    val algoliaIndexName: AlgoliaIndexName,
+    val algoliaIndex: Algolia.Index,
 )
 
-@Suppress("EnumEntryName")
-enum class AlgoliaIndexName {
-    articles,
-}
-
 //
 // Contentful
 //
@@ -46,19 +43,3 @@ data class ContentfulSpaceConfig(
     val token: String,
     val cmaToken: String,
 )
-
-//
-// Algolia
-//
-
-data class AlgoliaConfig(
-    val applicationId: String,
-    val apiKey: String,
-)
-
-val algoliaCconfig: AlgoliaConfig by lazy {
-    AlgoliaConfig(
-        applicationId = System.getenv("ALGOLIA_APP_ID"),
-        apiKey = System.getenv("ALGOLIA_API_KEY"),
-    )
-}

libs/utils/cms/contentful/src/main/kotlin/com/k33/platform/cms/space/research/article/ResearchArticle.kt

@@ -3,9 +3,9 @@ package com.k33.platform.cms.space.research.article
 import com.k33.platform.cms.clients.ContentfulGraphql
 import com.k33.platform.cms.content.Content
 import com.k33.platform.cms.objectIDString
-import com.k33.platform.cms.sync.Algolia
 import com.k33.platform.cms.utils.optional
 import com.k33.platform.cms.utils.richToPlainText
+import com.k33.platform.utils.algolia.Algolia
 import com.k33.platform.utils.config.lazyResourceWithoutWhitespace
 import kotlinx.serialization.json.JsonObject
 import kotlinx.serialization.json.contentOrNull

libs/utils/cms/contentful/src/main/kotlin/com/k33/platform/cms/space/research/page/ResearchPage.kt

@@ -3,9 +3,9 @@ package com.k33.platform.cms.space.research.page
 import com.k33.platform.cms.clients.ContentfulGraphql
 import com.k33.platform.cms.content.Content
 import com.k33.platform.cms.objectIDString
-import com.k33.platform.cms.sync.Algolia
 import com.k33.platform.cms.utils.optional
 import com.k33.platform.cms.utils.richToPlainText
+import com.k33.platform.utils.algolia.Algolia
 import com.k33.platform.utils.config.lazyResourceWithoutWhitespace
 import kotlinx.serialization.json.JsonObject
 import kotlinx.serialization.json.contentOrNull