#148: Define interface for supabase

src/main/kotlin/chatserver/MessageResult.kt

@@ -0,0 +1,16 @@
+package chatserver
+
+import chatserver.ReadChatRepository.ReadResult
+
+data class MessageResult(
+    override val isOk: Boolean,
+    override val item: List<String>,
+    override val error: Exception?,
+) :
+    ReadResult<List<String>> {
+    companion object {
+        fun ok(item: List<String>): MessageResult = MessageResult(true, item, null)
+
+        fun fail(e: Exception? = null): MessageResult = MessageResult(false, emptyList(), e)
+    }
+}

src/main/kotlin/chatserver/PresenceResult.kt

@@ -0,0 +1,16 @@
+package chatserver
+
+import chatserver.ReadChatRepository.ReadResult
+
+data class PresenceResult(
+    override val isOk: Boolean,
+    override val item: Map<String, Boolean>,
+    override val error: Exception?,
+) :
+    ReadResult<Map<String, Boolean>> {
+    companion object {
+        fun ok(item: Map<String, Boolean>): PresenceResult = PresenceResult(true, item, null)
+
+        fun fail(e: Exception? = null): PresenceResult = PresenceResult(false, emptyMap(), e)
+    }
+}

src/main/kotlin/chatserver/ProfileResult.kt

@@ -0,0 +1,16 @@
+package chatserver
+
+import chatserver.ReadChatRepository.ReadResult
+
+data class ProfileResult(
+    override val isOk: Boolean,
+    override val item: Map<String, String>,
+    override val error: Exception?,
+) :
+    ReadResult<Map<String, String>> {
+    companion object {
+        fun ok(item: Map<String, String>): ProfileResult = ProfileResult(true, item, null)
+
+        fun fail(e: Exception? = null): ProfileResult = ProfileResult(false, emptyMap(), e)
+    }
+}

src/main/kotlin/chatserver/ReadChatRepository.kt

@@ -0,0 +1,15 @@
+package chatserver
+
+import kotlinx.coroutines.flow.Flow
+
+interface ReadChatRepository<T : ReadChatRepository.ReadResult<*>> {
+    fun latest(): T
+
+    fun observe(): Flow<T>
+
+    interface ReadResult<T> {
+        val isOk: Boolean
+        val item: T
+        val error: Exception?
+    }
+}

src/main/kotlin/chatserver/SubscribeChatRepository.kt

@@ -0,0 +1,7 @@
+package chatserver
+
+interface SubscribeChatRepository {
+    fun subscribe()
+
+    fun unsubscribe()
+}

src/main/kotlin/chatserver/WriteChatRepository.kt

@@ -0,0 +1,5 @@
+package chatserver
+
+interface WriteChatRepository<T> {
+    fun write(item: T)
+}