feat: expose error of process instance (#269)

camunda-community-hub · Aug 25, 2022 · 1e158ba · 1e158ba
1 parent 20d5f6a
commit 1e158ba
Show file tree

Hide file tree

Showing 3 changed files with 11 additions and 1 deletion.
diff --git a/data/src/main/kotlin/io/zeebe/zeeqs/data/repository/ErrorRepository.kt b/data/src/main/kotlin/io/zeebe/zeeqs/data/repository/ErrorRepository.kt
@@ -6,4 +6,7 @@ import org.springframework.stereotype.Repository
 
 @Repository
 interface ErrorRepository: PagingAndSortingRepository<Error, Long> {
+
+    fun findByProcessInstanceKey(processInstanceKey: Long): Error?
+
 }
diff --git a/graphql-api/src/main/kotlin/io/zeebe/zeeqs/graphql/resolvers/type/ProcessInstanceResolver.kt b/graphql-api/src/main/kotlin/io/zeebe/zeeqs/graphql/resolvers/type/ProcessInstanceResolver.kt
@@ -16,7 +16,8 @@ class ProcessInstanceResolver(
     val incidentRepository: IncidentRepository,
     val elementInstanceRepository: ElementInstanceRepository,
     val timerRepository: TimerRepository,
-    val messageSubscriptionRepository: MessageSubscriptionRepository
+    val messageSubscriptionRepository: MessageSubscriptionRepository,
+    val errorRepository: ErrorRepository
 ) : GraphQLResolver<ProcessInstance> {
 
     fun startTime(processInstance: ProcessInstance, zoneId: String): String? {
@@ -77,4 +78,8 @@ class ProcessInstanceResolver(
         return messageSubscriptionRepository.findByProcessInstanceKey(processInstance.key)
     }
 
+    fun error(processInstance: ProcessInstance): Error? {
+        return errorRepository.findByProcessInstanceKey(processInstance.key)
+    }
+
 }
diff --git a/graphql-api/src/main/resources/graphql/ProcessInstance.graphqls b/graphql-api/src/main/resources/graphql/ProcessInstance.graphqls
@@ -34,6 +34,8 @@ type ProcessInstance {
     timers: [Timer!]
     # the opened message subscriptions related to the process instance (e.g. message catch events)
     messageSubscriptions: [MessageSubscription!]
+    # the occurred error related to the process instance
+    error: Error
 }
 
 enum ProcessInstanceState {