From dc4899c240aa4554eb0c7e49cfaa902ec5cf96d4 Mon Sep 17 00:00:00 2001
From: Faruk AYDIN <omerfaruk26@gmail.com>
Date: Sat, 6 Aug 2022 15:03:43 +0300
Subject: [PATCH] refactor: Adjust flow query to use joinRelated

---
 .../backend/src/graphql/queries/get-flows.ts  | 27 ++++++++-----------
 1 file changed, 11 insertions(+), 16 deletions(-)

diff --git a/packages/backend/src/graphql/queries/get-flows.ts b/packages/backend/src/graphql/queries/get-flows.ts
index 5f849393..db6e03ac 100644
--- a/packages/backend/src/graphql/queries/get-flows.ts
+++ b/packages/backend/src/graphql/queries/get-flows.ts
@@ -1,5 +1,6 @@
 import Context from '../../types/express/context';
 import paginate from '../../helpers/pagination';
+import Flow from '../../models/flow';
 
 type Params = {
   appKey?: string;
@@ -8,22 +9,16 @@ type Params = {
 };
 
 const getFlows = async (_parent: unknown, params: Params, context: Context) => {
-  const userStepsQuery = context.currentUser
-    .$relatedQuery('steps')
-    .select('flow_id')
-    .distinctOn('flow_id');
-
-  if (params.appKey) {
-    userStepsQuery.where('app_key', params.appKey);
-  }
-
-  const flowsQuery = context.currentUser
-    .$relatedQuery('flows')
-    .withGraphFetched('[steps.[connection]]')
-    .whereIn(
-      'flows.id',
-      userStepsQuery
-    );
+  const flowsQuery = Flow.query()
+    .joinRelated('steps')
+    .withGraphFetched('steps.[connection]')
+    .where('flows.user_id', context.currentUser.id)
+    .andWhere((builder) => {
+      if (params.appKey) {
+        builder.where('steps.app_key', params.appKey);
+      }
+    })
+    .orderBy('updated_at', 'desc');
 
   return paginate(flowsQuery, params.limit, params.offset);
 };