Creepso/pstreams-providers
1
0
Fork 0
mirror of https://github.com/p-stream/providers.git synced 2026-04-21 16:42:28 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

Fix validatePlayableStream crashing everything

Browse source
This commit is contained in:
TheTank 2026-02-02 13:36:16 -05:00
parent 9aac094373
commit 6f761c0187
1 changed files with 18 additions and 7 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

11
src/runners/runner.ts
View file

@ -111,6 +111,7 @@ export async function runAllProviders(list: ProviderList, ops: ProviderRunnerOpt
// return stream is there are any // return stream is there are any
if (output.stream?.[0]) { if (output.stream?.[0]) {
try {
const playableStream = await validatePlayableStream(output.stream[0], ops, source.id); const playableStream = await validatePlayableStream(output.stream[0], ops, source.id);
if (!playableStream) throw new NotFoundError('No streams found'); if (!playableStream) throw new NotFoundError('No streams found');
@ -118,6 +119,16 @@ export async function runAllProviders(list: ProviderList, ops: ProviderRunnerOpt
sourceId: source.id, sourceId: source.id,
stream: playableStream, stream: playableStream,
}; };
} catch (error) {
const updateParams: UpdateEvent = {
id: source.id,
percentage: 100,
status: error instanceof NotFoundError ? 'notfound' : 'failure',
reason: error instanceof NotFoundError ? error.message : 'Stream validation failed',
error: error instanceof NotFoundError ? undefined : error,
};
ops.events?.update?.(updateParams);
}
} }
// filter disabled and run embed scrapers on listed embeds // filter disabled and run embed scrapers on listed embeds