From 95d38b740e61f768312f862ff25100c49df98504 Mon Sep 17 00:00:00 2001
From: Faruk AYDIN <omerfaruk26@gmail.com>
Date: Thu, 9 Dec 2021 17:42:22 +0100
Subject: [PATCH] feat: Implement getFlows graphQL query

---
 .../backend/src/graphql/queries/get-flows.ts   | 18 ++++++++++++++++++
 packages/backend/src/graphql/root-query.ts     |  4 +++-
 2 files changed, 21 insertions(+), 1 deletion(-)
 create mode 100644 packages/backend/src/graphql/queries/get-flows.ts

diff --git a/packages/backend/src/graphql/queries/get-flows.ts b/packages/backend/src/graphql/queries/get-flows.ts
new file mode 100644
index 00000000..3e8e2437
--- /dev/null
+++ b/packages/backend/src/graphql/queries/get-flows.ts
@@ -0,0 +1,18 @@
+import { GraphQLList, GraphQLString } from 'graphql';
+import Flow from '../../models/flow';
+import RequestWithCurrentUser from '../../types/express/request-with-current-user';
+import flowType from '../types/flow';
+
+const getFlowsResolver = async (req: RequestWithCurrentUser) => {
+  const flows = await Flow.query()
+    .where({ user_id: req.currentUser.id});
+
+  return flows;
+}
+
+const getFlows = {
+  type: GraphQLList(flowType),
+  resolve: (_: any, _params: any, req: RequestWithCurrentUser) => getFlowsResolver(req)
+}
+
+export default getFlows;
diff --git a/packages/backend/src/graphql/root-query.ts b/packages/backend/src/graphql/root-query.ts
index 7a5a976b..622179ec 100644
--- a/packages/backend/src/graphql/root-query.ts
+++ b/packages/backend/src/graphql/root-query.ts
@@ -4,6 +4,7 @@ import getApp from './queries/get-app';
 import getConnectedApps from './queries/get-connected-apps';
 import getAppConnections from './queries/get-app-connections';
 import testConnection from './queries/test-connection';
+import getFlows from './queries/get-flows';
 
 const rootQuery = new GraphQLObjectType({
   name: 'Query',
@@ -12,7 +13,8 @@ const rootQuery = new GraphQLObjectType({
     getApp,
     getConnectedApps,
     getAppConnections,
-    testConnection
+    testConnection,
+    getFlows
   }
 });