✨ Desktop: Integrate backend with worker

Author: pajowu

desktop/desktop-backend/src/backend.rs

@@ -61,6 +61,7 @@ impl BackendState {
 
 #[derive(Deserialize)]
 struct GetUnassingedTaskQuery {
+    #[serde(rename = "task_type")]
     task_types: Vec<TaskType>,
 }
 

desktop/src-tauri/src/backend_plugin.rs

@@ -9,9 +9,9 @@ use tauri::{
 };
 use tauri_plugin_log::log;
 
-struct BackendState {
-    local_addr: SocketAddr,
-    token: String,
+pub struct BackendState {
+    pub local_addr: SocketAddr,
+    pub token: String,
 }
 pub fn init<R: Runtime>() -> TauriPlugin<R> {
     Builder::new("transcribee_backend")

desktop/src-tauri/src/lib.rs

@@ -67,8 +67,8 @@ pub fn run() {
         )
         .plugin(tauri_plugin_shell::init())
         .plugin(tauri_plugin_opener::init())
-        .plugin(worker_plugin::init())
         .plugin(backend_plugin::init())
+        .plugin(worker_plugin::init())
         .invoke_handler(tauri::generate_handler![greet, ffmpeg_help])
         .run(tauri::generate_context!())
         .expect("error while running tauri application");

desktop/src-tauri/src/worker_plugin.rs

@@ -7,10 +7,10 @@ use tauri::{
 };
 use tauri_plugin_shell::ShellExt;
 
+use crate::backend_plugin::BackendState;
+
 pub fn init<R: Runtime>() -> TauriPlugin<R> {
-    // Make the plugin config optional
-    // by using `Builder::<R, Option<Config>>` instead
-    Builder::<R>::new("transcribee-worker")
+    Builder::new("transcribee-worker")
         .setup(|app, _| {
             let ext = if cfg!(target_family = "windows") {
                 "bat"
@@ -24,14 +24,16 @@ pub fn init<R: Runtime>() -> TauriPlugin<R> {
             println!("{:?}", resource_path);
 
             let app = app.clone();
+
             tauri::async_runtime::spawn(async move {
                 let shell = app.shell();
+                let backend_state = app.state::<BackendState>();
 
                 loop {
                     info!(target: "worker", "starting worker");
                     let (mut events, _) = shell
                         .command(resource_path.clone())
-                        .args(["--help"])
+                        .args(["--coordinator", &format!("http://{}:{}/", backend_state.local_addr.ip(), backend_state.local_addr.port()), "--token", &backend_state.token])
                         .spawn()
                         .unwrap();