mizorewwwandClaude Opus 5.5
2249b1fd1a
Stored queue results never change, but terminal failures were saved as 502 and the page retried every 5xx, so users saw "reconnecting" indefinitely. Pending and expired-link outcomes now answer 409, any other stored 5xx is normalized to 422 (also for restored snapshots), lock failures are retried by the worker, and the page reconnects only on network errors, 429, 502, 503 and 504. Co-Authored-By: Claude Opus 5.5 <noreply@anthropic.com>
37 lines
2.2 KiB
JavaScript
37 lines
2.2 KiB
JavaScript
import test from 'node:test';
|
|
import assert from 'node:assert/strict';
|
|
import { readQueueWithReconnect } from '../src/queueReconnect.ts';
|
|
|
|
test('reconnect keeps reading the original ticket across backend restart', async () => {
|
|
const calls=[];
|
|
const replies=[new Error('EOF'),{ok:false,status:503,data:{}},{ok:true,status:202,data:{ticket:'original',ahead:12}}];
|
|
const result=await readQueueWithReconnect(async()=>{calls.push('original');const next=replies.shift();if(next instanceof Error)throw next;return next},new AbortController().signal,async()=>{});
|
|
assert.equal(result.data.ticket,'original');assert.deepEqual(calls,['original','original','original']);
|
|
});
|
|
test('expired tickets and final errors are not endlessly retried',async()=>{
|
|
let calls=0;
|
|
const result=await readQueueWithReconnect(async()=>{calls++;return {ok:false,status:404,data:{}}},new AbortController().signal,async()=>{});
|
|
assert.equal(result.status,404);assert.equal(calls,1);
|
|
});
|
|
test('retry timeout and cancellation stop reconnect',async()=>{
|
|
let now=0;
|
|
const result=await readQueueWithReconnect(async()=>({ok:false,status:503,data:{}}),new AbortController().signal,async()=>{now+=30000},()=>now,{maxWaitMs:60000});
|
|
assert.equal(result.status,503);assert.equal(now,60000);
|
|
const controller=new AbortController();controller.abort();
|
|
await assert.rejects(readQueueWithReconnect(async()=>{throw Error('must not run')},controller.signal),{name:'AbortError'});
|
|
});
|
|
|
|
test('the normal queue keeps its ticket after more than a minute of network errors',async()=>{
|
|
let elapsed=0,calls=0,retries=0;
|
|
const result=await readQueueWithReconnect(async()=>{calls++;if(calls<5)throw new TypeError('Failed to fetch');return {ok:true,status:202,data:{ticket:'original'}}},new AbortController().signal,async()=>{elapsed+=30000},()=>elapsed,{onRetry:()=>{retries++}});
|
|
assert.equal(result.data.ticket,'original');assert.equal(retries,4);assert.equal(elapsed,120000);
|
|
});
|
|
|
|
test('stored business failures are final, not reconnect loops',async()=>{
|
|
for(const status of [409,422,500]){
|
|
let calls=0;
|
|
const result=await readQueueWithReconnect(async()=>{calls++;return {ok:false,status,data:{message:'final'}}},new AbortController().signal,async()=>{});
|
|
assert.equal(result.status,status);assert.equal(calls,1);
|
|
}
|
|
});
|