feat: full effect executed action into element.

ibm-iloom · ibm-iloom · commit e9d2740521cd · 2020-03-21T16:16:05.000+02:00
feat: When action is executed success, New ElementFlow.kt should be insert into db
feat: Once the executed action is done, element workflow &amp; stage should be updated to the one related to executed task.
diff --git a/clef-workflow-api/clef-workflow-api-adapter/clef-workflow-api-adapter-element/src/main/kotlin/io/quee/clef/workflow/api/adapter/element/creator/ElementFlowIdentityCreatorImpl.kt b/clef-workflow-api/clef-workflow-api-adapter/clef-workflow-api-adapter-element/src/main/kotlin/io/quee/clef/workflow/api/adapter/element/creator/ElementFlowIdentityCreatorImpl.kt
@@ -3,8 +3,12 @@ package io.quee.clef.workflow.api.adapter.element.creator
 import io.quee.clef.workflow.api.adapter.entity.element.ElementFlow
 import io.quee.clef.workflow.api.adapter.entity.workflow.StageTask
 import io.quee.clef.workflow.api.adapter.entity.workflow.TaskAction
+import io.quee.clef.workflow.api.adapter.entity.workflow.Workflow
+import io.quee.clef.workflow.api.adapter.entity.workflow.WorkflowStage
 import io.quee.clef.workflow.api.adapter.shared.creator.BaseStoreIdentityCreator
 import io.quee.clef.workflow.api.domain.element.flow.ElementFlowIdentity
+import io.quee.clef.workflow.api.domain.workflow.WorkflowIdentity
+import io.quee.clef.workflow.api.domain.workflow.stage.StageIdentity
 import io.quee.clef.workflow.api.domain.workflow.stage.action.TaskActionIdentity
 import io.quee.clef.workflow.api.domain.workflow.stage.task.StageTaskIdentity
 import io.quee.clef.workflow.api.store.element.creator.ElementFlowIdentityCreator
@@ -15,9 +19,32 @@ import io.quee.clef.workflow.api.store.element.creator.ElementFlowIdentityCreato
  * Project **clef-workflow** [Quee.IO](https://quee.io/)<br></br>
  */
 class ElementFlowIdentityCreatorImpl : BaseStoreIdentityCreator<ElementFlowIdentity>(), ElementFlowIdentityCreator {
+    private lateinit var fromWorkflow: Workflow
+    private lateinit var toWorkflow: Workflow
+    private lateinit var fromStage: WorkflowStage
+    private lateinit var toStage: WorkflowStage
     private lateinit var fromTask: StageTask
     private lateinit var toTask: StageTask
     private lateinit var action: TaskAction
+    override fun WorkflowIdentity.fromWorkflow(): ElementFlowIdentityCreator {
+        fromWorkflow = this as Workflow
+        return this@ElementFlowIdentityCreatorImpl
+    }
+
+    override fun WorkflowIdentity.toWorkflow(): ElementFlowIdentityCreator {
+        toWorkflow = this as Workflow
+        return this@ElementFlowIdentityCreatorImpl
+    }
+
+    override fun StageIdentity.fromStage(): ElementFlowIdentityCreator {
+        fromStage = this as WorkflowStage
+        return this@ElementFlowIdentityCreatorImpl
+    }
+
+    override fun StageIdentity.toStage(): ElementFlowIdentityCreator {
+        toStage = this as WorkflowStage
+        return this@ElementFlowIdentityCreatorImpl
+    }
 
     override fun StageTaskIdentity.fromTask(): ElementFlowIdentityCreator {
         fromTask = this as StageTask
@@ -35,6 +62,6 @@ class ElementFlowIdentityCreatorImpl : BaseStoreIdentityCreator<ElementFlowIdent
     }
 
     override fun create(): ElementFlowIdentity {
-        return ElementFlow(fromTask, toTask, action, identityStatus = identityStatus)
+        return ElementFlow(fromTask, toTask, action, fromWorkflow, toWorkflow, fromStage, toStage, identityStatus = identityStatus)
     }
 }
diff --git a/clef-workflow-api/clef-workflow-api-adapter/clef-workflow-api-adapter-element/src/main/kotlin/io/quee/clef/workflow/api/adapter/element/updater/ElementIdentityUpdaterImpl.kt b/clef-workflow-api/clef-workflow-api-adapter/clef-workflow-api-adapter-element/src/main/kotlin/io/quee/clef/workflow/api/adapter/element/updater/ElementIdentityUpdaterImpl.kt
@@ -3,11 +3,13 @@ package io.quee.clef.workflow.api.adapter.element.updater
 import io.quee.clef.workflow.api.adapter.entity.element.Element
 import io.quee.clef.workflow.api.adapter.entity.element.ElementFlow
 import io.quee.clef.workflow.api.adapter.entity.workflow.StageTask
+import io.quee.clef.workflow.api.adapter.entity.workflow.Workflow
 import io.quee.clef.workflow.api.adapter.entity.workflow.WorkflowStage
 import io.quee.clef.workflow.api.adapter.shared.entity.BaseIdentity
 import io.quee.clef.workflow.api.adapter.shared.updater.BaseStoreIdentityUpdater
 import io.quee.clef.workflow.api.domain.element.ElementIdentity
 import io.quee.clef.workflow.api.domain.element.flow.ElementFlowIdentity
+import io.quee.clef.workflow.api.domain.workflow.WorkflowIdentity
 import io.quee.clef.workflow.api.domain.workflow.stage.StageIdentity
 import io.quee.clef.workflow.api.domain.workflow.stage.task.StageTaskIdentity
 import io.quee.clef.workflow.api.store.element.updater.ElementIdentityUpdater
@@ -20,6 +22,11 @@ import io.quee.clef.workflow.api.store.element.updater.ElementIdentityUpdater
 class ElementIdentityUpdaterImpl(private val element: Element) : BaseStoreIdentityUpdater<ElementIdentity>(), ElementIdentityUpdater {
     override fun entity(): BaseIdentity = element
 
+    override fun WorkflowIdentity.currentWorkflow(): ElementIdentityUpdater {
+        element.workflow = this as Workflow
+        return this@ElementIdentityUpdaterImpl
+    }
+
     override fun StageIdentity.currentStage(): ElementIdentityUpdater {
         element.currentStage = this as WorkflowStage
         return this@ElementIdentityUpdaterImpl
diff --git a/clef-workflow-api/clef-workflow-api-adapter/clef-workflow-api-adapter-entity/src/main/kotlin/io/quee/clef/workflow/api/adapter/entity/element/ElementFlow.kt b/clef-workflow-api/clef-workflow-api-adapter/clef-workflow-api-adapter-entity/src/main/kotlin/io/quee/clef/workflow/api/adapter/entity/element/ElementFlow.kt
@@ -3,6 +3,8 @@ package io.quee.clef.workflow.api.adapter.entity.element
 import io.quee.api.develop.shared.model.IdentityStatus
 import io.quee.clef.workflow.api.adapter.entity.workflow.StageTask
 import io.quee.clef.workflow.api.adapter.entity.workflow.TaskAction
+import io.quee.clef.workflow.api.adapter.entity.workflow.Workflow
+import io.quee.clef.workflow.api.adapter.entity.workflow.WorkflowStage
 import io.quee.clef.workflow.api.adapter.shared.entity.BaseIdentity
 import io.quee.clef.workflow.api.domain.element.flow.ElementFlowIdentity
 import java.time.LocalDateTime
@@ -19,6 +21,10 @@ class ElementFlow(
         @ManyToOne(optional = false) override var fromTask: StageTask,
         @ManyToOne(optional = false) override var toTask: StageTask,
         @ManyToOne(optional = false) override var action: TaskAction,
+        @ManyToOne(optional = false) override var fromWorkflow: Workflow,
+        @ManyToOne(optional = false) override var toWorkflow: Workflow,
+        @ManyToOne(optional = false) override var fromStage: WorkflowStage,
+        @ManyToOne(optional = false) override var toStage: WorkflowStage,
         @Id override var uuid: String = UUID.randomUUID().toString(),
         @Column(nullable = false) @Enumerated(EnumType.STRING) override var identityStatus: IdentityStatus = IdentityStatus.ENABLED,
         @Column(nullable = false) override var creationDate: LocalDateTime = LocalDateTime.now()
diff --git a/clef-workflow-api/clef-workflow-api-adapter/clef-workflow-api-adapter-stage/src/main/kotlin/io/quee/clef/workflow/api/adapter/stage/query/StageStoreQueryImpl.kt b/clef-workflow-api/clef-workflow-api-adapter/clef-workflow-api-adapter-stage/src/main/kotlin/io/quee/clef/workflow/api/adapter/stage/query/StageStoreQueryImpl.kt
@@ -1,9 +1,11 @@
 package io.quee.clef.workflow.api.adapter.stage.query
 
+import io.quee.clef.workflow.api.adapter.entity.workflow.StageTask
 import io.quee.clef.workflow.api.adapter.entity.workflow.WorkflowStage
 import io.quee.clef.workflow.api.adapter.shared.query.StoreQueryImpl
 import io.quee.clef.workflow.api.adapter.stage.repository.WorkflowStageRepository
 import io.quee.clef.workflow.api.domain.workflow.stage.StageIdentity
+import io.quee.clef.workflow.api.domain.workflow.stage.task.StageTaskIdentity
 import io.quee.clef.workflow.api.store.stage.query.StageStoreQuery
 
 /**
@@ -19,4 +21,9 @@ class StageStoreQueryImpl(
 
     override fun existByKey(stageKey: String): Boolean =
             workflowStageRepository.existsByStageKey(stageKey)
+
+    override fun findByTask(stageTaskIdentity: StageTaskIdentity): StageIdentity? {
+        val tasks = listOf(stageTaskIdentity as StageTask)
+        return workflowStageRepository.findByTasksInOrInitialTaskIn(tasks, tasks)
+    }
 }
diff --git a/clef-workflow-api/clef-workflow-api-adapter/clef-workflow-api-adapter-stage/src/main/kotlin/io/quee/clef/workflow/api/adapter/stage/repository/WorkflowStageRepository.kt b/clef-workflow-api/clef-workflow-api-adapter/clef-workflow-api-adapter-stage/src/main/kotlin/io/quee/clef/workflow/api/adapter/stage/repository/WorkflowStageRepository.kt
@@ -1,5 +1,6 @@
 package io.quee.clef.workflow.api.adapter.stage.repository
 
+import io.quee.clef.workflow.api.adapter.entity.workflow.StageTask
 import io.quee.clef.workflow.api.adapter.entity.workflow.WorkflowStage
 import io.quee.clef.workflow.api.adapter.shared.repository.MainRepository
 import org.springframework.stereotype.Repository
@@ -12,6 +13,7 @@ import org.springframework.stereotype.Repository
 @Repository
 interface WorkflowStageRepository : MainRepository<WorkflowStage> {
     fun findByStageKeyAndUuid(workflowKey: String, uuid: String): WorkflowStage?
-    fun existsByStageKeyAndUuid(workflowKey: String, uuid: String): Boolean
     fun existsByStageKey(workflowKey: String): Boolean
+
+    fun findByTasksInOrInitialTaskIn(tasks: List<StageTask>, initialTask: List<StageTask>): WorkflowStage?
 }
diff --git a/clef-workflow-api/clef-workflow-api-adapter/clef-workflow-api-adapter-workflow/src/main/kotlin/io/quee/clef/workflow/api/adapter/workflow/query/WorkflowStoreQueryImpl.kt b/clef-workflow-api/clef-workflow-api-adapter/clef-workflow-api-adapter-workflow/src/main/kotlin/io/quee/clef/workflow/api/adapter/workflow/query/WorkflowStoreQueryImpl.kt
@@ -1,9 +1,11 @@
 package io.quee.clef.workflow.api.adapter.workflow.query
 
 import io.quee.clef.workflow.api.adapter.entity.workflow.Workflow
+import io.quee.clef.workflow.api.adapter.entity.workflow.WorkflowStage
 import io.quee.clef.workflow.api.adapter.shared.query.StoreQueryImpl
 import io.quee.clef.workflow.api.adapter.workflow.repository.WorkflowRepository
 import io.quee.clef.workflow.api.domain.workflow.WorkflowIdentity
+import io.quee.clef.workflow.api.domain.workflow.stage.StageIdentity
 import io.quee.clef.workflow.api.store.workflow.query.WorkflowStoreQuery
 
 /**
@@ -22,4 +24,9 @@ class WorkflowStoreQueryImpl(
 
     override fun existByKey(workflowKey: String): Boolean =
             workflowRepository.existsByWorkflowKey(workflowKey)
+
+    override fun findByStage(stageIdentity: StageIdentity): WorkflowIdentity? {
+        val stages = listOf(stageIdentity as WorkflowStage)
+        return workflowRepository.findByStagesInOrInitialStageIn(stages, stages)
+    }
 }
diff --git a/clef-workflow-api/clef-workflow-api-adapter/clef-workflow-api-adapter-workflow/src/main/kotlin/io/quee/clef/workflow/api/adapter/workflow/repository/WorkflowRepository.kt b/clef-workflow-api/clef-workflow-api-adapter/clef-workflow-api-adapter-workflow/src/main/kotlin/io/quee/clef/workflow/api/adapter/workflow/repository/WorkflowRepository.kt
@@ -1,6 +1,7 @@
 package io.quee.clef.workflow.api.adapter.workflow.repository
 
 import io.quee.clef.workflow.api.adapter.entity.workflow.Workflow
+import io.quee.clef.workflow.api.adapter.entity.workflow.WorkflowStage
 import io.quee.clef.workflow.api.adapter.shared.repository.MainRepository
 import org.springframework.stereotype.Repository
 
@@ -14,4 +15,6 @@ interface WorkflowRepository : MainRepository<Workflow> {
     fun findByWorkflowKeyAndUuid(workflowKey: String, uuid: String): Workflow?
     fun existsByWorkflowKeyAndUuid(workflowKey: String, uuid: String): Boolean
     fun existsByWorkflowKey(workflowKey: String): Boolean
+
+    fun findByStagesInOrInitialStageIn(stages: List<WorkflowStage>, initialStage: List<WorkflowStage>): Workflow?
 }
diff --git a/clef-workflow-api/clef-workflow-api-domain/clef-workflow-api-domain-element/src/main/kotlin/io/quee/clef/workflow/api/domain/element/flow/ElementFlowIdentity.kt b/clef-workflow-api/clef-workflow-api-domain/clef-workflow-api-domain-element/src/main/kotlin/io/quee/clef/workflow/api/domain/element/flow/ElementFlowIdentity.kt
@@ -1,6 +1,8 @@
 package io.quee.clef.workflow.api.domain.element.flow
 
 import io.quee.api.develop.shared.model.Identity
+import io.quee.clef.workflow.api.domain.workflow.WorkflowIdentity
+import io.quee.clef.workflow.api.domain.workflow.stage.StageIdentity
 import io.quee.clef.workflow.api.domain.workflow.stage.action.TaskActionIdentity
 import io.quee.clef.workflow.api.domain.workflow.stage.task.StageTaskIdentity
 
@@ -10,6 +12,10 @@ import io.quee.clef.workflow.api.domain.workflow.stage.task.StageTaskIdentity
  * Project **clef-workflow** [Quee.IO](https://quee.io/)<br></br>
  */
 interface ElementFlowIdentity : Identity {
+    val fromWorkflow: WorkflowIdentity
+    val toWorkflow: WorkflowIdentity
+    val fromStage: StageIdentity
+    val toStage: StageIdentity
     val fromTask: StageTaskIdentity
     val toTask: StageTaskIdentity
     val action: TaskActionIdentity
diff --git a/clef-workflow-api/clef-workflow-api-port/clef-workflow-api-port-element/src/main/kotlin/io/quee/clef/workflow/api/port/element/ElementContextPort.kt b/clef-workflow-api/clef-workflow-api-port/clef-workflow-api-port-element/src/main/kotlin/io/quee/clef/workflow/api/port/element/ElementContextPort.kt
@@ -5,6 +5,7 @@ import io.quee.clef.workflow.api.store.element.ElementFlowStore
 import io.quee.clef.workflow.api.store.element.ElementStore
 import io.quee.clef.workflow.api.usecase.domain.element.ElementDomainUseCaseFactoryImpl
 import io.quee.clef.workflow.api.usecase.element.ElementUseCaseFactoryImpl
+import io.quee.clef.workflow.api.usecase.factory.domain.StageDomainUseCaseFactory
 import io.quee.clef.workflow.api.usecase.factory.domain.TaskActionDomainUseCaseFactory
 import io.quee.clef.workflow.api.usecase.factory.domain.WorkflowDomainUseCaseFactory
 import io.quee.clef.workflow.api.usecase.factory.element.ElementUseCaseFactory
@@ -26,15 +27,17 @@ class ElementContextPort {
             elementDomainUseCaseFactory: ElementDomainUseCaseFactory,
             workflowDomainUseCaseFactory: WorkflowDomainUseCaseFactory,
             taskActionDomainUseCaseFactory: TaskActionDomainUseCaseFactory,
-            identityAccessValidation: IdentityAccessValidation
+            identityAccessValidation: IdentityAccessValidation,
+            stageDomainUseCaseFactory: StageDomainUseCaseFactory
     ): ElementUseCaseFactory =
             ElementUseCaseFactoryImpl(
                     elementStore,
                     elementFlowStore,
                     elementDomainUseCaseFactory,
                     workflowDomainUseCaseFactory,
                     taskActionDomainUseCaseFactory,
-                    identityAccessValidation
+                    identityAccessValidation,
+                    stageDomainUseCaseFactory
             )
 
     @Bean
diff --git a/clef-workflow-api/clef-workflow-api-store/clef-workflow-api-store-element/src/main/kotlin/io/quee/clef/workflow/api/store/element/creator/ElementFlowIdentityCreator.kt b/clef-workflow-api/clef-workflow-api-store/clef-workflow-api-store-element/src/main/kotlin/io/quee/clef/workflow/api/store/element/creator/ElementFlowIdentityCreator.kt
@@ -2,6 +2,8 @@ package io.quee.clef.workflow.api.store.element.creator
 
 import io.quee.api.develop.store.StoreIdentityCreator
 import io.quee.clef.workflow.api.domain.element.flow.ElementFlowIdentity
+import io.quee.clef.workflow.api.domain.workflow.WorkflowIdentity
+import io.quee.clef.workflow.api.domain.workflow.stage.StageIdentity
 import io.quee.clef.workflow.api.domain.workflow.stage.action.TaskActionIdentity
 import io.quee.clef.workflow.api.domain.workflow.stage.task.StageTaskIdentity
 
@@ -11,6 +13,10 @@ import io.quee.clef.workflow.api.domain.workflow.stage.task.StageTaskIdentity
  * Project **clef-workflow** [Quee.IO](https://quee.io/)<br></br>
  */
 interface ElementFlowIdentityCreator : StoreIdentityCreator<ElementFlowIdentity> {
+    fun WorkflowIdentity.fromWorkflow(): ElementFlowIdentityCreator
+    fun WorkflowIdentity.toWorkflow(): ElementFlowIdentityCreator
+    fun StageIdentity.fromStage(): ElementFlowIdentityCreator
+    fun StageIdentity.toStage(): ElementFlowIdentityCreator
     fun StageTaskIdentity.fromTask(): ElementFlowIdentityCreator
     fun StageTaskIdentity.toTask(): ElementFlowIdentityCreator
     fun TaskActionIdentity.action(): ElementFlowIdentityCreator
diff --git a/clef-workflow-api/clef-workflow-api-store/clef-workflow-api-store-element/src/main/kotlin/io/quee/clef/workflow/api/store/element/updater/ElementIdentityUpdater.kt b/clef-workflow-api/clef-workflow-api-store/clef-workflow-api-store-element/src/main/kotlin/io/quee/clef/workflow/api/store/element/updater/ElementIdentityUpdater.kt
@@ -3,6 +3,7 @@ package io.quee.clef.workflow.api.store.element.updater
 import io.quee.api.develop.store.StoreIdentityUpdater
 import io.quee.clef.workflow.api.domain.element.ElementIdentity
 import io.quee.clef.workflow.api.domain.element.flow.ElementFlowIdentity
+import io.quee.clef.workflow.api.domain.workflow.WorkflowIdentity
 import io.quee.clef.workflow.api.domain.workflow.stage.StageIdentity
 import io.quee.clef.workflow.api.domain.workflow.stage.task.StageTaskIdentity
 
@@ -12,6 +13,7 @@ import io.quee.clef.workflow.api.domain.workflow.stage.task.StageTaskIdentity
  * Project **clef-workflow** [Quee.IO](https://quee.io/)<br></br>
  */
 interface ElementIdentityUpdater : StoreIdentityUpdater<ElementIdentity> {
+    fun WorkflowIdentity.currentWorkflow(): ElementIdentityUpdater
     fun StageIdentity.currentStage(): ElementIdentityUpdater
     fun StageTaskIdentity.currentTask(): ElementIdentityUpdater
     fun ElementFlowIdentity.addFlow(): ElementIdentityUpdater
diff --git a/clef-workflow-api/clef-workflow-api-store/clef-workflow-api-store-stage/src/main/kotlin/io/quee/clef/workflow/api/store/stage/query/StageStoreQuery.kt b/clef-workflow-api/clef-workflow-api-store/clef-workflow-api-store-stage/src/main/kotlin/io/quee/clef/workflow/api/store/stage/query/StageStoreQuery.kt
@@ -2,6 +2,7 @@ package io.quee.clef.workflow.api.store.stage.query
 
 import io.quee.api.develop.store.StoreQuery
 import io.quee.clef.workflow.api.domain.workflow.stage.StageIdentity
+import io.quee.clef.workflow.api.domain.workflow.stage.task.StageTaskIdentity
 
 /**
  * Created By [**Ibrahim Al-Tamimi **](https://www.linkedin.com/in/iloom/)<br></br>
@@ -15,4 +16,6 @@ interface StageStoreQuery : StoreQuery<StageIdentity> {
     ): StageIdentity?
 
     fun existByKey(stageKey: String): Boolean
+
+    fun findByTask(stageTaskIdentity: StageTaskIdentity): StageIdentity?
 }
diff --git a/clef-workflow-api/clef-workflow-api-store/clef-workflow-api-store-workflow/src/main/kotlin/io/quee/clef/workflow/api/store/workflow/query/WorkflowStoreQuery.kt b/clef-workflow-api/clef-workflow-api-store/clef-workflow-api-store-workflow/src/main/kotlin/io/quee/clef/workflow/api/store/workflow/query/WorkflowStoreQuery.kt
@@ -2,6 +2,7 @@ package io.quee.clef.workflow.api.store.workflow.query
 
 import io.quee.api.develop.store.StoreQuery
 import io.quee.clef.workflow.api.domain.workflow.WorkflowIdentity
+import io.quee.clef.workflow.api.domain.workflow.stage.StageIdentity
 
 /**
  * Created By [**Ibrahim Al-Tamimi **](https://www.linkedin.com/in/iloom/)<br></br>
@@ -20,4 +21,5 @@ interface WorkflowStoreQuery : StoreQuery<WorkflowIdentity> {
     ): Boolean
 
     fun existByKey(workflowKey: String): Boolean
+    fun findByStage(stageIdentity: StageIdentity): WorkflowIdentity?
 }
diff --git a/clef-workflow-api/clef-workflow-api-store/clef-workflow-api-store-workflow/src/test/kotlin/io/quee/clef/workflow/api/store/workflow/query/FakeWorkflowStoreQuery.kt b/clef-workflow-api/clef-workflow-api-store/clef-workflow-api-store-workflow/src/test/kotlin/io/quee/clef/workflow/api/store/workflow/query/FakeWorkflowStoreQuery.kt
@@ -2,6 +2,7 @@ package io.quee.clef.workflow.api.store.workflow.query
 
 import io.quee.api.develop.shared.model.PageData
 import io.quee.clef.workflow.api.domain.workflow.WorkflowIdentity
+import io.quee.clef.workflow.api.domain.workflow.stage.StageIdentity
 
 /**
  * Created By [**Ibrahim Al-Tamimi **](https://www.linkedin.com/in/iloom/)<br></br>
@@ -24,6 +25,10 @@ class FakeWorkflowStoreQuery(private val list: List<WorkflowIdentity>) : Workflo
         it.workflowKey == workflowKey
     } != null
 
+    override fun findByStage(stageIdentity: StageIdentity): WorkflowIdentity? {
+        TODO("Not yet implemented")
+    }
+
     override fun find(uuid: String): WorkflowIdentity? = list.find {
         it.uuid == uuid
     }
diff --git a/clef-workflow-api/clef-workflow-api-usecase-factory/clef-workflow-api-usecase-factory-domain/src/main/kotlin/io/quee/clef/workflow/api/usecase/factory/domain/StageDomainUseCaseFactory.kt b/clef-workflow-api/clef-workflow-api-usecase-factory/clef-workflow-api-usecase-factory-domain/src/main/kotlin/io/quee/clef/workflow/api/usecase/factory/domain/StageDomainUseCaseFactory.kt
@@ -6,6 +6,7 @@ import io.quee.api.develop.usecase.model.ResponseAdapter
 import io.quee.api.develop.usecase.type.CommandUseCase
 import io.quee.api.develop.usecase.type.FunctionalUseCase
 import io.quee.clef.workflow.api.domain.workflow.stage.StageIdentity
+import io.quee.clef.workflow.api.domain.workflow.stage.task.StageTaskIdentity
 import io.quee.clef.workflow.api.usecase.factory.domain.request.AddTaskToStageRequest
 import io.quee.clef.workflow.api.usecase.factory.domain.request.ExistByKeyRequest
 import io.quee.clef.workflow.api.usecase.factory.domain.request.FindDomainByKeyAndUuidRequest
@@ -17,6 +18,7 @@ import io.quee.clef.workflow.api.usecase.factory.domain.request.FindDomainByKeyA
  */
 interface StageDomainUseCaseFactory : UseCaseFactory {
     val findStageByKeyAndUuidUseCase: FunctionalUseCase<FindDomainByKeyAndUuidRequest, ResponseAdapter<StageIdentity>>
+    val findStageByTaskUseCase: FunctionalUseCase<RequestAdapter<StageTaskIdentity>, ResponseAdapter<StageIdentity>>
     val validateStageExistenceUseCase: CommandUseCase<ExistByKeyRequest>
     val addTaskToStageUseCase: CommandUseCase<AddTaskToStageRequest>
     val deleteAllStagesUseCase: CommandUseCase<RequestAdapter<List<StageIdentity>>>
diff --git a/clef-workflow-api/clef-workflow-api-usecase-factory/clef-workflow-api-usecase-factory-domain/src/main/kotlin/io/quee/clef/workflow/api/usecase/factory/domain/WorkflowDomainUseCaseFactory.kt b/clef-workflow-api/clef-workflow-api-usecase-factory/clef-workflow-api-usecase-factory-domain/src/main/kotlin/io/quee/clef/workflow/api/usecase/factory/domain/WorkflowDomainUseCaseFactory.kt
@@ -6,6 +6,7 @@ import io.quee.api.develop.usecase.model.ResponseAdapter
 import io.quee.api.develop.usecase.type.CommandUseCase
 import io.quee.api.develop.usecase.type.FunctionalUseCase
 import io.quee.clef.workflow.api.domain.workflow.WorkflowIdentity
+import io.quee.clef.workflow.api.domain.workflow.stage.StageIdentity
 import io.quee.clef.workflow.api.usecase.factory.domain.request.AddStageToWorkflowRequest
 import io.quee.clef.workflow.api.usecase.factory.domain.request.ExistByKeyRequest
 import io.quee.clef.workflow.api.usecase.factory.domain.request.FindDomainByKeyAndUuidRequest
@@ -17,6 +18,7 @@ import io.quee.clef.workflow.api.usecase.factory.domain.request.FindDomainByKeyA
  */
 interface WorkflowDomainUseCaseFactory : UseCaseFactory {
     val findWorkflowByKeyAndUuidUseCase: FunctionalUseCase<FindDomainByKeyAndUuidRequest, ResponseAdapter<WorkflowIdentity>>
+    val findWorkflowByStageUseCase: FunctionalUseCase<RequestAdapter<StageIdentity>, ResponseAdapter<WorkflowIdentity>>
     val validateWorkflowExistenceUseCase: CommandUseCase<ExistByKeyRequest>
     val addStageToWorkflowUseCase: CommandUseCase<AddStageToWorkflowRequest>
     val deleteAllWorkflowUseCase: CommandUseCase<RequestAdapter<List<WorkflowIdentity>>>
diff --git a/clef-workflow-api/clef-workflow-api-usecase/clef-workflow-api-usecase-domain/clef-workflow-api-usecase-domain-stage/src/main/kotlin/io/quee/clef/workflow/api/usecase/domain/stage/StageDomainUseCaseFactoryImpl.kt b/clef-workflow-api/clef-workflow-api-usecase/clef-workflow-api-usecase-domain/clef-workflow-api-usecase-domain-stage/src/main/kotlin/io/quee/clef/workflow/api/usecase/domain/stage/StageDomainUseCaseFactoryImpl.kt
diff --git a/clef-workflow-api/clef-workflow-api-usecase/clef-workflow-api-usecase-domain/clef-workflow-api-usecase-domain-stage/src/main/kotlin/io/quee/clef/workflow/api/usecase/domain/stage/main/FindStageByTaskUseCase.kt b/clef-workflow-api/clef-workflow-api-usecase/clef-workflow-api-usecase-domain/clef-workflow-api-usecase-domain-stage/src/main/kotlin/io/quee/clef/workflow/api/usecase/domain/stage/main/FindStageByTaskUseCase.kt
diff --git a/clef-workflow-api/clef-workflow-api-usecase/clef-workflow-api-usecase-domain/clef-workflow-api-usecase-domain-workflow/src/main/kotlin/io/quee/clef/workflow/api/usecase/domain/workflow/WorkflowDomainUseCaseFactoryImpl.kt b/clef-workflow-api/clef-workflow-api-usecase/clef-workflow-api-usecase-domain/clef-workflow-api-usecase-domain-workflow/src/main/kotlin/io/quee/clef/workflow/api/usecase/domain/workflow/WorkflowDomainUseCaseFactoryImpl.kt
diff --git a/clef-workflow-api/clef-workflow-api-usecase/clef-workflow-api-usecase-domain/clef-workflow-api-usecase-domain-workflow/src/main/kotlin/io/quee/clef/workflow/api/usecase/domain/workflow/main/FindWorkflowByStageUseCase.kt b/clef-workflow-api/clef-workflow-api-usecase/clef-workflow-api-usecase-domain/clef-workflow-api-usecase-domain-workflow/src/main/kotlin/io/quee/clef/workflow/api/usecase/domain/workflow/main/FindWorkflowByStageUseCase.kt
diff --git a/clef-workflow-api/clef-workflow-api-usecase/clef-workflow-api-usecase-element/src/main/kotlin/io/quee/clef/workflow/api/usecase/element/ElementUseCaseFactoryImpl.kt b/clef-workflow-api/clef-workflow-api-usecase/clef-workflow-api-usecase-element/src/main/kotlin/io/quee/clef/workflow/api/usecase/element/ElementUseCaseFactoryImpl.kt
diff --git a/clef-workflow-api/clef-workflow-api-usecase/clef-workflow-api-usecase-element/src/main/kotlin/io/quee/clef/workflow/api/usecase/element/main/ExecuteActionIntoElementUseCase.kt b/clef-workflow-api/clef-workflow-api-usecase/clef-workflow-api-usecase-element/src/main/kotlin/io/quee/clef/workflow/api/usecase/element/main/ExecuteActionIntoElementUseCase.kt
