X-Git-Url: https://git.r.bdr.sh/rbdr/forum/blobdiff_plain/18ced3bfaff8ca40edb1a96e631ba1553a3a7a6d..605230e032808155d62ed773cc551b5ae1847a5f:/src/stores/apollo.js

diff --git a/src/stores/apollo.js b/src/stores/apollo.js
index e2deecd..f84a183 100644
--- a/src/stores/apollo.js
+++ b/src/stores/apollo.js
@@ -1,6 +1,6 @@
 import { ApolloError } from '@apollo/client/core';
 import { readable } from 'svelte/store';
-import { client } from '$config/apollo';
+import { client } from '$/config/apollo';
 
 /*
  * This is a generic store for use with apollo
@@ -8,33 +8,39 @@ import { client } from '$config/apollo';
 
 export const store = function store({ key, query, initialValue = null, variables = {} }) {
 
-  return readable({
-    loading: true,
-    data: initialValue,
-    error: undefined
-  }, (set) => {
-
-    const handleError = function (error) {
-
-      return set({
-        loading: false,
-        data: initialValue,
-        error
-      });
-    };
-
-    client.watchQuery({ query, variables }).subscribe((result) => {
-
-      if (result.errors) {
-        const error = new ApolloError({ graphQLErrors: result.errors });
-        return handleError(error);
-      }
-
-      set({
-        loading: false,
-        data: result.data[key],
-        error: undefined
-      });
-    }, (error) => handleError(error));
-  });
+  return readable(
+    {
+      loading: true,
+      data: initialValue,
+      error: undefined
+    },
+    (set) => {
+
+      const handleError = function (error) {
+
+        return set({
+          loading: false,
+          data: initialValue,
+          error
+        });
+      };
+
+      client.watchQuery({ query, variables }).subscribe(
+        (result) => {
+
+          if (result.errors) {
+            const error = new ApolloError({ graphQLErrors: result.errors });
+            return handleError(error);
+          }
+
+          set({
+            loading: false,
+            data: result.data[key],
+            error: undefined
+          });
+        },
+        (error) => handleError(error)
+      );
+    }
+  );
 };