@urql/exchange-auth - npm Package Compare versions

Comparing version 2.1.4 to 2.1.5-canary-657bd0c6

CHANGELOG.md

 # Changelog
 
+## 2.1.5-canary-657bd0c6
+
+### Patch Changes
+
+- Handle `refreshAuth` rejections and pass the resulting error on to `OperationResult`s on the authentication queue
+  Submitted by [@kitten](https://github.com/kitten) (See [#3307](https://github.com/urql-graphql/urql/pull/3307))
+- Updated dependencies (See [#3298](https://github.com/urql-graphql/urql/pull/3298), [#3288](https://github.com/urql-graphql/urql/pull/3288), and [#3299](https://github.com/urql-graphql/urql/pull/3299))
+  - @urql/core@4.0.11-canary-657bd0c6
+
 ## 2.1.4
@@ -4,0 +13,0 @@

dist/urql-exchange-auth.js

@@ -71,5 +71,5 @@ Object.defineProperty(exports, '__esModule', { value: true });
     var retries = wonka.makeSubject();
+    var errors = wonka.makeSubject();
     var retryQueue = new Map();
-    function flushQueue(_config) {
-      if (_config) config = _config;
+    function flushQueue() {
       authPromise = undefined;
@@ -80,2 +80,10 @@ var queue = retryQueue;
     }
+    function errorQueue(error) {
+      authPromise = undefined;
+      var queue = retryQueue;
+      retryQueue = new Map();
+      queue.forEach(operation => {
+        errors.next(core.makeErrorResult(operation, error));
+      });
+    }
     var authPromise;
@@ -106,3 +114,6 @@ var config = null;
         }
-      })).then(flushQueue);
+      })).then(_config => {
+        if (_config) config = _config;
+        flushQueue();
+      });
       function refreshAuth(operation) {
@@ -114,3 +125,3 @@ // add to retry queue to try again later
         if (config && !authPromise) {
-          authPromise = config.refreshAuth().finally(flushQueue);
+          authPromise = config.refreshAuth().then(flushQueue).catch(errorQueue);
         }
@@ -147,3 +158,3 @@ }
       var result$ = forward(opsWithAuth$);
-      return wonka.filter(result => {
+      return wonka.merge([errors.source, wonka.filter(result => {
         if (!bypassQueue.has(result.operation.context._instance) && result.error && didAuthError(result) && !result.operation.context.authAttempt) {
@@ -157,3 +168,3 @@ refreshAuth(result.operation);
         return true;
-      })(result$);
+      })(result$)]);
     };
@@ -160,0 +171,0 @@ };

dist/urql-exchange-auth.min.js

@@ -1,2 +0,2 @@
-Object.defineProperty(exports,"__esModule",{value:!0});var t=require("wonka"),e=require("@urql/core"),n=(t,n)=>e.makeOperation(t.kind,t,{...t.context,authAttempt:n});exports.authExchange=function(r){return({client:o,forward:a})=>{var i,c=new Set,u=t.makeSubject(),s=new Map;function p(t){t&&(h=t),i=void 0;var e=s;s=new Map,e.forEach(u.next)}var h=null;return l=>{function d(t){s.set(t.key,n(t,!0)),h&&!i&&(i=h.refreshAuth().finally(p))}function x(t){return h?h.addAuthToOperation(t):t}i=Promise.resolve().then((()=>r({mutate(n,r,a){var i=o.createRequestOperation("mutation",e.createRequest(n,r),a);return t.toPromise(t.take(1)(t.filter((t=>t.operation.key===i.key&&i.context._instance===t.operation.context._instance))(t.onStart((()=>{var t=x(i);c.add(t.context._instance),u.next(t)}))(k))))},appendHeaders(t,n){var r="function"==typeof t.context.fetchOptions?t.context.fetchOptions():t.context.fetchOptions||{};return e.makeOperation(t.kind,t,{...t.context,fetchOptions:{...r,headers:{...r.headers,...n}}})}}))).then(p);var f=t.filter(Boolean)(t.map((t=>"teardown"===t.kind?(s.delete(t.key),t):t.context._instance&&c.has(t.context._instance)?t:t.context.authAttempt?x(t):i?(s.has(t.key)||s.set(t.key,n(t,!1)),null):function(t){return!t.context.authAttempt&&h&&h.willAuthError&&h.willAuthError(t)}(t)?(d(t),null):x(n(t,!1))))(t.merge([u.source,l]))),k=a(f);return t.filter((t=>!c.has(t.operation.context._instance)&&t.error&&function(t){return h&&h.didAuthError&&h.didAuthError(t.error,t.operation)}(t)&&!t.operation.context.authAttempt?(d(t.operation),!1):(c.has(t.operation.context._instance)&&c.delete(t.operation.context._instance),!0)))(k)}}};
+Object.defineProperty(exports,"__esModule",{value:!0});var e=require("wonka"),t=require("@urql/core"),n=(e,n)=>t.makeOperation(e.kind,e,{...e.context,authAttempt:n});exports.authExchange=function(r){return({client:o,forward:a})=>{var i,c=new Set,u=e.makeSubject(),s=e.makeSubject(),p=new Map;function h(){i=void 0;var e=p;p=new Map,e.forEach(u.next)}function d(e){i=void 0;var n=p;p=new Map,n.forEach((n=>{s.next(t.makeErrorResult(n,e))}))}var l=null;return x=>{function f(e){p.set(e.key,n(e,!0)),l&&!i&&(i=l.refreshAuth().then(h).catch(d))}function k(e){return l?l.addAuthToOperation(e):e}i=Promise.resolve().then((()=>r({mutate(n,r,a){var i=o.createRequestOperation("mutation",t.createRequest(n,r),a);return e.toPromise(e.take(1)(e.filter((e=>e.operation.key===i.key&&i.context._instance===e.operation.context._instance))(e.onStart((()=>{var e=k(i);c.add(e.context._instance),u.next(e)}))(v))))},appendHeaders(e,n){var r="function"==typeof e.context.fetchOptions?e.context.fetchOptions():e.context.fetchOptions||{};return t.makeOperation(e.kind,e,{...e.context,fetchOptions:{...r,headers:{...r.headers,...n}}})}}))).then((e=>{e&&(l=e),h()}));var m=e.filter(Boolean)(e.map((e=>"teardown"===e.kind?(p.delete(e.key),e):e.context._instance&&c.has(e.context._instance)?e:e.context.authAttempt?k(e):i?(p.has(e.key)||p.set(e.key,n(e,!1)),null):function(e){return!e.context.authAttempt&&l&&l.willAuthError&&l.willAuthError(e)}(e)?(f(e),null):k(n(e,!1))))(e.merge([u.source,x]))),v=a(m);return e.merge([s.source,e.filter((e=>!c.has(e.operation.context._instance)&&e.error&&function(e){return l&&l.didAuthError&&l.didAuthError(e.error,e.operation)}(e)&&!e.operation.context.authAttempt?(f(e.operation),!1):(c.has(e.operation.context._instance)&&c.delete(e.operation.context._instance),!0)))(v)])}}};
 //# sourceMappingURL=urql-exchange-auth.min.js.map

package.json

 {
   "name": "@urql/exchange-auth",
-  "version": "2.1.4",
+  "version": "2.1.5-canary-657bd0c6",
   "description": "An exchange for managing authentication and token refresh in urql",
@@ -9,2 +9,3 @@ "sideEffects": false,
   "license": "MIT",
+  "author": "urql GraphQL Contributors",
   "repository": {
@@ -43,3 +44,3 @@ "type": "git",
   "dependencies": {
-    "@urql/core": ">=4.0.0",
+    "@urql/core": "4.0.11-canary-657bd0c6",
     "wonka": "^6.3.2"
@@ -49,3 +50,3 @@ },
     "graphql": "^16.0.0",
-    "@urql/core": "4.0.8"
+    "@urql/core": "4.0.11-canary-657bd0c6"
   },
@@ -52,0 +53,0 @@ "publishConfig": {

New alerts

No v1

Quality

Package is not semver >=1. This means it is not stable and does not support ^ ranges.

Found 1 instance in 1 package

Fixed alerts

No contributors or author data

Maintenance

Package does not specify a list of contributors or an author in package.json.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

109047

increased by4.29%

Lines of code

437

increased by5.3%

Number of low maintenance alerts

1

decreased by-50%

Worsened metrics

Number of low quality alerts

2

increased by100%

Dependency changes

• + Added@urql/core@4.0.11-canary-657bd0c6(transitive)

• - Removed@urql/core@5.1.0(transitive)

• Updated@urql/core@4.0.11-canary-657bd0c6