forked from baron/baron-sso
ci: add code check badges and coverage reports
This commit is contained in:
@@ -34,9 +34,12 @@ function shouldUseWorker(useWorker: boolean | undefined) {
|
||||
async function fetchAllCursorPagesInWorker<TItem>(
|
||||
request: CursorFetchRequest,
|
||||
): Promise<CursorPageResponse<TItem>> {
|
||||
const worker = new Worker(new URL("./cursorFetch.worker.ts", import.meta.url), {
|
||||
type: "module",
|
||||
});
|
||||
const worker = new Worker(
|
||||
new URL("./cursorFetch.worker.ts", import.meta.url),
|
||||
{
|
||||
type: "module",
|
||||
},
|
||||
);
|
||||
const id = createRequestId();
|
||||
|
||||
return new Promise((resolve, reject) => {
|
||||
|
||||
@@ -1,7 +1,7 @@
|
||||
import {
|
||||
fetchAllCursorPagesMainThread,
|
||||
type CursorFetchRequest,
|
||||
type CursorPageResponse,
|
||||
fetchAllCursorPagesMainThread,
|
||||
} from "./cursorFetchCore";
|
||||
|
||||
type CursorWorkerRequestMessage = {
|
||||
@@ -21,23 +21,24 @@ type CursorWorkerResponseMessage<TItem> =
|
||||
error: string;
|
||||
};
|
||||
|
||||
self.addEventListener("message", async (event: MessageEvent<CursorWorkerRequestMessage>) => {
|
||||
const { id, request } = event.data;
|
||||
self.addEventListener(
|
||||
"message",
|
||||
async (event: MessageEvent<CursorWorkerRequestMessage>) => {
|
||||
const { id, request } = event.data;
|
||||
|
||||
try {
|
||||
const response = await fetchAllCursorPagesMainThread(request);
|
||||
self.postMessage({
|
||||
id,
|
||||
ok: true,
|
||||
response,
|
||||
} satisfies CursorWorkerResponseMessage<unknown>);
|
||||
} catch (error) {
|
||||
self.postMessage({
|
||||
id,
|
||||
ok: false,
|
||||
error: error instanceof Error ? error.message : String(error),
|
||||
} satisfies CursorWorkerResponseMessage<unknown>);
|
||||
}
|
||||
});
|
||||
|
||||
export {};
|
||||
try {
|
||||
const response = await fetchAllCursorPagesMainThread(request);
|
||||
self.postMessage({
|
||||
id,
|
||||
ok: true,
|
||||
response,
|
||||
} satisfies CursorWorkerResponseMessage<unknown>);
|
||||
} catch (error) {
|
||||
self.postMessage({
|
||||
id,
|
||||
ok: false,
|
||||
error: error instanceof Error ? error.message : String(error),
|
||||
} satisfies CursorWorkerResponseMessage<unknown>);
|
||||
}
|
||||
},
|
||||
);
|
||||
|
||||
@@ -74,7 +74,9 @@ export async function fetchAllCursorPagesMainThread<TItem>({
|
||||
});
|
||||
|
||||
if (!response.ok) {
|
||||
throw new Error(`Cursor page request failed with status ${response.status}`);
|
||||
throw new Error(
|
||||
`Cursor page request failed with status ${response.status}`,
|
||||
);
|
||||
}
|
||||
|
||||
const page = (await response.json()) as CursorPageResponse<TItem>;
|
||||
|
||||
@@ -1,6 +1,6 @@
|
||||
export {
|
||||
fetchAllCursorPages,
|
||||
fetchAllCursorPagesMainThread,
|
||||
type CursorFetchRequest,
|
||||
type CursorPageResponse,
|
||||
fetchAllCursorPages,
|
||||
fetchAllCursorPagesMainThread,
|
||||
} from "./cursorFetch";
|
||||
|
||||
Reference in New Issue
Block a user