graphql-http-ws-client
Advanced tools
Comparing version 0.0.5 to 0.1.0
| import { ApolloClient } from "apollo-client"; | ||
| import { concat, split } from "apollo-link"; | ||
| import { HttpLink } from "apollo-link-http"; | ||
| import { WebSocketLink } from "apollo-link-ws"; | ||
| import { SubscriptionClient } from "subscriptions-transport-ws"; | ||
| import { RetryLink } from "apollo-link-retry"; | ||
| import { getMainDefinition } from "apollo-utilities"; | ||
| import { InMemoryCache } from "apollo-cache-inmemory"; | ||
| import createGraphQLLinks from "./createGraphQLLinks"; | ||
| export default (graphQLURL, passedOptions = {}) => { | ||
| const httpURLToWS = (url) => { | ||
| return url.replace(/(http)(s)?:\/\//, "ws$2://"); | ||
| }; | ||
| const options = Object.assign({ | ||
| createHTTPLink: true, | ||
| createWebsocketLink: true, | ||
| resolvers: {} | ||
| }, passedOptions); | ||
| let httpLink = null; | ||
| if(options.createHTTPLink) { | ||
| if(typeof options.fetch !== 'function' && (typeof window !== 'object' || typeof window.fetch !== 'function')) | ||
| throw new Error(`Missing fetch implementation on window.fetch or options.fetch`); | ||
| const fetchImplementation = (typeof options.fetch === 'function') ? options.fetch : window.fetch; | ||
| httpLink = new HttpLink({ uri: graphQLURL, fetch: fetchImplementation }); | ||
| } | ||
| const links = createGraphQLLinks(graphQLURL, options); | ||
| let websocketLink = null; | ||
| let subscriptionClient = null; | ||
| if(options.createWebsocketLink) { | ||
| if(typeof options.websocket !== 'function' && (typeof window !== 'object' || typeof window.WebSocket !== 'function')) | ||
| throw new Error(`Missing websocket implementation on window.WebSocket or options.websocket`); | ||
| const websocketImplementation = (typeof options.websocket === 'function') ? options.websocket : window.WebSocket; | ||
| subscriptionClient = new SubscriptionClient(httpURLToWS(graphQLURL), { | ||
| reconnect: true, | ||
| }, websocketImplementation); | ||
| websocketLink = new WebSocketLink(subscriptionClient); | ||
| } | ||
| let transportLink = null; | ||
| if(httpLink !== null && websocketLink !== null) { // httpLink and websocketLink exist | ||
| transportLink = split(({ query }) => { | ||
| const { kind, operation } = getMainDefinition(query); | ||
| return kind === 'OperationDefinition' && operation === 'subscription'; | ||
| }, | ||
| websocketLink, | ||
| httpLink); | ||
| } | ||
| else if(websocketLink !== null) // only websocketLink exists | ||
| transportLink = websocketLink; | ||
| else if(httpLink !== null) // only httpLink (no Subscriptions) | ||
| transportLink = httpLink; | ||
| const retryLink = new RetryLink({ | ||
| attempts: { | ||
| max: Infinity | ||
| } | ||
| }); | ||
| const link = concat(retryLink, transportLink); | ||
| const defaultApolloOptions = (typeof options.defaultApolloOptions === 'object' && options.defaultApolloOptions !== null) ? options.defaultApolloOptions : {}; | ||
@@ -70,3 +19,3 @@ | ||
| cache: cache, | ||
| link: link, | ||
| link: links.link, | ||
| defaultOptions: defaultApolloOptions, | ||
@@ -76,11 +25,6 @@ resolvers: options.resolvers | ||
| return { | ||
| return Object.assign(links, { | ||
| client: client, | ||
| subscriptionClient: subscriptionClient, | ||
| cache: cache, | ||
| link: link, | ||
| httpLink: httpLink, | ||
| websocketLink: websocketLink, | ||
| retryLink: retryLink | ||
| } | ||
| cache: cache | ||
| }); | ||
| } |
| { | ||
| "name": "graphql-http-ws-client", | ||
| "version": "0.0.5", | ||
| "version": "0.1.0", | ||
| "private": false, | ||
@@ -5,0 +5,0 @@ "author": { |
No alert changes
Improved metrics
- Total package byte prevSize
- increased by9.61%
5829
- Number of package files
- increased by33.33%
4
- Lines of code
- increased by13.89%
82
No dependency changes