boos
e0a5f57793
Vendor the rebranded BoosAPI Desktop client (Tauri + Vue) into metapi as a monorepo subdirectory under desktop/. Source only — node_modules, dist, Cargo target and the upstream .git history are excluded. desktop/ keeps its own independent Cargo workspace (desktop/src-tauri with crates/*); it is not part of the backend boosapi crate, so a `cargo check` at the metapi root still compiles only the backend. Build the desktop app from desktop/src-tauri per desktop/README.md. Note: app icons are still placeholder assets pending the final BoosAPI logo. The updater signing keys live outside the repo and are not included.
85 lines
2.8 KiB
TypeScript
85 lines
2.8 KiB
TypeScript
import { afterEach, beforeEach, describe, expect, it } from 'vitest'
|
|
import {
|
|
clearKaTeXWorker,
|
|
renderKaTeXInWorker,
|
|
setKaTeXWorker,
|
|
setKaTeXWorkerMaxConcurrency,
|
|
WORKER_BUSY_CODE,
|
|
} from '../../src/workers/katexWorkerClient'
|
|
|
|
// A minimal controllable fake Worker for tests
|
|
class FakeWorker {
|
|
onmessage: ((ev: MessageEvent<any>) => any) | null = null
|
|
onerror: ((ev: ErrorEvent) => any) | null = null
|
|
private inbox: Array<{ id: string, content: string, displayMode: boolean }> = []
|
|
|
|
postMessage(data: { id: string, content: string, displayMode: boolean }) {
|
|
// store request, do not auto-resolve
|
|
this.inbox.push({ id: data.id, content: data.content, displayMode: data.displayMode })
|
|
}
|
|
|
|
// Resolve the oldest pending request
|
|
resolveNext(htmlFactory?: (content: string) => string) {
|
|
const msg = this.inbox.shift()
|
|
if (!msg)
|
|
return false
|
|
const html = htmlFactory ? htmlFactory(msg.content) : `<span>${msg.content}</span>`
|
|
this.onmessage?.({
|
|
data: { id: msg.id, html, content: msg.content, displayMode: msg.displayMode },
|
|
} as any)
|
|
return true
|
|
}
|
|
|
|
// For completeness
|
|
terminate() {}
|
|
}
|
|
|
|
describe('katexWorkerClient concurrency cap', () => {
|
|
let worker: FakeWorker
|
|
|
|
beforeEach(() => {
|
|
worker = new FakeWorker()
|
|
setKaTeXWorker(worker as unknown as Worker)
|
|
setKaTeXWorkerMaxConcurrency(5)
|
|
})
|
|
|
|
afterEach(() => {
|
|
clearKaTeXWorker()
|
|
})
|
|
|
|
it('6th concurrent render rejects with WORKER_BUSY; after freeing one, retry succeeds', async () => {
|
|
const contents = ['a', 'b', 'c', 'd', 'e', 'f']
|
|
|
|
// Fire 5 in-flight renders that will remain pending
|
|
const p1 = renderKaTeXInWorker(contents[0], true, 2000)
|
|
const p2 = renderKaTeXInWorker(contents[1], true, 2000)
|
|
const p3 = renderKaTeXInWorker(contents[2], true, 2000)
|
|
const p4 = renderKaTeXInWorker(contents[3], true, 2000)
|
|
const p5 = renderKaTeXInWorker(contents[4], true, 2000)
|
|
|
|
// 6th should be busy
|
|
await expect(renderKaTeXInWorker(contents[5], true, 2000)).rejects.toMatchObject({ code: WORKER_BUSY_CODE })
|
|
|
|
// Free one slot by resolving one of the pending requests
|
|
worker.resolveNext()
|
|
|
|
// Now retry the 6th; it should be accepted and resolve once we resolveNext again
|
|
const p6 = renderKaTeXInWorker(contents[5], true, 2000)
|
|
|
|
// Resolve remaining in some order
|
|
worker.resolveNext(c => `<ok>${c}</ok>`) // resolves one of p2..p6
|
|
worker.resolveNext(c => `<ok>${c}</ok>`)
|
|
worker.resolveNext(c => `<ok>${c}</ok>`)
|
|
worker.resolveNext(c => `<ok>${c}</ok>`)
|
|
worker.resolveNext(c => `<ok>${c}</ok>`)
|
|
|
|
const results = await Promise.all([p1, p2, p3, p4, p5, p6].map(p => p.catch(e => e)))
|
|
|
|
// Ensure all resolved to HTML strings, not errors
|
|
for (const r of results) {
|
|
expect(typeof r).toBe('string')
|
|
expect(r).toMatch(/<ok>|<span>/)
|
|
}
|
|
})
|
|
})
|