X-Git-Url: https://git.r.bdr.sh/rbdr/forum/blobdiff_plain/74b03c33ff37d7363721bc2c33abb867dc9ea87c..605230e032808155d62ed773cc551b5ae1847a5f:/src/stores/apollo.js diff --git a/src/stores/apollo.js b/src/stores/apollo.js index 0ac2443..f84a183 100644 --- a/src/stores/apollo.js +++ b/src/stores/apollo.js @@ -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) + ); + } + ); };