Add error handling for invalid FIMP messages

This commit is contained in:
Adrian Jagielak 2025-09-24 23:52:39 +02:00
parent f25c437ed3
commit c611be58de
No known key found for this signature in database
GPG Key ID: 0818CF7AF6C62BFB

View File

@ -82,7 +82,24 @@ export async function sendFimpMsg({
}, timeoutMs);
const onResponse = (topic: string, buffer: any) => {
const msg = JSON.parse(buffer.toString());
let bufferToString;
try {
bufferToString = buffer.toString();
} catch (e) {
log.warn('Invalid message received from hub MQTT broker', e);
return;
}
let msg;
try {
msg = JSON.parse(bufferToString);
} catch (e) {
log.warn(
`Invalid FIMP message received from hub MQTT broker\nMessage: ${bufferToString}`,
e,
);
return;
}
if (msg.corid === uid) {
if (msg.type === 'evt.error.report') {