mirrors/pikasTech-HWLAB
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Merge pull request #2112 from pikasTech/fix/2097-cloud-diagnostic-log

Browse Source 
fix(hwlab-node): log cloud diagnostics
This commit is contained in:
Lyon
2026-06-25 11:04:21 +08:00
committed by GitHub
parent 796de839c5 c8a76f33ac
commit 7a88ce49c9
1 changed files with 2 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files
internal/cloud/hwpod-node-ws-registry.ts
+2
View File
@@ -24,6 +24,7 @@ type PendingDispatch = {
export function createHwpodNodeWsRegistry(options: any = {}) { export function createHwpodNodeWsRegistry(options: any = {}) {
const now = options.now ?? (() => new Date().toISOString()); const now = options.now ?? (() => new Date().toISOString());
const clock = options.clock ?? (() => Date.now()); const clock = options.clock ?? (() => Date.now());
const logger = options.logger ?? console;
const connections = new Map<string, HwpodNodeConnection>(); const connections = new Map<string, HwpodNodeConnection>();
const pending = new Map<string, PendingDispatch>(); const pending = new Map<string, PendingDispatch>();
const socketConnections = new WeakMap<object, HwpodNodeConnection>(); const socketConnections = new WeakMap<object, HwpodNodeConnection>();
@@ -145,6 +146,7 @@ export function createHwpodNodeWsRegistry(options: any = {}) {
const diagnostic = normalizeDiagnostic(message.diagnostic, now()); const diagnostic = normalizeDiagnostic(message.diagnostic, now());
connection.diagnostics.push(diagnostic); connection.diagnostics.push(diagnostic);
if (connection.diagnostics.length > 50) connection.diagnostics = connection.diagnostics.slice(-50); if (connection.diagnostics.length > 50) connection.diagnostics = connection.diagnostics.slice(-50);
logger.warn?.(JSON.stringify({ event: "hwpod-node.diagnostic", nodeId: connection.nodeId || nodeId || null, connectionId: connection.id, diagnostic, valuesPrinted: false }));
sendJson(connection, { type: "ack", requestId: safeText(message.requestId) || "diagnostic", ok: true, message: "diagnostic recorded" }); sendJson(connection, { type: "ack", requestId: safeText(message.requestId) || "diagnostic", ok: true, message: "diagnostic recorded" });
return; return;
} }