Compare commits

..

No commits in common. "f8d7f82c50c46fd0d723ad94c39e0ddc96a43201" and "8c38f0e4ba52e8943e8b3f292f60f02421b929ca" have entirely different histories.

2 changed files with 38 additions and 45 deletions

View File

@ -1,41 +1,36 @@
use core::panic;
use std::sync::Arc; use std::sync::Arc;
use tauri::{path::BaseDirectory, Manager}; use tauri::{path::BaseDirectory, Manager};
use tauri::http::{
Request as TauriRequest,
Response as TauriResponse,
};
use axum::body::{
Body as AxumBody,
to_bytes,
};
use axum::extract::Request as AxumRequest;
use tokio::sync::{Mutex, MutexGuard}; use tokio::sync::{Mutex, MutexGuard};
use tower::{Service, ServiceExt}; use tower::{Service, ServiceExt};
async fn process_tauri_request( async fn process_tauri_request(
request: TauriRequest<Vec<u8>>, request: tauri::http::Request<Vec<u8>>,
mut router: MutexGuard<'_, axum::Router>, mut router: MutexGuard<'_, axum::Router>,
) -> TauriResponse<Vec<u8>> { ) -> tauri::http::Response<Vec<u8>> {
// Convert the Tauri request to an Axum request
let (parts, body) = request.into_parts(); let (parts, body) = request.into_parts();
let body = AxumBody::from(body); let body = axum::body::Body::from(body);
let request = AxumRequest::from_parts(parts, body);
// Process the request with the router let request = axum::extract::Request::from_parts(parts, body);
let response = router
.as_service() let response = match router.as_service().ready().await {
.ready().await Ok(ready_service) => ready_service.call(request).await,
.expect("Failed to get ready service") Err(_error) => panic!("Failed to get ready service"),
.call(request).await };
.expect("Failed to get response from router");
let response = match response {
Ok(response) => response,
Err(_error) => panic!("Problem getting response from request."),
};
// Convert the Axum response to a Tauri response
let (parts, body) = response.into_parts(); let (parts, body) = response.into_parts();
let body = to_bytes(body, usize::MAX).await let body = match axum::body::to_bytes(body, usize::MAX).await {
.expect("Failed to convert body to bytes") Ok(bytes) => bytes.to_vec(),
.to_vec(); Err(_error) => panic!("Problem converting response body to bytes."),
let response = TauriResponse::from_parts(parts, body); };
let response = tauri::http::Response::from_parts(parts, body);
response response
} }
@ -44,34 +39,32 @@ async fn process_tauri_request(
pub fn run() { pub fn run() {
tauri::Builder::default() tauri::Builder::default()
.setup(|app| { .setup(|app| {
let assets_path = app let resource_path_buf = app
.path() .path()
.resolve("assets", BaseDirectory::Resource) .resolve("assets", BaseDirectory::Resource)
.expect("Path should be resolvable"); .expect("Path should be resolvable");
let router = Arc::new(Mutex::new(
app::get_router(resource_path_buf.as_path()).clone(),
));
// Adds the router to the application state // Adds the router to the application state
// This makes it so we can retrieve it from any app instance (see bellow) // This makes it so we can retrieve it from any app instance (see bellow)
let router = Arc::new(Mutex::new(
app::get_router(assets_path.as_path()).clone(),
));
app.manage(router); app.manage(router);
Ok(()) Ok(())
}) })
.register_asynchronous_uri_scheme_protocol( .register_asynchronous_uri_scheme_protocol("axum", move |app, request, responder| {
"axum", let router = Arc::clone(&app.state::<Arc<Mutex<axum::Router>>>());
move |app, request, responder| {
// Retrieve the router from the application state and clone it for the async block
let router = Arc::clone(&app.state::<Arc<Mutex<axum::Router>>>());
// Spawn a new async task to process the request tauri::async_runtime::spawn(async move {
tauri::async_runtime::spawn(async move { let router = router.lock().await;
let router = router.lock().await;
let response = process_tauri_request(request, router).await; let response = process_tauri_request(request, router).await;
responder.respond(response);
}); responder.respond(response);
} });
) })
.run(tauri::generate_context!()) .run(tauri::generate_context!())
.expect("error while running tauri application"); .expect("error while running tauri application");
} }

View File

@ -4,8 +4,8 @@
"identifier": "org.p4pillon.pharma.desktop", "identifier": "org.p4pillon.pharma.desktop",
"build": { "build": {
"beforeDevCommand": { "beforeDevCommand": {
"cwd": "../app", "script": "cargo run",
"script": "cargo run" "cwd": "../clego"
}, },
"devUrl": "http://localhost:3000", "devUrl": "http://localhost:3000",
"frontendDist": "axum://place.holder/" "frontendDist": "axum://place.holder/"