remove support for any serializable object on key value store

backend/src/main/kotlin/me/sujanpoudel/playdeals/domain/entities/Mappers.kt

@@ -1,10 +1,8 @@
 package me.sujanpoudel.playdeals.domain.entities
 
-import io.vertx.core.json.Json
 import io.vertx.sqlclient.Row
 import me.sujanpoudel.playdeals.common.asEnum
 import me.sujanpoudel.playdeals.common.get
-import kotlin.reflect.KClass
 
 fun Row.asAppDeal(): DealEntity {
   return DealEntity(
@@ -28,11 +26,5 @@ fun Row.asAppDeal(): DealEntity {
   )
 }
 
-fun <T : Any> Row.asKeyValue(clazz: KClass<out T>): KeyValueEntity<T> {
-  return KeyValueEntity(
-    get("key"),
-    getString("value").let {
-      Json.CODEC.fromValue(it, clazz.java)
-    }
-  )
-}
+fun Row?.valueOrNull() = this?.getString("value")
+fun Row.value(): String = getString("value")

backend/src/main/kotlin/me/sujanpoudel/playdeals/jobs/RedditPostsScrapper.kt

@@ -9,7 +9,6 @@ import me.sujanpoudel.playdeals.common.SIMPLE_NAME
 import me.sujanpoudel.playdeals.common.loggingExecutionTime
 import me.sujanpoudel.playdeals.log
 import me.sujanpoudel.playdeals.repositories.KeyValuesRepository
-import me.sujanpoudel.playdeals.repositories.get
 import org.jobrunr.jobs.lambdas.JobRequest
 import org.jobrunr.scheduling.JobRequestScheduler
 import org.jobrunr.scheduling.RecurringJobBuilder
@@ -45,7 +44,7 @@ class RedditPostsScrapper(
   override suspend fun handleRequest(jobRequest: Request): Unit = loggingExecutionTime(
     "$SIMPLE_NAME:: handleRequest"
   ) {
-    val lastPostTime = keyValueRepository.get<String>(LAST_REDDIT_POST_TIME)?.let(OffsetDateTime::parse)
+    val lastPostTime = keyValueRepository.get(LAST_REDDIT_POST_TIME)?.let(OffsetDateTime::parse)
 
     val posts = loggingExecutionTime(
       "$SIMPLE_NAME:: Fetched reddit post, last created post was at : '$lastPostTime'"

backend/src/main/kotlin/me/sujanpoudel/playdeals/repositories/KeyValuesRepository.kt

@@ -1,18 +1,9 @@
 package me.sujanpoudel.playdeals.repositories
 
-import me.sujanpoudel.playdeals.domain.entities.KeyValueEntity
-import kotlin.reflect.KClass
-
 interface KeyValuesRepository {
-  suspend fun <T : Any> set(key: String, value: T, clazz: KClass<out T> = value::class): KeyValueEntity<T>
+  suspend fun set(key: String, value: String): String
 
-  suspend fun <T : Any> get(key: String, clazz: KClass<T>): T?
+  suspend fun get(key: String): String?
 
   suspend fun delete(key: String)
 }
-
-suspend inline fun <reified T : Any> KeyValuesRepository.set(key: String, value: T): KeyValueEntity<T> {
-  return set(key, value, T::class)
-}
-
-suspend inline fun <reified T : Any> KeyValuesRepository.get(key: String) = get(key, T::class)

backend/src/main/kotlin/me/sujanpoudel/playdeals/repositories/persistent/PersistentKeyValuesRepository.kt

@@ -1,41 +1,38 @@
 package me.sujanpoudel.playdeals.repositories.persistent
 
-import io.vertx.core.json.Json
 import io.vertx.kotlin.coroutines.await
 import io.vertx.sqlclient.SqlClient
 import me.sujanpoudel.playdeals.common.exec
-import me.sujanpoudel.playdeals.domain.entities.KeyValueEntity
-import me.sujanpoudel.playdeals.domain.entities.asKeyValue
+import me.sujanpoudel.playdeals.domain.entities.value
+import me.sujanpoudel.playdeals.domain.entities.valueOrNull
 import me.sujanpoudel.playdeals.repositories.KeyValuesRepository
-import kotlin.reflect.KClass
-
-private fun Any.serializeToString(): String = Json.CODEC.toString(this)
 
 class PersistentKeyValuesRepository(
   private val sqlClient: SqlClient
 ) : KeyValuesRepository {
 
-  override suspend fun <T : Any> set(key: String, value: T, clazz: KClass<out T>): KeyValueEntity<T> {
+  override suspend fun set(key: String, value: String): String {
     return sqlClient.preparedQuery(
       """
       INSERT INTO "key_value_store" VALUES ($1,$2)
           ON CONFLICT(key) DO UPDATE SET value = $2
       RETURNING *
       """.trimIndent()
-    ).exec(key, value.serializeToString())
+    ).exec(key, value)
       .await()
       .first()
-      .asKeyValue<T>(clazz)
+      .value()
   }
 
-  override suspend fun <T : Any> get(key: String, clazz: KClass<T>): T? {
+  override suspend fun get(key: String): String? {
     return sqlClient.preparedQuery(
       """
       SELECT * FROM "key_value_store" WHERE key = $1
       """.trimIndent()
     ).exec(key)
       .await()
-      .firstOrNull()?.asKeyValue(clazz)?.value
+      .firstOrNull()
+      .valueOrNull()
   }
 
   override suspend fun delete(key: String) {

backend/src/test/kotlin/me/sujanpoudel/playdeals/repositories/PersistentKeyValueRepositoryTest.kt

@@ -0,0 +1,61 @@
+package me.sujanpoudel.playdeals.repositories
+
+import io.kotest.matchers.shouldBe
+import io.vertx.core.Vertx
+import io.vertx.kotlin.coroutines.await
+import io.vertx.sqlclient.SqlClient
+import me.sujanpoudel.playdeals.IntegrationTest
+import me.sujanpoudel.playdeals.common.exec
+import me.sujanpoudel.playdeals.domain.entities.value
+import me.sujanpoudel.playdeals.get
+import org.junit.jupiter.api.Test
+import java.time.OffsetDateTime
+
+class PersistentKeyValueRepositoryTest(vertx: Vertx) : IntegrationTest(vertx) {
+
+  private val repository by lazy { di.get<KeyValuesRepository>() }
+  private val sqlClient by lazy { di.get<SqlClient>() }
+
+  @Test
+  fun `should create new entry on db`() = runTest {
+    val value = repository.set(KEY, "test")
+
+    val valueFromDb = sqlClient.preparedQuery(""" SELECT * from "key_value_store" where key=$1""")
+      .exec(KEY)
+      .await()
+      .first()
+      .getString("value")
+
+    value shouldBe valueFromDb
+  }
+
+  @Test
+  fun `should perform update if item with id already exists`() = runTest {
+    repository.set(KEY, "test")
+
+    val updated = repository.set(KEY, "test1")
+
+    val fromDb = sqlClient.preparedQuery(""" SELECT * from "key_value_store" where key=$1""")
+      .exec(KEY)
+      .await()
+      .first()
+      .value()
+
+    fromDb shouldBe updated
+  }
+
+  @Test
+  fun `should be able to serialize unknown types`() = runTest {
+    val value = OffsetDateTime.now()
+
+    repository.set(KEY, value.toString())
+
+    val fromDb = repository.get(KEY).let(OffsetDateTime::parse)
+
+    fromDb shouldBe value
+  }
+
+  companion object {
+    const val KEY = "test_key"
+  }
+}