@urql/core
Advanced tools
Comparing version 5.0.6 to 5.0.7-canary-36a07165f45ab743e8938ee814378199fbc9cf89
@@ -8,5 +8,5 @@ var graphql_web = require('@0no-co/graphql.web'); | ||
if (graphQlErrs) { | ||
for (var err of graphQlErrs) { | ||
for (var i = 0, l = graphQlErrs.length; i < l; i++) { | ||
if (error) error += '\n'; | ||
error += `[GraphQL] ${err.message}`; | ||
error += `[GraphQL] ${graphQlErrs[i].message}`; | ||
} | ||
@@ -125,5 +125,5 @@ } | ||
var _out = '['; | ||
for (var value of x) { | ||
for (var i = 0, l = x.length; i < l; i++) { | ||
if (_out.length > 1) _out += ','; | ||
_out += stringify(value, includeFiles) || 'null'; | ||
_out += stringify(x[i], includeFiles) || 'null'; | ||
} | ||
@@ -145,7 +145,7 @@ _out += ']'; | ||
var out = '{'; | ||
for (var _key of keys) { | ||
var _value = stringify(x[_key], includeFiles); | ||
if (_value) { | ||
for (var _i = 0, _l = keys.length; _i < _l; _i++) { | ||
var value = stringify(x[keys[_i]], includeFiles); | ||
if (value) { | ||
if (out.length > 1) out += ','; | ||
out += stringify(_key, includeFiles) + ':' + _value; | ||
out += stringify(keys[_i], includeFiles) + ':' + value; | ||
} | ||
@@ -164,3 +164,3 @@ } | ||
seen.add(x); | ||
for (var key of Object.keys(x)) extract(map, `${path}.${key}`, x[key]); | ||
for (var key in x) extract(map, `${path}.${key}`, x[key]); | ||
} | ||
@@ -346,3 +346,4 @@ }; | ||
var getOperationName = query => { | ||
for (var node of query.definitions) { | ||
for (var i = 0, l = query.definitions.length; i < l; i++) { | ||
var node = query.definitions[i]; | ||
if (node.kind === graphql_web.Kind.OPERATION_DEFINITION) { | ||
@@ -359,3 +360,4 @@ return node.name ? node.name.value : undefined; | ||
var getOperationType = query => { | ||
for (var node of query.definitions) { | ||
for (var i = 0, l = query.definitions.length; i < l; i++) { | ||
var node = query.definitions[i]; | ||
if (node.kind === graphql_web.Kind.OPERATION_DEFINITION) { | ||
@@ -405,7 +407,11 @@ return node.operation; | ||
if (typeof target === 'object' && target != null) { | ||
if (Array.isArray(target)) { | ||
target = [...target]; | ||
for (var i = 0, l = source.length; i < l; i++) target[i] = deepMerge(target[i], source[i]); | ||
} | ||
if (!target.constructor || target.constructor === Object || Array.isArray(target)) { | ||
target = Array.isArray(target) ? [...target] : { | ||
target = { | ||
...target | ||
}; | ||
for (var key of Object.keys(source)) target[key] = deepMerge(target[key], source[key]); | ||
for (var key in source) target[key] = deepMerge(target[key], source[key]); | ||
return target; | ||
@@ -452,3 +458,4 @@ } | ||
if (incremental) { | ||
var _loop = function (patch) { | ||
var _loop = function () { | ||
var patch = incremental[i]; | ||
if (Array.isArray(patch.errors)) { | ||
@@ -474,3 +481,3 @@ errors.push(...patch.errors); | ||
} | ||
for (var i = 0, l = path.length; i < l; prop = path[i++]) { | ||
for (var _i = 0, _l = path.length; _i < _l; prop = path[_i++]) { | ||
part = part[prop] = Array.isArray(part[prop]) ? [...part[prop]] : { | ||
@@ -482,3 +489,3 @@ ...part[prop] | ||
var startIndex = +prop >= 0 ? prop : 0; | ||
for (var _i = 0, _l = patch.items.length; _i < _l; _i++) part[startIndex + _i] = deepMerge(part[startIndex + _i], patch.items[_i]); | ||
for (var _i2 = 0, _l2 = patch.items.length; _i2 < _l2; _i2++) part[startIndex + _i2] = deepMerge(part[startIndex + _i2], patch.items[_i2]); | ||
} else if (patch.data !== undefined) { | ||
@@ -488,4 +495,4 @@ part[prop] = deepMerge(part[prop], patch.data); | ||
}; | ||
for (var patch of incremental) { | ||
_loop(patch); | ||
for (var i = 0, l = incremental.length; i < l; i++) { | ||
_loop(); | ||
} | ||
@@ -708,2 +715,3 @@ } else { | ||
*/ | ||
var decoder = typeof TextDecoder !== 'undefined' ? new TextDecoder() : null; | ||
@@ -710,0 +718,0 @@ var boundaryHeaderRe = /boundary="?([^=";]+)"?/i; |
@@ -1,2 +0,2 @@ | ||
var e=require("@0no-co/graphql.web"),r=require("wonka"),t=r=>r&&"string"==typeof r.message&&(r.extensions||"GraphQLError"===r.name)?r:"object"==typeof r&&"string"==typeof r.message?new e.GraphQLError(r.message,r.nodes,r.source,r.positions,r.path,r,r.extensions||{}):new e.GraphQLError(r);class a extends Error{constructor(e){var r=(e.graphQLErrors||[]).map(t),a=((e,r)=>{var t="";if(e)return`[Network] ${e.message}`;if(r)for(var a of r)t&&(t+="\n"),t+=`[GraphQL] ${a.message}`;return t})(e.networkError,r);super(a),this.name="CombinedError",this.message=a,this.graphQLErrors=r,this.networkError=e.networkError,this.response=e.response}toString(){return this.message}}var n=(e,r)=>{for(var t=0|(r||5381),a=0,n=0|e.length;a<n;a++)t=(t<<5)+t+e.charCodeAt(a);return t},o=new Set,s=new WeakMap,i=(e,r)=>{if(null===e||o.has(e))return"null";if("object"!=typeof e)return JSON.stringify(e)||"";if(e.toJSON)return i(e.toJSON(),r);if(Array.isArray(e)){var t="[";for(var a of e)t.length>1&&(t+=","),t+=i(a,r)||"null";return t+"]"}if(!r&&(l!==f&&e instanceof l||p!==f&&e instanceof p))return"null";var n=Object.keys(e).sort();if(!n.length&&e.constructor&&Object.getPrototypeOf(e).constructor!==Object.prototype.constructor){var c=s.get(e)||Math.random().toString(36).slice(2);return s.set(e,c),i({__key:c},r)}o.add(e);var d="{";for(var u of n){var y=i(e[u],r);y&&(d.length>1&&(d+=","),d+=i(u,r)+":"+y)}return o.delete(e),d+"}"},c=(e,r,t)=>{if(null==t||"object"!=typeof t||t.toJSON||o.has(t));else if(Array.isArray(t))for(var a=0,n=t.length;a<n;a++)c(e,`${r}.${a}`,t[a]);else if(t instanceof l||t instanceof p)e.set(r,t);else for(var s of(o.add(t),Object.keys(t)))c(e,`${r}.${s}`,t[s])},d=(e,r)=>(o.clear(),i(e,r||!1));class f{}var l="undefined"!=typeof File?File:f,p="undefined"!=typeof Blob?Blob:f,u=/("{3}[\s\S]*"{3}|"(?:\\.|[^"])*")/g,y=/(?:#[^\n\r]+)?(?:[\r\n]+|$)/g,h=(e,r)=>r%2==0?e.replace(y,"\n"):e,v=e=>e.split(u).map(h).join("").trim(),x=new Map,m=new Map,g=r=>{var t;return"string"==typeof r?t=v(r):r.loc&&m.get(r.__key)===r?t=r.loc.source.body:(t=x.get(r)||v(e.print(r)),x.set(r,t)),"string"==typeof r||r.loc||(r.loc={start:0,end:t.length,source:{body:t,name:"gql",locationOffset:{line:1,column:1}}}),t},b=e=>{var r;if(e.documentId)r=n(e.documentId);else if(r=n(g(e)),e.definitions){var t=O(e);t&&(r=n(`\n# ${t}`,r))}return r},w=r=>{var t,a;return"string"==typeof r?(t=b(r),a=m.get(t)||e.parse(r,{noLocation:!0})):(t=r.__key||b(r),a=m.get(t)||r),a.loc||g(a),a.__key=t,m.set(t,a),a},O=r=>{for(var t of r.definitions)if(t.kind===e.Kind.OPERATION_DEFINITION)return t.name?t.name.value:void 0},k=(e,r,t)=>{if(!("data"in r||"errors"in r&&Array.isArray(r.errors)))throw new Error("No Content");var n="subscription"===e.kind;return{operation:e,data:r.data,error:Array.isArray(r.errors)?new a({graphQLErrors:r.errors,response:t}):void 0,extensions:r.extensions?{...r.extensions}:void 0,hasNext:null==r.hasNext?n:r.hasNext,stale:!1}},N=(e,r)=>{if("object"==typeof e&&null!=e&&(!e.constructor||e.constructor===Object||Array.isArray(e))){for(var t of(e=Array.isArray(e)?[...e]:{...e},Object.keys(r)))e[t]=N(e[t],r[t]);return e}return r},E=(e,r,t,n)=>{var o=e.error?e.error.graphQLErrors:[],s=!!e.extensions||!!(r.payload||r).extensions,i={...e.extensions,...(r.payload||r).extensions},c=r.incremental;"path"in r&&(c=[r]);var d={data:e.data};if(c){var f=function(e){Array.isArray(e.errors)&&o.push(...e.errors),e.extensions&&(Object.assign(i,e.extensions),s=!0);var r="data",t=d,a=[];if(e.path)a=e.path;else if(n){var c=n.find((r=>r.id===e.id));a=e.subPath?[...c.path,...e.subPath]:c.path}for(var f=0,l=a.length;f<l;r=a[f++])t=t[r]=Array.isArray(t[r])?[...t[r]]:{...t[r]};if(e.items)for(var p=+r>=0?r:0,u=0,y=e.items.length;u<y;u++)t[p+u]=N(t[p+u],e.items[u]);else void 0!==e.data&&(t[r]=N(t[r],e.data))};for(var l of c)f(l)}else d.data=(r.payload||r).data||e.data,o=r.errors||r.payload&&r.payload.errors||o;return{operation:e.operation,data:d.data,error:o.length?new a({graphQLErrors:o,response:t}):void 0,extensions:s?i:void 0,hasNext:null!=r.hasNext?r.hasNext:e.hasNext,stale:!1}},A=(e,r,t)=>({operation:e,data:void 0,error:new a({networkError:r,response:t}),extensions:void 0,hasNext:!1,stale:!1}),j="undefined"!=typeof TextDecoder?new TextDecoder:null,q=/boundary="?([^=";]+)"?/i,S=/data: ?([^\n]+)/,I=e=>"Buffer"===e.constructor.name?e.toString():j.decode(e);async function*L(e){if(e.body[Symbol.asyncIterator])for await(var r of e.body)yield I(r);else{var t,a=e.body.getReader();try{for(;!(t=await a.read()).done;)yield I(t.value)}finally{a.cancel()}}}async function*T(e,r){var t,a="";for await(var n of e)for(a+=n;(t=a.indexOf(r))>-1;)yield a.slice(0,t),a=a.slice(t+r.length)}exports.CombinedError=a,exports.createRequest=(e,r,t)=>{var a=r||{},o=w(e),s=d(a,!0),i=o.__key;return"{}"!==s&&(i=n(s,i)),{key:i,query:o,variables:a,extensions:t}},exports.getOperationType=r=>{for(var t of r.definitions)if(t.kind===e.Kind.OPERATION_DEFINITION)return t.operation},exports.keyDocument=w,exports.makeErrorResult=A,exports.makeFetchBody=function(e){var r={query:void 0,documentId:void 0,operationName:O(e.query),variables:e.variables||void 0,extensions:e.extensions};return!("documentId"in e.query)||!e.query.documentId||e.query.definitions&&e.query.definitions.length?e.extensions&&e.extensions.persistedQuery&&!e.extensions.persistedQuery.miss||(r.query=g(e.query)):r.documentId=e.query.documentId,r},exports.makeFetchOptions=(e,r)=>{var t={accept:"subscription"===e.kind?"text/event-stream, multipart/mixed":"application/graphql-response+json, application/graphql+json, application/json, text/event-stream, multipart/mixed"},a=("function"==typeof e.context.fetchOptions?e.context.fetchOptions():e.context.fetchOptions)||{};if(a.headers)if((e=>"has"in e&&!Object.keys(e).length)(a.headers))a.headers.forEach(((e,r)=>{t[r]=e}));else if(Array.isArray(a.headers))a.headers.forEach(((e,r)=>{Array.isArray(e)?t[e[0]]=t[e[0]]?`${t[e[0]]},${e[1]}`:e[1]:t[r]=e}));else for(var n in a.headers)t[n.toLowerCase()]=a.headers[n];var s=((e,r)=>{var t,a;if(r&&("query"!==e.kind||!e.context.preferGetMethod)){var n=d(r),s=(t=r.variables,a=new Map,l===f&&p===f||(o.clear(),c(a,"variables",t)),a);if(s.size){var i=new FormData;i.append("operations",n),i.append("map",d({...[...s.keys()].map((e=>[e]))}));var u=0;for(var y of s.values())i.append(""+u++,y);return i}return n}})(e,r);return"string"!=typeof s||t["content-type"]||(t["content-type"]="application/json"),{...a,method:s?"POST":"GET",body:s,headers:t}},exports.makeFetchSource=function(e,t,a){var n;return"undefined"!=typeof AbortController&&(a.signal=(n=new AbortController).signal),r.onEnd((()=>{n&&n.abort()}))(r.filter((e=>!!e))(r.fromAsyncIterable(async function*(e,r,t){var a,n=!0,o=null;try{yield await Promise.resolve();var s,i,c=(a=await(e.context.fetch||fetch)(r,t)).headers.get("Content-Type")||"";for await(var d of(s=/multipart\/mixed/i.test(c)?async function*(e,r){var t,a=e.match(q),n="--"+(a?a[1]:"-"),o=!0;for await(var s of T(L(r),"\r\n"+n)){if(o){o=!1;var i=s.indexOf(n);if(!(i>-1))continue;s=s.slice(i+n.length)}try{yield t=JSON.parse(s.slice(s.indexOf("\r\n\r\n")+4))}catch(e){if(!t)throw e}if(t&&!1===t.hasNext)break}t&&!1!==t.hasNext&&(yield{hasNext:!1})}(c,a):/text\/event-stream/i.test(c)?async function*(e){var r;for await(var t of T(L(e),"\n\n")){var a=t.match(S);if(a){var n=a[1];try{yield r=JSON.parse(n)}catch(e){if(!r)throw e}if(r&&!1===r.hasNext)break}}r&&!1!==r.hasNext&&(yield{hasNext:!1})}(a):/text\//i.test(c)?async function*(e){var r=await e.text();try{var t=JSON.parse(r);yield t}catch(e){throw new Error(r)}}(a):async function*(e){yield JSON.parse(await e.text())}(a),s))d.pending&&!o?i=d.pending:d.pending&&(i=[...i,...d.pending]),o=o?E(o,d,a,i):k(e,d,a),n=!1,yield o,n=!0;o||(yield o=k(e,{},a))}catch(r){if(!n)throw r;yield A(e,a&&(a.status<200||a.status>=300)&&a.statusText?new Error(a.statusText):r,a)}}(e,t,a))))},exports.makeFetchURL=(e,r)=>{var t="query"===e.kind&&e.context.preferGetMethod;if(!t||!r)return e.context.url;var a,n,o=(n=(a=e.context.url).indexOf("?"))>-1?[a.slice(0,n),new URLSearchParams(a.slice(n+1))]:[a,new URLSearchParams];for(var s in r){var i=r[s];i&&o[1].set(s,"object"==typeof i?d(i):i)}var c=o.join("?");return c.length>2047&&"force"!==t?(e.context.preferGetMethod=!1,e.context.url):c},exports.makeResult=k,exports.mergeResultPatch=E,exports.stringifyDocument=g,exports.stringifyVariables=d; | ||
var e=require("@0no-co/graphql.web"),r=require("wonka"),t=r=>r&&"string"==typeof r.message&&(r.extensions||"GraphQLError"===r.name)?r:"object"==typeof r&&"string"==typeof r.message?new e.GraphQLError(r.message,r.nodes,r.source,r.positions,r.path,r,r.extensions||{}):new e.GraphQLError(r);class n extends Error{constructor(e){var r=(e.graphQLErrors||[]).map(t),n=((e,r)=>{var t="";if(e)return`[Network] ${e.message}`;if(r)for(var n=0,a=r.length;n<a;n++)t&&(t+="\n"),t+=`[GraphQL] ${r[n].message}`;return t})(e.networkError,r);super(n),this.name="CombinedError",this.message=n,this.graphQLErrors=r,this.networkError=e.networkError,this.response=e.response}toString(){return this.message}}var a=(e,r)=>{for(var t=0|(r||5381),n=0,a=0|e.length;n<a;n++)t=(t<<5)+t+e.charCodeAt(n);return t},o=new Set,s=new WeakMap,i=(e,r)=>{if(null===e||o.has(e))return"null";if("object"!=typeof e)return JSON.stringify(e)||"";if(e.toJSON)return i(e.toJSON(),r);if(Array.isArray(e)){for(var t="[",n=0,a=e.length;n<a;n++)t.length>1&&(t+=","),t+=i(e[n],r)||"null";return t+"]"}if(!r&&(f!==c&&e instanceof f||p!==c&&e instanceof p))return"null";var d=Object.keys(e).sort();if(!d.length&&e.constructor&&Object.getPrototypeOf(e).constructor!==Object.prototype.constructor){var l=s.get(e)||Math.random().toString(36).slice(2);return s.set(e,l),i({__key:l},r)}o.add(e);for(var u="{",y=0,h=d.length;y<h;y++){var v=i(e[d[y]],r);v&&(u.length>1&&(u+=","),u+=i(d[y],r)+":"+v)}return o.delete(e),u+"}"},d=(e,r,t)=>{if(null==t||"object"!=typeof t||t.toJSON||o.has(t));else if(Array.isArray(t))for(var n=0,a=t.length;n<a;n++)d(e,`${r}.${n}`,t[n]);else if(t instanceof f||t instanceof p)e.set(r,t);else for(var s in o.add(t),t)d(e,`${r}.${s}`,t[s])},l=(e,r)=>(o.clear(),i(e,r||!1));class c{}var f="undefined"!=typeof File?File:c,p="undefined"!=typeof Blob?Blob:c,u=/("{3}[\s\S]*"{3}|"(?:\\.|[^"])*")/g,y=/(?:#[^\n\r]+)?(?:[\r\n]+|$)/g,h=(e,r)=>r%2==0?e.replace(y,"\n"):e,v=e=>e.split(u).map(h).join("").trim(),x=new Map,g=new Map,m=r=>{var t;return"string"==typeof r?t=v(r):r.loc&&g.get(r.__key)===r?t=r.loc.source.body:(t=x.get(r)||v(e.print(r)),x.set(r,t)),"string"==typeof r||r.loc||(r.loc={start:0,end:t.length,source:{body:t,name:"gql",locationOffset:{line:1,column:1}}}),t},w=e=>{var r;if(e.documentId)r=a(e.documentId);else if(r=a(m(e)),e.definitions){var t=O(e);t&&(r=a(`\n# ${t}`,r))}return r},b=r=>{var t,n;return"string"==typeof r?(t=w(r),n=g.get(t)||e.parse(r,{noLocation:!0})):(t=r.__key||w(r),n=g.get(t)||r),n.loc||m(n),n.__key=t,g.set(t,n),n},O=r=>{for(var t=0,n=r.definitions.length;t<n;t++){var a=r.definitions[t];if(a.kind===e.Kind.OPERATION_DEFINITION)return a.name?a.name.value:void 0}},k=(e,r,t)=>{if(!("data"in r||"errors"in r&&Array.isArray(r.errors)))throw new Error("No Content");var a="subscription"===e.kind;return{operation:e,data:r.data,error:Array.isArray(r.errors)?new n({graphQLErrors:r.errors,response:t}):void 0,extensions:r.extensions?{...r.extensions}:void 0,hasNext:null==r.hasNext?a:r.hasNext,stale:!1}},N=(e,r)=>{if("object"==typeof e&&null!=e){if(Array.isArray(e)){e=[...e];for(var t=0,n=r.length;t<n;t++)e[t]=N(e[t],r[t])}if(!e.constructor||e.constructor===Object||Array.isArray(e)){for(var a in e={...e},r)e[a]=N(e[a],r[a]);return e}}return r},E=(e,r,t,a)=>{var o=e.error?e.error.graphQLErrors:[],s=!!e.extensions||!!(r.payload||r).extensions,i={...e.extensions,...(r.payload||r).extensions},d=r.incremental;"path"in r&&(d=[r]);var l={data:e.data};if(d)for(var c=function(){var e=d[f];Array.isArray(e.errors)&&o.push(...e.errors),e.extensions&&(Object.assign(i,e.extensions),s=!0);var r="data",t=l,n=[];if(e.path)n=e.path;else if(a){var c=a.find((r=>r.id===e.id));n=e.subPath?[...c.path,...e.subPath]:c.path}for(var p=0,u=n.length;p<u;r=n[p++])t=t[r]=Array.isArray(t[r])?[...t[r]]:{...t[r]};if(e.items)for(var y=+r>=0?r:0,h=0,v=e.items.length;h<v;h++)t[y+h]=N(t[y+h],e.items[h]);else void 0!==e.data&&(t[r]=N(t[r],e.data))},f=0,p=d.length;f<p;f++)c();else l.data=(r.payload||r).data||e.data,o=r.errors||r.payload&&r.payload.errors||o;return{operation:e.operation,data:l.data,error:o.length?new n({graphQLErrors:o,response:t}):void 0,extensions:s?i:void 0,hasNext:null!=r.hasNext?r.hasNext:e.hasNext,stale:!1}},A=(e,r,t)=>({operation:e,data:void 0,error:new n({networkError:r,response:t}),extensions:void 0,hasNext:!1,stale:!1}),q="undefined"!=typeof TextDecoder?new TextDecoder:null,S=/boundary="?([^=";]+)"?/i,j=/data: ?([^\n]+)/,I=e=>"Buffer"===e.constructor.name?e.toString():q.decode(e);async function*L(e){if(e.body[Symbol.asyncIterator])for await(var r of e.body)yield I(r);else{var t,n=e.body.getReader();try{for(;!(t=await n.read()).done;)yield I(t.value)}finally{n.cancel()}}}async function*T(e,r){var t,n="";for await(var a of e)for(n+=a;(t=n.indexOf(r))>-1;)yield n.slice(0,t),n=n.slice(t+r.length)}exports.CombinedError=n,exports.createRequest=(e,r,t)=>{var n=r||{},o=b(e),s=l(n,!0),i=o.__key;return"{}"!==s&&(i=a(s,i)),{key:i,query:o,variables:n,extensions:t}},exports.getOperationType=r=>{for(var t=0,n=r.definitions.length;t<n;t++){var a=r.definitions[t];if(a.kind===e.Kind.OPERATION_DEFINITION)return a.operation}},exports.keyDocument=b,exports.makeErrorResult=A,exports.makeFetchBody=function(e){var r={query:void 0,documentId:void 0,operationName:O(e.query),variables:e.variables||void 0,extensions:e.extensions};return!("documentId"in e.query)||!e.query.documentId||e.query.definitions&&e.query.definitions.length?e.extensions&&e.extensions.persistedQuery&&!e.extensions.persistedQuery.miss||(r.query=m(e.query)):r.documentId=e.query.documentId,r},exports.makeFetchOptions=(e,r)=>{var t={accept:"subscription"===e.kind?"text/event-stream, multipart/mixed":"application/graphql-response+json, application/graphql+json, application/json, text/event-stream, multipart/mixed"},n=("function"==typeof e.context.fetchOptions?e.context.fetchOptions():e.context.fetchOptions)||{};if(n.headers)if((e=>"has"in e&&!Object.keys(e).length)(n.headers))n.headers.forEach(((e,r)=>{t[r]=e}));else if(Array.isArray(n.headers))n.headers.forEach(((e,r)=>{Array.isArray(e)?t[e[0]]=t[e[0]]?`${t[e[0]]},${e[1]}`:e[1]:t[r]=e}));else for(var a in n.headers)t[a.toLowerCase()]=n.headers[a];var s=((e,r)=>{var t,n;if(r&&("query"!==e.kind||!e.context.preferGetMethod)){var a=l(r),s=(t=r.variables,n=new Map,f===c&&p===c||(o.clear(),d(n,"variables",t)),n);if(s.size){var i=new FormData;i.append("operations",a),i.append("map",l({...[...s.keys()].map((e=>[e]))}));var u=0;for(var y of s.values())i.append(""+u++,y);return i}return a}})(e,r);return"string"!=typeof s||t["content-type"]||(t["content-type"]="application/json"),{...n,method:s?"POST":"GET",body:s,headers:t}},exports.makeFetchSource=function(e,t,n){var a;return"undefined"!=typeof AbortController&&(n.signal=(a=new AbortController).signal),r.onEnd((()=>{a&&a.abort()}))(r.filter((e=>!!e))(r.fromAsyncIterable(async function*(e,r,t){var n,a=!0,o=null;try{yield await Promise.resolve();var s,i,d=(n=await(e.context.fetch||fetch)(r,t)).headers.get("Content-Type")||"";for await(var l of(s=/multipart\/mixed/i.test(d)?async function*(e,r){var t,n=e.match(S),a="--"+(n?n[1]:"-"),o=!0;for await(var s of T(L(r),"\r\n"+a)){if(o){o=!1;var i=s.indexOf(a);if(!(i>-1))continue;s=s.slice(i+a.length)}try{yield t=JSON.parse(s.slice(s.indexOf("\r\n\r\n")+4))}catch(e){if(!t)throw e}if(t&&!1===t.hasNext)break}t&&!1!==t.hasNext&&(yield{hasNext:!1})}(d,n):/text\/event-stream/i.test(d)?async function*(e){var r;for await(var t of T(L(e),"\n\n")){var n=t.match(j);if(n){var a=n[1];try{yield r=JSON.parse(a)}catch(e){if(!r)throw e}if(r&&!1===r.hasNext)break}}r&&!1!==r.hasNext&&(yield{hasNext:!1})}(n):/text\//i.test(d)?async function*(e){var r=await e.text();try{var t=JSON.parse(r);yield t}catch(e){throw new Error(r)}}(n):async function*(e){yield JSON.parse(await e.text())}(n),s))l.pending&&!o?i=l.pending:l.pending&&(i=[...i,...l.pending]),o=o?E(o,l,n,i):k(e,l,n),a=!1,yield o,a=!0;o||(yield o=k(e,{},n))}catch(r){if(!a)throw r;yield A(e,n&&(n.status<200||n.status>=300)&&n.statusText?new Error(n.statusText):r,n)}}(e,t,n))))},exports.makeFetchURL=(e,r)=>{var t="query"===e.kind&&e.context.preferGetMethod;if(!t||!r)return e.context.url;var n,a,o=(a=(n=e.context.url).indexOf("?"))>-1?[n.slice(0,a),new URLSearchParams(n.slice(a+1))]:[n,new URLSearchParams];for(var s in r){var i=r[s];i&&o[1].set(s,"object"==typeof i?l(i):i)}var d=o.join("?");return d.length>2047&&"force"!==t?(e.context.preferGetMethod=!1,e.context.url):d},exports.makeResult=k,exports.mergeResultPatch=E,exports.stringifyDocument=m,exports.stringifyVariables=l; | ||
//# sourceMappingURL=urql-core-chunk.min.js.map |
Object.defineProperty(exports, '__esModule', { value: true }); | ||
var fetchSource = require('./urql-core-chunk.js'); | ||
var urqlCoreInternal = require('./urql-core-chunk.js'); | ||
exports.makeFetchBody = fetchSource.makeFetchBody; | ||
exports.makeFetchOptions = fetchSource.makeFetchOptions; | ||
exports.makeFetchSource = fetchSource.makeFetchSource; | ||
exports.makeFetchURL = fetchSource.makeFetchURL; | ||
exports.makeFetchBody = urqlCoreInternal.makeFetchBody; | ||
exports.makeFetchOptions = urqlCoreInternal.makeFetchOptions; | ||
exports.makeFetchSource = urqlCoreInternal.makeFetchSource; | ||
exports.makeFetchURL = urqlCoreInternal.makeFetchURL; | ||
//# sourceMappingURL=urql-core-internal.js.map |
@@ -410,3 +410,3 @@ import { AnyVariables, TypedDocumentNode, DocumentNode, GraphQLError, Exchange, FetchBody, Operation, ExecutionResult, DefinitionNode, DocumentInput, RequestExtensions, GraphQLRequest, OperationResult, FormattedNode, OperationType, OperationContext, CombinedError } from './urql-core-chunk.js'; | ||
*/ | ||
declare const mergeResultPatch: (prevResult: OperationResult, nextResult: ExecutionResult, response?: any, pending?: ExecutionResult['pending']) => OperationResult; | ||
declare const mergeResultPatch: (prevResult: OperationResult, nextResult: ExecutionResult, response?: any, pending?: ExecutionResult["pending"]) => OperationResult; | ||
/** Creates an `OperationResult` containing a network error for requests that encountered unexpected errors. | ||
@@ -413,0 +413,0 @@ * |
Object.defineProperty(exports, '__esModule', { value: true }); | ||
var graphql_web = require('@0no-co/graphql.web'); | ||
var fetchSource = require('./urql-core-chunk.js'); | ||
var urqlCoreInternal = require('./urql-core-chunk.js'); | ||
var wonka = require('wonka'); | ||
@@ -9,3 +9,5 @@ | ||
if (Array.isArray(obj)) { | ||
for (var item of obj) collectTypes(item, types); | ||
for (var i = 0, l = obj.length; i < l; i++) { | ||
collectTypes(obj[i], types); | ||
} | ||
} else if (typeof obj === 'object' && obj !== null) { | ||
@@ -34,4 +36,4 @@ for (var _key in obj) { | ||
var definitions = []; | ||
for (var definition of node.definitions) { | ||
var newDefinition = formatNode(definition); | ||
for (var i = 0, l = node.definitions.length; i < l; i++) { | ||
var newDefinition = formatNode(node.definitions[i]); | ||
definitions.push(newDefinition); | ||
@@ -47,3 +49,4 @@ } | ||
var _directives = {}; | ||
for (var directive of node.directives) { | ||
for (var _i = 0, _l = node.directives.length; _i < _l; _i++) { | ||
var directive = node.directives[_i]; | ||
var name = directive.name.value; | ||
@@ -67,3 +70,4 @@ if (name[0] !== '_') { | ||
if (node.selectionSet) { | ||
for (var selection of node.selectionSet.selections || []) { | ||
for (var _i2 = 0, _l2 = node.selectionSet.selections.length; _i2 < _l2; _i2++) { | ||
var selection = node.selectionSet.selections[_i2]; | ||
hasTypename = hasTypename || selection.kind === graphql_web.Kind.FIELD && selection.name.value === '__typename' && !selection.alias; | ||
@@ -119,3 +123,3 @@ var newSelection = formatNode(selection); | ||
var formatDocument = node => { | ||
var query = fetchSource.keyDocument(node); | ||
var query = urqlCoreInternal.keyDocument(node); | ||
var result = formattedDocs.get(query.__key); | ||
@@ -268,8 +272,9 @@ if (!result) { | ||
} | ||
source.unshift(fetchSource.keyDocument(body)); | ||
for (var document of source) { | ||
for (var definition of document.definitions) { | ||
source.unshift(urqlCoreInternal.keyDocument(body)); | ||
for (var _i = 0; _i < source.length; _i++) { | ||
for (var j = 0; j < source[_i].definitions.length; j++) { | ||
var definition = source[_i].definitions[j]; | ||
if (definition.kind === graphql_web.Kind.FRAGMENT_DEFINITION) { | ||
var name = definition.name.value; | ||
var _value = fetchSource.stringifyDocument(definition); | ||
var _value = urqlCoreInternal.stringifyDocument(definition); | ||
// Fragments will be deduplicated according to this Map | ||
@@ -288,3 +293,3 @@ if (!fragmentNames.has(name)) { | ||
} | ||
return fetchSource.keyDocument({ | ||
return urqlCoreInternal.keyDocument({ | ||
kind: graphql_web.Kind.DOCUMENT, | ||
@@ -354,3 +359,3 @@ definitions | ||
}) : undefined; | ||
var result = cachedResult || fetchSource.makeResult(operation, { | ||
var result = cachedResult || urqlCoreInternal.makeResult(operation, { | ||
data: null | ||
@@ -509,3 +514,3 @@ }); | ||
extensions: includeExtensions && result.extensions ? JSON.parse(result.extensions) : undefined, | ||
error: result.error ? new fetchSource.CombinedError({ | ||
error: result.error ? new urqlCoreInternal.CombinedError({ | ||
networkError: result.error.networkError ? new Error(result.error.networkError) : undefined, | ||
@@ -672,3 +677,3 @@ graphQLErrors: result.error.graphQLErrors | ||
var createSubscriptionSource = operation => { | ||
var observableish = forwardSubscription(fetchSource.makeFetchBody(operation), operation); | ||
var observableish = forwardSubscription(urqlCoreInternal.makeFetchBody(operation), operation); | ||
return wonka.make(observer => { | ||
@@ -679,3 +684,3 @@ var isComplete = false; | ||
function nextResult(value) { | ||
observer.next(result = result ? fetchSource.mergeResultPatch(result, value) : fetchSource.makeResult(operation, value)); | ||
observer.next(result = result ? urqlCoreInternal.mergeResultPatch(result, value) : urqlCoreInternal.makeResult(operation, value)); | ||
} | ||
@@ -696,3 +701,3 @@ Promise.resolve().then(() => { | ||
} else { | ||
observer.next(fetchSource.makeErrorResult(operation, error)); | ||
observer.next(urqlCoreInternal.makeErrorResult(operation, error)); | ||
} | ||
@@ -790,5 +795,5 @@ observer.complete(); | ||
var fetchResults$ = wonka.mergeMap(operation => { | ||
var body = fetchSource.makeFetchBody(operation); | ||
var url = fetchSource.makeFetchURL(operation, body); | ||
var fetchOptions = fetchSource.makeFetchOptions(operation, body); | ||
var body = urqlCoreInternal.makeFetchBody(operation); | ||
var url = urqlCoreInternal.makeFetchURL(operation, body); | ||
var fetchOptions = urqlCoreInternal.makeFetchOptions(operation, body); | ||
process.env.NODE_ENV !== 'production' ? dispatchDebug({ | ||
@@ -804,3 +809,3 @@ type: 'fetchRequest', | ||
}) : undefined; | ||
var source = wonka.takeUntil(wonka.filter(op => op.kind === 'teardown' && op.key === operation.key)(ops$))(fetchSource.makeFetchSource(operation, url, fetchOptions)); | ||
var source = wonka.takeUntil(wonka.filter(op => op.kind === 'teardown' && op.key === operation.key)(ops$))(urqlCoreInternal.makeFetchSource(operation, url, fetchOptions)); | ||
if (process.env.NODE_ENV !== 'production') { | ||
@@ -948,2 +953,3 @@ return wonka.onPush(result => { | ||
/** Configuration options passed when creating a new {@link Client}. | ||
@@ -1066,3 +1072,4 @@ * | ||
// key, then `stale` refers to it | ||
for (var _operation of queue) { | ||
for (var i = 0; i < queue.length; i++) { | ||
var _operation = queue[i]; | ||
if (_operation.key === result.operation.key) { | ||
@@ -1120,3 +1127,3 @@ dispatched.delete(_operation.key); | ||
var requestOperationType; | ||
if (process.env.NODE_ENV !== 'production' && kind !== 'teardown' && (requestOperationType = fetchSource.getOperationType(request.query)) !== kind) { | ||
if (process.env.NODE_ENV !== 'production' && kind !== 'teardown' && (requestOperationType = urqlCoreInternal.getOperationType(request.query)) !== kind) { | ||
throw new Error(`Expected operation of type "${kind}" but found "${requestOperationType}"`); | ||
@@ -1172,9 +1179,9 @@ } | ||
query(query, variables, context) { | ||
return client.executeQuery(fetchSource.createRequest(query, variables), context); | ||
return client.executeQuery(urqlCoreInternal.createRequest(query, variables), context); | ||
}, | ||
subscription(query, variables, context) { | ||
return client.executeSubscription(fetchSource.createRequest(query, variables), context); | ||
return client.executeSubscription(urqlCoreInternal.createRequest(query, variables), context); | ||
}, | ||
mutation(query, variables, context) { | ||
return client.executeMutation(fetchSource.createRequest(query, variables), context); | ||
return client.executeMutation(urqlCoreInternal.createRequest(query, variables), context); | ||
} | ||
@@ -1219,9 +1226,9 @@ }); | ||
exports.CombinedError = fetchSource.CombinedError; | ||
exports.createRequest = fetchSource.createRequest; | ||
exports.makeErrorResult = fetchSource.makeErrorResult; | ||
exports.makeResult = fetchSource.makeResult; | ||
exports.mergeResultPatch = fetchSource.mergeResultPatch; | ||
exports.stringifyDocument = fetchSource.stringifyDocument; | ||
exports.stringifyVariables = fetchSource.stringifyVariables; | ||
exports.CombinedError = urqlCoreInternal.CombinedError; | ||
exports.createRequest = urqlCoreInternal.createRequest; | ||
exports.makeErrorResult = urqlCoreInternal.makeErrorResult; | ||
exports.makeResult = urqlCoreInternal.makeResult; | ||
exports.mergeResultPatch = urqlCoreInternal.mergeResultPatch; | ||
exports.stringifyDocument = urqlCoreInternal.stringifyDocument; | ||
exports.stringifyVariables = urqlCoreInternal.stringifyVariables; | ||
exports.Client = Client; | ||
@@ -1228,0 +1235,0 @@ exports.cacheExchange = cacheExchange; |
@@ -1,2 +0,2 @@ | ||
Object.defineProperty(exports,"__esModule",{value:!0});var e=require("@0no-co/graphql.web"),r=require("./urql-core-chunk.min.js"),t=require("wonka"),n=(e,r)=>{if(Array.isArray(e))for(var t of e)n(t,r);else if("object"==typeof e&&null!==e)for(var o in e)"__typename"===o&&"string"==typeof e[o]?r.add(e[o]):n(e[o],r);return r},o=r=>{if("definitions"in r){var t=[];for(var n of r.definitions){var a=o(n);t.push(a)}return{...r,definitions:t}}if("directives"in r&&r.directives&&r.directives.length){var i=[],s={};for(var u of r.directives){var c=u.name.value;"_"!==c[0]?i.push(u):c=c.slice(1),s[c]=u}r={...r,directives:i,_directives:s}}if("selectionSet"in r){var l=[],p=r.kind===e.Kind.OPERATION_DEFINITION;if(r.selectionSet){for(var d of r.selectionSet.selections||[]){p=p||d.kind===e.Kind.FIELD&&"__typename"===d.name.value&&!d.alias;var k=o(d);l.push(k)}return p||l.push({kind:e.Kind.FIELD,name:{kind:e.Kind.NAME,value:"__typename"},_generated:!0}),{...r,selectionSet:{...r.selectionSet,selections:l}}}}return r},a=new Map,i=e=>{var t=r.keyDocument(e),n=a.get(t.__key);return n||(a.set(t.__key,n=o(t)),Object.defineProperty(n,"__key",{value:t.__key,enumerable:!1})),n};function s(e,r,t){return{...r,kind:e,context:r.context?{...r.context,...t}:t||r.context}}var u=()=>{},c=({kind:e})=>"mutation"!==e&&"query"!==e,l=e=>{var r=i(e.query);if(r!==e.query){var t=s(e.kind,e);return t.query=r,t}return e},p=(e,r)=>e.reexecuteOperation(s(r.kind,r,{requestPolicy:"network-only"})),d=new Set,k=e=>({client:r,forward:n})=>e.reduceRight(((e,n)=>n({client:r,forward:r=>t.share(e(t.share(r))),dispatchDebug(e){}})),n),f=({onOperation:e,onResult:r,onError:n})=>({forward:o})=>a=>t.mergeMap((e=>{n&&e.error&&n(e.error,e.operation);var o=r&&r(e)||e;return"then"in o?t.fromPromise(o):t.fromValue(o)}))(o(t.mergeMap((r=>{var n=e&&e(r)||r;return"then"in n?t.fromPromise(n):t.fromValue(n)}))(a))),y=({})=>e=>t.filter((e=>!1))(e),h=function e(n){var o=0,a=new Map,i=new Map,c=new Set,l=[],p={url:n.url,fetchSubscriptions:n.fetchSubscriptions,fetchOptions:n.fetchOptions,fetch:n.fetch,preferGetMethod:n.preferGetMethod,requestPolicy:n.requestPolicy||"cache-first"},d=t.makeSubject();function f(e){"mutation"!==e.kind&&"teardown"!==e.kind&&c.has(e.key)||("teardown"===e.kind?c.delete(e.key):"mutation"!==e.kind&&c.add(e.key),d.next(e))}var h=!1;function m(e){if(e&&f(e),!h){for(h=!0;h&&(e=l.shift());)f(e);h=!1}}var v=e=>{var r=t.takeUntil(t.filter((r=>"teardown"===r.kind&&r.key===e.key))(d.source))(t.filter((r=>r.operation.kind===e.kind&&r.operation.key===e.key&&(!r.operation.context._instance||r.operation.context._instance===e.context._instance)))(q));return r="query"!==e.kind?t.takeWhile((e=>!!e.hasNext),!0)(r):t.switchMap((r=>{var n=t.fromValue(r);return r.stale||r.hasNext?n:t.merge([n,t.map((()=>(r.stale=!0,r)))(t.take(1)(t.filter((r=>r.key===e.key))(d.source)))])}))(r),r="mutation"!==e.kind?t.onEnd((()=>{c.delete(e.key),a.delete(e.key),i.delete(e.key),h=!1;for(var r=l.length-1;r>=0;r--)l[r].key===e.key&&l.splice(r,1);f(s("teardown",e,e.context))}))(t.onPush((r=>{if(r.stale)if(r.hasNext){for(var t of l)if(t.key===r.operation.key){c.delete(t.key);break}}else c.delete(e.key);else r.hasNext||c.delete(e.key);a.set(e.key,r)}))(r)):t.onStart((()=>{f(e)}))(r),t.share(r)},x=this instanceof e?this:Object.create(e.prototype),g=Object.assign(x,{suspense:!!n.suspense,operations$:d.source,reexecuteOperation(e){if("teardown"===e.kind)m(e);else if("mutation"===e.kind)l.push(e),Promise.resolve().then(m);else if(i.has(e.key)){for(var r=!1,t=0;t<l.length;t++)l[t].key===e.key&&(l[t]=e,r=!0);r||c.has(e.key)&&"network-only"!==e.context.requestPolicy?(c.delete(e.key),Promise.resolve().then(m)):(l.push(e),Promise.resolve().then(m))}},createRequestOperation:(e,r,t)=>(t||(t={}),s(e,r,{_instance:"mutation"===e?o=o+1|0:void 0,...p,...t,requestPolicy:t.requestPolicy||p.requestPolicy,suspense:t.suspense||!1!==t.suspense&&g.suspense})),executeRequestOperation:e=>{return r="mutation"===e.kind?v(e):t.lazy((()=>{var r=i.get(e.key);r||i.set(e.key,r=v(e)),r=t.onStart((()=>{m(e)}))(r);var n=a.get(e.key);return"query"===e.kind&&n&&(n.stale||n.hasNext)?t.switchMap(t.fromValue)(t.merge([r,t.filter((r=>r===a.get(e.key)))(t.fromValue(n))])):r})),(n=e=>r(e)).toPromise=()=>t.toPromise(t.take(1)(t.filter((e=>!e.stale&&!e.hasNext))(n))),n.then=(e,r)=>n.toPromise().then(e,r),n.subscribe=e=>t.subscribe(e)(n),n;var r,n},executeQuery(e,r){var t=g.createRequestOperation("query",e,r);return g.executeRequestOperation(t)},executeSubscription(e,r){var t=g.createRequestOperation("subscription",e,r);return g.executeRequestOperation(t)},executeMutation(e,r){var t=g.createRequestOperation("mutation",e,r);return g.executeRequestOperation(t)},readQuery(e,r,n){var o=null;return t.subscribe((e=>{o=e}))(g.query(e,r,n)).unsubscribe(),o},query:(e,t,n)=>g.executeQuery(r.createRequest(e,t),n),subscription:(e,t,n)=>g.executeSubscription(r.createRequest(e,t),n),mutation:(e,t,n)=>g.executeMutation(r.createRequest(e,t),n)}),w=u,b=k(n.exchanges),q=t.share(b({client:g,dispatchDebug:w,forward:y({dispatchDebug:w})})(d.source));return t.publish(q),g},m=h;exports.CombinedError=r.CombinedError,exports.createRequest=r.createRequest,exports.makeErrorResult=r.makeErrorResult,exports.makeResult=r.makeResult,exports.mergeResultPatch=r.mergeResultPatch,exports.stringifyDocument=r.stringifyDocument,exports.stringifyVariables=r.stringifyVariables,exports.Client=h,exports.cacheExchange=({forward:e,client:o})=>{var a=new Map,i=new Map,s=e=>"query"===e.kind&&"network-only"!==e.context.requestPolicy&&("cache-only"===e.context.requestPolicy||a.has(e.key));return u=>{var d=t.map((e=>{var t=a.get(e.key)||r.makeResult(e,{data:null});return t={...t,operation:e},"cache-and-network"===e.context.requestPolicy&&(t.stale=!0,p(o,e)),t}))(t.filter((e=>!c(e)&&s(e)))(u)),k=t.tap((e=>{var{operation:r}=e;if(r){var t=r.context.additionalTypenames||[];if("subscription"!==e.operation.kind&&(t=(e=>[...n(e,new Set)])(e.data).concat(t)),"mutation"===e.operation.kind||"subscription"===e.operation.kind){for(var s=new Set,u=0;u<t.length;u++){var c=t[u],l=i.get(c);for(var d of(l||i.set(c,l=new Set),l.values()))s.add(d);l.clear()}for(var k of s.values())a.has(k)&&(r=a.get(k).operation,a.delete(k),p(o,r))}else if("query"===r.kind&&e.data){a.set(r.key,e);for(var f=0;f<t.length;f++){var y=t[f],h=i.get(y);h||i.set(y,h=new Set),h.add(r.key)}}}}))(e(t.filter((e=>"query"!==e.kind||"cache-only"!==e.context.requestPolicy))(t.map((e=>e))(t.merge([t.map(l)(t.filter((e=>!c(e)&&!s(e)))(u)),t.filter((e=>c(e)))(u)])))));return t.merge([d,k])}},exports.composeExchanges=k,exports.createClient=m,exports.debugExchange=({forward:e})=>r=>e(r),exports.errorExchange=f,exports.fetchExchange=({forward:e})=>n=>{var o=t.mergeMap((e=>{var o=r.makeFetchBody(e),a=r.makeFetchURL(e,o),i=r.makeFetchOptions(e,o);return t.takeUntil(t.filter((r=>"teardown"===r.kind&&r.key===e.key))(n))(r.makeFetchSource(e,a,i))}))(t.filter((e=>"teardown"!==e.kind&&("subscription"!==e.kind||!!e.context.fetchSubscriptions)))(n)),a=e(t.filter((e=>"teardown"===e.kind||"subscription"===e.kind&&!e.context.fetchSubscriptions))(n));return t.merge([o,a])},exports.formatDocument=i,exports.gql=function(t){for(var n=new Map,o=[],a=[],i=Array.isArray(t)?t[0]:t||"",s=1;s<arguments.length;s++){var u=arguments[s];u&&u.definitions?a.push(u):i+=u,i+=arguments[0][s]}for(var c of(a.unshift(r.keyDocument(i)),a))for(var l of c.definitions)if(l.kind===e.Kind.FRAGMENT_DEFINITION){var p=l.name.value,d=r.stringifyDocument(l);n.has(p)||(n.set(p,d),o.push(l))}else o.push(l);return r.keyDocument({kind:e.Kind.DOCUMENT,definitions:o})},exports.makeOperation=s,exports.mapExchange=f,exports.ssrExchange=(e={})=>{var n=!!e.staleWhileRevalidate,o=!!e.includeExtensions,a={},i=[],s=e=>{i.push(e.operation.key),1===i.length&&Promise.resolve().then((()=>{for(var e;e=i.shift();)a[e]=null}))},u=({client:i,forward:u})=>c=>{var k=e&&"boolean"==typeof e.isClient?!!e.isClient:!i.suspense,f=u(t.map(l)(t.filter((e=>"teardown"===e.kind||!a[e.key]||!!a[e.key].hasNext||"network-only"===e.context.requestPolicy))(c))),y=t.map((e=>{var t=((e,t,n)=>({operation:e,data:t.data?JSON.parse(t.data):void 0,extensions:n&&t.extensions?JSON.parse(t.extensions):void 0,error:t.error?new r.CombinedError({networkError:t.error.networkError?new Error(t.error.networkError):void 0,graphQLErrors:t.error.graphQLErrors}):void 0,stale:!1,hasNext:!!t.hasNext}))(e,a[e.key],o);return n&&!d.has(e.key)&&(t.stale=!0,d.add(e.key),p(i,e)),{...t,operation:e}}))(t.filter((e=>"teardown"!==e.kind&&!!a[e.key]&&"network-only"!==e.context.requestPolicy))(c));return k?y=t.tap(s)(y):f=t.tap((e=>{var{operation:r}=e;if("mutation"!==r.kind){var t=((e,r)=>{var t={hasNext:e.hasNext};return void 0!==e.data&&(t.data=JSON.stringify(e.data)),r&&void 0!==e.extensions&&(t.extensions=JSON.stringify(e.extensions)),e.error&&(t.error={graphQLErrors:e.error.graphQLErrors.map((e=>e.path||e.extensions?{message:e.message,path:e.path,extensions:e.extensions}:e.message))},e.error.networkError&&(t.error.networkError=""+e.error.networkError)),t})(e,o);a[r.key]=t}}))(f),t.merge([f,y])};return u.restoreData=e=>{for(var r in e)null!==a[r]&&(a[r]=e[r])},u.extractData=()=>{var e={};for(var r in a)null!=a[r]&&(e[r]=a[r]);return e},e&&e.initialState&&u.restoreData(e.initialState),u},exports.subscriptionExchange=({forwardSubscription:e,enableAllOperations:n,isSubscriptionOperation:o})=>({client:a,forward:i})=>{var u=o||(e=>"subscription"===e.kind||!!n&&("query"===e.kind||"mutation"===e.kind));return n=>{var o=t.mergeMap((o=>{var{key:i}=o,u=t.filter((e=>"teardown"===e.kind&&e.key===i))(n);return t.takeUntil(u)((n=>{var o=e(r.makeFetchBody(n),n);return t.make((e=>{var t,i,u=!1;function c(t){e.next(i=i?r.mergeResultPatch(i,t):r.makeResult(n,t))}return Promise.resolve().then((()=>{u||(t=o.subscribe({next:c,error(t){Array.isArray(t)?c({errors:t}):e.next(r.makeErrorResult(n,t)),e.complete()},complete(){u||(u=!0,"subscription"===n.kind&&a.reexecuteOperation(s("teardown",n,n.context)),i&&i.hasNext&&c({hasNext:!1}),e.complete())}}))})),()=>{u=!0,t&&t.unsubscribe()}}))})(o))}))(t.filter((e=>"teardown"!==e.kind&&u(e)))(n)),c=i(t.filter((e=>"teardown"===e.kind||!u(e)))(n));return t.merge([o,c])}}; | ||
Object.defineProperty(exports,"__esModule",{value:!0});var e=require("@0no-co/graphql.web"),r=require("./urql-core-chunk.min.js"),t=require("wonka"),n=(e,r)=>{if(Array.isArray(e))for(var t=0,i=e.length;t<i;t++)n(e[t],r);else if("object"==typeof e&&null!==e)for(var o in e)"__typename"===o&&"string"==typeof e[o]?r.add(e[o]):n(e[o],r);return r},i=r=>{if("definitions"in r){for(var t=[],n=0,o=r.definitions.length;n<o;n++){var a=i(r.definitions[n]);t.push(a)}return{...r,definitions:t}}if("directives"in r&&r.directives&&r.directives.length){for(var s=[],u={},c=0,l=r.directives.length;c<l;c++){var d=r.directives[c],p=d.name.value;"_"!==p[0]?s.push(d):p=p.slice(1),u[p]=d}r={...r,directives:s,_directives:u}}if("selectionSet"in r){var k=[],f=r.kind===e.Kind.OPERATION_DEFINITION;if(r.selectionSet){for(var h=0,y=r.selectionSet.selections.length;h<y;h++){var v=r.selectionSet.selections[h];f=f||v.kind===e.Kind.FIELD&&"__typename"===v.name.value&&!v.alias;var m=i(v);k.push(m)}return f||k.push({kind:e.Kind.FIELD,name:{kind:e.Kind.NAME,value:"__typename"},_generated:!0}),{...r,selectionSet:{...r.selectionSet,selections:k}}}}return r},o=new Map,a=e=>{var t=r.keyDocument(e),n=o.get(t.__key);return n||(o.set(t.__key,n=i(t)),Object.defineProperty(n,"__key",{value:t.__key,enumerable:!1})),n};function s(e,r,t){return{...r,kind:e,context:r.context?{...r.context,...t}:t||r.context}}var u=()=>{},c=({kind:e})=>"mutation"!==e&&"query"!==e,l=e=>{var r=a(e.query);if(r!==e.query){var t=s(e.kind,e);return t.query=r,t}return e},d=(e,r)=>e.reexecuteOperation(s(r.kind,r,{requestPolicy:"network-only"})),p=new Set,k=e=>({client:r,forward:n})=>e.reduceRight(((e,n)=>n({client:r,forward:r=>t.share(e(t.share(r))),dispatchDebug(e){}})),n),f=({onOperation:e,onResult:r,onError:n})=>({forward:i})=>o=>t.mergeMap((e=>{n&&e.error&&n(e.error,e.operation);var i=r&&r(e)||e;return"then"in i?t.fromPromise(i):t.fromValue(i)}))(i(t.mergeMap((r=>{var n=e&&e(r)||r;return"then"in n?t.fromPromise(n):t.fromValue(n)}))(o))),h=({})=>e=>t.filter((e=>!1))(e),y=function e(n){var i=0,o=new Map,a=new Map,c=new Set,l=[],d={url:n.url,fetchSubscriptions:n.fetchSubscriptions,fetchOptions:n.fetchOptions,fetch:n.fetch,preferGetMethod:n.preferGetMethod,requestPolicy:n.requestPolicy||"cache-first"},p=t.makeSubject();function f(e){"mutation"!==e.kind&&"teardown"!==e.kind&&c.has(e.key)||("teardown"===e.kind?c.delete(e.key):"mutation"!==e.kind&&c.add(e.key),p.next(e))}var y=!1;function v(e){if(e&&f(e),!y){for(y=!0;y&&(e=l.shift());)f(e);y=!1}}var m=e=>{var r=t.takeUntil(t.filter((r=>"teardown"===r.kind&&r.key===e.key))(p.source))(t.filter((r=>r.operation.kind===e.kind&&r.operation.key===e.key&&(!r.operation.context._instance||r.operation.context._instance===e.context._instance)))(q));return r="query"!==e.kind?t.takeWhile((e=>!!e.hasNext),!0)(r):t.switchMap((r=>{var n=t.fromValue(r);return r.stale||r.hasNext?n:t.merge([n,t.map((()=>(r.stale=!0,r)))(t.take(1)(t.filter((r=>r.key===e.key))(p.source)))])}))(r),r="mutation"!==e.kind?t.onEnd((()=>{c.delete(e.key),o.delete(e.key),a.delete(e.key),y=!1;for(var r=l.length-1;r>=0;r--)l[r].key===e.key&&l.splice(r,1);f(s("teardown",e,e.context))}))(t.onPush((r=>{if(r.stale)if(r.hasNext)for(var t=0;t<l.length;t++){var n=l[t];if(n.key===r.operation.key){c.delete(n.key);break}}else c.delete(e.key);else r.hasNext||c.delete(e.key);o.set(e.key,r)}))(r)):t.onStart((()=>{f(e)}))(r),t.share(r)},x=this instanceof e?this:Object.create(e.prototype),g=Object.assign(x,{suspense:!!n.suspense,operations$:p.source,reexecuteOperation(e){if("teardown"===e.kind)v(e);else if("mutation"===e.kind)l.push(e),Promise.resolve().then(v);else if(a.has(e.key)){for(var r=!1,t=0;t<l.length;t++)l[t].key===e.key&&(l[t]=e,r=!0);r||c.has(e.key)&&"network-only"!==e.context.requestPolicy?(c.delete(e.key),Promise.resolve().then(v)):(l.push(e),Promise.resolve().then(v))}},createRequestOperation:(e,r,t)=>(t||(t={}),s(e,r,{_instance:"mutation"===e?i=i+1|0:void 0,...d,...t,requestPolicy:t.requestPolicy||d.requestPolicy,suspense:t.suspense||!1!==t.suspense&&g.suspense})),executeRequestOperation:e=>{return r="mutation"===e.kind?m(e):t.lazy((()=>{var r=a.get(e.key);r||a.set(e.key,r=m(e)),r=t.onStart((()=>{v(e)}))(r);var n=o.get(e.key);return"query"===e.kind&&n&&(n.stale||n.hasNext)?t.switchMap(t.fromValue)(t.merge([r,t.filter((r=>r===o.get(e.key)))(t.fromValue(n))])):r})),(n=e=>r(e)).toPromise=()=>t.toPromise(t.take(1)(t.filter((e=>!e.stale&&!e.hasNext))(n))),n.then=(e,r)=>n.toPromise().then(e,r),n.subscribe=e=>t.subscribe(e)(n),n;var r,n},executeQuery(e,r){var t=g.createRequestOperation("query",e,r);return g.executeRequestOperation(t)},executeSubscription(e,r){var t=g.createRequestOperation("subscription",e,r);return g.executeRequestOperation(t)},executeMutation(e,r){var t=g.createRequestOperation("mutation",e,r);return g.executeRequestOperation(t)},readQuery(e,r,n){var i=null;return t.subscribe((e=>{i=e}))(g.query(e,r,n)).unsubscribe(),i},query:(e,t,n)=>g.executeQuery(r.createRequest(e,t),n),subscription:(e,t,n)=>g.executeSubscription(r.createRequest(e,t),n),mutation:(e,t,n)=>g.executeMutation(r.createRequest(e,t),n)}),w=u,b=k(n.exchanges),q=t.share(b({client:g,dispatchDebug:w,forward:h({dispatchDebug:w})})(p.source));return t.publish(q),g},v=y;exports.CombinedError=r.CombinedError,exports.createRequest=r.createRequest,exports.makeErrorResult=r.makeErrorResult,exports.makeResult=r.makeResult,exports.mergeResultPatch=r.mergeResultPatch,exports.stringifyDocument=r.stringifyDocument,exports.stringifyVariables=r.stringifyVariables,exports.Client=y,exports.cacheExchange=({forward:e,client:i})=>{var o=new Map,a=new Map,s=e=>"query"===e.kind&&"network-only"!==e.context.requestPolicy&&("cache-only"===e.context.requestPolicy||o.has(e.key));return u=>{var p=t.map((e=>{var t=o.get(e.key)||r.makeResult(e,{data:null});return t={...t,operation:e},"cache-and-network"===e.context.requestPolicy&&(t.stale=!0,d(i,e)),t}))(t.filter((e=>!c(e)&&s(e)))(u)),k=t.tap((e=>{var{operation:r}=e;if(r){var t=r.context.additionalTypenames||[];if("subscription"!==e.operation.kind&&(t=(e=>[...n(e,new Set)])(e.data).concat(t)),"mutation"===e.operation.kind||"subscription"===e.operation.kind){for(var s=new Set,u=0;u<t.length;u++){var c=t[u],l=a.get(c);for(var p of(l||a.set(c,l=new Set),l.values()))s.add(p);l.clear()}for(var k of s.values())o.has(k)&&(r=o.get(k).operation,o.delete(k),d(i,r))}else if("query"===r.kind&&e.data){o.set(r.key,e);for(var f=0;f<t.length;f++){var h=t[f],y=a.get(h);y||a.set(h,y=new Set),y.add(r.key)}}}}))(e(t.filter((e=>"query"!==e.kind||"cache-only"!==e.context.requestPolicy))(t.map((e=>e))(t.merge([t.map(l)(t.filter((e=>!c(e)&&!s(e)))(u)),t.filter((e=>c(e)))(u)])))));return t.merge([p,k])}},exports.composeExchanges=k,exports.createClient=v,exports.debugExchange=({forward:e})=>r=>e(r),exports.errorExchange=f,exports.fetchExchange=({forward:e})=>n=>{var i=t.mergeMap((e=>{var i=r.makeFetchBody(e),o=r.makeFetchURL(e,i),a=r.makeFetchOptions(e,i);return t.takeUntil(t.filter((r=>"teardown"===r.kind&&r.key===e.key))(n))(r.makeFetchSource(e,o,a))}))(t.filter((e=>"teardown"!==e.kind&&("subscription"!==e.kind||!!e.context.fetchSubscriptions)))(n)),o=e(t.filter((e=>"teardown"===e.kind||"subscription"===e.kind&&!e.context.fetchSubscriptions))(n));return t.merge([i,o])},exports.formatDocument=a,exports.gql=function(t){for(var n=new Map,i=[],o=[],a=Array.isArray(t)?t[0]:t||"",s=1;s<arguments.length;s++){var u=arguments[s];u&&u.definitions?o.push(u):a+=u,a+=arguments[0][s]}o.unshift(r.keyDocument(a));for(var c=0;c<o.length;c++)for(var l=0;l<o[c].definitions.length;l++){var d=o[c].definitions[l];if(d.kind===e.Kind.FRAGMENT_DEFINITION){var p=d.name.value,k=r.stringifyDocument(d);n.has(p)||(n.set(p,k),i.push(d))}else i.push(d)}return r.keyDocument({kind:e.Kind.DOCUMENT,definitions:i})},exports.makeOperation=s,exports.mapExchange=f,exports.ssrExchange=(e={})=>{var n=!!e.staleWhileRevalidate,i=!!e.includeExtensions,o={},a=[],s=e=>{a.push(e.operation.key),1===a.length&&Promise.resolve().then((()=>{for(var e;e=a.shift();)o[e]=null}))},u=({client:a,forward:u})=>c=>{var k=e&&"boolean"==typeof e.isClient?!!e.isClient:!a.suspense,f=u(t.map(l)(t.filter((e=>"teardown"===e.kind||!o[e.key]||!!o[e.key].hasNext||"network-only"===e.context.requestPolicy))(c))),h=t.map((e=>{var t=((e,t,n)=>({operation:e,data:t.data?JSON.parse(t.data):void 0,extensions:n&&t.extensions?JSON.parse(t.extensions):void 0,error:t.error?new r.CombinedError({networkError:t.error.networkError?new Error(t.error.networkError):void 0,graphQLErrors:t.error.graphQLErrors}):void 0,stale:!1,hasNext:!!t.hasNext}))(e,o[e.key],i);return n&&!p.has(e.key)&&(t.stale=!0,p.add(e.key),d(a,e)),{...t,operation:e}}))(t.filter((e=>"teardown"!==e.kind&&!!o[e.key]&&"network-only"!==e.context.requestPolicy))(c));return k?h=t.tap(s)(h):f=t.tap((e=>{var{operation:r}=e;if("mutation"!==r.kind){var t=((e,r)=>{var t={hasNext:e.hasNext};return void 0!==e.data&&(t.data=JSON.stringify(e.data)),r&&void 0!==e.extensions&&(t.extensions=JSON.stringify(e.extensions)),e.error&&(t.error={graphQLErrors:e.error.graphQLErrors.map((e=>e.path||e.extensions?{message:e.message,path:e.path,extensions:e.extensions}:e.message))},e.error.networkError&&(t.error.networkError=""+e.error.networkError)),t})(e,i);o[r.key]=t}}))(f),t.merge([f,h])};return u.restoreData=e=>{for(var r in e)null!==o[r]&&(o[r]=e[r])},u.extractData=()=>{var e={};for(var r in o)null!=o[r]&&(e[r]=o[r]);return e},e&&e.initialState&&u.restoreData(e.initialState),u},exports.subscriptionExchange=({forwardSubscription:e,enableAllOperations:n,isSubscriptionOperation:i})=>({client:o,forward:a})=>{var u=i||(e=>"subscription"===e.kind||!!n&&("query"===e.kind||"mutation"===e.kind));return n=>{var i=t.mergeMap((i=>{var{key:a}=i,u=t.filter((e=>"teardown"===e.kind&&e.key===a))(n);return t.takeUntil(u)((n=>{var i=e(r.makeFetchBody(n),n);return t.make((e=>{var t,a,u=!1;function c(t){e.next(a=a?r.mergeResultPatch(a,t):r.makeResult(n,t))}return Promise.resolve().then((()=>{u||(t=i.subscribe({next:c,error(t){Array.isArray(t)?c({errors:t}):e.next(r.makeErrorResult(n,t)),e.complete()},complete(){u||(u=!0,"subscription"===n.kind&&o.reexecuteOperation(s("teardown",n,n.context)),a&&a.hasNext&&c({hasNext:!1}),e.complete())}}))})),()=>{u=!0,t&&t.unsubscribe()}}))})(i))}))(t.filter((e=>"teardown"!==e.kind&&u(e)))(n)),c=a(t.filter((e=>"teardown"===e.kind||!u(e)))(n));return t.merge([i,c])}}; | ||
//# sourceMappingURL=urql-core.min.js.map |
{ | ||
"name": "@urql/core", | ||
"version": "5.0.6", | ||
"version": "5.0.7-canary-36a07165f45ab743e8938ee814378199fbc9cf89", | ||
"description": "The shared core for the highly customizable and versatile GraphQL client", | ||
@@ -56,3 +56,3 @@ "sideEffects": false, | ||
"scripts": { | ||
"test": "vitest --config ../../vitest.config.ts", | ||
"test": "vitest", | ||
"clean": "rimraf dist", | ||
@@ -59,0 +59,0 @@ "check": "tsc --noEmit", |
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
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
930132
5417
3