hasura/graphql-engine
1
0
Fork 0
mirror of https://github.com/hasura/graphql-engine.git synced 2024-12-14 17:02:49 +03:00
Code Issues Projects Releases Wiki Activity

console: reuse websocket connection in api explorer (#5064)

Browse Source
This commit is contained in:
Sameer Kolhar 2020-06-12 20:02:21 +05:30 committed by GitHub
parent c49dddf0c8
commit fd00892371
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 23 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

32
console/src/components/Services/ApiExplorer/Actions.js
View File

@ -44,6 +44,20 @@ const CREATE_WEBSOCKET_CLIENT = 'ApiExplorer/CREATE_WEBSOCKET_CLIENT';
const FOCUS_ROLE_HEADER = 'ApiExplorer/FOCUS_ROLE_HEADER';
const UNFOCUS_ROLE_HEADER = 'ApiExplorer/UNFOCUS_ROLE_HEADER';
let websocketSubscriptionClient;
const getSubscriptionInstance = (url, headers) => {
return new SubscriptionClient(url, {
connectionParams: {
headers: {
...headers,
},
lazy: true,
},
reconnect: true,
});
};
const SET_LOADING = 'ApiExplorer/SET_LOADING';
export const setLoading = isLoading => ({
type: SET_LOADING,
@ -163,15 +177,15 @@ const createWsClient = (url, headers) => {
const websocketProtocol = gqlUrl.protocol === 'https:' ? 'wss' : 'ws';
const headersFinal = getHeadersAsJSON(headers);
const graphqlUrl = `${websocketProtocol}://${url.split('//')[1]}`;
const client = new SubscriptionClient(graphqlUrl, {
connectionParams: {
headers: {
...headersFinal,
},
},
reconnect: true,
});
return client;
if (!websocketSubscriptionClient) {
websocketSubscriptionClient = getSubscriptionInstance(
graphqlUrl,
headersFinal
);
}
return websocketSubscriptionClient;
};
const graphqlSubscriber = (graphQLParams, url, headers) => {