WardPearce
59 lines
1.6 KiB
TypeScript
59 lines
1.6 KiB
TypeScript
import { writable, type Writable } from 'svelte/store';
|
|
import type { SynciousProgressModel } from './model';
|
|
import { getVideoProgress } from '.';
|
|
|
|
const synciousCacheStore: Writable<SynciousProgressModel[] | null> = writable(null);
|
|
|
|
const videoIds: string[] = [];
|
|
const pendingResolves = new Map<string, (result: SynciousProgressModel | undefined) => void>();
|
|
|
|
let timeout: ReturnType<typeof setTimeout> | null = null;
|
|
const DEBOUNCE_MS = 1000;
|
|
const BATCH_SIZE = 100;
|
|
|
|
async function processBatches(): Promise<void> {
|
|
const batches: string[][] = [];
|
|
|
|
while (videoIds.length > 0) {
|
|
batches.push(videoIds.splice(0, BATCH_SIZE));
|
|
}
|
|
|
|
const results: SynciousProgressModel[] = [];
|
|
|
|
for (const batch of batches) {
|
|
const res: SynciousProgressModel[] = await getVideoProgress(batch.join(','));
|
|
results.push(...res);
|
|
|
|
// Resolve pending promises for this batch
|
|
for (const videoId of batch) {
|
|
const match = res.find((item) => item.video_id === videoId);
|
|
const resolve = pendingResolves.get(videoId);
|
|
if (resolve) {
|
|
resolve(match);
|
|
pendingResolves.delete(videoId);
|
|
}
|
|
}
|
|
}
|
|
|
|
synciousCacheStore.set(results);
|
|
}
|
|
|
|
export function queueSyncious(videoId: string): Promise<SynciousProgressModel | undefined> {
|
|
videoIds.push(videoId);
|
|
|
|
const promise = new Promise<SynciousProgressModel | undefined>((resolve) => {
|
|
pendingResolves.set(videoId, resolve);
|
|
});
|
|
|
|
if (timeout) clearTimeout(timeout);
|
|
timeout = setTimeout(() => {
|
|
processBatches().catch((e) => {
|
|
console.error('Failed to process batches:', e);
|
|
});
|
|
}, DEBOUNCE_MS);
|
|
|
|
return promise;
|
|
}
|
|
|
|
export { synciousCacheStore };
|