Vito
8bcde4fbe4
* feat(library): manage native editor drafts and recovery * fix(library): fence pair archive retries against restored storage * feat(library): add native recipe editor dialogs * fix(library): read archive counts through the editor controller * feat(library): reconcile editor saves and archived pairs Wire the concept's heading actions (Library Export and + New prompt, Images New prompt, history ← Prompt library, Edit metadata and pair Send to ComfyUI) and the Negative variants + Add negative and Show archived controls. Saves navigate or reconcile in place through createLibraryDetail.accept, invalidate cached shelf state by write generation, browse and restore archived pairs, and offer an explicit Library reload when storage was restored. * fix(library): refresh archived pairs and align editor outcomes * test(library): enforce approved native editor presentation * test(library): verify editor host and coverage compatibility Adds the rejected connected-target host assertion, pins the stock host listing at 80 cases, documents the native editor, and keeps Save/Archive focus after a failed write. * docs(testing): correct host case totals and cover archive focus * fix(library): fence editor reloads after restore and settle outcome copy
108 lines
8.8 KiB
JavaScript
108 lines
8.8 KiB
JavaScript
function validId(value) { return Number.isSafeInteger(value) && value > 0; }
|
|
function parent(value) {
|
|
return value && validId(value.id) && typeof value.text==='string';
|
|
}
|
|
function parameters(filters,limit) {
|
|
const query=new URLSearchParams({limit:String(limit)});
|
|
for(const key of ['text','category']) {
|
|
if(filters[key]!==undefined && typeof filters[key]!=='string') throw new TypeError('Invalid library filter');
|
|
if(filters[key]) query.set(key,filters[key]);
|
|
}
|
|
if(filters.tags!==undefined && (!Array.isArray(filters.tags) || filters.tags.some(tag=>typeof tag!=='string'))) throw new TypeError('Invalid library tags');
|
|
for(const tag of filters.tags || []) if(tag.trim()) query.append('tag',tag.trim());
|
|
const sort=filters.sort || 'newest';
|
|
if(!['newest','oldest','name','rating'].includes(sort)) throw new TypeError('Invalid library sort');
|
|
query.set('sort',sort);return query;
|
|
}
|
|
function validatePage(page,cursor) {
|
|
if(!page || !Array.isArray(page.items) || page.items.some(item=>!parent(item)) || !Number.isSafeInteger(page.total) || page.total<0 || typeof page.has_more!=='boolean' || !(page.next_cursor===null || (typeof page.next_cursor==='string' && page.next_cursor.length)) || page.has_more!==(page.next_cursor!==null) || (page.has_more && cursor===page.next_cursor)) throw new TypeError('Invalid library page');
|
|
}
|
|
export function createLibraryStream({api,onChange=()=>{},restore}) {
|
|
let state=Object.freeze({items:Object.freeze([]),total:0,cursor:null,hasMore:true,loading:false,error:null});
|
|
let query=parameters({},40),request,disposed=false,seen=new Set();
|
|
if(restore) {
|
|
query=parameters(restore.filters,40);const saved=restore.state;
|
|
validatePage({items:saved.items,total:saved.total,next_cursor:saved.cursor,has_more:saved.cursor!==null},null);
|
|
if(new Set(saved.items.map(item=>item.id)).size!==saved.items.length) throw new TypeError('Duplicate restored parent');
|
|
state=Object.freeze({...saved,items:Object.freeze(saved.items.map(item=>Object.freeze({...item}))),loading:false,error:null});seen=new Set(state.items.map(item=>item.id));
|
|
}
|
|
const emit=patch=>{state=Object.freeze({...state,...patch});onChange(state);};
|
|
async function loadMore() {
|
|
if(disposed || state.loading || !state.hasMore) return 0;
|
|
const current=request=new AbortController();const cursor=state.cursor;
|
|
emit({loading:true,error:null});const params=new URLSearchParams(query);if(cursor!==null) params.set('cursor',cursor);
|
|
try {
|
|
const page=await api.get(`/prompt_manager/library?${params}`,{signal:current.signal});
|
|
if(disposed || current!==request) return 0;
|
|
validatePage(page,cursor);const incoming=[];const added=new Set();
|
|
for(const item of page.items) if(!seen.has(item.id) && !added.has(item.id)) {added.add(item.id);incoming.push(Object.freeze({...item}));}
|
|
for(const value of added) seen.add(value);
|
|
request=null;emit({items:incoming.length?Object.freeze([...state.items,...incoming]):state.items,total:page.total,cursor:page.next_cursor,hasMore:page.has_more,loading:false,error:null});return incoming.length;
|
|
} catch(error) {if(!disposed && current===request) {request=null;emit({loading:false,error});}return 0;}
|
|
}
|
|
return {get state(){return state;},loadMore,async reset(filters={}) {
|
|
if(disposed) return 0;const next=parameters(filters,40);request?.abort();request=null;query=next;seen=new Set();emit({items:Object.freeze([]),total:0,cursor:null,hasMore:true,loading:false,error:null});return loadMore();
|
|
},dispose(){disposed=true;request?.abort();request=null;}};
|
|
}
|
|
/**
|
|
* Saved roles for one selection. A pair outside the bounded variant page is
|
|
* passed separately as `selectedPair` (an exact-ID read) and must belong to the
|
|
* same positive; it never enters `detail.variants`.
|
|
*/
|
|
export function libraryPromptRoles(detail,pairId=null,selectedPair=null) {
|
|
let variant=pairId===null?null:detail.variants.find(item=>item.id===pairId);
|
|
if(pairId!==null && !variant && selectedPair?.id===pairId) {
|
|
if(selectedPair.positive_prompt_id!==detail.positive.id || selectedPair.positive_text!==detail.positive.text || typeof selectedPair.negative_text!=='string') throw new TypeError('Saved negative variant belongs to another prompt');
|
|
variant=selectedPair;
|
|
}
|
|
if(pairId!==null && !variant) throw new TypeError('Saved negative variant is unavailable');
|
|
return {positive:{status:'resolved',text:detail.positive.text,source:'library'},negative:variant?{status:'resolved',text:variant.negative_text,source:'library'}:{status:'unresolved',text:null,source:null,message:'Choose a saved negative variant to inspect or send it.'}};
|
|
}
|
|
const ARCHIVE_SCOPES=new Set(['active','archived','all']);
|
|
export function createLibraryDetail({api,onChange,archive='active'}) {
|
|
if(!ARCHIVE_SCOPES.has(archive)) throw new TypeError('Invalid archive scope');
|
|
let request,disposed=false,id;
|
|
let state=Object.freeze({detail:null,loading:false,error:null,loadingVariants:false,variantsError:null});
|
|
const emit=patch=>{state=Object.freeze({...state,...patch});onChange(state);};
|
|
function validate(detail) {
|
|
if(!parent(detail.positive) || detail.positive.id!==id || !Array.isArray(detail.variants) || detail.variants.some(item=>!validId(item.id) || typeof item.negative_text!=='string' || typeof item.explicit_empty!=='boolean' || item.explicit_empty!==(item.negative_text==='')) || new Set(detail.variants.map(item=>item.id)).size!==detail.variants.length) throw new TypeError('Invalid prompt history');
|
|
const total=detail.variant_total ?? detail.variants.length,more=detail.variants_has_more ?? false,cursor=detail.variants_next_cursor ?? null;
|
|
if(!Number.isSafeInteger(total) || total<detail.variants.length || typeof more!=='boolean' || !(cursor===null || (typeof cursor==='string' && cursor.length>0)) || more!==(cursor!==null)) throw new TypeError('Invalid negative variant page');
|
|
return {...detail,variant_total:total,variants_has_more:more,variants_next_cursor:cursor};
|
|
}
|
|
async function fetch(append) {
|
|
if(disposed || (append && (!state.detail?.variants_has_more || state.loadingVariants || state.loading))) return 0;
|
|
request?.abort();const current=request=new AbortController();const previous=state.detail;const cursor=append?previous.variants_next_cursor:null;
|
|
emit(append?{loadingVariants:true,variantsError:null}:{detail:null,loading:true,error:null,loadingVariants:false,variantsError:null});
|
|
try {
|
|
if(!validId(id)) throw new TypeError('Invalid positive prompt');
|
|
const query=new URLSearchParams({variant_limit:'40'});if(archive!=='active') query.set('archive',archive);if(cursor) query.set('variant_cursor',cursor);
|
|
const raw=await api.get(`/prompt_manager/library/${id}?${query}`,{signal:current.signal});
|
|
if(disposed || request!==current) return 0;
|
|
const detail=validate(raw);
|
|
if(append) {
|
|
if(detail.positive.text!==previous.positive.text || (detail.variants_has_more && detail.variants_next_cursor===cursor)) throw new TypeError('Prompt history changed. Reload it before continuing.');
|
|
const variants=new Map(previous.variants.map(item=>[item.id,item]));for(const item of detail.variants) if(!variants.has(item.id)) variants.set(item.id,item);detail.variants=[...variants.values()];
|
|
}
|
|
request=null;emit({detail,loading:false,error:null,loadingVariants:false,variantsError:null});return detail.variants.length-(append?previous.variants.length:0);
|
|
} catch(error) {if(!disposed && request===current) {request=null;emit(append?{loadingVariants:false,variantsError:error}:{loading:false,error});}return 0;}
|
|
}
|
|
/** Same-parent reconciliation: a validated authoritative detail replaces the current one and supersedes any read. */
|
|
function accept(detail) {
|
|
if(disposed) throw new TypeError('Prompt history is disposed');
|
|
const next=validate(detail);
|
|
request?.abort();request=null;
|
|
emit({detail:next,loading:false,error:null,loadingVariants:false,variantsError:null});
|
|
}
|
|
return {get state(){return state;},load(value){id=value;return fetch(false);},loadMore(){return fetch(true);},accept,dispose(){disposed=true;request?.abort();}};
|
|
}
|
|
|
|
export function libraryWindow(count,columns,top,height,focused=-1) {
|
|
if(count<=120) return Array.from({length:count},(_,index)=>index);
|
|
const rows=Math.ceil(count/columns),first=Math.max(0,Math.floor(top/578)-2),last=Math.min(rows-1,Math.ceil((top+height)/578)+2);
|
|
const keep=new Set();
|
|
for(let row=first;row<=last;row++) keep.add(row);
|
|
if(focused>=0 && focused<count) keep.add(Math.floor(focused/columns));
|
|
return [...keep].sort((a,b)=>a-b).flatMap(row=>Array.from({length:columns},(_,column)=>row*columns+column).filter(index=>index<count));
|
|
}
|