Merge pull request #2098 from automatisch/aut-1258

feat(useAuthenticateApp): use REST API endpoint to create connection

packages/web/src/graphql/mutations/create-connection.js

@@ -1,13 +0,0 @@
-import { gql } from '@apollo/client';
-export const CREATE_CONNECTION = gql`
-  mutation CreateConnection($input: CreateConnectionInput) {
-    createConnection(input: $input) {
-      id
-      key
-      verified
-      formattedData {
-        screenName
-      }
-    }
-  }
-`;

packages/web/src/graphql/mutations/index.js

@@ -1,10 +1,9 @@
-import { CREATE_CONNECTION } from './create-connection';
 import { UPDATE_CONNECTION } from './update-connection';
 import { VERIFY_CONNECTION } from './verify-connection';
 import { RESET_CONNECTION } from './reset-connection';
 import { GENERATE_AUTH_URL } from './generate-auth-url';
+
 const mutations = {
-  createConnection: CREATE_CONNECTION,
   updateConnection: UPDATE_CONNECTION,
   verifyConnection: VERIFY_CONNECTION,
   resetConnection: RESET_CONNECTION,

packages/web/src/hooks/useAuthenticateApp.ee.js

@@ -7,6 +7,7 @@ import {
 } from 'helpers/authenticationSteps';
 import computeAuthStepVariables from 'helpers/computeAuthStepVariables';
 import useAppAuth from './useAppAuth';
+import useCreateConnection from './useCreateConnection';
 import useFormatMessage from './useFormatMessage';
 
 function getSteps(auth, hasConnection, useShared) {
@@ -27,6 +28,7 @@ function getSteps(auth, hasConnection, useShared) {
 export default function useAuthenticateApp(payload) {
   const { appKey, appAuthClientId, connectionId, useShared = false } = payload;
   const { data: auth } = useAppAuth(appKey);
+  const { mutateAsync: createConnection } = useCreateConnection(appKey);
   const [authenticationInProgress, setAuthenticationInProgress] =
     React.useState(false);
   const formatMessage = useFormatMessage();
@@ -65,8 +67,13 @@ export default function useAuthenticateApp(payload) {
           }
 
           if (step.type === 'mutation') {
-            const stepResponse = await processMutation(step.name, variables);
-            response[step.name] = stepResponse;
+            if (step.name === 'createConnection') {
+              const stepResponse = await createConnection(variables);
+              response[step.name] = stepResponse?.data;
+            } else {
+              const stepResponse = await processMutation(step.name, variables);
+              response[step.name] = stepResponse;
+            }
           } else if (step.type === 'openWithPopup') {
             const stepResponse = await processPopupMessage(popup);
             response[step.name] = stepResponse;

packages/web/src/hooks/useCreateConnection.js

@@ -0,0 +1,26 @@
+import { useMutation, useQueryClient } from '@tanstack/react-query';
+
+import api from 'helpers/api';
+
+export default function useCreateConnection(appKey) {
+  const queryClient = useQueryClient();
+
+  const query = useMutation({
+    mutationFn: async ({ appAuthClientId, formattedData }) => {
+      const { data } = await api.post(`/v1/apps/${appKey}/connections`, {
+        appAuthClientId,
+        formattedData,
+      });
+
+      return data;
+    },
+
+    onSuccess: () => {
+      queryClient.invalidateQueries({
+        queryKey: ['apps', appKey, 'connections'],
+      });
+    },
+  });
+
+  return query;
+}