chore: Release

Cargo.lock

@@ -2995,7 +2995,7 @@ dependencies = [
 
 [[package]]
 name = "letterbox-notmuch"
-version = "0.15.9"
+version = "0.15.11"
 dependencies = [
  "itertools",
  "log",
@@ -3010,15 +3010,18 @@ dependencies = [
 
 [[package]]
 name = "letterbox-procmail2notmuch"
-version = "0.15.9"
+version = "0.15.11"
 dependencies = [
  "anyhow",
  "clap",
+ "serde",
+ "sqlx",
+ "tokio 1.44.2",
 ]
 
 [[package]]
 name = "letterbox-server"
-version = "0.15.9"
+version = "0.15.11"
 dependencies = [
  "ammonia",
  "anyhow",
@@ -3062,7 +3065,7 @@ dependencies = [
 
 [[package]]
 name = "letterbox-shared"
-version = "0.15.9"
+version = "0.15.11"
 dependencies = [
  "build-info",
  "letterbox-notmuch",
@@ -3072,7 +3075,7 @@ dependencies = [
 
 [[package]]
 name = "letterbox-web"
-version = "0.15.9"
+version = "0.15.11"
 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.9"
+version = "0.15.11"
 repository = "https://git.z.xinu.tv/wathiede/letterbox"
 
 [profile.dev]

procmail2notmuch/Cargo.toml

@@ -12,4 +12,7 @@ version.workspace = true
 
 [dependencies]
 anyhow = "1.0.69"
-clap = { version = "4.5.37", features = ["derive"] }
+clap = { version = "4.5.37", features = ["derive", "env"] }
+serde = { version = "1.0.219", features = ["derive"] }
+sqlx = { version = "0.8.5", features = ["postgres", "runtime-tokio"] }
+tokio = { version = "1.44.2", features = ["rt", "macros", "rt-multi-thread"] }

procmail2notmuch/src/main.rs

@@ -1,8 +1,12 @@
 use std::{collections::HashMap, convert::Infallible, io::Write, str::FromStr};
 
-use clap::{Parser, ValueEnum};
+use clap::{Parser, Subcommand};
+use serde::{Deserialize, Serialize};
+use sqlx::{types::Json, PgPool};
 
-#[derive(Copy, Clone, Debug, Default, PartialEq, Eq, Hash, Ord, PartialOrd)]
+#[derive(
+    Copy, Clone, Debug, Default, PartialEq, Eq, Hash, Ord, PartialOrd, Serialize, Deserialize,
+)]
 enum MatchType {
     From,
     Sender,
@@ -19,16 +23,17 @@ enum MatchType {
     #[default]
     Unknown,
 }
-#[derive(Debug, Default)]
+#[derive(Debug, Default, Serialize, Deserialize)]
 struct Match {
     match_type: MatchType,
     needle: String,
 }
 
-#[derive(Debug, Default)]
+#[derive(Debug, Default, Serialize, Deserialize)]
 struct Rule {
+    stop_on_match: bool,
     matches: Vec<Match>,
-    tags: Option<String>,
+    tag: Option<String>,
 }
 
 fn unescape(s: &str) -> String {
@@ -155,13 +160,109 @@ impl FromStr for Match {
     }
 }
 
+#[derive(Debug, Subcommand)]
+enum Mode {
+    Debug,
+    Notmuchrc,
+    LoadSql {
+        #[arg(short, long, default_value = env!("DATABASE_URL"))]
+        dsn: String,
+    },
+}
+
+/// 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,
+
+    #[command(subcommand)]
+    mode: Mode,
+}
+
+#[tokio::main]
+async fn main() -> anyhow::Result<()> {
+    let args = Args::parse();
+    let mut rules = Vec::new();
+    let mut cur_rule = Rule::default();
+    for l in std::fs::read_to_string(args.input)?.lines() {
+        let l = if let Some(idx) = l.find('#') {
+            &l[..idx]
+        } else {
+            l
+        }
+        .trim();
+        if l.is_empty() {
+            continue;
+        }
+        if l.find('=').is_some() {
+            // Probably a variable assignment, skip line
+            continue;
+        }
+        let first = l.chars().nth(0).unwrap_or(' ');
+        match first {
+            ':' => {
+                // start of rule
+            }
+            '*' => {
+                // add to current rule
+                let m: Match = l.parse()?;
+                cur_rule.matches.push(m);
+            }
+            '.' => {
+                // delivery to folder
+                cur_rule.tag = Some(cleanup_match(
+                    "",
+                    &l.replace('.', "/")
+                        .replace(' ', "")
+                        .trim_matches('/')
+                        .to_string(),
+                ));
+                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.tag = Some(cleanup_match("", "inbox"));
+                rules.push(cur_rule);
+                cur_rule = Rule::default();
+            } // variable, should only be $DEFAULT in my config
+            _ => panic!("Unhandled first character '{}'\nLine: {}", first, l),
+        }
+    }
+    match args.mode {
+        Mode::Debug => print_rules(&rules),
+        Mode::Notmuchrc => notmuch_from_rules(std::io::stdout(), &rules)?,
+        Mode::LoadSql { dsn } => load_sql(&dsn, &rules).await?,
+    }
+    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}");
+    }
+}
+
 fn notmuch_from_rules<W: Write>(mut w: W, rules: &[Rule]) -> anyhow::Result<()> {
     // TODO(wathiede): if reindexing this many tags is too slow, see if combining rules per tag is
     // faster.
     let mut lines = Vec::new();
     for r in rules {
         for m in &r.matches {
-            if let Some(t) = &r.tags {
+            if let Some(t) = &r.tag {
                 if let MatchType::Unknown = m.match_type {
                     eprintln!("rule has unknown match {:?}", r);
                     continue;
@@ -206,92 +307,25 @@ fn notmuch_from_rules<W: Write>(mut w: W, rules: &[Rule]) -> anyhow::Result<()>
     Ok(())
 }
 
-#[derive(Debug, Copy, Clone, PartialEq, Eq, PartialOrd, Ord, ValueEnum)]
+async fn load_sql(dsn: &str, rules: &[Rule]) -> anyhow::Result<()> {
-enum Mode {
+    let pool = PgPool::connect(dsn).await?;
-    Debug,
+    println!("clearing email_rule table");
-    Notmuchrc,
+    sqlx::query!("DELETE FROM email_rule")
-}
+        .execute(&pool)
+        .await?;
 
-/// Simple program to greet a person
+    for (order, rule) in rules.iter().enumerate() {
-#[derive(Parser, Debug)]
+        println!("inserting {order}: {rule:?}");
-#[command(version, about, long_about = None)]
+        sqlx::query!(
-struct Args {
+            r#"
-    #[arg(short, long, default_value = "/home/wathiede/dotfiles/procmailrc")]
+        INSERT INTO email_rule (sort_order, rule)
-    input: String,
+        VALUES ($1, $2)
-
+            "#,
-    #[arg(value_enum)]
+            order as i32,
-    mode: Mode,
+            Json(rule) as _
-}
+        )
-
+        .execute(&pool)
-fn main() -> anyhow::Result<()> {
+        .await?;
-    let args = Args::parse();
-    let mut rules = Vec::new();
-    let mut cur_rule = Rule::default();
-    for l in std::fs::read_to_string(args.input)?.lines() {
-        let l = if let Some(idx) = l.find('#') {
-            &l[..idx]
-        } else {
-            l
-        }
-        .trim();
-        if l.is_empty() {
-            continue;
-        }
-        if l.find('=').is_some() {
-            // Probably a variable assignment, skip line
-            continue;
-        }
-        let first = l.chars().nth(0).unwrap_or(' ');
-        match first {
-            ':' => {
-                // start of rule
-            }
-            '*' => {
-                // add to current rule
-                let m: Match = l.parse()?;
-                cur_rule.matches.push(m);
-            }
-            '.' => {
-                // delivery to folder
-                cur_rule.tags = Some(cleanup_match(
-                    "",
-                    &l.replace('.', "/")
-                        .replace(' ', "")
-                        .trim_matches('/')
-                        .to_string(),
-                ));
-                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 = Some(cleanup_match("", "inbox"));
-                rules.push(cur_rule);
-                cur_rule = Rule::default();
-            } // variable, should only be $DEFAULT in my config
-            _ => panic!("Unhandled first character '{}'\nLine: {}", first, l),
-        }
-    }
-    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.9", path = "../notmuch", registry = "xinu" }
+letterbox-notmuch = { version = "0.15.11", path = "../notmuch", registry = "xinu" }
-letterbox-shared = { version = "0.15.9", path = "../shared", registry = "xinu" }
+letterbox-shared = { version = "0.15.11", path = "../shared", registry = "xinu" }
 linkify = "0.10.0"
 log = "0.4.17"
 lol_html = "2.0.0"

server/migrations/20250419202131_email-rules.down.sql

@@ -0,0 +1,3 @@
+DROP TABLE IF NOT EXISTS email_rule;
+
+-- Add down migration script here

server/migrations/20250419202131_email-rules.up.sql

@@ -0,0 +1,5 @@
+CREATE TABLE IF NOT EXISTS email_rule (
+    id integer NOT NULL GENERATED ALWAYS AS IDENTITY,
+    sort_order integer NOT NULL,
+    rule jsonb NOT NULL
+);

server/src/bin/letterbox-server.rs

@@ -142,6 +142,7 @@ async fn view_cid(
     Ok(inline_attachment_response(attachment))
 }
 
+// TODO make this work with gitea message ids like `wathiede/letterbox/pulls/91@git.z.xinu.tv`
 async fn view_original(
     State(AppState { nm, .. }): State<AppState>,
     extract::Path(id): extract::Path<String>,

shared/Cargo.toml

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

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.9", path = "../shared", registry = "xinu" }
+letterbox-shared = { version = "0.15.11", path = "../shared", registry = "xinu" }
-letterbox-notmuch = { version = "0.15.9", path = "../notmuch", registry = "xinu" }
+letterbox-notmuch = { version = "0.15.11", path = "../notmuch", registry = "xinu" }
 seed_hooks = { version = "0.4.0", registry = "xinu" }
 strum_macros = "0.27.1"
 gloo-console = "0.3.0"
@@ -50,9 +50,10 @@ features = [
   "Clipboard",
   "DomRect",
   "Element",
+  "History",
   "MediaQueryList",
   "Navigator",
-  "Window",
+  "Performance",
-  "History",
   "ScrollRestoration",
+  "Window",
 ]

web/src/view/mod.rs

@@ -263,81 +263,107 @@ fn search_results(
     } else {
         set_title(query);
     }
-    let rows = results.iter().map(|r| {
+    let rows: Vec<_> = results
-        let tid = r.thread.clone();
+        .iter()
-        let check_tid = r.thread.clone();
+        .map(|r| {
-        let datetime = human_age(r.timestamp as i64);
+            let tid = r.thread.clone();
-        let unread_idx = r.tags.iter().position(|e| e == &"unread");
+            let check_tid = r.thread.clone();
-        let mut tags = r.tags.clone();
+            let datetime = human_age(r.timestamp as i64);
-        if let Some(idx) = unread_idx {
+            let unread_idx = r.tags.iter().position(|e| e == &"unread");
-            tags.remove(idx);
+            let mut tags = r.tags.clone();
-        };
+            if let Some(idx) = unread_idx {
-        let is_unread = unread_idx.is_some();
+                tags.remove(idx);
-        let mut title_break = None;
+            };
-        const TITLE_LENGTH_WRAP_LIMIT: usize = 40;
+            let is_unread = unread_idx.is_some();
-        for w in r.subject.split_whitespace() {
+            let mut title_break = None;
-            if w.len() > TITLE_LENGTH_WRAP_LIMIT {
+            const TITLE_LENGTH_WRAP_LIMIT: usize = 40;
-                title_break = Some(C!["break-all", "text-pretty"]);
+            for w in r.subject.split_whitespace() {
+                if w.len() > TITLE_LENGTH_WRAP_LIMIT {
+                    title_break = Some(C!["break-all", "text-pretty"]);
+                }
             }
-        }
-        div![
-            C![
-                "flex",
-                "flex-nowrap",
-                "w-auto",
-                "flex-auto",
-                "py-4",
-                "border-b",
-                "border-neutral-800"
-            ],
             div![
-                C!["flex", "items-center", "mr-4"],
+                C![
-                input![
+                    "flex",
-                    C![&tw_classes::CHECKBOX],
+                    "flex-nowrap",
-                    attrs! {
+                    "w-auto",
-                        At::Type=>"checkbox",
+                    "flex-auto",
-                        At::Checked=>selected_threads.contains(&tid).as_at_value(),
+                    "py-4",
-                    }
+                    "border-b",
+                    "border-neutral-800"
                 ],
-                ev(Ev::Input, move |e| {
-                    if let Some(input) = e
-                        .target()
-                        .as_ref()
-                        .expect("failed to get reference to target")
-                        .dyn_ref::<web_sys::HtmlInputElement>()
-                    {
-                        if input.checked() {
-                            Msg::SelectionAddThread(check_tid)
-                        } else {
-                            Msg::SelectionRemoveThread(check_tid)
-                        }
-                    } else {
-                        Msg::Noop
-                    }
-                }),
-            ],
-            a![
-                C!["flex-grow"],
-                IF!(is_unread => C!["font-bold"]),
-                attrs! {
-                    At::Href => urls::thread(&tid)
-                },
-                div![title_break, &r.subject],
-                span![C!["text-xs"], pretty_authors(&r.authors)],
                 div![
-                    C!["flex", "flex-wrap", "justify-between"],
+                    C!["flex", "items-center", "mr-4"],
-                    span![tags_chiclet(&tags)],
+                    input![
-                    span![C!["text-sm"], datetime]
+                        C![&tw_classes::CHECKBOX],
+                        attrs! {
+                            At::Type=>"checkbox",
+                            At::Checked=>selected_threads.contains(&tid).as_at_value(),
+                        }
+                    ],
+                    ev(Ev::Input, move |e| {
+                        if let Some(input) = e
+                            .target()
+                            .as_ref()
+                            .expect("failed to get reference to target")
+                            .dyn_ref::<web_sys::HtmlInputElement>()
+                        {
+                            if input.checked() {
+                                Msg::SelectionAddThread(check_tid)
+                            } else {
+                                Msg::SelectionRemoveThread(check_tid)
+                            }
+                        } else {
+                            Msg::Noop
+                        }
+                    }),
+                ],
+                a![
+                    C!["flex-grow"],
+                    IF!(is_unread => C!["font-bold"]),
+                    attrs! {
+                        At::Href => urls::thread(&tid)
+                    },
+                    div![title_break, &r.subject],
+                    span![C!["text-xs"], pretty_authors(&r.authors)],
+                    div![
+                        C!["flex", "flex-wrap", "justify-between"],
+                        span![tags_chiclet(&tags)],
+                        span![C!["text-sm"], datetime]
+                    ]
                 ]
             ]
-        ]
+        })
-    });
+        .collect();
     let show_bulk_edit = !selected_threads.is_empty();
-    let all_selected = selected_threads.len() == results.len();
+    let all_selected = (selected_threads.len() == results.len()) && !rows.is_empty();
+    let content = if rows.is_empty() {
+        let caught_up = query.contains("is:unread");
+        let read_emoji = ["👻", "👽", "👾", "🤖", "💀"];
+        let no_results_emoji = ["🙈", "👀", "🤦", "🤷", "🙅", "🛟", "🍩", "🌑", "💿", "🔍"];
+        let now = seed::window()
+            .performance()
+            .map(|p| p.now() as usize)
+            .unwrap_or(0);
+        let (emoji, text) = if caught_up {
+            let idx = now % read_emoji.len();
+            (read_emoji[idx], "All caught up!")
+        } else {
+            let idx = now % no_results_emoji.len();
+            (no_results_emoji[idx], "No results")
+        };
+        div![
+            C!["text-center"],
+            h1![C!["text-9xl"], emoji],
+            p![C!["mt-8", "text-3xl", "font-semibold"], text]
+        ]
+    } else {
+        div![rows]
+    };
     div![
         C!["flex", "flex-col", "flex-auto", "p-4"],
         search_toolbar(count, pager, show_bulk_edit, all_selected),
-        div![rows],
+        content,
         search_toolbar(count, pager, show_bulk_edit, all_selected),
     ]
 }