Mirror: The highly customizable and versatile GraphQL client with which you add on features like normalized caching as you grow.
fix(auth): Fix authExchange’s retry queue ignoring teardowns (#3235)
authored by
Phil Pluckthun
and committed by
GitHub
9bf55832
c356285e
+11
-13
+5
.changeset/weak-eagles-walk.md
+5
.changeset/weak-eagles-walk.md
+6
-13
exchanges/auth/src/authExchange.ts
+6
-13
exchanges/auth/src/authExchange.ts
···
306
306
return config ? config.addAuthToOperation(operation) : operation;
307
307
}
308
308
309
-
const teardownOps$ = pipe(
310
-
operations$,
311
-
filter(operation => operation.kind === 'teardown')
312
-
);
313
-
314
-
const pendingOps$ = pipe(
315
-
operations$,
316
-
filter(operation => operation.kind !== 'teardown')
317
-
);
318
-
319
309
const opsWithAuth$ = pipe(
320
-
merge([retries.source, pendingOps$]),
310
+
merge([retries.source, operations$]),
321
311
map(operation => {
322
-
if (
312
+
if (operation.kind === 'teardown') {
313
+
retryQueue.delete(operation.key);
314
+
return operation;
315
+
} else if (
323
316
operation.context._instance &&
324
317
bypassQueue.has(operation.context._instance)
325
318
) {
···
346
339
filter(Boolean)
347
340
) as Source<Operation>;
348
341
349
-
const result$ = pipe(merge([opsWithAuth$, teardownOps$]), forward);
342
+
const result$ = pipe(opsWithAuth$, forward);
350
343
351
344
return pipe(
352
345
result$,