Method AddWebsocketRouter

src/render/plugins/net_ws/ws_server.cpp:181–290

    }

    void WsPluginServer::AddWebsocketRouter(const std::string &path) {
        auto fn_get_socket_fd = [](std::shared_ptr<asio2::http_session> &sess_ptr) -> uint64_t {
            auto& s = sess_ptr->socket();
            return (uint64_t)s.native_handle();
        };
        server_->bind(path, websocket::listener<asio2::http_session>{}
            .on("message", [=, this](std::shared_ptr<asio2::http_session> &sess_ptr, std::string_view data) {
                auto socket_fd = fn_get_socket_fd(sess_ptr);
                if (path == kUrlMedia) {
                    stream_routers_.VisitAll([=](auto k, std::shared_ptr<WsStreamRouter>& router) mutable {
                        if (socket_fd == k) {
                            router->OnMessage(sess_ptr, socket_fd, data);
                        }
                    });
                }
                else if (path == kUrlFileTransfer) {
                    ft_routers_.VisitAll([=](auto k, auto &router) mutable {
                        if (socket_fd == k) {
                            router->OnMessage(sess_ptr, socket_fd, data);
                        }
                    });
                }
            })
            .on("open", [=, this](std::shared_ptr<asio2::http_session> &sess_ptr) {
                auto query = sess_ptr->get_request().get_query();
                auto params = UrlHelper::ParseQueryString(std::string(query.data(), query.size()));
                for (const auto& [k, v] : params) {
                    LOGI("query param, k: {}, v: {}", k, v);
                }
                LOGI("App server {} open, query: {}", path, query);
                bool only_audio = std::atoi(params["only_audio"].c_str()) == 1;
                std::string server_device_id;
                std::string visitor_device_id;
                std::string stream_id;
                bool force_gdi = false;
                if (params.contains("remote_device_id")) {
                    server_device_id = params["remote_device_id"];
                }
                if (params.contains("visitor_device_id")) {
                    visitor_device_id = params["visitor_device_id"];
                }
                if (params.contains("stream_id")) {
                    stream_id = params["stream_id"];
                }
                if (params.contains("force_gdi")) {
                    force_gdi = [&]() {
                        if (auto v = params["force_gdi"]; v == "true") {
                            return true;
                        }
                        return false;
                    } ();
                }

                LOGI("Force GDI : {}", force_gdi);

                // TEST //
                if (stream_id.empty()) {
                    LOGE("!!!MUST HAVE STREAM ID!!!");