Fix error handling

This commit is contained in:
Justin Spahr-Summers 2024-09-27 11:20:39 +01:00
commit 1cb6869681
No known key found for this signature in database
GPG key ID: E78498BF3C053CA7

View file

@ -90,7 +90,7 @@ export class SSEServerTransport implements Transport {
try {
await this.handleMessage(JSON.parse(body));
} catch (error) {
} catch {
res.writeHead(400).end(`Invalid message: ${body}`);
return;
}
@ -106,7 +106,7 @@ export class SSEServerTransport implements Transport {
validateMessage(message);
} catch (error) {
this.onerror?.(error as Error);
return;
throw error;
}
this.onmessage?.(message);