fix: resolve Linux CI cargo targets, permission errors, and implement headless GTK stdin loop

Author: 989tqT

plug.app/rt/.cargo/config.toml

@@ -33,7 +33,9 @@ fn compare_versions(registry: &str, local: &str) -> bool {
 }
 
 pub fn download_file_hr(url: &str, dest: &str) -> i32 {
-    let req = ureq::get(url).set("Cache-Control", "no-cache");
+    let req = ureq::get(url)
+        .set("Cache-Control", "no-cache")
+        .set("User-Agent", "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/120.0.0.0 Safari/537.36");
     match req.call() {
         Ok(res) => {
             if let Ok(mut file) = fs::File::create(dest) {

plug.app/rt/handlers/ops/cmds/c_plug/check/mod.rs

@@ -97,7 +97,7 @@ pub fn install_plugin_manually(clean_name: &str, session_hash: &str, registry_sh
                 if let Ok(_) = fs::copy(&local_wasm, &tmp_wasm) {
                     downloaded_wasm = true;
                     if !silent {
-                        print_info(&format!("local fallback: copy plugin from {}", local_wasm.display()));
+                        print_info(&format!("local fallback: copy plugin: {}", clean_name));
                     }
                 }
             }
@@ -117,7 +117,7 @@ pub fn install_plugin_manually(clean_name: &str, session_hash: &str, registry_sh
                     if let Ok(_) = fs::copy(&local_toml, &tmp_toml) {
                         downloaded_toml = true;
                         if !silent {
-                            print_info(&format!("local fallback: copy manifest from {}", local_toml.display()));
+                            print_info("local fallback: copy manifest");
                         }
                     }
                 }
@@ -137,7 +137,7 @@ pub fn install_plugin_manually(clean_name: &str, session_hash: &str, registry_sh
 
             let sha256_hex = crate::ops::utils::calculate_buffer_sha256(&wasm_bytes);
 
-            // phase 2.3: verify against registry-pinned hash (fail-closed on missing or mismatch)
+            // verify against registry-pinned hash (fail-closed on missing or mismatch)
             if registry_sha256.is_empty() {
                 print_error(&format!("[SECURITY] Missing pinned hash in registry for plugin: {}. Aborting installation.", clean_name));
                 let _ = fs::remove_file(&tmp_wasm);

plug.app/rt/handlers/ops/cmds/c_plug/mod.rs

@@ -4,7 +4,7 @@ use std::time::{Instant, Duration};
 use crate::ops::host::print_info;
 
 pub fn download_with_progress(url: &str, dest_path: &str, silent: bool) -> bool {
-    let agent = "plug-agent";
+    let agent = "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/120.0.0.0 Safari/537.36";
     let req = ureq::get(url).set("User-Agent", agent);
     let response = match req.call() {
         Ok(res) => res,

plug.app/rt/handlers/ops/cmds/c_plug/progress.rs

@@ -6,21 +6,6 @@ use serde_json::Value;
 const DEFAULT_TIMEOUT: u64 = 30;
 const USER_AGENT: &str = "plug-runtime/1.0.0";
 
-/// execute get reqest and return raw string
-pub fn http_get(url: &str) -> Result<String, String> {
-    let agent = ureq::AgentBuilder::new()
-        .timeout(Duration::from_secs(DEFAULT_TIMEOUT))
-        .build();
-
-    let response = agent.get(url)
-        .set("User-Agent", USER_AGENT)
-        .call()
-        .map_err(|e| format!("GET failed: {}", e))?;
-
-    response.into_string()
-        .map_err(|e| format!("Failed to read response body: {}", e))
-}
-
 /// execute post reqest with json body
 pub fn http_post_json(url: &str, json_payload: &str) -> Result<String, String> {
     // check input json format validity
@@ -40,12 +25,3 @@ pub fn http_post_json(url: &str, json_payload: &str) -> Result<String, String> {
     response.into_string()
         .map_err(|e| format!("Failed to read response body: {}", e))
 }
-
-/// check if internet is online
-pub fn is_online() -> bool {
-    // quick check using google dns
-    ureq::get("http://clients3.google.com/generate_204")
-        .timeout(Duration::from_secs(3))
-        .call()
-        .is_ok()
-}

plug.app/rt/handlers/ops/net.rs

@@ -37,12 +37,56 @@ std::vector<TabState> g_tabs;
 int g_active_tab = 0;
 std::mutex g_mutex;
 
+extern "C" bool g_headless_mode;
 static std::thread g_cmd_thread;
 static std::mutex g_cmd_mutex;
 static std::condition_variable g_cmd_cv;
 struct CmdItem { int tab; std::string cmd; };
 static std::queue<CmdItem> g_cmd_queue;
 static std::atomic_bool g_cmd_thread_running{false};
+static std::thread g_headless_stdin_thread;
+
+static void headless_stdin_worker(void) {
+    std::string line;
+    while (std::getline(std::cin, line)) {
+        if (line.empty()) continue;
+        
+        if (line == "__dump_state__") {
+            std::lock_guard<std::mutex> lk(g_mutex);
+            std::cout << "\n---STATE_DUMP_START---\n";
+            std::cout << "{\n";
+            std::cout << "  \"active_tab\": " << g_active_tab << ",\n";
+            std::cout << "  \"tabs\": [\n";
+            for (size_t i = 0; i < g_tabs.size(); ++i) {
+                std::string title_utf8 = g_tabs[i].title;
+                std::string raw_input = g_tabs[i].input_buffer;
+                std::string escaped_input;
+                for (char c : raw_input) {
+                    if (c == '\\') escaped_input += "\\\\";
+                    else if (c == '"') escaped_input += "\\\"";
+                    else escaped_input += c;
+                }
+                std::cout << "    {\n";
+                std::cout << "      \"index\": " << i << ",\n";
+                std::cout << "      \"title\": \"" << title_utf8 << "\",\n";
+                std::cout << "      \"input_buffer\": \"" << escaped_input << "\",\n";
+                std::cout << "      \"plugin_owner\": \"" << (g_tabs[i].plugin_owner.empty() ? "" : g_tabs[i].plugin_owner) << "\"\n";
+                std::cout << "    }" << (i + 1 < g_tabs.size() ? "," : "") << "\n";
+            }
+            std::cout << "  ]\n";
+            std::cout << "}\n";
+            std::cout << "---STATE_DUMP_END---\n" << std::endl;
+            continue;
+        }
+
+        // push command to queue
+        {
+            std::lock_guard<std::mutex> clk(g_cmd_mutex);
+            g_cmd_queue.push({g_active_tab, line});
+            g_cmd_cv.notify_one();
+        }
+    }
+}
 thread_local int g_print_tab = -1;
 int g_hover_close_tab = -1;
 std::vector<HitBox> g_tab_close_boxes;
@@ -429,7 +473,7 @@ static void on_drag_end(GtkGestureDrag *gesture, double offset_x, double offset_
 }
 
 static gboolean on_tick(GtkWidget *widget, GdkFrameClock *frame_clock, gpointer user_data) {
-    // Check if command thread is active (pseudo-logic for now to match Windows)
+    // check if command thread is active
     if (!g_cmd_thread_running) {
         g_cmd_thread_running = true;
         g_cmd_thread = std::thread([]() {
@@ -450,6 +494,9 @@ static gboolean on_tick(GtkWidget *widget, GdkFrameClock *frame_clock, gpointer
                 }
             }
         });
+        if (g_headless_mode) {
+            g_headless_stdin_thread = std::thread(headless_stdin_worker);
+        }
     }
 
     {
@@ -546,6 +593,9 @@ void main_l_cleanup(void) {
         g_object_unref(g_app);
         g_app = NULL;
     }
+    if (g_headless_stdin_thread.joinable()) {
+        g_headless_stdin_thread.detach();
+    }
 }
 
 void main_l_print_info(const char* msg) {

plug.app/src/linux/api/intf/main_l.cpp

@@ -4,6 +4,11 @@ project(plug LANGUAGES C CXX)
 set(CMAKE_CXX_STANDARD 17)
 set(CMAKE_CXX_STANDARD_REQUIRED ON)
 
+option(PLUG_ENABLE_HEADLESS_MODE "Enable headless mode for E2E testing" OFF)
+if(PLUG_ENABLE_HEADLESS_MODE)
+    add_compile_definitions(PLUG_ENABLE_HEADLESS_MODE)
+endif()
+
 set(ROOT_DIR "${CMAKE_CURRENT_SOURCE_DIR}/../..")
 set(APP_DIR "${ROOT_DIR}/plug.app")
 set(COMMON_DIR "${APP_DIR}/cmn")

plug.cross/linux/CMakeLists.txt

@@ -80,7 +80,8 @@ def main():
             sys_drive += "\\"
         plug_dir = Path(sys_drive) / ".plug" / "plugins"
     else:
-        plug_dir = Path("/.plug/plugins")
+        # on linux systemdrive is not set so app default to c:\
+        plug_dir = Path("C:\\") / ".plug" / "plugins"
 
     # backup existing plugin folder if it exists
     backup_dir = plug_dir.parent / "plugins_backup"