mirror of
https://github.com/4gray/iptvnator.git
synced 2026-10-10 18:26:43 -08:00
4gray
7c49995e23
Add support for multiple EPG sources by introducing a new `EpgStore` structure that holds a vector of `EpgSource` instances. Replace the static `EPG_DATA` with a thread-safe `OnceCell` containing a mutex-protected `EpgStore`. Implement the `fetch_and_parse_epg` function to fetch and update EPG data from a given URL, handling both gzipped and regular XML data formats. Enhance error handling and logging for better traceability during data fetching and parsing.
131 lines
3.6 KiB
Rust
131 lines
3.6 KiB
Rust
use log::info;
|
|
use std::path::Path;
|
|
use std::process::Command;
|
|
|
|
#[tauri::command]
|
|
async fn open_in_mpv(url: String, path: String) -> Result<(), String> {
|
|
info!("Custom MVP path: {}", path);
|
|
let mpv_paths = if cfg!(target_os = "windows") {
|
|
vec![
|
|
r"C:\Program Files\mpv\mpv.exe",
|
|
r"C:\Program Files (x86)\mpv\mpv.exe",
|
|
]
|
|
} else if cfg!(target_os = "linux") {
|
|
vec!["/usr/bin/mpv", "/usr/local/bin/mpv", "/snap/bin/mpv"]
|
|
} else {
|
|
vec![
|
|
"/Applications/mpv.app/Contents/MacOS/mpv",
|
|
"/opt/homebrew/bin/mpv",
|
|
"/usr/local/bin/mpv",
|
|
]
|
|
};
|
|
|
|
let mpv_path = if !path.is_empty() && Path::new(&path).exists() {
|
|
path
|
|
} else {
|
|
mpv_paths
|
|
.iter()
|
|
.find(|&path| Path::new(path).exists())
|
|
.map(|s| s.to_string())
|
|
.unwrap_or_else(|| "mpv".to_string())
|
|
};
|
|
|
|
info!("Using the following MPV player path: {}", mpv_path);
|
|
|
|
Command::new(mpv_path)
|
|
.arg(&url)
|
|
.spawn()
|
|
.map_err(|e| e.to_string())?;
|
|
|
|
Ok(())
|
|
}
|
|
|
|
#[tauri::command]
|
|
async fn open_in_vlc(url: String, path: String) -> Result<(), String> {
|
|
info!("Custom MVP path: {}", path);
|
|
let vlc_paths = if cfg!(target_os = "windows") {
|
|
vec![
|
|
r"C:\Program Files\VideoLAN\VLC\vlc.exe",
|
|
r"C:\Program Files (x86)\VideoLAN\VLC\vlc.exe",
|
|
]
|
|
} else if cfg!(target_os = "linux") {
|
|
vec!["/usr/bin/vlc", "/usr/local/bin/vlc", "/snap/bin/vlc"]
|
|
} else {
|
|
vec![
|
|
"/Applications/VLC.app/Contents/MacOS/VLC",
|
|
"/opt/homebrew/bin/vlc",
|
|
"/usr/local/bin/vlc",
|
|
]
|
|
};
|
|
|
|
let vlc_path = if !path.is_empty() && Path::new(&path).exists() {
|
|
path
|
|
} else {
|
|
vlc_paths
|
|
.iter()
|
|
.find(|&path| Path::new(path).exists())
|
|
.map(|s| s.to_string())
|
|
.unwrap_or_else(|| "vlc".to_string())
|
|
};
|
|
|
|
info!("Using VLC player path: {}", vlc_path);
|
|
|
|
Command::new(vlc_path)
|
|
.arg(&url)
|
|
.spawn()
|
|
.map_err(|e| e.to_string())?;
|
|
|
|
Ok(())
|
|
}
|
|
|
|
mod epg;
|
|
use epg::get_programs_by_channel;
|
|
|
|
#[tauri::command]
|
|
async fn fetch_epg(url: Vec<String>) -> Result<(), String> {
|
|
for single_url in url {
|
|
epg::fetch_and_parse_epg(single_url)
|
|
.await
|
|
.map_err(|e| e.to_string())?;
|
|
}
|
|
Ok(())
|
|
}
|
|
|
|
#[tauri::command]
|
|
async fn get_channel_programs(channel_id: String) -> Result<Vec<epg::Program>, String> {
|
|
get_programs_by_channel(channel_id)
|
|
.await
|
|
.map_err(|e| e.to_string())
|
|
}
|
|
|
|
#[cfg_attr(mobile, tauri::mobile_entry_point)]
|
|
pub fn run() {
|
|
tauri::Builder::default()
|
|
.plugin(tauri_plugin_dialog::init())
|
|
.plugin(tauri_plugin_process::init())
|
|
.plugin(tauri_plugin_updater::Builder::new().build())
|
|
.plugin(tauri_plugin_fs::init())
|
|
.plugin(tauri_plugin_os::init())
|
|
.plugin(tauri_plugin_window_state::Builder::new().build())
|
|
.plugin(tauri_plugin_shell::init())
|
|
.plugin(tauri_plugin_http::init())
|
|
.invoke_handler(tauri::generate_handler![
|
|
fetch_epg,
|
|
get_channel_programs,
|
|
open_in_mpv,
|
|
open_in_vlc
|
|
])
|
|
.setup(|app| {
|
|
if cfg!(debug_assertions) {
|
|
app.handle().plugin(
|
|
tauri_plugin_log::Builder::default()
|
|
.level(log::LevelFilter::Info)
|
|
.build(),
|
|
)?;
|
|
}
|
|
Ok(())
|
|
})
|
|
.run(tauri::generate_context!())
|
|
.expect("error while running tauri application");
|
|
}
|