dancefinder-app/utils/graph-client/utils.js

import { execute, makePromise, ApolloLink, Observable } from 'apollo-link';
import { HttpLink } from 'apollo-link-http';
import gql from 'graphql-tag';
const { includeCredentials } = require('./middleware');
import { onError } from 'apollo-link-error';
import { default as webAuth} from '../auth';

const defaultGraphUri = '/query/';
const httpLink = new HttpLink({ uri: defaultGraphUri, fetch: includeCredentials, credentials: 'same-origin' });
const errorLink = onError(({ graphQLErrors, networkError, operation, forward }) => {
      if (graphQLErrors) {
        console.log('GraphQL errors:', graphQLErrors);
        // for (let err of graphQLErrors) {
        //   switch (err.extensions.code) {
        //     case 'UNAUTHENTICATED':
        //       // error code is set to UNAUTHENTICATED
        //       // when AuthenticationError thrown in resolver
        //
        //       // modify the operation context with a new token
        //   }
        // }
      }
      if (networkError) {
        if (networkError.statusCode === 401) {
          return new Observable(observer => {
            webAuth.checkSession(() => {
              const subscriber = {
                next: observer.next.bind(observer),
                error: observer.error.bind(observer),
                complete: observer.complete.bind(observer)
              };

              // Retry last failed request
              forward(operation).subscribe(subscriber);
            }, (err) => {
              console.log(err);
              observer.error(err)
            });
          });
        }
      }
    }
);

export const createQuery = (query, variables) => { // eslint-disable-line
  const operation = {
    query: gql(query),
    variables: variables
  };
  return makePromise(execute(ApolloLink.from([errorLink, httpLink]), operation));
};