Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
6 changes: 4 additions & 2 deletions .beads/issues.jsonl

Large diffs are not rendered by default.

17 changes: 12 additions & 5 deletions .beads/sync_base.jsonl

Large diffs are not rendered by default.

6 changes: 1 addition & 5 deletions web/demo/README.md
Original file line number Diff line number Diff line change
@@ -1,7 +1,3 @@
# Demo notes

Run the embedding integration test locally:

npm run test:integration:embedding

Set EMBED_NODE=1 to force Node fallback if needed.
Run `npm run test:integration:embedding` locally; set `EMBED_NODE=1` to force the Node fallback if needed.
46 changes: 43 additions & 3 deletions web/demo/js/embedding-service.js
Original file line number Diff line number Diff line change
Expand Up @@ -53,21 +53,61 @@ const NODE_FALLBACK_ENABLED = typeof process !== 'undefined' && process.env && (
let nodeExtractorPromise = null;
let nodeExtractorError = null;

function createSharpStub() {
const stub = function sharpUnavailable() {
throw new Error('sharp unavailable');
};
stub.default = stub;
return stub;
}

function withSharpStub(loadFn) {
if (typeof require !== 'function') {
return loadFn();
}
let Module = null;
try {
Module = require('module');
} catch (err) {
return loadFn();
}
let sharpPath = null;
try {
sharpPath = require.resolve('sharp');
} catch (err) {
return loadFn();
}
const existing = require.cache[sharpPath];
const stubModule = new Module(sharpPath);
stubModule.exports = createSharpStub();
stubModule.loaded = true;
require.cache[sharpPath] = stubModule;
try {
return loadFn();
} finally {
if (existing) {
require.cache[sharpPath] = existing;
} else {
delete require.cache[sharpPath];
}
}
}

async function getNodeExtractor() {
if (!NODE_FALLBACK_ENABLED) return null;
if (!nodeExtractorPromise) {
nodeExtractorPromise = (async () => {
let mod = null;
try {
if (typeof require === 'function') {
mod = require('@xenova/transformers');
mod = withSharpStub(() => require('@xenova/transformers'));
} else {
mod = await import('@xenova/transformers');
mod = await withSharpStub(() => import('@xenova/transformers'));
}
} catch (primaryErr) {
// Fallback to dynamic import if require failed, or vice versa
try {
mod = await import('@xenova/transformers');
mod = await withSharpStub(() => import('@xenova/transformers'));
} catch (importErr) {
throw importErr || primaryErr;
}
Expand Down