Method ProcessPanelStreamMessage

src/render/plugins/plugin_event_router.cpp:263–297

    }

    void PluginEventRouter::ProcessPanelStreamMessage(const std::shared_ptr<GrPluginPanelStreamMessage>& event) {
        if (!event->body_) {
            return;
        }

        try {
            LOGI("ProcessPanelStreamMessage: {}", event->body_->AsString());
            json obj = json::parse(event->body_->AsString());
            auto event = obj["event"].get<std::string>();
            auto from_device = obj["from_device"].get<std::string>();
            if (event == "restart_render") {
                app_->SendAppMessage(MsgPanelStreamRestartRender {
                    .from_device_ = from_device,
                });
            }
            else if (event == "lock_screen") {
                app_->SendAppMessage(MsgPanelStreamLockScreen {
                    .from_device_ = from_device,
                });
            }
            else if (event == "restart_device") {
                app_->SendAppMessage(MsgPanelStreamRestartDevice {
                    .from_device_ = from_device,
                });
            }
            else if (event == "shutdown_device") {
                app_->SendAppMessage(MsgPanelStreamShutdownDevice {
                    .from_device_ = from_device,
                });
            }
        }
        catch(const std::exception& e) {
            LOGE("ProcessPanelStreamMessage failed: {}, body: {}", e.what(), event->body_->AsString());
        }
    }

    void PluginEventRouter::ReportRelayAlive(const std::string& device_id, int64_t timestamp) {
        app_->PostGlobalTask([=, this]() {