chore: Release

Cargo.lock

@@ -863,9 +863,9 @@ dependencies = [
 
 [[package]]
 name = "clap"
-version = "4.5.36"
+version = "4.5.37"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "2df961d8c8a0d08aa9945718ccf584145eee3f3aa06cddbeac12933781102e04"
+checksum = "eccb054f56cbd38340b380d4a8e69ef1f02f1af43db2f0cc817a4774d80ae071"
 dependencies = [
  "clap_builder",
  "clap_derive",
@@ -873,9 +873,9 @@ dependencies = [
 
 [[package]]
 name = "clap_builder"
-version = "4.5.36"
+version = "4.5.37"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "132dbda40fb6753878316a489d5a1242a8ef2f0d9e47ba01c951ea8aa7d013a5"
+checksum = "efd9466fac8543255d3b1fcad4762c5e116ffe808c8a3043d4263cd4fd4862a2"
 dependencies = [
  "anstream",
  "anstyle",
@@ -2995,7 +2995,7 @@ dependencies = [
 
 [[package]]
 name = "letterbox-notmuch"
-version = "0.15.7"
+version = "0.15.9"
 dependencies = [
  "itertools",
  "log",
@@ -3010,14 +3010,15 @@ dependencies = [
 
 [[package]]
 name = "letterbox-procmail2notmuch"
-version = "0.15.7"
+version = "0.15.9"
 dependencies = [
  "anyhow",
+ "clap",
 ]
 
 [[package]]
 name = "letterbox-server"
-version = "0.15.7"
+version = "0.15.9"
 dependencies = [
  "ammonia",
  "anyhow",
@@ -3061,7 +3062,7 @@ dependencies = [
 
 [[package]]
 name = "letterbox-shared"
-version = "0.15.7"
+version = "0.15.9"
 dependencies = [
  "build-info",
  "letterbox-notmuch",
@@ -3071,7 +3072,7 @@ dependencies = [
 
 [[package]]
 name = "letterbox-web"
-version = "0.15.7"
+version = "0.15.9"
 dependencies = [
  "build-info",
  "build-info-build",

Cargo.toml

@@ -8,7 +8,7 @@ authors = ["Bill Thiede <git@xinu.tv>"]
 edition = "2021"
 license = "UNLICENSED"
 publish = ["xinu"]
-version = "0.15.7"
+version = "0.15.9"
 repository = "https://git.z.xinu.tv/wathiede/letterbox"
 
 [profile.dev]

procmail2notmuch/Cargo.toml

@@ -12,3 +12,4 @@ version.workspace = true
 
 [dependencies]
 anyhow = "1.0.69"
+clap = { version = "4.5.37", features = ["derive"] }

procmail2notmuch/src/main.rs

@@ -1,13 +1,15 @@
-use std::{convert::Infallible, io::Write, str::FromStr};
+use std::{collections::HashMap, convert::Infallible, io::Write, str::FromStr};
 
-#[derive(Debug, Default)]
+use clap::{Parser, ValueEnum};
+
+#[derive(Copy, Clone, Debug, Default, PartialEq, Eq, Hash, Ord, PartialOrd)]
 enum MatchType {
     From,
     Sender,
     To,
     Cc,
     Subject,
-    List,
+    ListId,
     DeliveredTo,
     XForwardedTo,
     ReplyTo,
@@ -26,7 +28,7 @@ struct Match {
 #[derive(Debug, Default)]
 struct Rule {
     matches: Vec<Match>,
-    tags: Vec<String>,
+    tags: Option<String>,
 }
 
 fn unescape(s: &str) -> String {
@@ -38,6 +40,10 @@ fn cleanup_match(prefix: &str, s: &str) -> String {
 }
 
 mod matches {
+    // From https://linux.die.net/man/5/procmailrc
+    // If the regular expression contains '^TO_' it will be substituted by '(^((Original-)?(Resent-)?(To|Cc|Bcc)|(X-Envelope |Apparently(-Resent)?)-To):(.*[^-a-zA-Z0-9_.])?)'
+    // If the regular expression contains '^TO' it will be substituted by '(^((Original-)?(Resent-)?(To|Cc|Bcc)|(X-Envelope |Apparently(-Resent)?)-To):(.*[^a-zA-Z])?)', which should catch all destination specifications containing a specific word.
+
     pub const TO: &'static str = "TO";
     pub const CC: &'static str = "Cc";
     pub const TOCC: &'static str = "(TO|Cc)";
@@ -109,7 +115,7 @@ impl FromStr for Match {
                 });
             } else if needle.starts_with(LIST_ID) {
                 return Ok(Match {
-                    match_type: MatchType::List,
+                    match_type: MatchType::ListId,
                     needle: cleanup_match(LIST_ID, needle),
                 });
             } else if needle.starts_with(REPLY_TO) {
@@ -155,7 +161,7 @@ fn notmuch_from_rules<W: Write>(mut w: W, rules: &[Rule]) -> anyhow::Result<()>
     let mut lines = Vec::new();
     for r in rules {
         for m in &r.matches {
-            for t in &r.tags {
+            if let Some(t) = &r.tags {
                 if let MatchType::Unknown = m.match_type {
                     eprintln!("rule has unknown match {:?}", r);
                     continue;
@@ -168,7 +174,7 @@ fn notmuch_from_rules<W: Write>(mut w: W, rules: &[Rule]) -> anyhow::Result<()>
                     MatchType::To => "to:",
                     MatchType::Cc => "to:",
                     MatchType::Subject => "subject:",
-                    MatchType::List => "List-ID:",
+                    MatchType::ListId => "List-ID:",
                     MatchType::Body => "",
                     // TODO(wathiede): these will probably require adding fields to notmuch
                     // index. Handle them later.
@@ -200,11 +206,28 @@ fn notmuch_from_rules<W: Write>(mut w: W, rules: &[Rule]) -> anyhow::Result<()>
     Ok(())
 }
 
+#[derive(Debug, Copy, Clone, PartialEq, Eq, PartialOrd, Ord, ValueEnum)]
+enum Mode {
+    Debug,
+    Notmuchrc,
+}
+
+/// Simple program to greet a person
+#[derive(Parser, Debug)]
+#[command(version, about, long_about = None)]
+struct Args {
+    #[arg(short, long, default_value = "/home/wathiede/dotfiles/procmailrc")]
+    input: String,
+
+    #[arg(value_enum)]
+    mode: Mode,
+}
+
 fn main() -> anyhow::Result<()> {
-    let input = "/home/wathiede/dotfiles/procmailrc";
+    let args = Args::parse();
     let mut rules = Vec::new();
     let mut cur_rule = Rule::default();
-    for l in std::fs::read_to_string(input)?.lines() {
+    for l in std::fs::read_to_string(args.input)?.lines() {
         let l = if let Some(idx) = l.find('#') {
             &l[..idx]
         } else {
@@ -230,7 +253,7 @@ fn main() -> anyhow::Result<()> {
             }
             '.' => {
                 // delivery to folder
-                cur_rule.tags.push(cleanup_match(
+                cur_rule.tags = Some(cleanup_match(
                     "",
                     &l.replace('.', "/")
                         .replace(' ', "")
@@ -240,16 +263,35 @@ fn main() -> anyhow::Result<()> {
                 rules.push(cur_rule);
                 cur_rule = Rule::default();
             }
+            '/' => cur_rule = Rule::default(), // Ex. /dev/null
             '|' => cur_rule = Rule::default(), // external command
             '$' => {
                 // TODO(wathiede): tag messages with no other tag as 'inbox'
-                cur_rule.tags.push(cleanup_match("", "inbox"));
+                cur_rule.tags = Some(cleanup_match("", "inbox"));
                 rules.push(cur_rule);
                 cur_rule = Rule::default();
             } // variable, should only be $DEFAULT in my config
-            _ => panic!("Unhandled first character '{}' {}", first, l),
+            _ => panic!("Unhandled first character '{}'\nLine: {}", first, l),
         }
     }
-    notmuch_from_rules(std::io::stdout(), &rules)?;
+    match args.mode {
+        Mode::Debug => print_rules(&rules),
+        Mode::Notmuchrc => notmuch_from_rules(std::io::stdout(), &rules)?,
+    }
     Ok(())
 }
+
+fn print_rules(rules: &[Rule]) {
+    let mut tally = HashMap::new();
+    for r in rules {
+        for m in &r.matches {
+            *tally.entry(m.match_type).or_insert(0) += 1;
+        }
+    }
+    let mut sorted: Vec<_> = tally.iter().map(|(k, v)| (v, k)).collect();
+    sorted.sort();
+    sorted.reverse();
+    for (v, k) in sorted {
+        println!("{k:?}: {v}");
+    }
+}

server/Cargo.toml

@@ -27,8 +27,8 @@ css-inline = "0.14.0"
 futures = "0.3.31"
 headers = "0.4.0"
 html-escape = "0.2.13"
-letterbox-notmuch = { version = "0.15.7", path = "../notmuch", registry = "xinu" }
-letterbox-shared = { version = "0.15.7", path = "../shared", registry = "xinu" }
+letterbox-notmuch = { version = "0.15.9", path = "../notmuch", registry = "xinu" }
+letterbox-shared = { version = "0.15.9", path = "../shared", registry = "xinu" }
 linkify = "0.10.0"
 log = "0.4.17"
 lol_html = "2.0.0"

server/src/bin/letterbox-server.rs

@@ -29,7 +29,7 @@ use serde::Deserialize;
 use sqlx::postgres::PgPool;
 use tokio::{net::TcpListener, sync::Mutex};
 use tower_http::trace::{DefaultMakeSpan, TraceLayer};
-use tracing::info;
+use tracing::{info, warn};
 
 // Make our own error that wraps `anyhow::Error`.
 struct AppError(letterbox_server::ServerError);
@@ -142,6 +142,25 @@ async fn view_cid(
     Ok(inline_attachment_response(attachment))
 }
 
+async fn view_original(
+    State(AppState { nm, .. }): State<AppState>,
+    extract::Path(id): extract::Path<String>,
+) -> Result<impl IntoResponse, AppError> {
+    info!("view_original {id}");
+    let mid = if id.starts_with("id:") {
+        id.to_string()
+    } else {
+        format!("id:{}", id)
+    };
+    let files = nm.files(&mid)?;
+    let Some(path) = files.first() else {
+        warn!("failed to find files for message {mid}");
+        return Ok((StatusCode::NOT_FOUND, mid).into_response());
+    };
+    let str = std::fs::read_to_string(&path)?;
+    Ok(str.into_response())
+}
+
 async fn graphiql() -> impl IntoResponse {
     response::Html(
         GraphiQLSource::build()
@@ -260,6 +279,7 @@ async fn main() -> Result<(), Box<dyn Error>> {
             get(download_attachment),
         )
         .route("/view/attachment/{id}/{idx}/{*rest}", get(view_attachment))
+        .route("/original/{id}", get(view_original))
         .route("/cid/{id}/{cid}", get(view_cid))
         .route("/ws", any(start_ws))
         .route_service("/graphql/ws", GraphQLSubscription::new(schema.clone()))

shared/Cargo.toml

@@ -12,6 +12,6 @@ version.workspace = true
 
 [dependencies]
 build-info = "0.0.40"
-letterbox-notmuch = { version = "0.15.7", path = "../notmuch", registry = "xinu" }
+letterbox-notmuch = { version = "0.15.9", path = "../notmuch", registry = "xinu" }
 serde = { version = "1.0.147", features = ["derive"] }
 strum_macros = "0.27.1"

shared/src/lib.rs

@@ -20,6 +20,13 @@ pub enum WebsocketMessage {
 
 pub mod urls {
     pub const MOUNT_POINT: &'static str = "/api";
+    pub fn view_original(host: Option<&str>, id: &str) -> String {
+        if let Some(host) = host {
+            format!("//{host}/api/original/{id}")
+        } else {
+            format!("/api/original/{id}")
+        }
+    }
     pub fn cid_prefix(host: Option<&str>, cid: &str) -> String {
         if let Some(host) = host {
             format!("//{host}/api/cid/{cid}/")

web/Cargo.toml

@@ -33,8 +33,8 @@ wasm-bindgen = "=0.2.100"
 uuid = { version = "1.13.1", features = [
   "js",
 ] } # direct dep to set js feature, prevents Rng issues
-letterbox-shared = { version = "0.15.7", path = "../shared", registry = "xinu" }
-letterbox-notmuch = { version = "0.15.7", path = "../notmuch", registry = "xinu" }
+letterbox-shared = { version = "0.15.9", path = "../shared", registry = "xinu" }
+letterbox-notmuch = { version = "0.15.9", path = "../notmuch", registry = "xinu" }
 seed_hooks = { version = "0.4.0", registry = "xinu" }
 strum_macros = "0.27.1"
 gloo-console = "0.3.0"

web/src/view/mod.rs

@@ -694,6 +694,8 @@ fn render_open_header(msg: &ShowThreadQueryThreadOnEmailThreadMessages) -> Node<
         .collect();
     let show_x_original_to = !*to_xinu.borrow() && msg.x_original_to.is_some();
     let show_delivered_to = !*to_xinu.borrow() && !show_x_original_to && msg.delivered_to.is_some();
+    let host = seed::window().location().host().expect("couldn't get host");
+    let href = letterbox_shared::urls::view_original(Some(&host), &msg.id);
     div![
         C!["flex", "p-4", "bg-neutral-800"],
         div![avatar],
@@ -775,6 +777,8 @@ fn render_open_header(msg: &ShowThreadQueryThreadOnEmailThreadMessages) -> Node<
             C!["text-right"],
             msg.timestamp
                 .map(|ts| div![C!["text-xs", "text-nowrap"], human_age(ts)]),
+            div![
+                C!["p-2"],
                 i![C![
                     "mx-4",
                     "read-status",
@@ -789,6 +793,20 @@ fn render_open_header(msg: &ShowThreadQueryThreadOnEmailThreadMessages) -> Node<
                     e.stop_propagation();
                     Msg::SetUnread(id, !is_unread)
                 }),
+            ],
+            div![
+                C!["text-xs"],
+                span![a![
+                    attrs! {
+                        At::Href=>href,
+                        At::Target=>"_blank",
+                    },
+                    "View original",
+                    ev(Ev::Click, move |e| {
+                        e.stop_propagation();
+                    })
+                ]]
+            ]
         ]
     ]
 }
@@ -931,6 +949,8 @@ fn render_closed_header(msg: &ShowThreadQueryThreadOnEmailThreadMessages) -> Nod
             C!["text-right"],
             msg.timestamp
                 .map(|ts| div![C!["text-xs", "text-nowrap"], human_age(ts)]),
+            div![
+                C!["p-2"],
                 i![C![
                     "mx-4",
                     "read-status",
@@ -944,7 +964,8 @@ fn render_closed_header(msg: &ShowThreadQueryThreadOnEmailThreadMessages) -> Nod
                 ev(Ev::Click, move |e| {
                     e.stop_propagation();
                     Msg::SetUnread(id, !is_unread)
-            }),
+                })
+            ],
         ]
     ]
 }
@@ -977,7 +998,7 @@ fn message_render(msg: &ShowThreadQueryThreadOnEmailThreadMessages, open: bool)
         ],
         IF!(open =>
         div![
-            C!["bg-white", "text-black", "p-4", "min-w-full", "w-0","overflow-x-auto", from],
+            C!["content", "bg-white", "text-black", "p-4", "min-w-full", "w-0","overflow-x-auto", from],
             match &msg.body {
                 ShowThreadQueryThreadOnEmailThreadMessagesBody::UnhandledContentType(
                     ShowThreadQueryThreadOnEmailThreadMessagesBodyOnUnhandledContentType { contents ,content_tree},
@@ -1081,7 +1102,6 @@ fn render_attachements(
     ]
 }
 
-// TODO: add cathup_mode:bool and hide elements when true
 #[topo::nested]
 fn thread(
     thread: &ShowThreadQueryThreadOnEmailThread,
@@ -1172,13 +1192,7 @@ fn thread(
             el_ref(content_el),
             messages,
             IF!(!catchup_mode => click_to_top())
-        ],
-        /* TODO(wathiede): plumb in orignal id
-        a![
-        attrs! {At::Href=>api::original(&thread_node.0.as_ref().expect("message missing").id)},
-        "Original"
-        ],
-        */
+        ]
     ]
 }
 

web/static/overrides.css

@@ -2,23 +2,23 @@ html {
   background-color: black;
 }
 
-.mail-thread a,
+.mail-thread .content a,
 .news-post a {
   color: var(--color-link) !important;
   text-decoration: underline;
 }
 
-.mail-thread br,
+.mail-thread .content br,
 .news-post br {
   display: block;
   margin-top: 1em;
   content: " ";
 }
 
-.mail-thread h1,
-.mail-thread h2,
-.mail-thread h3,
-.mail-thread h4,
+.mail-thread .content h1,
+.mail-thread .content h2,
+.mail-thread .content h3,
+.mail-thread .content h4,
 .news-post h1,
 .news-post h2,
 .news-post h3,
@@ -27,12 +27,12 @@ html {
   margin-bottom: 1em !important;
 }
 
-.mail-thread p,
+.mail-thread .content p,
 .news-post p {
   margin-bottom: 1em;
 }
 
-.mail-thread pre,
+.mail-thread .content pre,
 .news-post pre {
   font-family: monospace;
   background-color: #eee !important;
@@ -40,28 +40,28 @@ html {
   white-space: break-spaces;
 }
 
-.mail-thread code,
+.mail-thread .content code,
 .news-post code {
   font-family: monospace;
   white-space: break-spaces;
   background-color: #eee !important;
 }
 
-.mail-thread blockquote {
+.mail-thread .content blockquote {
   padding-left: 1em;
   border-left: 2px solid #ddd;
 }
 
-.mail-thread ol,
-.mail-thread ul {
+.mail-thread .content ol,
+.mail-thread .content ul {
   margin-left: 2em;
 }
 
-.mail-thread .noreply-news-bloomberg-com a {
+.mail-thread .content .noreply-news-bloomberg-com a {
   background-color: initial !important;
 }
 
-.mail-thread .noreply-news-bloomberg-com h2 {
+.mail-thread .content .noreply-news-bloomberg-com h2 {
   margin: 0 !important;
   padding: 0 !important;
 }