Ne uplne otestovany prepis storu

src/boot/apollo.js

@@ -0,0 +1,96 @@
+// import {boot} from "quasar/wrappers";
+import {ApolloClient, ApolloLink, fromPromise, InMemoryCache} from '@apollo/client/core'
+import {createUploadLink} from 'apollo-upload-client';
+import {onError} from "@apollo/client/link/error";
+import {useUserStore} from "stores/User";
+import {useAppStore} from "stores/App";
+import {Notify} from "quasar";
+import {errorObject, warningObject} from "src/composables/dialog";
+
+const handleRefreshToken = (store, forward, operation) => {
+    return fromPromise(useUserStore(store).refreshAccessToken()
+        .catch((error) => {
+            Notify.create(warningObject("Tvoje přihlášení vypřešlo. Přihlaš se prosím znovu."));
+            window.location = "/login";
+        }))
+        .filter((value) => Boolean(value))
+        .flatMap((accessToken) => {
+            const oldHeaders = operation.getContext().headers;
+            operation.setContext({
+                headers: {
+                    ...oldHeaders, authorization: `Bearer ${accessToken}`,
+                },
+            });
+
+            // retry the request, returning the new observable
+            return forward(operation);
+        });
+}
+
+
+
+export const apolloWrapper = {};
+export default (({store}) => {
+    const uploadLink = createUploadLink({
+        uri: process.env.API_URL + '/graphql',
+    })
+
+    const authLink = new ApolloLink((operation, forward) => {
+        const accessToken = useUserStore(store).getAccessToken();
+
+        if (accessToken) {
+            operation.setContext({
+                headers: {"Authorization": `Bearer ${accessToken}`},
+            });
+        }
+        return forward(operation);
+    });
+
+    const errorLink = onError(({graphQLErrors, networkError, operation, forward}) => {
+        if (networkError?.statusCode === 401) {
+            return handleRefreshToken(store, forward, operation);
+        }
+
+        if (graphQLErrors) {
+            for (const error of graphQLErrors) {
+                if (error.message === "Not found") {
+                    useAppStore(store).appStatus = 404;
+                } else if (error.message.includes("401") || error.message.includes("Not authorized")) {
+                    return handleRefreshToken(store, forward, operation);
+                } else {
+                    Notify.create(errorObject("API error: " + error.message));
+                }
+            }
+        }
+    });
+
+
+    const apolloClient = new ApolloClient({
+        link: ApolloLink.from([authLink, errorLink, uploadLink]), cache: new InMemoryCache(), connectToDevTools: true,
+    });
+    // const  apolloProvider = createApolloProvider({
+    //     defaultClient: apolloClient,
+    // });
+
+
+    apolloWrapper.query = (query, variables = {}) => {
+        return apolloClient.query({
+            query: query, fetchPolicy: 'no-cache', variables: variables
+        })
+            .then((response) => response)
+            .catch(err => {
+                console.error("Error during query: ", err)
+                return err;
+            })
+    };
+    apolloWrapper.mutate = (mutation, variables) => {
+        return apolloClient
+            .mutate({
+                mutation: mutation, fetchPolicy: 'no-cache', variables: variables,
+            })
+            .then((response) => response)
+            .catch(err => {
+                console.error("Error during mutation: ", err);
+            })
+    };
+});