From 51fa86246165095062d58c7623222034b30b4e94 Mon Sep 17 00:00:00 2001
From: Ali BARIN <ali.barin53@gmail.com>
Date: Tue, 24 Oct 2023 17:29:43 +0000
Subject: [PATCH] feat(queries/get-executions): add flowId filter support

---
 packages/backend/src/graphql/queries/get-executions.ts |  9 +++++++++
 packages/backend/src/graphql/schema.graphql            | 10 +++++++++-
 2 files changed, 18 insertions(+), 1 deletion(-)

diff --git a/packages/backend/src/graphql/queries/get-executions.ts b/packages/backend/src/graphql/queries/get-executions.ts
index dec2ed38..377a033f 100644
--- a/packages/backend/src/graphql/queries/get-executions.ts
+++ b/packages/backend/src/graphql/queries/get-executions.ts
@@ -3,9 +3,14 @@ import Context from '../../types/express/context';
 import Execution from '../../models/execution';
 import paginate from '../../helpers/pagination';
 
+type Filters = {
+  flowId?: string;
+}
+
 type Params = {
   limit: number;
   offset: number;
+  filters?: Filters;
 };
 
 const getExecutions = async (
@@ -41,6 +46,10 @@ const getExecutions = async (
     .groupBy('executions.id')
     .orderBy('updated_at', 'desc');
 
+  if (params.filters?.flowId) {
+    executions.where('flow_id', params.filters.flowId);
+  }
+
   return paginate(executions, params.limit, params.offset);
 };
 
diff --git a/packages/backend/src/graphql/schema.graphql b/packages/backend/src/graphql/schema.graphql
index 1c98a8b3..97c534d1 100644
--- a/packages/backend/src/graphql/schema.graphql
+++ b/packages/backend/src/graphql/schema.graphql
@@ -20,7 +20,11 @@ type Query {
   ): FlowConnection
   getStepWithTestExecutions(stepId: String!): [Step]
   getExecution(executionId: String!): Execution
-  getExecutions(limit: Int!, offset: Int!): ExecutionConnection
+  getExecutions(
+    limit: Int!
+    offset: Int!
+    filters: ExecutionFiltersInput
+  ): ExecutionConnection
   getExecutionSteps(
     executionId: String!
     limit: Int!
@@ -795,6 +799,10 @@ type Notification {
   description: String
 }
 
+input ExecutionFiltersInput {
+  flowId: String
+}
+
 schema {
   query: Query
   mutation: Mutation