From 67d994e78340d3521eca3d1819254a5f23d45368 Mon Sep 17 00:00:00 2001 From: zhaohe Date: Wed, 26 Mar 2025 15:33:12 +0800 Subject: [PATCH] update --- README.md | 5 +++++ src/extapi_service.cpp | 9 +++++++++ 2 files changed, 14 insertions(+) diff --git a/README.md b/README.md index b48ba08..5b4e6ef 100644 --- a/README.md +++ b/README.md @@ -24,4 +24,9 @@ ping cmd : 0111 0100 00 00 6400 read_reg : +``` + +``` +第三方库说明: +https://iflytop1.feishu.cn/wiki/wikcnDuCFRGDunHGzns8gRV4Ahh ``` \ No newline at end of file diff --git a/src/extapi_service.cpp b/src/extapi_service.cpp index d80d9cf..0ba3a4b 100644 --- a/src/extapi_service.cpp +++ b/src/extapi_service.cpp @@ -58,11 +58,14 @@ void ExtAPIService::initCanPassthroughServer() { */ m_canPassthroughServer.reset(new WebSocketServer(19005, "0.0.0.0")); m_canPassthroughServer->setOnConnectionCallback([this](weak_ptr webSocket, shared_ptr connectionState) { + logger->info("url: {}", webSocket.lock()->getUrl()); + logger->info("m_canPassthroughServer on connect remote ip: {}", connectionState->getRemoteIp()); auto ws = webSocket.lock(); if (!ws) return; ws->setOnMessageCallback([this, webSocket](const ix::WebSocketMessagePtr &msg) { // + logger->info("m_canPassthroughServer on message {}", webSocket.lock()->getUrl()); try { if (msg->type == ix::WebSocketMessageType::Message) { logger->info("websocket-ch -> {}({})", msg->str, msg->wireSize); @@ -79,6 +82,12 @@ void ExtAPIService::initCanPassthroughServer() { }); }); + m_canPassthroughServer->setOnClientMessageCallback([this](std::shared_ptr, WebSocket &, const WebSocketMessagePtr &) { + + + + }); + m_zcanreceiverhost->registerListener([this](uint8_t fromboardid, uint8_t *packet, size_t len) { string hexStr = StringUtils().bytesToString((uint8_t *)packet, len); auto clients = m_canPassthroughServer->getClients();