40 lines
3.9 KiB
JavaScript
40 lines
3.9 KiB
JavaScript
import {test} from 'node:test';
|
|
import assert from 'node:assert/strict';
|
|
import {claimLegacyCanvasEditing,createBrowserCanvasMigration} from '../../src/lib/browser-canvas-migration.ts';
|
|
import {canvasMigrationStorageKey} from '../../src/lib/canvas-migration.ts';
|
|
import {createRegistry,builtinComponents} from '../../src/lib/canvas-core/index.ts';
|
|
const id=n=>`10000000-0000-4000-8000-${String(n).padStart(12,'0')}`,scope={accountId:id(1),workspaceId:id(2)},root=id(3),registry=createRegistry(builtinComponents());
|
|
function fixture(){
|
|
const records=new Map(),held=new Map(),calls=[];
|
|
const storage={getItem:key=>records.get(key)??null,setItem:(key,value)=>records.set(key,value),removeItem:key=>records.delete(key)};
|
|
const locks={request(name,options,work){calls.push({name,options});return Promise.resolve().then(async()=>{
|
|
const state=held.get(name)??{shared:0,exclusive:false},granted=options.mode==='shared'?!state.exclusive:!state.exclusive&&!state.shared;
|
|
if(!granted)return work(null);
|
|
if(options.mode==='shared')state.shared++;else state.exclusive=true;held.set(name,state);
|
|
try{return await work({name,mode:options.mode});}finally{if(options.mode==='shared')state.shared--;else state.exclusive=false;if(!state.shared&&!state.exclusive)held.delete(name);}
|
|
});}};
|
|
const controller=new AbortController(),options={scope,registry,locks,storage,signal:controller.signal,isCurrentIdentity:()=>true};
|
|
return{records,held,calls,controller,options};
|
|
}
|
|
test('editable legacy views share a lease and exclude migration until every editor releases',async()=>{
|
|
const f=fixture(),one=await claimLegacyCanvasEditing({...f.options,canvasId:root}),two=await claimLegacyCanvasEditing({...f.options,canvasId:root});
|
|
const migration=createBrowserCanvasMigration(f.options);
|
|
await assert.rejects(()=>migration.resume(),/migration_busy/);await one.release();await assert.rejects(()=>migration.resume(),/migration_busy/);
|
|
await two.release();assert.equal((await migration.resume()).status,'idle');assert.equal(f.held.size,0);
|
|
assert.ok(f.calls.every(call=>call.name===canvasMigrationStorageKey(scope)+':editing'&&call.options.ifAvailable===true));
|
|
assert.deepEqual(f.calls.slice(0,2).map(call=>call.options.mode),['shared','shared']);assert.ok(f.calls.slice(2).every(call=>call.options.mode==='exclusive'));
|
|
});
|
|
test('pending migration blocks affected old views and corrupt records cannot enable editing',async()=>{
|
|
const f=fixture(),key=canvasMigrationStorageKey(scope),job={version:1,...scope,rootId:root,id:id(4),phase:'pending',body:JSON.stringify({protocol_version:2,request_id:id(4),expected_versions:{[root]:1}})};
|
|
f.storage=f.options.storage;f.storage.setItem(key,JSON.stringify(job));
|
|
await assert.rejects(()=>claimLegacyCanvasEditing({...f.options,canvasId:root}),/migration_response_unknown/);assert.equal(f.held.size,0);
|
|
const unrelated=await claimLegacyCanvasEditing({...f.options,canvasId:id(99)});await unrelated.release();
|
|
const saved=JSON.stringify({version:2,data:'retain'});f.storage.setItem(key,saved);
|
|
await assert.rejects(()=>claimLegacyCanvasEditing({...f.options,canvasId:root}),/migration_interpreter_unavailable/);assert.equal(f.storage.getItem(key),saved);assert.equal(f.held.size,0);
|
|
});
|
|
test('aborted or stale view lifetimes release leases and cannot acquire a late editing grant',async()=>{
|
|
const f=fixture(),lease=await claimLegacyCanvasEditing({...f.options,canvasId:root});f.controller.abort();await lease.release();assert.equal(f.held.size,0);await lease.release();
|
|
const g=fixture(),waiting=claimLegacyCanvasEditing({...g.options,canvasId:root});g.controller.abort();await assert.rejects(waiting,{name:'AbortError'});assert.equal(g.held.size,0);
|
|
const h=fixture();let current=true;const stale=claimLegacyCanvasEditing({...h.options,canvasId:root,isCurrentIdentity:()=>current});current=false;await assert.rejects(stale,/identity_changed/);assert.equal(h.held.size,0);
|
|
});
|