40 lines
2.6 KiB
JavaScript
40 lines
2.6 KiB
JavaScript
import assert from 'node:assert/strict'
|
|
import test from 'node:test'
|
|
import { readFileSync } from 'node:fs'
|
|
import ts from 'typescript'
|
|
import * as vue from 'vue'
|
|
import * as pinia from 'pinia'
|
|
const source = readFileSync(new URL('./customsPending.ts', import.meta.url), 'utf8')
|
|
const code = ts.transpileModule(source, { compilerOptions: { module: ts.ModuleKind.CommonJS, target: ts.ScriptTarget.ES2022 } }).outputText
|
|
function deferred() { let resolve, reject; const promise = new Promise((a,b) => { resolve=a; reject=b }); return { promise, resolve, reject } }
|
|
function harness(t, read) {
|
|
const context=pinia.createPinia();pinia.setActivePinia(context);t.after(()=>pinia.disposePinia(context))
|
|
const deps={vue,pinia,'../api/customs':{getMerchantCustomsPendingCount:read}}, exports={}
|
|
new Function('require','exports',code)(id=>{assert.ok(id in deps,id);return deps[id]},exports)
|
|
return exports.useCustomsPendingStore()
|
|
}
|
|
test('does not request without a permitted identity; preserves counts while refreshing and accepts zero',async t=>{
|
|
const pending=deferred();let calls=0
|
|
const store=harness(t,()=>++calls===1?Promise.resolve(2):pending.promise)
|
|
await store.refresh();assert.equal(calls,0)
|
|
store.setScope('customer-a');await store.refresh();assert.equal(store.count,2)
|
|
const load=store.refresh();await store.refresh();assert.equal(calls,2);assert.equal(store.count,2)
|
|
pending.resolve(0);await load;assert.equal(store.count,0);assert.equal(store.loading,false)
|
|
})
|
|
test('logout, permission removal and account switches discard old in-flight responses',async t=>{
|
|
const pending=deferred();const store=harness(t,()=>pending.promise)
|
|
store.setScope('a');const load=store.refresh();store.setScope('')
|
|
pending.resolve(9);await load;assert.equal(store.count,null);assert.equal(store.error,'')
|
|
store.setScope('b');assert.equal(store.count,null)
|
|
})
|
|
test('successful mutation can force a newer refresh without being overwritten by an older query',async t=>{
|
|
const a=deferred(),b=deferred();let calls=0;const store=harness(t,()=>++calls===1?a.promise:b.promise)
|
|
store.setScope('a');const first=store.refresh();const second=store.refresh(true)
|
|
b.resolve(1);await second;a.resolve(2);await first;assert.equal(store.count,1)
|
|
})
|
|
test('failure is distinguishable from zero and retry restores authoritative count',async t=>{
|
|
let fail=true;const store=harness(t,()=>fail?Promise.reject(new Error('offline')):Promise.resolve(3))
|
|
store.setScope('a');await store.refresh();assert.equal(store.count,null);assert.notEqual(store.error,'')
|
|
fail=false;await store.refresh();assert.equal(store.count,3);assert.equal(store.error,'')
|
|
})
|