clientSocket.pipe(upstreamSocket);

upstreamSocket.pipe(clientSocket);

});

clientSocket.on("error", (error) => {

store.recordEvent({

sessionId: params.settings.sessionId,

ts: Date.now(),

sourceScope: "openclaw",

sourceProcess: params.settings.sourceProcess,

protocol: "connect",

direction: "local",

kind: "error",

flowId,

host: hostname,

path: req.url ?? "",

errorText: error.message,

});

upstreamSocket.destroy();

});

upstreamSocket.on("error", (error) => {

store.recordEvent({

sessionId: params.settings.sessionId,

path: req.url ?? "",

errorText: error.message,

});

clientSocket.end();

clientSocket.destroy();

});

});