feat: add syntax highlighting for Nushell

changes/v0.15.10.md

@@ -0,0 +1,2 @@
+- it's now possible to directly copy images into Stacks, using the macOS
+  content menu

src-tauri/src/commands.rs

@@ -12,7 +12,7 @@ use crate::state::SharedState;
 use crate::store::{
     InProgressStream, MimeType, Movement, Settings, StackLockStatus, StackSortOrder,
 };
-use crate::ui::{generate_preview, with_meta, Item as UIItem, Nav, UI};
+use crate::ui::{with_meta, Item as UIItem, Nav, UI};
 use crate::view::View;
 
 #[derive(Debug, Clone, serde::Serialize)]
@@ -170,13 +170,15 @@ pub async fn store_pipe_stack_to_shell(
                         streamer.append(&buffer[..size]);
 
                         if mime_type == MimeType::TextPlain {
-                            let preview = generate_preview(
-                                "dark",
-                                &Some(streamer.content.clone()),
-                                &streamer.content_meta.mime_type,
-                                &streamer.content_meta.content_type,
-                                true,
-                            );
+                            let preview = state.with_lock(|state| {
+                                state.ui.generate_preview(
+                                    &Some(streamer.content.clone()),
+                                    &streamer.content_meta.mime_type,
+                                    &streamer.content_meta.content_type,
+                                    true,
+                                )
+                            });
+
                             let content = String::from_utf8_lossy(&streamer.content);
                             let content = Content {
                                 mime_type: streamer.content_meta.mime_type.clone(),
@@ -403,13 +405,15 @@ pub async fn store_pipe_to_command(
                         streamer.append(&buffer[..size]);
 
                         if mime_type == MimeType::TextPlain {
-                            let preview = generate_preview(
-                                "dark",
-                                &Some(streamer.content.clone()),
-                                &streamer.content_meta.mime_type,
-                                &streamer.content_meta.content_type,
-                                true,
-                            );
+                            let preview = state.with_lock(|state| {
+                                state.ui.generate_preview(
+                                    &Some(streamer.content.clone()),
+                                    &streamer.content_meta.mime_type,
+                                    &streamer.content_meta.content_type,
+                                    true,
+                                )
+                            });
+
                             let content = String::from_utf8_lossy(&streamer.content);
                             let content = Content {
                                 mime_type: streamer.content_meta.mime_type.clone(),
@@ -574,13 +578,10 @@ pub fn store_get_content(state: tauri::State<SharedState>, hash: ssri::Integrity
             _ => (0, 0),
         };
 
-        let preview = generate_preview(
-            &state.ui.theme_mode,
-            &content,
-            &meta.mime_type,
-            &meta.content_type,
-            false,
-        );
+        let preview =
+            state
+                .ui
+                .generate_preview(&content, &meta.mime_type, &meta.content_type, false);
 
         Content {
             mime_type: meta.mime_type,

src-tauri/src/http.rs

@@ -18,7 +18,6 @@ use hyper_util::rt::TokioIo;
 
 use crate::state::SharedState;
 use crate::store::{infer_mime_type, InProgressStream, MimeType};
-use crate::ui::generate_preview;
 
 type BoxError = Box<dyn std::error::Error + Send + Sync>;
 type HTTPResult = Result<Response<BoxBody<Bytes, BoxError>>, BoxError>;
@@ -59,14 +58,9 @@ fn get_as_html(state: SharedState, hash: ssri::Integrity) -> HTTPResult {
     let preview = state.with_lock(|state| {
         let content = state.store.get_content(&hash);
         let meta = state.store.get_content_meta(&hash).unwrap();
-
-        generate_preview(
-            &state.ui.theme_mode,
-            &content,
-            &meta.mime_type,
-            &meta.content_type,
-            false,
-        )
+        state
+            .ui
+            .generate_preview(&content, &meta.mime_type, &meta.content_type, false)
     });
 
     Ok(Response::builder()
@@ -158,13 +152,14 @@ async fn post(
     while let Some(frame) = body.frame().await {
         let data = frame?.into_data().unwrap();
         streamer.append(&data);
-        let preview = generate_preview(
-            "dark",
-            &Some(streamer.content.clone()),
-            &MimeType::TextPlain,
-            &"Text".to_string(),
-            true,
-        );
+        let preview = state.with_lock(|state| {
+            state.ui.generate_preview(
+                &Some(streamer.content.clone()),
+                &MimeType::TextPlain,
+                &"Text".to_string(),
+                true,
+            )
+        });
 
         let content = String::from_utf8_lossy(&streamer.content);
         let content = Content {

src-tauri/src/main.rs

@@ -10,7 +10,6 @@ mod commands;
 mod content_bus;
 mod content_type;
 mod http;
-mod publish;
 mod serve;
 mod spotlight;
 mod state;

src-tauri/src/serve.rs

@@ -12,7 +12,6 @@ use crate::clipboard;
 use crate::commands;
 use crate::content_bus;
 use crate::http;
-use crate::publish;
 use crate::spotlight;
 use crate::state::{SharedState, State};
 
@@ -101,14 +100,12 @@ pub async fn serve<A: tauri::Assets>(context: tauri::Context<A>, db_path: String
                 let _ = window.move_window(Position::Center);
             }
 
-            let (packet_sender, packet_receiver) = std::sync::mpsc::channel();
-
+            let (packet_sender, _) = std::sync::mpsc::channel();
             let state = State::new(&db_path, packet_sender);
             let mutex = tracing_mutex_span::TracingMutexSpan::new("SharedState", state);
             let state: SharedState = Arc::new(mutex);
             app.manage(state.clone());
 
-            publish::spawn(state.clone(), packet_receiver);
             content_bus::spawn_tiktokens(app.handle(), state.clone());
 
             http::start(app.handle().clone(), state.clone(), &db_path);