From d1a7d5b28e67556a47d1cee5b16f4726f19fffdb Mon Sep 17 00:00:00 2001
From: geoffsee <>
Date: Sun, 31 Aug 2025 19:59:09 -0400
Subject: [PATCH] fix format error

---
 Cargo.lock                            | 14 ++++++------
 crates/chat-ui/README.md              |  2 +-
 crates/chat-ui/src/app.rs             | 32 ++++++++++++++-------------
 crates/chat-ui/src/main.rs            |  7 ++----
 crates/predict-otron-9000/src/main.rs | 22 ++++++------------
 5 files changed, 34 insertions(+), 43 deletions(-)

diff --git a/Cargo.lock b/Cargo.lock
index 48bb7ee..ddfafa3 100644
--- a/Cargo.lock
+++ b/Cargo.lock
@@ -893,7 +893,7 @@ checksum = "b94f61472cee1439c0b966b47e3aca9ae07e45d070759512cd390ea2bebc6675"
 
 [[package]]
 name = "cli"
-version = "0.1.2"
+version = "0.1.3"
 
 [[package]]
 name = "codee"
@@ -1471,7 +1471,7 @@ dependencies = [
 
 [[package]]
 name = "embeddings-engine"
-version = "0.1.2"
+version = "0.1.3"
 dependencies = [
  "async-openai",
  "axum",
@@ -2093,7 +2093,7 @@ dependencies = [
 
 [[package]]
 name = "gemma-runner"
-version = "0.1.2"
+version = "0.1.3"
 dependencies = [
  "anyhow",
  "candle-core 0.9.1 (git+https://github.com/huggingface/candle.git)",
@@ -2274,7 +2274,7 @@ checksum = "2304e00983f87ffb38b55b444b5e3b60a884b5d30c0fca7d82fe33449bbe55ea"
 
 [[package]]
 name = "helm-chart-tool"
-version = "0.1.2"
+version = "0.1.3"
 dependencies = [
  "anyhow",
  "clap",
@@ -2684,7 +2684,7 @@ dependencies = [
 
 [[package]]
 name = "inference-engine"
-version = "0.1.2"
+version = "0.1.3"
 dependencies = [
  "ab_glyph",
  "anyhow",
@@ -3177,7 +3177,7 @@ checksum = "241eaef5fd12c88705a01fc1066c48c4b36e0dd4377dcdc7ec3942cea7a69956"
 
 [[package]]
 name = "llama-runner"
-version = "0.1.2"
+version = "0.1.3"
 dependencies = [
  "anyhow",
  "candle-core 0.9.1 (git+https://github.com/huggingface/candle.git)",
@@ -4056,7 +4056,7 @@ dependencies = [
 
 [[package]]
 name = "predict-otron-9000"
-version = "0.1.2"
+version = "0.1.3"
 dependencies = [
  "axum",
  "chat-ui",
diff --git a/crates/chat-ui/README.md b/crates/chat-ui/README.md
index edb321e..c37bc08 100644
--- a/crates/chat-ui/README.md
+++ b/crates/chat-ui/README.md
@@ -29,7 +29,7 @@ cd crates/chat-ui
 This starts the development server on port 8788 with auto-reload capabilities.
 
 ### Usage
-1. Start the predict-otron-9000 server: `./scripts/run_server.sh`
+1. Start the predict-otron-9000 server: `./scripts/run.sh`
 2. Start the chat-ui: `cd crates/chat-ui && ./run.sh`
 3. Navigate to `http://localhost:8788`
 4. Start chatting with your AI models!
diff --git a/crates/chat-ui/src/app.rs b/crates/chat-ui/src/app.rs
index 43dd2a5..6a540a6 100644
--- a/crates/chat-ui/src/app.rs
+++ b/crates/chat-ui/src/app.rs
@@ -12,7 +12,6 @@ pub struct AppConfig {
 
 impl Default for AppConfig {
     fn default() -> Self {
-
         let conf = get_configuration(Some(concat!(env!("CARGO_MANIFEST_DIR"), "/Cargo.toml")))
             .expect("failed to read config");
 
@@ -41,6 +40,7 @@ pub fn create_router(leptos_options: LeptosOptions) -> Router {
         .with_state(leptos_options)
 }
 
+use gloo_net::http::Request;
 use leptos::prelude::*;
 use leptos_meta::{provide_meta_context, MetaTags, Stylesheet, Title};
 use leptos_router::{
@@ -48,7 +48,6 @@ use leptos_router::{
     StaticSegment,
 };
 use serde::{Deserialize, Serialize};
-use gloo_net::http::Request;
 use web_sys::console;
 // Remove spawn_local import as we'll use different approach
 
@@ -122,7 +121,10 @@ pub async fn fetch_models() -> Result<Vec<ModelInfo>, String> {
 }
 
 // API client function to send chat completion requests
-pub async fn send_chat_completion(messages: Vec<ChatMessage>, model: String) -> Result<String, String> {
+pub async fn send_chat_completion(
+    messages: Vec<ChatMessage>,
+    model: String,
+) -> Result<String, String> {
     let request = ChatRequest {
         model,
         messages,
@@ -206,20 +208,20 @@ pub fn App() -> impl IntoView {
 fn ChatPage() -> impl IntoView {
     // State for conversation messages
     let messages = RwSignal::new(Vec::<ChatMessage>::new());
-    
+
     // State for current user input
     let input_text = RwSignal::new(String::new());
-    
+
     // State for loading indicator
     let is_loading = RwSignal::new(false);
-    
+
     // State for error messages
     let error_message = RwSignal::new(Option::<String>::None);
-    
+
     // State for available models and selected model
     let available_models = RwSignal::new(Vec::<ModelInfo>::new());
     let selected_model = RwSignal::new(String::from("gemma-3-1b-it")); // Default model
-    
+
     // Client-side only: Fetch models on component mount
     #[cfg(target_arch = "wasm32")]
     {
@@ -249,7 +251,7 @@ fn ChatPage() -> impl IntoView {
             role: "user".to_string(),
             content: user_input.clone(),
         };
-        
+
         messages.update(|msgs| msgs.push(user_message.clone()));
         input_text.set(String::new());
         is_loading.set(true);
@@ -259,11 +261,11 @@ fn ChatPage() -> impl IntoView {
         #[cfg(target_arch = "wasm32")]
         {
             use leptos::task::spawn_local;
-            
+
             // Prepare messages for API call
             let current_messages = messages.get();
             let current_model = selected_model.get();
-            
+
             // Spawn async task to call API
             spawn_local(async move {
                 match send_chat_completion(current_messages, current_model).await {
@@ -307,7 +309,7 @@ fn ChatPage() -> impl IntoView {
                 <h1>"Predict-Otron-9000 Chat"</h1>
                 <div class="model-selector">
                     <label for="model-select">"Model:"</label>
-                    <select 
+                    <select
                         id="model-select"
                         prop:value=move || selected_model.get()
                         on:change=move |ev| {
@@ -329,7 +331,7 @@ fn ChatPage() -> impl IntoView {
                     </select>
                 </div>
             </div>
-            
+
             <div class="chat-messages">
                 <For
                     each=move || messages.get().into_iter().enumerate()
@@ -344,7 +346,7 @@ fn ChatPage() -> impl IntoView {
                         }
                     }
                 />
-                
+
                 {move || {
                     if is_loading.get() {
                         view! {
@@ -379,7 +381,7 @@ fn ChatPage() -> impl IntoView {
                     on:keydown=on_key_down
                     class:disabled=move || is_loading.get()
                 />
-                <button 
+                <button
                     on:click=on_button_click
                     class:disabled=move || is_loading.get() || input_text.get().trim().is_empty()
                 >
diff --git a/crates/chat-ui/src/main.rs b/crates/chat-ui/src/main.rs
index 0fac0d9..bc4f200 100644
--- a/crates/chat-ui/src/main.rs
+++ b/crates/chat-ui/src/main.rs
@@ -1,14 +1,11 @@
-
-
-
 #[cfg(feature = "ssr")]
 #[tokio::main]
 async fn main() {
     use axum::Router;
+    use chat_ui::app::*;
     use leptos::logging::log;
     use leptos::prelude::*;
     use leptos_axum::{generate_route_list, LeptosRoutes};
-    use chat_ui::app::*;
 
     let conf = get_configuration(None).expect("failed to read config");
     let addr = conf.leptos_options.site_addr;
@@ -26,4 +23,4 @@ async fn main() {
 #[cfg(not(feature = "ssr"))]
 pub fn main() {
     // no client-side main function
-}
\ No newline at end of file
+}
diff --git a/crates/predict-otron-9000/src/main.rs b/crates/predict-otron-9000/src/main.rs
index 2af994b..6d4a517 100644
--- a/crates/predict-otron-9000/src/main.rs
+++ b/crates/predict-otron-9000/src/main.rs
@@ -4,27 +4,27 @@ mod middleware;
 mod standalone_mode;
 
 use crate::standalone_mode::create_standalone_router;
+use axum::handler::Handler;
+use axum::http::StatusCode as AxumStatusCode;
+use axum::http::header;
 use axum::response::IntoResponse;
 use axum::routing::get;
-use axum::{Router, http::Uri, response::Html, serve, ServiceExt};
+use axum::{Router, ServiceExt, http::Uri, response::Html, serve};
 use config::ServerConfig;
 use ha_mode::create_ha_router;
 use inference_engine::AppState;
+use log::info;
 use middleware::{MetricsLayer, MetricsLoggerFuture, MetricsStore};
+use mime_guess::from_path;
 use rust_embed::Embed;
 use std::env;
 use std::path::Component::ParentDir;
-use axum::handler::Handler;
-use axum::http::header;
-use mime_guess::from_path;
 use tokio::net::TcpListener;
 use tower::MakeService;
 use tower_http::classify::ServerErrorsFailureClass::StatusCode;
 use tower_http::cors::{Any, CorsLayer};
 use tower_http::trace::TraceLayer;
 use tracing_subscriber::{layer::SubscriberExt, util::SubscriberInitExt};
-use axum::http::{StatusCode as AxumStatusCode };
-use log::info;
 
 #[derive(Embed)]
 #[folder = "../../target/site"]
@@ -34,7 +34,6 @@ use log::info;
 #[include = "*.ico"]
 struct Asset;
 
-
 async fn static_handler(uri: Uri) -> axum::response::Response {
     // Strip the leading `/`
     let path = uri.path().trim_start_matches('/');
@@ -49,18 +48,12 @@ async fn static_handler(uri: Uri) -> axum::response::Response {
             let body = content.data.into_owned();
             let mime = from_path(path).first_or_octet_stream();
 
-            (
-                [(header::CONTENT_TYPE, mime.as_ref())],
-                body,
-            )
-                .into_response()
+            ([(header::CONTENT_TYPE, mime.as_ref())], body).into_response()
         }
         None => (AxumStatusCode::NOT_FOUND, "404 Not Found").into_response(),
     }
 }
 
-
-
 #[tokio::main]
 async fn main() {
     // Initialize tracing
@@ -123,7 +116,6 @@ async fn main() {
     // Create the leptos router for the web frontend
     let leptos_router = chat_ui::app::create_router(leptos_config.config.leptos_options);
 
-
     // Merge the service router with base routes and add middleware layers
     let app = Router::new()
         .route("/pkg/{*path}", get(static_handler))