mirror of
https://github.com/clash-verge-rev/clash-verge-rev
synced 2025-05-05 05:13:44 +08:00
91 lines
2.9 KiB
Rust
91 lines
2.9 KiB
Rust
extern crate warp;
|
|
|
|
use super::resolve;
|
|
use crate::config::{Config, IVerge, DEFAULT_PAC};
|
|
use anyhow::{bail, Result};
|
|
use port_scanner::local_port_available;
|
|
use std::convert::Infallible;
|
|
use tauri::AppHandle;
|
|
use warp::Filter;
|
|
|
|
#[derive(serde::Deserialize, Debug)]
|
|
struct QueryParam {
|
|
param: String,
|
|
}
|
|
|
|
/// check whether there is already exists
|
|
pub fn check_singleton() -> Result<()> {
|
|
let port = IVerge::get_singleton_port();
|
|
|
|
if !local_port_available(port) {
|
|
tauri::async_runtime::block_on(async {
|
|
let resp = reqwest::get(format!("http://127.0.0.1:{port}/commands/ping"))
|
|
.await?
|
|
.text()
|
|
.await?;
|
|
|
|
if &resp == "ok" {
|
|
let argvs: Vec<String> = std::env::args().collect();
|
|
if argvs.len() > 1 {
|
|
let param = argvs[1].as_str();
|
|
reqwest::get(format!(
|
|
"http://127.0.0.1:{port}/commands/scheme?param={param}"
|
|
))
|
|
.await?
|
|
.text()
|
|
.await?;
|
|
} else {
|
|
reqwest::get(format!("http://127.0.0.1:{port}/commands/visible"))
|
|
.await?
|
|
.text()
|
|
.await?;
|
|
}
|
|
bail!("app exists");
|
|
}
|
|
|
|
log::error!("failed to setup singleton listen server");
|
|
Ok(())
|
|
})
|
|
} else {
|
|
Ok(())
|
|
}
|
|
}
|
|
|
|
/// The embed server only be used to implement singleton process
|
|
/// maybe it can be used as pac server later
|
|
pub fn embed_server(app_handle: AppHandle) {
|
|
let port = IVerge::get_singleton_port();
|
|
|
|
tauri::async_runtime::spawn(async move {
|
|
let ping = warp::path!("commands" / "ping").map(move || "ok");
|
|
|
|
let visible = warp::path!("commands" / "visible").map(move || {
|
|
resolve::create_window(&app_handle);
|
|
"ok"
|
|
});
|
|
|
|
let pac = warp::path!("commands" / "pac").map(move || {
|
|
let content = Config::verge()
|
|
.latest()
|
|
.pac_file_content
|
|
.clone()
|
|
.unwrap_or(DEFAULT_PAC.to_string());
|
|
let port = Config::verge()
|
|
.latest()
|
|
.verge_mixed_port
|
|
.unwrap_or(Config::clash().data().get_mixed_port());
|
|
content.replace("%mixed-port%", &format!("{}", port))
|
|
});
|
|
let scheme = warp::path!("commands" / "scheme")
|
|
.and(warp::query::<QueryParam>())
|
|
.and_then(scheme_handler);
|
|
|
|
async fn scheme_handler(query: QueryParam) -> Result<impl warp::Reply, Infallible> {
|
|
resolve::resolve_scheme(query.param).await;
|
|
Ok("ok")
|
|
}
|
|
let commands = ping.or(visible).or(pac).or(scheme);
|
|
warp::serve(commands).run(([127, 0, 0, 1], port)).await;
|
|
});
|
|
}
|