Extract MutationEngine and TableBinding abstractions (#201)

Author: em3s

core/src/main/kotlin/com/kakao/actionbase/core/edge/EdgeEvent.kt

@@ -6,6 +6,6 @@ data class EdgeEvent(
     val source: Any,
     val target: Any,
     override val event: Event,
-) : MutationEvent<Pair<Any, Any>> {
-    override val id: Pair<Any, Any> = source to target
+) : MutationEvent {
+    override val key: MutationKey = MutationKey.SourceTarget(source, target)
 }

core/src/main/kotlin/com/kakao/actionbase/core/edge/MultiEdgeEvent.kt

@@ -3,6 +3,8 @@ package com.kakao.actionbase.core.edge
 import com.kakao.actionbase.core.state.Event
 
 data class MultiEdgeEvent(
-    override val id: Any,
+    val id: Any,
     override val event: Event,
-) : MutationEvent<Any>
+) : MutationEvent {
+    override val key: MutationKey = MutationKey.Id(id)
+}

core/src/main/kotlin/com/kakao/actionbase/core/edge/MutationEvent.kt

@@ -3,11 +3,22 @@ package com.kakao.actionbase.core.edge
 import com.kakao.actionbase.core.metadata.common.ModelSchema
 import com.kakao.actionbase.core.state.Event
 
-sealed interface MutationEvent<K : Any> {
-    val id: K
+sealed interface MutationKey {
+    data class SourceTarget(
+        val source: Any,
+        val target: Any,
+    ) : MutationKey
+
+    data class Id(
+        val id: Any,
+    ) : MutationKey
+}
+
+sealed interface MutationEvent {
+    val key: MutationKey
     val event: Event
+}
 
-    interface Source<out E : MutationEvent<*>> {
-        fun createEvent(schema: ModelSchema): E
-    }
+interface UnresolvedEvent {
+    fun createEvent(schema: ModelSchema): MutationEvent
 }

core/src/main/kotlin/com/kakao/actionbase/core/edge/payload/EdgeBulkMutationRequest.kt

@@ -2,7 +2,7 @@ package com.kakao.actionbase.core.edge.payload
 
 import com.kakao.actionbase.core.edge.Edge
 import com.kakao.actionbase.core.edge.EdgeEvent
-import com.kakao.actionbase.core.edge.MutationEvent
+import com.kakao.actionbase.core.edge.UnresolvedEvent
 import com.kakao.actionbase.core.metadata.common.ModelSchema
 import com.kakao.actionbase.core.state.Event
 import com.kakao.actionbase.core.state.EventType
@@ -13,7 +13,7 @@ data class EdgeBulkMutationRequest(
     data class MutationItem(
         val type: EventType,
         val edge: Edge,
-    ) : MutationEvent.Source<EdgeEvent> {
+    ) : UnresolvedEvent {
         override fun createEvent(schema: ModelSchema): EdgeEvent {
             require(schema is ModelSchema.Edge) { "Expected ModelSchema.Edge, but got ${schema::class.simpleName}" }
             val source = schema.source.type.cast(edge.source)

core/src/main/kotlin/com/kakao/actionbase/core/edge/payload/EdgeMutationResponse.kt

@@ -1,5 +1,7 @@
 package com.kakao.actionbase.core.edge.payload
 
+import com.kakao.actionbase.core.edge.MutationKey
+
 data class EdgeMutationResponse(
     val results: List<Item>,
 ) {
@@ -11,11 +13,15 @@ data class EdgeMutationResponse(
     )
 
     companion object {
-        fun from(statuses: List<EdgeMutationStatus>) =
+        fun from(results: List<MutationResult>) =
             EdgeMutationResponse(
-                statuses
-                    .map { Item(source = it.source, target = it.target, count = it.count, status = it.status) }
-                    .sortedBy { "${it.source}:${it.target}" },
+                results
+                    .map {
+                        val key =
+                            it.key as? MutationKey.SourceTarget
+                                ?: error("EdgeMutationResponse requires SourceTarget key, got ${it.key::class.simpleName}")
+                        Item(source = key.source, target = key.target, count = it.count, status = it.status)
+                    }.sortedBy { "${it.source}:${it.target}" },
             )
     }
 }

core/src/main/kotlin/com/kakao/actionbase/core/edge/payload/EdgeMutationStatus.kt

@@ -2,7 +2,7 @@ package com.kakao.actionbase.core.edge.payload
 
 import com.kakao.actionbase.core.edge.MultiEdge
 import com.kakao.actionbase.core.edge.MultiEdgeEvent
-import com.kakao.actionbase.core.edge.MutationEvent
+import com.kakao.actionbase.core.edge.UnresolvedEvent
 import com.kakao.actionbase.core.metadata.common.ModelSchema
 import com.kakao.actionbase.core.state.Event
 import com.kakao.actionbase.core.state.EventType
@@ -13,7 +13,7 @@ data class MultiEdgeBulkMutationRequest(
     data class MutationItem(
         val type: EventType,
         val edge: MultiEdge,
-    ) : MutationEvent.Source<MultiEdgeEvent> {
+    ) : UnresolvedEvent {
         override fun createEvent(schema: ModelSchema): MultiEdgeEvent {
             require(schema is ModelSchema.MultiEdge) { "Expected ModelSchema.MultiEdge, but got ${schema::class.simpleName}" }
             val id = schema.id.type.cast(edge.id)

core/src/main/kotlin/com/kakao/actionbase/core/edge/payload/MultiEdgeBulkMutationRequest.kt

@@ -1,5 +1,7 @@
 package com.kakao.actionbase.core.edge.payload
 
+import com.kakao.actionbase.core.edge.MutationKey
+
 data class MultiEdgeMutationResponse(
     val results: List<Item>,
 ) {
@@ -10,11 +12,15 @@ data class MultiEdgeMutationResponse(
     )
 
     companion object {
-        fun from(statuses: List<MultiEdgeMutationStatus>) =
+        fun from(results: List<MutationResult>) =
             MultiEdgeMutationResponse(
-                statuses
-                    .map { Item(id = it.id, count = it.count, status = it.status) }
-                    .sortedBy { it.toString() },
+                results
+                    .map {
+                        val key =
+                            it.key as? MutationKey.Id
+                                ?: error("MultiEdgeMutationResponse requires Id key, got ${it.key::class.simpleName}")
+                        Item(id = key.id, count = it.count, status = it.status)
+                    }.sortedBy { it.id.toString() },
             )
     }
 }

core/src/main/kotlin/com/kakao/actionbase/core/edge/payload/MultiEdgeMutationResponse.kt

@@ -0,0 +1,21 @@
+package com.kakao.actionbase.core.edge.payload
+
+import com.kakao.actionbase.core.edge.MutationKey
+import com.kakao.actionbase.core.state.State
+
+data class MutationResult(
+    val key: MutationKey,
+    val count: Int,
+    val status: String,
+    val before: State = State.initial,
+    val after: State = State.initial,
+    val acc: Long = 0,
+) {
+    companion object {
+        fun of(
+            key: MutationKey,
+            count: Int,
+            status: String,
+        ) = MutationResult(key, count, status)
+    }
+}