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();