|
|
@@ -834,8 +834,10 @@ function handlePrivateMessage(
|
|
|
if (channel.startsWith("orders.") && channel.endsWith(address)) {
|
|
|
const payload = parsed.data;
|
|
|
const records = Array.isArray(payload) ? payload : [payload];
|
|
|
+ logger.info({ accountId, channel, recordCount: records.length }, 'Received order update message from WebSocket');
|
|
|
for (const record of records) {
|
|
|
const update = record ?? {};
|
|
|
+ logger.info({ accountId, orderUpdate: update }, 'Processing order update event');
|
|
|
routeOrder(accountId, update);
|
|
|
}
|
|
|
return;
|