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

Modified the try-catch block

Browse source
This commit is contained in:
Vijay 2024-03-07 21:32:46 +05:30
parent da7c83774c
commit 284226166e
1 changed files with 10 additions and 21 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

31
src/runners/runner.ts
View file

@ -88,22 +88,16 @@ export async function runAllProviders(list: ProviderList, ops: ProviderRunnerOpt
if (!output || (!output.stream?.length && !output.embeds.length)) {
throw new NotFoundError('No streams found');
}
} catch (err) {
if (err instanceof NotFoundError) {
ops.events?.update?.({
id: source.id,
percentage: 100,
status: 'notfound',
reason: err.message,
});
continue;
}
ops.events?.update?.({
} catch (error) {
const updateParams: UpdateEvent = {
id: source.id,
percentage: 100,
status: 'failure',
error: err,
});
status: error instanceof NotFoundError ? 'notfound' : 'failure',
reason: error instanceof NotFoundError ? error.message : undefined,
error: error instanceof NotFoundError ? undefined : error,
};
ops.events?.update?.(updateParams);
continue;
}
if (!output) throw new Error('Invalid media type');
@ -161,16 +155,11 @@ export async function runAllProviders(list: ProviderList, ops: ProviderRunnerOpt
percentage: 100,
status: error instanceof NotFoundError ? 'notfound' : 'failure',
reason: error instanceof NotFoundError ? error.message : undefined,
error,
error: error instanceof NotFoundError ? undefined : error,
};
ops.events?.update?.(updateParams);
if (error instanceof NotFoundError) {
continue;
}
throw error;
continue;
}
return {