From 1058c7fc328d8c3ab74e65d189328834bd6583c9 Mon Sep 17 00:00:00 2001 From: mrjvs Date: Fri, 29 Dec 2023 22:09:02 +0100 Subject: [PATCH] Rename method --- src/index.ts | 14 +++++++------- 1 file changed, 7 insertions(+), 7 deletions(-) diff --git a/src/index.ts b/src/index.ts index c6b4ddf..8b4a32c 100644 --- a/src/index.ts +++ b/src/index.ts @@ -61,7 +61,7 @@ async function writeSSEEvent( }); } -function stringifyError(err: any): any { +function makeErrorDto(err: any): any { return err ? { name: err.name, message: err.message, stack: err.stack } : undefined; } @@ -119,7 +119,7 @@ app.get('/scrape', async (context) => { const err = evt.error as any; writeSSEEvent(stream, 'update', { ...evt, - error: stringifyError(evt.error), + error: makeErrorDto(evt.error), }); }, }, @@ -133,7 +133,7 @@ app.get('/scrape', async (context) => { await writeSSEEvent(stream, 'noOutput', ''); return await stream.close(); } catch (e: any) { - await writeSSEEvent(stream, 'error', stringifyError(e) ?? {}); + await writeSSEEvent(stream, 'error', makeErrorDto(e) ?? {}); return await stream.close(); } }); @@ -183,7 +183,7 @@ app.get('/scrape/embed', async (context) => { update(evt) { writeSSEEvent(stream, 'update', { ...evt, - error: stringifyError(evt.error), + error: makeErrorDto(evt.error), }); }, }, @@ -197,7 +197,7 @@ app.get('/scrape/embed', async (context) => { await writeSSEEvent(stream, 'noOutput', ''); return await stream.close(); } catch (e: any) { - await writeSSEEvent(stream, 'error', stringifyError(e) ?? {}); + await writeSSEEvent(stream, 'error', makeErrorDto(e) ?? {}); return await stream.close(); } }); @@ -247,7 +247,7 @@ app.get('/scrape/source', async (context) => { update(evt) { writeSSEEvent(stream, 'update', { ...evt, - error: stringifyError(evt.error), + error: makeErrorDto(evt.error), }); }, }, @@ -261,7 +261,7 @@ app.get('/scrape/source', async (context) => { await writeSSEEvent(stream, 'noOutput', ''); return await stream.close(); } catch (e: any) { - await writeSSEEvent(stream, 'error', stringifyError(e) ?? {}); + await writeSSEEvent(stream, 'error', makeErrorDto(e) ?? {}); return await stream.close(); } });