@elba-security/graphql-zeus
Advanced tools
Comparing version 4.0.10 to 4.0.11-alpha.0
@@ -10,6 +10,5 @@ "use strict"; | ||
) => fn(queryConstruct(t, tName, options?.operationName)(o), options?.variables).then((r:any) => { | ||
seekForAliases(r) | ||
return r | ||
return seekForAliases(r) | ||
}); | ||
`, | ||
}; |
@@ -9,11 +9,13 @@ "use strict"; | ||
if (Array.isArray(value)) { | ||
value.forEach(seekForAliases); | ||
return value.map(seekForAliases); | ||
} else { | ||
if (typeof value === 'object') { | ||
seekForAliases(value); | ||
return seekForAliases(value); | ||
} | ||
} | ||
return value; | ||
}; | ||
if (typeof response === 'object' && response) { | ||
const keys = Object.keys(response); | ||
const newResponse = { ...response }; | ||
const keys = Object.keys(newResponse); | ||
if (keys.length < 1) { | ||
@@ -23,15 +25,19 @@ return; | ||
keys.forEach((k) => { | ||
const value = response[k]; | ||
const value = newResponse[k]; | ||
if (k.indexOf('__alias__') !== -1) { | ||
const [operation, alias] = k.split('__alias__'); | ||
response[alias] = { | ||
[operation]: value, | ||
console.log(newResponse); | ||
newResponse[alias] = { | ||
[operation]: traverseAlias(value), | ||
}; | ||
delete response[k]; | ||
delete newResponse[k]; | ||
} else { | ||
newResponse[k] = traverseAlias(value); | ||
} | ||
traverseAlias(value); | ||
}); | ||
return newResponse; | ||
} | ||
return response; | ||
}; | ||
`, | ||
}; |
@@ -1,2 +0,2 @@ | ||
declare const _default: "\nexport const apiSubscription = (options: chainOptions) => (\n query: string,\n ) => {\n try {\n const queryString = options[0] + '?query=' + encodeURIComponent(query);\n const wsString = queryString.replace('http', 'ws');\n const host = (options.length > 1 && options[1]?.websocket?.[0]) || wsString;\n const webSocketOptions = options[1]?.websocket || [host];\n const ws = new WebSocket(...webSocketOptions);\n return {\n ws,\n on: (e: (args: any) => void) => {\n ws.onmessage = (event:any) => {\n if(event.data){\n const parsed = JSON.parse(event.data)\n const data = parsed.data\n if (data) {\n seekForAliases(data);\n }\n return e(data);\n }\n };\n },\n off: (e: (args: any) => void) => {\n ws.onclose = e;\n },\n error: (e: (args: any) => void) => {\n ws.onerror = e;\n },\n open: (e: () => void) => {\n ws.onopen = e;\n },\n };\n } catch {\n throw new Error('No websockets implemented');\n }\n };\n"; | ||
declare const _default: "\nexport const apiSubscription = (options: chainOptions) => (\n query: string,\n ) => {\n try {\n const queryString = options[0] + '?query=' + encodeURIComponent(query);\n const wsString = queryString.replace('http', 'ws');\n const host = (options.length > 1 && options[1]?.websocket?.[0]) || wsString;\n const webSocketOptions = options[1]?.websocket || [host];\n const ws = new WebSocket(...webSocketOptions);\n return {\n ws,\n on: (e: (args: any) => void) => {\n ws.onmessage = (event:any) => {\n if(event.data){\n const parsed = JSON.parse(event.data)\n const data = parsed.data\n if (data) {\n return e(seekForAliases(data));\n }\n return e(data);\n }\n };\n },\n off: (e: (args: any) => void) => {\n ws.onclose = e;\n },\n error: (e: (args: any) => void) => {\n ws.onerror = e;\n },\n open: (e: () => void) => {\n ws.onopen = e;\n },\n };\n } catch {\n throw new Error('No websockets implemented');\n }\n };\n"; | ||
export default _default; |
@@ -21,3 +21,3 @@ "use strict"; | ||
if (data) { | ||
seekForAliases(data); | ||
return e(seekForAliases(data)); | ||
} | ||
@@ -24,0 +24,0 @@ return e(data); |
@@ -1,2 +0,2 @@ | ||
declare const _default: "\nexport const apiSubscription = (options: chainOptions) => (\n query: string,\n ) => {\n try {\n const WebSocket = require('ws');\n const queryString = options[0] + '?query=' + encodeURIComponent(query);\n const wsString = queryString.replace('http', 'ws');\n const host = (options.length > 1 && options[1]?.websocket?.[0]) || wsString;\n const webSocketOptions = options[1]?.websocket || [host];\n const ws = new WebSocket(...webSocketOptions);\n return {\n ws,\n on: (e: (args: any) => void) => {\n ws.onmessage = (event:any) => {\n if(event.data){\n const parsed = JSON.parse(event.data)\n const data = parsed.data\n if (data) {\n seekForAliases(data);\n }\n return e(data);\n }\n };\n },\n off: (e: (args: any) => void) => {\n ws.onclose = e;\n },\n error: (e: (args: any) => void) => {\n ws.onerror = e;\n },\n open: (e: () => void) => {\n ws.onopen = e;\n },\n };\n } catch {\n throw new Error('No websockets implemented. Please install ws');\n }\n };\n"; | ||
declare const _default: "\nexport const apiSubscription = (options: chainOptions) => (\n query: string,\n ) => {\n try {\n const WebSocket = require('ws');\n const queryString = options[0] + '?query=' + encodeURIComponent(query);\n const wsString = queryString.replace('http', 'ws');\n const host = (options.length > 1 && options[1]?.websocket?.[0]) || wsString;\n const webSocketOptions = options[1]?.websocket || [host];\n const ws = new WebSocket(...webSocketOptions);\n return {\n ws,\n on: (e: (args: any) => void) => {\n ws.onmessage = (event:any) => {\n if(event.data){\n const parsed = JSON.parse(event.data)\n const data = parsed.data\n if (data) {\n return e(seekForAliases(data));\n }\n return e(data);\n }\n };\n },\n off: (e: (args: any) => void) => {\n ws.onclose = e;\n },\n error: (e: (args: any) => void) => {\n ws.onerror = e;\n },\n open: (e: () => void) => {\n ws.onopen = e;\n },\n };\n } catch {\n throw new Error('No websockets implemented. Please install ws');\n }\n };\n"; | ||
export default _default; |
@@ -22,3 +22,3 @@ "use strict"; | ||
if (data) { | ||
seekForAliases(data); | ||
return e(seekForAliases(data)); | ||
} | ||
@@ -25,0 +25,0 @@ return e(data); |
{ | ||
"name": "@elba-security/graphql-zeus", | ||
"version": "4.0.10", | ||
"version": "4.0.11-alpha.0", | ||
"private": false, | ||
@@ -5,0 +5,0 @@ "license": "MIT", |
Sorry, the diff of this file is not supported yet
No v1
QualityPackage is not semver >=1. This means it is not stable and does not support ^ ranges.
Found 1 instance in 1 package
869093
7891
1