@shopify/graphql-client - npm Package Compare versions

Comparing version 1.2.1 to 1.2.2

dist/graphql-client/constants.js

@@ -17,3 +17,3 @@ 'use strict';
 // This is value is replaced with package.json version during rollup build process
-const DEFAULT_CLIENT_VERSION = '1.2.1';
+const DEFAULT_CLIENT_VERSION = '1.2.2';
 const RETRY_WAIT_TIME = 1000;
@@ -20,0 +20,0 @@ const RETRIABLE_STATUS_CODES = [429, 503];

dist/graphql-client/graphql-client.js

@@ -246,3 +246,3 @@ 'use strict';
     if (!response.body?.getReader &&
-        !response.body[Symbol.asyncIterator]) {
+        !response.body?.[Symbol.asyncIterator]) {
         throw new Error('API multipart response did not return an iterable body', {
@@ -249,0 +249,0 @@ cause: response,

dist/umd/graphql-client.js

@@ -1,2 +0,2 @@
-/*! shopify/graphql-client@1.2.1 -- Copyright (c) 2023-present, Shopify Inc. -- license (MIT): https://github.com/Shopify/shopify-app-js/blob/main/LICENSE.md */
+/*! shopify/graphql-client@1.2.2 -- Copyright (c) 2023-present, Shopify Inc. -- license (MIT): https://github.com/Shopify/shopify-app-js/blob/main/LICENSE.md */
 (function (global, factory) {
@@ -22,3 +22,3 @@ typeof exports === 'object' && typeof module !== 'undefined' ? factory(exports) :
     // This is value is replaced with package.json version during rollup build process
-    const DEFAULT_CLIENT_VERSION = '1.2.1';
+    const DEFAULT_CLIENT_VERSION = '1.2.2';
     const RETRY_WAIT_TIME = 1000;
@@ -375,3 +375,3 @@ const RETRIABLE_STATUS_CODES = [429, 503];
         if (!response.body?.getReader &&
-            !response.body[Symbol.asyncIterator]) {
+            !response.body?.[Symbol.asyncIterator]) {
             throw new Error('API multipart response did not return an iterable body', {
@@ -378,0 +378,0 @@ cause: response,

dist/umd/graphql-client.min.js

@@ -1,3 +0,3 @@
-/*! shopify/graphql-client@1.2.1 -- Copyright (c) 2023-present, Shopify Inc. -- license (MIT): https://github.com/Shopify/shopify-app-js/blob/main/LICENSE.md */
-!function(e,r){"object"==typeof exports&&"undefined"!=typeof module?r(exports):"function"==typeof define&&define.amd?define(["exports"],r):r((e="undefined"!=typeof globalThis?globalThis:e||self).ShopifyGraphQLClient={})}(this,(function(e){"use strict";const r="GraphQL Client",t=0,n=3,s="An error occurred while fetching from the API. Review 'graphQLErrors' for details.",o="Response returned unexpected Content-Type:",a="An unknown error has occurred. The API did not return a data object or any errors in its response.",i={json:"application/json",multipart:"multipart/mixed"},c="X-SDK-Variant",u="X-SDK-Version",d="shopify-graphql-client",l="1.2.1",f=1e3,h=[429,503],y=/@(defer)\b/i,p=/boundary="?([^=";]+)"?/i,m="\r\n\r\n";function w(e,t=r){return e.startsWith(`${t}`)?e:`${t}: ${e}`}function g(e){return e instanceof Error?e.message:JSON.stringify(e)}function b(e){return e instanceof Error&&e.cause?e.cause:void 0}function x(e){return e.flatMap((({errors:e})=>e??[]))}function E({client:e,retries:r}){if(void 0!==r&&("number"!=typeof r||r<t||r>n))throw new Error(`${e}: The provided "retries" value (${r}) is invalid - it cannot be less than ${t} or greater than ${n}`)}function S(e,r){return r&&("object"!=typeof r||Array.isArray(r)||"object"==typeof r&&Object.keys(r).length>0)?{[e]:r}:{}}function A(e,r){if(0===e.length)return r;const t={[e.pop()]:r};return 0===e.length?t:A(e,t)}function T(e,r){return Object.keys(r||{}).reduce(((t,n)=>("object"==typeof r[n]||Array.isArray(r[n]))&&e[n]?(t[n]=T(e[n],r[n]),t):(t[n]=r[n],t)),Array.isArray(e)?[...e]:{...e})}function $([e,...r]){return r.reduce(T,{...e})}function j({clientLogger:e,customFetchApi:t=fetch,client:n=r,defaultRetryWaitTime:s=f,retriableCodes:o=h}){const a=async(r,i,c)=>{const u=i+1,d=c+1;let l;try{if(l=await t(...r),e({type:"HTTP-Response",content:{requestParams:r,response:l}}),!l.ok&&o.includes(l.status)&&u<=d)throw new Error;return l}catch(t){if(u<=d){const t=l?.headers.get("Retry-After");return await async function(e){return new Promise((r=>setTimeout(r,e)))}(t?parseInt(t,10):s),e({type:"HTTP-Retry",content:{requestParams:r,lastResponse:l,retryAttempt:i,maxRetries:c}}),a(r,u,c)}throw new Error(w(`${c>0?`Attempted maximum number of ${c} network retries. Last message - `:""}${g(t)}`,n))}};return a}async function k(e){const{errors:r,data:t,extensions:n}=await e.json();return{...S("data",t),...S("extensions",n),headers:e.headers,...r||!t?{errors:{networkStatusCode:e.status,message:w(r?s:a),...S("graphQLErrors",r),response:e}}:{}}}function R(e){return e.map((e=>{try{return JSON.parse(e)}catch(e){throw new Error(`Error in parsing multipart response - ${g(e)}`)}})).map((e=>{const{data:r,incremental:t,hasNext:n,extensions:s,errors:o}=e;if(!t)return{data:r||{},...S("errors",o),...S("extensions",s),hasNext:n};const a=t.map((({data:e,path:r,errors:t})=>({data:e&&r?A(r,e):{},...S("errors",t)})));return{data:1===a.length?a[0].data:$([...a.map((({data:e})=>e))]),...S("errors",x(a)),hasNext:n}}))}function I(e,r){if(e.length>0)throw new Error(s,{cause:{graphQLErrors:e}});if(0===Object.keys(r).length)throw new Error(a)}e.createGraphQLClient=function({headers:e,url:t,customFetchApi:n=fetch,retries:s=0,logger:a}){E({client:r,retries:s});const h={headers:e,url:t,retries:s},A=function(e){return r=>{e&&e(r)}}(a),T=function(e,{url:t,headers:n,retries:s}){return async(o,a={})=>{const{variables:i,headers:f,url:h,retries:y,signal:p}=a,m=JSON.stringify({query:o,variables:i});E({client:r,retries:y});const w=Object.entries({...n,...f}).reduce(((e,[r,t])=>(e[r]=Array.isArray(t)?t.join(", "):t.toString(),e)),{});w[c]||w[u]||(w[c]=d,w[u]=l);return e([h??t,{method:"POST",headers:w,body:m,signal:p}],1,y??s)}}(j({customFetchApi:n,clientLogger:A,defaultRetryWaitTime:f}),h),L=function(e){return async(...r)=>{if(y.test(r[0]))throw new Error(w("This operation will result in a streamable response - use requestStream() instead."));try{const t=await e(...r),{status:n,statusText:s}=t,a=t.headers.get("content-type")||"";return t.ok?a.includes(i.json)?k(t):{errors:{networkStatusCode:n,message:w(`${o} ${a}`),response:t}}:{errors:{networkStatusCode:n,message:w(s),response:t}}}catch(e){return{errors:{message:g(e)}}}}}(T),N=function(e){return async(...r)=>{if(!y.test(r[0]))throw new Error(w("This operation does not result in a streamable response - use request() instead."));try{const t=await e(...r),{statusText:n}=t;if(!t.ok)throw new Error(n,{cause:t});const s=t.headers.get("content-type")||"";switch(!0){case s.includes(i.json):return function(e){return{async*[Symbol.asyncIterator](){const r=await k(e);yield{...r,hasNext:!1}}}}(t);case s.includes(i.multipart):return function(e,r){const t=(r??"").match(p),n=`--${t?t[1]:"-"}`;if(!e.body?.getReader&&!e.body[Symbol.asyncIterator])throw new Error("API multipart response did not return an iterable body",{cause:e});const s=async function*(e){const r=new TextDecoder;if(e.body[Symbol.asyncIterator])for await(const t of e.body)yield r.decode(t);else{const t=e.body.getReader();let n;try{for(;!(n=await t.read()).done;)yield r.decode(n.value)}finally{t.cancel()}}}(e);let o,a={};return{async*[Symbol.asyncIterator](){try{let e=!0;for await(const r of function(e,r){return{async*[Symbol.asyncIterator](){try{let t="";for await(const n of e)if(t+=n,t.indexOf(r)>-1){const e=t.lastIndexOf(r),n=t.slice(0,e).split(r).filter((e=>e.trim().length>0)).map((e=>e.slice(e.indexOf(m)+m.length).trim()));n.length>0&&(yield n),t=t.slice(e+r.length),"--"===t.trim()&&(t="")}}catch(e){throw new Error(`Error occured while processing stream payload - ${g(e)}`)}}}}(s,n)){const t=R(r);o=t.find((e=>e.extensions))?.extensions??o;const n=x(t);a=$([a,...t.map((({data:e})=>e))]),e=t.slice(-1)[0].hasNext,I(n,a),yield{...S("data",a),...S("extensions",o),hasNext:e}}if(e)throw new Error("Response stream terminated unexpectedly")}catch(r){const t=b(r);yield{...S("data",a),...S("extensions",o),errors:{message:w(g(r)),networkStatusCode:e.status,...S("graphQLErrors",t?.graphQLErrors),response:e},hasNext:!1}}}}}(t,s);default:throw new Error(`${o} ${s}`,{cause:t})}}catch(e){return{async*[Symbol.asyncIterator](){const r=b(e);yield{errors:{message:w(g(e)),...S("networkStatusCode",r?.status),...S("response",r)},hasNext:!1}}}}}}(T);return{config:h,fetch:T,request:L,requestStream:N}}}));
+/*! shopify/graphql-client@1.2.2 -- Copyright (c) 2023-present, Shopify Inc. -- license (MIT): https://github.com/Shopify/shopify-app-js/blob/main/LICENSE.md */
+!function(e,r){"object"==typeof exports&&"undefined"!=typeof module?r(exports):"function"==typeof define&&define.amd?define(["exports"],r):r((e="undefined"!=typeof globalThis?globalThis:e||self).ShopifyGraphQLClient={})}(this,(function(e){"use strict";const r="GraphQL Client",t="An error occurred while fetching from the API. Review 'graphQLErrors' for details.",n="Response returned unexpected Content-Type:",s="An unknown error has occurred. The API did not return a data object or any errors in its response.",o="application/json",a="multipart/mixed",i="X-SDK-Variant",c="X-SDK-Version",u="shopify-graphql-client",d="1.2.2",l=[429,503],f=/@(defer)\b/i,y=/boundary="?([^=";]+)"?/i,h="\r\n\r\n";function p(e,t=r){return e.startsWith(`${t}`)?e:`${t}: ${e}`}function m(e){return e instanceof Error?e.message:JSON.stringify(e)}function w(e){return e instanceof Error&&e.cause?e.cause:void 0}function g(e){return e.flatMap((({errors:e})=>e??[]))}function b({client:e,retries:r}){if(void 0!==r&&("number"!=typeof r||r<0||r>3))throw new Error(`${e}: The provided "retries" value (${r}) is invalid - it cannot be less than 0 or greater than 3`)}function x(e,r){return r&&("object"!=typeof r||Array.isArray(r)||"object"==typeof r&&Object.keys(r).length>0)?{[e]:r}:{}}function E(e,r){if(0===e.length)return r;const t=e.pop(),n={[t]:r};return 0===e.length?n:E(e,n)}function S(e,r){return Object.keys(r||{}).reduce(((t,n)=>("object"==typeof r[n]||Array.isArray(r[n]))&&e[n]?(t[n]=S(e[n],r[n]),t):(t[n]=r[n],t)),Array.isArray(e)?[...e]:{...e})}function A([e,...r]){return r.reduce(S,{...e})}function T({clientLogger:e,customFetchApi:t=fetch,client:n=r,defaultRetryWaitTime:s=1e3,retriableCodes:o=l}){const a=async(r,i,c)=>{const u=i+1,d=c+1;let l;try{if(l=await t(...r),e({type:"HTTP-Response",content:{requestParams:r,response:l}}),!l.ok&&o.includes(l.status)&&u<=d)throw new Error;return l}catch(t){if(u<=d){const t=l?.headers.get("Retry-After");return await async function(e){return new Promise((r=>setTimeout(r,e)))}(t?parseInt(t,10):s),e({type:"HTTP-Retry",content:{requestParams:r,lastResponse:l,retryAttempt:i,maxRetries:c}}),a(r,u,c)}throw new Error(p(`${c>0?`Attempted maximum number of ${c} network retries. Last message - `:""}${m(t)}`,n))}};return a}async function $(e){const{errors:r,data:n,extensions:o}=await e.json();return{...x("data",n),...x("extensions",o),headers:e.headers,...r||!n?{errors:{networkStatusCode:e.status,message:p(r?t:s),...x("graphQLErrors",r),response:e}}:{}}}function k(e){return e.map((e=>{try{return JSON.parse(e)}catch(e){throw new Error(`Error in parsing multipart response - ${m(e)}`)}})).map((e=>{const{data:r,incremental:t,hasNext:n,extensions:s,errors:o}=e;if(!t)return{data:r||{},...x("errors",o),...x("extensions",s),hasNext:n};const a=t.map((({data:e,path:r,errors:t})=>({data:e&&r?E(r,e):{},...x("errors",t)})));return{data:1===a.length?a[0].data:A([...a.map((({data:e})=>e))]),...x("errors",g(a)),hasNext:n}}))}function j(e,r){if(e.length>0)throw new Error(t,{cause:{graphQLErrors:e}});if(0===Object.keys(r).length)throw new Error(s)}e.createGraphQLClient=function({headers:e,url:t,customFetchApi:s=fetch,retries:l=0,logger:E}){b({client:r,retries:l});const S={headers:e,url:t,retries:l},R=function(e){return r=>{e&&e(r)}}(E),I=function(e,{url:t,headers:n,retries:s}){return async(o,a={})=>{const{variables:l,headers:f,url:y,retries:h,signal:p}=a,m=JSON.stringify({query:o,variables:l});b({client:r,retries:h});const w=Object.entries({...n,...f}).reduce(((e,[r,t])=>(e[r]=Array.isArray(t)?t.join(", "):t.toString(),e)),{});w[i]||w[c]||(w[i]=u,w[c]=d);return e([y??t,{method:"POST",headers:w,body:m,signal:p}],1,h??s)}}(T({customFetchApi:s,clientLogger:R,defaultRetryWaitTime:1e3}),S),L=function(e){return async(...r)=>{if(f.test(r[0]))throw new Error(p("This operation will result in a streamable response - use requestStream() instead."));try{const t=await e(...r),{status:s,statusText:a}=t,i=t.headers.get("content-type")||"";return t.ok?i.includes(o)?$(t):{errors:{networkStatusCode:s,message:p(`${n} ${i}`),response:t}}:{errors:{networkStatusCode:s,message:p(a),response:t}}}catch(e){return{errors:{message:m(e)}}}}}(I),N=function(e){return async(...r)=>{if(!f.test(r[0]))throw new Error(p("This operation does not result in a streamable response - use request() instead."));try{const t=await e(...r),{statusText:s}=t;if(!t.ok)throw new Error(s,{cause:t});const i=t.headers.get("content-type")||"";switch(!0){case i.includes(o):return function(e){return{async*[Symbol.asyncIterator](){const r=await $(e);yield{...r,hasNext:!1}}}}(t);case i.includes(a):return function(e,r){const t=(r??"").match(y),n=`--${t?t[1]:"-"}`;if(!e.body?.getReader&&!e.body?.[Symbol.asyncIterator])throw new Error("API multipart response did not return an iterable body",{cause:e});const s=async function*(e){const r=new TextDecoder;if(e.body[Symbol.asyncIterator])for await(const t of e.body)yield r.decode(t);else{const t=e.body.getReader();let n;try{for(;!(n=await t.read()).done;)yield r.decode(n.value)}finally{t.cancel()}}}(e);let o,a={};return{async*[Symbol.asyncIterator](){try{let e=!0;for await(const r of function(e,r){return{async*[Symbol.asyncIterator](){try{let t="";for await(const n of e)if(t+=n,t.indexOf(r)>-1){const e=t.lastIndexOf(r),n=t.slice(0,e).split(r).filter((e=>e.trim().length>0)).map((e=>e.slice(e.indexOf(h)+4).trim()));n.length>0&&(yield n),t=t.slice(e+r.length),"--"===t.trim()&&(t="")}}catch(e){throw new Error(`Error occured while processing stream payload - ${m(e)}`)}}}}(s,n)){const t=k(r);o=t.find((e=>e.extensions))?.extensions??o;const n=g(t);a=A([a,...t.map((({data:e})=>e))]),e=t.slice(-1)[0].hasNext,j(n,a),yield{...x("data",a),...x("extensions",o),hasNext:e}}if(e)throw new Error("Response stream terminated unexpectedly")}catch(r){const t=w(r);yield{...x("data",a),...x("extensions",o),errors:{message:p(m(r)),networkStatusCode:e.status,...x("graphQLErrors",t?.graphQLErrors),response:e},hasNext:!1}}}}}(t,i);default:throw new Error(`${n} ${i}`,{cause:t})}}catch(e){return{async*[Symbol.asyncIterator](){const r=w(e);yield{errors:{message:p(m(e)),...x("networkStatusCode",r?.status),...x("response",r)},hasNext:!1}}}}}}(I);return{config:S,fetch:I,request:L,requestStream:N}}}));
 //# sourceMappingURL=graphql-client.min.js.map

package.json

 {
   "name": "@shopify/graphql-client",
-  "version": "1.2.1",
+  "version": "1.2.2",
   "description": "Shopify GraphQL Client - A lightweight generic GraphQL JS client to interact with Shopify GraphQL APIs",
@@ -80,3 +80,3 @@ "repository": {
     "regenerator-runtime": "^0.14.1",
-    "web-streams-polyfill": "^4.0.0"
+    "web-streams-polyfill": "^4.1.0"
   },
@@ -83,0 +83,0 @@ "bugs": {

No alert changes

Worsened metrics

Total package byte prevSize

233733

decreased by-2.84%

No dependency changes