Creepso/pstreams-providers
1
0
Fork 0
mirror of https://github.com/p-stream/providers.git synced 2026-01-11 20:10:33 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

Add logging to debug skip button functionality

Browse source
This commit is contained in:
Pas 2025-12-19 15:15:35 -07:00
parent 2a352cf6fb
commit 51d23885b6
1 changed files with 10 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

16
src/entrypoint/controls.ts
View file

@ -156,7 +156,9 @@ export function makeControls(ops: ProviderControlsInput): ProviderControls {
for (const currentSource of sources) {
// Check for abort before starting the source
console.log('[controls] Checking abort signal for source:', currentSource.id, 'aborted:', runnerOps.abortSignal?.aborted);
if (runnerOps.abortSignal?.aborted) {
console.log('[controls] Abort signal detected, calling abort event for:', currentSource.id);
runnerOps.events?.abort?.(currentSource.id);
return null;
}
@ -239,12 +241,14 @@ export function makeControls(ops: ProviderControlsInput): ProviderControls {
});
}
for (const [ind, embed] of sortedEmbeds.entries()) {
// Check for abort before starting each embed
if (runnerOps.abortSignal?.aborted) {
runnerOps.events?.abort?.([currentSource.id, ind].join('-'));
return null;
}
for (const [ind, embed] of sortedEmbeds.entries()) {
// Check for abort before starting each embed
console.log('[controls] Checking abort signal for embed:', [currentSource.id, ind].join('-'), 'aborted:', runnerOps.abortSignal?.aborted);
if (runnerOps.abortSignal?.aborted) {
console.log('[controls] Abort signal detected for embed, calling abort event for:', [currentSource.id, ind].join('-'));
runnerOps.events?.abort?.([currentSource.id, ind].join('-'));
return null;
}
const scraper = embeds.find((v) => v.id === embed.embedId);
if (!scraper) throw new Error('Invalid embed returned');