Compare commits
No commits in common. "master" and "letterbox-web-v0.17.37" have entirely different histories.
master
...
letterbox-
40
.github/copilot-instructions.md
vendored
40
.github/copilot-instructions.md
vendored
@ -1,40 +0,0 @@
|
|||||||
# Copilot/AI Agent Instructions for Letterbox
|
|
||||||
|
|
||||||
## Project Overview
|
|
||||||
- **Letterbox** is a Rust monorepo for a mail/newsreader system with a web frontend and a Rocket/GraphQL backend.
|
|
||||||
- Major crates: `server` (backend, Rocket+async-graphql), `web` (Seed-based WASM frontend), `notmuch` (mail integration), `shared` (common types), `procmail2notmuch` (migration/utility).
|
|
||||||
- Data flows: Email/news data is indexed and queried via the backend, exposed to the frontend via GraphQL. SQLx/Postgres is used for persistence. Notmuch and custom SQL are both used for mail storage/search.
|
|
||||||
|
|
||||||
## Key Workflows
|
|
||||||
- **Development**: Use `dev.sh` to launch a tmux session with live-reloading for both frontend (`trunk serve`) and backend (`cargo watch ... run`).
|
|
||||||
- **Build/Release**: Use `just patch|minor|major` for versioned releases (runs SQLx prepare, bumps versions, pushes). `Makefile`'s `release` target does similar steps.
|
|
||||||
- **Frontend**: In `web/`, use `cargo make serve` and `cargo make watch` for local dev. See `web/README.md` for Seed-specific details.
|
|
||||||
- **Backend**: In `server/`, run with `cargo run` or via the tmux/dev.sh workflow. SQL migrations are in `server/migrations/`.
|
|
||||||
|
|
||||||
## Project Conventions & Patterns
|
|
||||||
- **GraphQL**: All API boundaries are defined in `server/src/graphql.rs`. Use the `Query`, `Mutation`, and `Subscription` roots. Types are defined with `async-graphql` derive macros.
|
|
||||||
- **HTML Sanitization**: See `server/src/lib.rs` for custom HTML/CSS sanitization and transformation logic (e.g., `Transformer` trait, `sanitize_html`).
|
|
||||||
- **Tag/Query Parsing**: The `Query` struct in `server/src/lib.rs` parses user queries into filters for notmuch/newsreader/tantivy.
|
|
||||||
- **Shared Types**: Use the `shared` crate for types and helpers shared between frontend and backend.
|
|
||||||
- **Custom SQL**: Raw SQL queries are in `server/sql/`. Use these for complex queries not handled by SQLx macros.
|
|
||||||
- **Feature Flags**: The `tantivy` feature enables full-text search via Tantivy. Check for `#[cfg(feature = "tantivy")]` in backend code.
|
|
||||||
|
|
||||||
## Integration Points
|
|
||||||
- **Notmuch**: Integrated via the `notmuch` crate for mail indexing/search.
|
|
||||||
- **Postgres**: Used for newsreader and other persistent data (see `server/migrations/`).
|
|
||||||
- **GraphQL**: All client-server communication is via GraphQL endpoints defined in the backend.
|
|
||||||
- **Seed/Trunk**: Frontend is built with Seed (Rust/WASM) and served via Trunk.
|
|
||||||
|
|
||||||
## Examples
|
|
||||||
- To add a new GraphQL query, update `server/src/graphql.rs` and expose it in the `QueryRoot`.
|
|
||||||
- To add a new frontend page, add a module in `web/src/` and register it in the Seed app's router.
|
|
||||||
- To run the full dev environment: `./dev.sh` (requires tmux, trunk, cargo-watch, etc.).
|
|
||||||
|
|
||||||
## References
|
|
||||||
- See `web/README.md` for frontend/Seed workflow details.
|
|
||||||
- See `Justfile` and `Makefile` for release/versioning automation.
|
|
||||||
- See `server/src/lib.rs` and `server/src/graphql.rs` for backend architecture and conventions.
|
|
||||||
- See `server/sql/` for custom SQL queries.
|
|
||||||
|
|
||||||
---
|
|
||||||
If any conventions or workflows are unclear, please ask for clarification or check the referenced files for examples.
|
|
||||||
2536
Cargo.lock
generated
2536
Cargo.lock
generated
File diff suppressed because it is too large
Load Diff
@ -8,7 +8,7 @@ authors = ["Bill Thiede <git@xinu.tv>"]
|
|||||||
edition = "2021"
|
edition = "2021"
|
||||||
license = "UNLICENSED"
|
license = "UNLICENSED"
|
||||||
publish = ["xinu"]
|
publish = ["xinu"]
|
||||||
version = "0.17.55"
|
version = "0.17.37"
|
||||||
repository = "https://git.z.xinu.tv/wathiede/letterbox"
|
repository = "https://git.z.xinu.tv/wathiede/letterbox"
|
||||||
|
|
||||||
[profile.dev]
|
[profile.dev]
|
||||||
|
|||||||
@ -13,8 +13,8 @@ version.workspace = true
|
|||||||
[dependencies]
|
[dependencies]
|
||||||
anyhow = "1.0.98"
|
anyhow = "1.0.98"
|
||||||
clap = { version = "4.5.37", features = ["derive", "env"] }
|
clap = { version = "4.5.37", features = ["derive", "env"] }
|
||||||
letterbox-notmuch = { version = "0.17", registry = "xinu" }
|
letterbox-notmuch = { version = "0.17.9", registry = "xinu" }
|
||||||
letterbox-shared = { version = "0.17", registry = "xinu" }
|
letterbox-shared = { version = "0.17.9", registry = "xinu" }
|
||||||
serde = { version = "1.0.219", features = ["derive"] }
|
serde = { version = "1.0.219", features = ["derive"] }
|
||||||
sqlx = { version = "0.8.5", features = ["postgres", "runtime-tokio"] }
|
sqlx = { version = "0.8.5", features = ["postgres", "runtime-tokio"] }
|
||||||
tokio = { version = "1.44.2", features = ["rt", "macros", "rt-multi-thread"] }
|
tokio = { version = "1.44.2", features = ["rt", "macros", "rt-multi-thread"] }
|
||||||
|
|||||||
@ -3,11 +3,4 @@
|
|||||||
"extends": [
|
"extends": [
|
||||||
"config:recommended"
|
"config:recommended"
|
||||||
]
|
]
|
||||||
,
|
|
||||||
"packageRules": [
|
|
||||||
{
|
|
||||||
"matchPackageNames": ["wasm-bindgen"],
|
|
||||||
"enabled": false
|
|
||||||
}
|
|
||||||
]
|
|
||||||
}
|
}
|
||||||
|
|||||||
@ -1,6 +1,6 @@
|
|||||||
{
|
{
|
||||||
"db_name": "PostgreSQL",
|
"db_name": "PostgreSQL",
|
||||||
"query": "SELECT\n p.id,\n link,\n clean_summary\nFROM\n post AS p\nINNER JOIN feed AS f ON p.site = f.slug -- necessary to weed out nzb posts\nWHERE\n search_summary IS NULL\n -- TODO remove AND link ~ '^<'\nORDER BY\n ROW_NUMBER() OVER (PARTITION BY site ORDER BY date DESC)\nLIMIT 1000;\n",
|
"query": "SELECT\n p.id,\n link,\n clean_summary\nFROM\n post AS p\nINNER JOIN feed AS f ON p.site = f.slug -- necessary to weed out nzb posts\nWHERE\n search_summary IS NULL\n -- TODO remove AND link ~ '^<'\nORDER BY\n ROW_NUMBER() OVER (PARTITION BY site ORDER BY date DESC)\nLIMIT 100;\n",
|
||||||
"describe": {
|
"describe": {
|
||||||
"columns": [
|
"columns": [
|
||||||
{
|
{
|
||||||
@ -28,5 +28,5 @@
|
|||||||
true
|
true
|
||||||
]
|
]
|
||||||
},
|
},
|
||||||
"hash": "cf369e3d5547f400cb54004dd03783ef6998a000aec91c50a79405dcf1c53b17"
|
"hash": "3d271b404f06497a5dcde68cf6bf07291d70fa56058ea736ac24e91d33050c04"
|
||||||
}
|
}
|
||||||
@ -1,14 +0,0 @@
|
|||||||
{
|
|
||||||
"db_name": "PostgreSQL",
|
|
||||||
"query": "DELETE FROM snooze WHERE id = $1",
|
|
||||||
"describe": {
|
|
||||||
"columns": [],
|
|
||||||
"parameters": {
|
|
||||||
"Left": [
|
|
||||||
"Int4"
|
|
||||||
]
|
|
||||||
},
|
|
||||||
"nullable": []
|
|
||||||
},
|
|
||||||
"hash": "77f79f981a9736d18ffd4b87d3aec34d6a048162154a3aba833370c58a860795"
|
|
||||||
}
|
|
||||||
@ -1,26 +0,0 @@
|
|||||||
{
|
|
||||||
"db_name": "PostgreSQL",
|
|
||||||
"query": "\nSELECT id, message_id\nFROM snooze\nWHERE wake < NOW();\n ",
|
|
||||||
"describe": {
|
|
||||||
"columns": [
|
|
||||||
{
|
|
||||||
"ordinal": 0,
|
|
||||||
"name": "id",
|
|
||||||
"type_info": "Int4"
|
|
||||||
},
|
|
||||||
{
|
|
||||||
"ordinal": 1,
|
|
||||||
"name": "message_id",
|
|
||||||
"type_info": "Text"
|
|
||||||
}
|
|
||||||
],
|
|
||||||
"parameters": {
|
|
||||||
"Left": []
|
|
||||||
},
|
|
||||||
"nullable": [
|
|
||||||
false,
|
|
||||||
false
|
|
||||||
]
|
|
||||||
},
|
|
||||||
"hash": "c8383663124a5cc5912b54553f18f7064d33087ebfdf3c0c1c43cbe6d3577084"
|
|
||||||
}
|
|
||||||
@ -1,15 +0,0 @@
|
|||||||
{
|
|
||||||
"db_name": "PostgreSQL",
|
|
||||||
"query": "\n INSERT INTO snooze (message_id, wake)\n VALUES ($1, $2)\n ON CONFLICT (message_id) DO UPDATE\n SET wake = $2\n ",
|
|
||||||
"describe": {
|
|
||||||
"columns": [],
|
|
||||||
"parameters": {
|
|
||||||
"Left": [
|
|
||||||
"Text",
|
|
||||||
"Timestamptz"
|
|
||||||
]
|
|
||||||
},
|
|
||||||
"nullable": []
|
|
||||||
},
|
|
||||||
"hash": "effd0d0d91e6ad84546f7177f1fd39d4fad736b471eb5e55fd5ac74f7adff664"
|
|
||||||
}
|
|
||||||
@ -12,28 +12,29 @@ version.workspace = true
|
|||||||
# See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html
|
# See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html
|
||||||
|
|
||||||
[dependencies]
|
[dependencies]
|
||||||
chrono-tz = "0.10"
|
chrono-tz = "0.8"
|
||||||
html2text = "0.16"
|
html2text = "0.6"
|
||||||
ammonia = "4.1.0"
|
ammonia = "4.1.0"
|
||||||
anyhow = "1.0.98"
|
anyhow = "1.0.98"
|
||||||
askama = { version = "0.14.0", features = ["derive"] }
|
askama = { version = "0.14.0", features = ["derive"] }
|
||||||
async-graphql = { version = "7", features = ["log", "chrono"] }
|
async-graphql = { version = "7", features = ["log"] }
|
||||||
async-graphql-axum = "7.0.16"
|
async-graphql-axum = "7.0.16"
|
||||||
async-trait = "0.1.88"
|
async-trait = "0.1.88"
|
||||||
axum = { version = "0.8.3", features = ["ws"] }
|
axum = { version = "0.8.3", features = ["ws"] }
|
||||||
axum-macros = "0.5.0"
|
axum-macros = "0.5.0"
|
||||||
build-info = "0.0.42"
|
build-info = "0.0.41"
|
||||||
cacher = { version = "0.2.0", registry = "xinu" }
|
cacher = { version = "0.2.0", registry = "xinu" }
|
||||||
chrono = "0.4.40"
|
chrono = "0.4.40"
|
||||||
clap = { version = "4.5.37", features = ["derive"] }
|
clap = { version = "4.5.37", features = ["derive"] }
|
||||||
css-inline = "0.18.0"
|
css-inline = "0.17.0"
|
||||||
flate2 = "1.1.2"
|
flate2 = "1.1.2"
|
||||||
futures = "0.3.31"
|
futures = "0.3.31"
|
||||||
headers = "0.4.0"
|
headers = "0.4.0"
|
||||||
html-escape = "0.2.13"
|
html-escape = "0.2.13"
|
||||||
ical = "0.11"
|
icalendar = "0.17.1"
|
||||||
letterbox-notmuch = { path = "../notmuch", version = "0.17", registry = "xinu" }
|
ical = "0.10"
|
||||||
letterbox-shared = { path = "../shared", version = "0.17", registry = "xinu" }
|
letterbox-notmuch = { path = "../notmuch", version = "0.17.37", registry = "xinu" }
|
||||||
|
letterbox-shared = { path = "../shared", version = "0.17.37", registry = "xinu" }
|
||||||
linkify = "0.10.0"
|
linkify = "0.10.0"
|
||||||
lol_html = "2.3.0"
|
lol_html = "2.3.0"
|
||||||
mailparse = "0.16.1"
|
mailparse = "0.16.1"
|
||||||
@ -42,11 +43,11 @@ memmap = "0.7.0"
|
|||||||
quick-xml = { version = "0.38.1", features = ["serialize"] }
|
quick-xml = { version = "0.38.1", features = ["serialize"] }
|
||||||
regex = "1.11.1"
|
regex = "1.11.1"
|
||||||
reqwest = { version = "0.12.15", features = ["blocking"] }
|
reqwest = { version = "0.12.15", features = ["blocking"] }
|
||||||
scraper = "0.25.0"
|
scraper = "0.23.1"
|
||||||
serde = { version = "1.0.219", features = ["derive"] }
|
serde = { version = "1.0.219", features = ["derive"] }
|
||||||
serde_json = "1.0.140"
|
serde_json = "1.0.140"
|
||||||
sqlx = { version = "0.8.5", features = ["postgres", "runtime-tokio", "chrono"] }
|
sqlx = { version = "0.8.5", features = ["postgres", "runtime-tokio", "time"] }
|
||||||
tantivy = { version = "0.25.0", optional = true }
|
tantivy = { version = "0.24.1", optional = true }
|
||||||
thiserror = "2.0.12"
|
thiserror = "2.0.12"
|
||||||
tokio = "1.44.2"
|
tokio = "1.44.2"
|
||||||
tower-http = { version = "0.6.2", features = ["trace"] }
|
tower-http = { version = "0.6.2", features = ["trace"] }
|
||||||
@ -56,11 +57,11 @@ urlencoding = "2.1.3"
|
|||||||
#xtracing = { git = "http://git-private.h.xinu.tv/wathiede/xtracing.git" }
|
#xtracing = { git = "http://git-private.h.xinu.tv/wathiede/xtracing.git" }
|
||||||
#xtracing = { path = "../../xtracing" }
|
#xtracing = { path = "../../xtracing" }
|
||||||
xtracing = { version = "0.3.2", registry = "xinu" }
|
xtracing = { version = "0.3.2", registry = "xinu" }
|
||||||
zip = "6.0.0"
|
zip = "4.3.0"
|
||||||
|
|
||||||
|
|
||||||
[build-dependencies]
|
[build-dependencies]
|
||||||
build-info-build = "0.0.42"
|
build-info-build = "0.0.41"
|
||||||
|
|
||||||
[features]
|
[features]
|
||||||
#default = [ "tantivy" ]
|
#default = [ "tantivy" ]
|
||||||
|
|||||||
@ -1,2 +0,0 @@
|
|||||||
-- Add down migration script here
|
|
||||||
DROP TABLE IF EXISTS snooze;
|
|
||||||
@ -1,6 +0,0 @@
|
|||||||
-- Add up migration script here
|
|
||||||
CREATE TABLE IF NOT EXISTS snooze (
|
|
||||||
id integer NOT NULL GENERATED ALWAYS AS IDENTITY,
|
|
||||||
message_id text NOT NULL UNIQUE,
|
|
||||||
wake timestamptz NOT NULL
|
|
||||||
);
|
|
||||||
@ -10,4 +10,4 @@ WHERE
|
|||||||
-- TODO remove AND link ~ '^<'
|
-- TODO remove AND link ~ '^<'
|
||||||
ORDER BY
|
ORDER BY
|
||||||
ROW_NUMBER() OVER (PARTITION BY site ORDER BY date DESC)
|
ROW_NUMBER() OVER (PARTITION BY site ORDER BY date DESC)
|
||||||
LIMIT 1000;
|
LIMIT 100;
|
||||||
|
|||||||
File diff suppressed because it is too large
Load Diff
@ -45,6 +45,4 @@ pub enum ServerError {
|
|||||||
XmlError(#[from] quick_xml::Error),
|
XmlError(#[from] quick_xml::Error),
|
||||||
#[error("xml encoding error: {0}")]
|
#[error("xml encoding error: {0}")]
|
||||||
XmlEncodingError(#[from] quick_xml::encoding::EncodingError),
|
XmlEncodingError(#[from] quick_xml::encoding::EncodingError),
|
||||||
#[error("html to text error: {0}")]
|
|
||||||
Html2TextError(#[from] html2text::Error),
|
|
||||||
}
|
}
|
||||||
|
|||||||
@ -7,7 +7,6 @@ use async_graphql::{
|
|||||||
Union,
|
Union,
|
||||||
};
|
};
|
||||||
use cacher::FilesystemCacher;
|
use cacher::FilesystemCacher;
|
||||||
use chrono::{DateTime, Utc};
|
|
||||||
use futures::stream;
|
use futures::stream;
|
||||||
use letterbox_notmuch::Notmuch;
|
use letterbox_notmuch::Notmuch;
|
||||||
use serde::{Deserialize, Serialize};
|
use serde::{Deserialize, Serialize};
|
||||||
@ -629,42 +628,6 @@ impl MutationRoot {
|
|||||||
nm.tag_remove(&tag, &query)?;
|
nm.tag_remove(&tag, &query)?;
|
||||||
Ok(true)
|
Ok(true)
|
||||||
}
|
}
|
||||||
#[instrument(skip_all, fields(query=query, wake_time=wake_time.to_string(), rid=request_id()))]
|
|
||||||
async fn snooze<'ctx>(
|
|
||||||
&self,
|
|
||||||
ctx: &Context<'ctx>,
|
|
||||||
query: String,
|
|
||||||
wake_time: DateTime<Utc>,
|
|
||||||
) -> Result<bool, Error> {
|
|
||||||
info!("TODO snooze {query} until {wake_time})");
|
|
||||||
let pool = ctx.data_unchecked::<PgPool>();
|
|
||||||
sqlx::query!(
|
|
||||||
r#"
|
|
||||||
INSERT INTO snooze (message_id, wake)
|
|
||||||
VALUES ($1, $2)
|
|
||||||
ON CONFLICT (message_id) DO UPDATE
|
|
||||||
SET wake = $2
|
|
||||||
"#,
|
|
||||||
query,
|
|
||||||
wake_time
|
|
||||||
)
|
|
||||||
.execute(pool)
|
|
||||||
.await?;
|
|
||||||
|
|
||||||
let nm = ctx.data_unchecked::<Notmuch>();
|
|
||||||
let pool = ctx.data_unchecked::<PgPool>();
|
|
||||||
#[cfg(feature = "tantivy")]
|
|
||||||
let tantivy = ctx.data_unchecked::<TantivyConnection>();
|
|
||||||
|
|
||||||
let unread = false;
|
|
||||||
let query: Query = query.parse()?;
|
|
||||||
newsreader::set_read_status(pool, &query, unread).await?;
|
|
||||||
#[cfg(feature = "tantivy")]
|
|
||||||
tantivy.reindex_thread(pool, &query).await?;
|
|
||||||
nm::set_read_status(nm, &query, unread).await?;
|
|
||||||
|
|
||||||
Ok(true)
|
|
||||||
}
|
|
||||||
/// Drop and recreate tantivy index. Warning this is slow
|
/// Drop and recreate tantivy index. Warning this is slow
|
||||||
#[cfg(feature = "tantivy")]
|
#[cfg(feature = "tantivy")]
|
||||||
async fn drop_and_load_index<'ctx>(&self, ctx: &Context<'ctx>) -> Result<bool, Error> {
|
async fn drop_and_load_index<'ctx>(&self, ctx: &Context<'ctx>) -> Result<bool, Error> {
|
||||||
@ -676,18 +639,6 @@ impl MutationRoot {
|
|||||||
|
|
||||||
Ok(true)
|
Ok(true)
|
||||||
}
|
}
|
||||||
#[instrument(skip_all, fields(rid=request_id()))]
|
|
||||||
async fn label_unprocessed<'ctx>(
|
|
||||||
&self,
|
|
||||||
ctx: &Context<'ctx>,
|
|
||||||
limit: Option<usize>,
|
|
||||||
) -> Result<bool, Error> {
|
|
||||||
let nm = ctx.data_unchecked::<Notmuch>();
|
|
||||||
let pool = ctx.data_unchecked::<PgPool>();
|
|
||||||
label_unprocessed(&nm, &pool, false, limit, "tag:unprocessed").await?;
|
|
||||||
Ok(true)
|
|
||||||
}
|
|
||||||
|
|
||||||
#[instrument(skip_all, fields(rid=request_id()))]
|
#[instrument(skip_all, fields(rid=request_id()))]
|
||||||
async fn refresh<'ctx>(&self, ctx: &Context<'ctx>) -> Result<bool, Error> {
|
async fn refresh<'ctx>(&self, ctx: &Context<'ctx>) -> Result<bool, Error> {
|
||||||
let nm = ctx.data_unchecked::<Notmuch>();
|
let nm = ctx.data_unchecked::<Notmuch>();
|
||||||
@ -697,10 +648,7 @@ impl MutationRoot {
|
|||||||
newsreader::refresh(pool, cacher).await?;
|
newsreader::refresh(pool, cacher).await?;
|
||||||
|
|
||||||
// Process email labels
|
// Process email labels
|
||||||
label_unprocessed(&nm, &pool, false, Some(1000), "tag:unprocessed").await?;
|
label_unprocessed(&nm, &pool, false, Some(10), "tag:unprocessed").await?;
|
||||||
|
|
||||||
// Look for snoozed messages and mark unread
|
|
||||||
wakeup(&nm, &pool).await?;
|
|
||||||
|
|
||||||
#[cfg(feature = "tantivy")]
|
#[cfg(feature = "tantivy")]
|
||||||
{
|
{
|
||||||
@ -722,33 +670,6 @@ impl SubscriptionRoot {
|
|||||||
|
|
||||||
pub type GraphqlSchema = Schema<QueryRoot, MutationRoot, SubscriptionRoot>;
|
pub type GraphqlSchema = Schema<QueryRoot, MutationRoot, SubscriptionRoot>;
|
||||||
|
|
||||||
#[instrument(name = "wakeup", skip_all)]
|
|
||||||
pub async fn wakeup(nm: &Notmuch, pool: &PgPool) -> Result<(), Error> {
|
|
||||||
for row in sqlx::query!(
|
|
||||||
r#"
|
|
||||||
SELECT id, message_id
|
|
||||||
FROM snooze
|
|
||||||
WHERE wake < NOW();
|
|
||||||
"#
|
|
||||||
)
|
|
||||||
.fetch_all(pool)
|
|
||||||
.await?
|
|
||||||
{
|
|
||||||
let query: Query = row.message_id.parse()?;
|
|
||||||
info!("need to wake {query}");
|
|
||||||
let unread = true;
|
|
||||||
newsreader::set_read_status(pool, &query, unread).await?;
|
|
||||||
#[cfg(feature = "tantivy")]
|
|
||||||
tantivy.reindex_thread(pool, &query).await?;
|
|
||||||
nm::set_read_status(nm, &query, unread).await?;
|
|
||||||
|
|
||||||
sqlx::query!("DELETE FROM snooze WHERE id = $1", row.id)
|
|
||||||
.execute(pool)
|
|
||||||
.await?;
|
|
||||||
}
|
|
||||||
Ok(())
|
|
||||||
}
|
|
||||||
|
|
||||||
#[instrument(skip_all, fields(query=query))]
|
#[instrument(skip_all, fields(query=query))]
|
||||||
pub async fn compute_catchup_ids(
|
pub async fn compute_catchup_ids(
|
||||||
nm: &Notmuch,
|
nm: &Notmuch,
|
||||||
|
|||||||
@ -19,7 +19,6 @@ use std::{
|
|||||||
|
|
||||||
use async_trait::async_trait;
|
use async_trait::async_trait;
|
||||||
use cacher::{Cacher, FilesystemCacher};
|
use cacher::{Cacher, FilesystemCacher};
|
||||||
use chrono::NaiveDateTime;
|
|
||||||
use css_inline::{CSSInliner, InlineError, InlineOptions};
|
use css_inline::{CSSInliner, InlineError, InlineOptions};
|
||||||
pub use error::ServerError;
|
pub use error::ServerError;
|
||||||
use linkify::{LinkFinder, LinkKind};
|
use linkify::{LinkFinder, LinkKind};
|
||||||
@ -31,6 +30,7 @@ use maplit::{hashmap, hashset};
|
|||||||
use regex::Regex;
|
use regex::Regex;
|
||||||
use reqwest::StatusCode;
|
use reqwest::StatusCode;
|
||||||
use scraper::{Html, Selector};
|
use scraper::{Html, Selector};
|
||||||
|
use sqlx::types::time::PrimitiveDateTime;
|
||||||
use thiserror::Error;
|
use thiserror::Error;
|
||||||
use tracing::{debug, error, info, warn};
|
use tracing::{debug, error, info, warn};
|
||||||
use url::Url;
|
use url::Url;
|
||||||
@ -754,7 +754,6 @@ pub struct Query {
|
|||||||
pub is_notmuch: bool,
|
pub is_notmuch: bool,
|
||||||
pub is_newsreader: bool,
|
pub is_newsreader: bool,
|
||||||
pub is_tantivy: bool,
|
pub is_tantivy: bool,
|
||||||
pub is_snoozed: bool,
|
|
||||||
pub corpus: Option<Corpus>,
|
pub corpus: Option<Corpus>,
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -778,9 +777,6 @@ impl fmt::Display for Query {
|
|||||||
if self.is_newsreader {
|
if self.is_newsreader {
|
||||||
write!(f, "is:news ")?;
|
write!(f, "is:news ")?;
|
||||||
}
|
}
|
||||||
if self.is_snoozed {
|
|
||||||
write!(f, "is:snoozed ")?;
|
|
||||||
}
|
|
||||||
match self.corpus {
|
match self.corpus {
|
||||||
Some(c) => write!(f, "corpus:{c:?}")?,
|
Some(c) => write!(f, "corpus:{c:?}")?,
|
||||||
_ => (),
|
_ => (),
|
||||||
@ -837,7 +833,6 @@ impl FromStr for Query {
|
|||||||
let mut is_notmuch = false;
|
let mut is_notmuch = false;
|
||||||
let mut is_newsreader = false;
|
let mut is_newsreader = false;
|
||||||
let mut is_tantivy = false;
|
let mut is_tantivy = false;
|
||||||
let mut is_snoozed = false;
|
|
||||||
let mut corpus = None;
|
let mut corpus = None;
|
||||||
for word in s.split_whitespace() {
|
for word in s.split_whitespace() {
|
||||||
if word == "is:unread" {
|
if word == "is:unread" {
|
||||||
@ -877,8 +872,6 @@ impl FromStr for Query {
|
|||||||
is_newsreader = true;
|
is_newsreader = true;
|
||||||
} else if word == "is:newsreader" {
|
} else if word == "is:newsreader" {
|
||||||
is_newsreader = true;
|
is_newsreader = true;
|
||||||
} else if word == "is:snoozed" {
|
|
||||||
is_snoozed = true;
|
|
||||||
} else {
|
} else {
|
||||||
remainder.push(word.to_string());
|
remainder.push(word.to_string());
|
||||||
}
|
}
|
||||||
@ -897,14 +890,13 @@ impl FromStr for Query {
|
|||||||
is_notmuch,
|
is_notmuch,
|
||||||
is_newsreader,
|
is_newsreader,
|
||||||
is_tantivy,
|
is_tantivy,
|
||||||
is_snoozed,
|
|
||||||
corpus,
|
corpus,
|
||||||
})
|
})
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
pub struct ThreadSummaryRecord {
|
pub struct ThreadSummaryRecord {
|
||||||
pub site: Option<String>,
|
pub site: Option<String>,
|
||||||
pub date: Option<NaiveDateTime>,
|
pub date: Option<PrimitiveDateTime>,
|
||||||
pub is_read: Option<bool>,
|
pub is_read: Option<bool>,
|
||||||
pub title: Option<String>,
|
pub title: Option<String>,
|
||||||
pub uid: String,
|
pub uid: String,
|
||||||
@ -922,7 +914,11 @@ async fn thread_summary_from_row(r: ThreadSummaryRecord) -> ThreadSummary {
|
|||||||
title = clean_title(&title).await.expect("failed to clean title");
|
title = clean_title(&title).await.expect("failed to clean title");
|
||||||
ThreadSummary {
|
ThreadSummary {
|
||||||
thread: format!("{NEWSREADER_THREAD_PREFIX}{}", r.uid),
|
thread: format!("{NEWSREADER_THREAD_PREFIX}{}", r.uid),
|
||||||
timestamp: r.date.expect("post missing date").and_utc().timestamp() as isize,
|
timestamp: r
|
||||||
|
.date
|
||||||
|
.expect("post missing date")
|
||||||
|
.assume_utc()
|
||||||
|
.unix_timestamp() as isize,
|
||||||
date_relative: format!("{:?}", r.date),
|
date_relative: format!("{:?}", r.date),
|
||||||
//date_relative: "TODO date_relative".to_string(),
|
//date_relative: "TODO date_relative".to_string(),
|
||||||
matched: 0,
|
matched: 0,
|
||||||
|
|||||||
@ -6,7 +6,7 @@ use letterbox_shared::compute_color;
|
|||||||
use maplit::hashmap;
|
use maplit::hashmap;
|
||||||
use scraper::Selector;
|
use scraper::Selector;
|
||||||
use sqlx::postgres::PgPool;
|
use sqlx::postgres::PgPool;
|
||||||
use tracing::{error, info, instrument, warn};
|
use tracing::{error, info, instrument};
|
||||||
use url::Url;
|
use url::Url;
|
||||||
|
|
||||||
use crate::{
|
use crate::{
|
||||||
@ -86,10 +86,6 @@ pub async fn search(
|
|||||||
query: &Query,
|
query: &Query,
|
||||||
) -> Result<Vec<(i32, ThreadSummary)>, async_graphql::Error> {
|
) -> Result<Vec<(i32, ThreadSummary)>, async_graphql::Error> {
|
||||||
info!("search({after:?} {before:?} {first:?} {last:?} {query:?}");
|
info!("search({after:?} {before:?} {first:?} {last:?} {query:?}");
|
||||||
if query.is_snoozed {
|
|
||||||
warn!("TODO implement snooze for newsreader::search");
|
|
||||||
return Ok(Vec::new());
|
|
||||||
}
|
|
||||||
if !is_newsreader_query(query) {
|
if !is_newsreader_query(query) {
|
||||||
return Ok(Vec::new());
|
return Ok(Vec::new());
|
||||||
}
|
}
|
||||||
@ -215,7 +211,11 @@ pub async fn thread(
|
|||||||
}
|
}
|
||||||
let title = clean_title(&r.title.unwrap_or("NO TITLE".to_string())).await?;
|
let title = clean_title(&r.title.unwrap_or("NO TITLE".to_string())).await?;
|
||||||
let is_read = r.is_read.unwrap_or(false);
|
let is_read = r.is_read.unwrap_or(false);
|
||||||
let timestamp = r.date.expect("post missing date").and_utc().timestamp();
|
let timestamp = r
|
||||||
|
.date
|
||||||
|
.expect("post missing date")
|
||||||
|
.assume_utc()
|
||||||
|
.unix_timestamp();
|
||||||
Ok(Thread::News(NewsPost {
|
Ok(Thread::News(NewsPost {
|
||||||
thread_id,
|
thread_id,
|
||||||
is_read,
|
is_read,
|
||||||
|
|||||||
@ -64,10 +64,6 @@ pub async fn search(
|
|||||||
last: Option<i32>,
|
last: Option<i32>,
|
||||||
query: &Query,
|
query: &Query,
|
||||||
) -> Result<Vec<(i32, ThreadSummary)>, async_graphql::Error> {
|
) -> Result<Vec<(i32, ThreadSummary)>, async_graphql::Error> {
|
||||||
if query.is_snoozed {
|
|
||||||
warn!("TODO implement snooze for nm::search");
|
|
||||||
return Ok(Vec::new());
|
|
||||||
}
|
|
||||||
if !is_notmuch_query(query) {
|
if !is_notmuch_query(query) {
|
||||||
return Ok(Vec::new());
|
return Ok(Vec::new());
|
||||||
}
|
}
|
||||||
|
|||||||
@ -43,11 +43,6 @@
|
|||||||
}}</div>
|
}}</div>
|
||||||
<div style="margin-bottom:4px;"><b>Start:</b> {{ local_fmt_start }}</div>
|
<div style="margin-bottom:4px;"><b>Start:</b> {{ local_fmt_start }}</div>
|
||||||
<div style="margin-bottom:4px;"><b>End:</b> {{ local_fmt_end }}</div>
|
<div style="margin-bottom:4px;"><b>End:</b> {{ local_fmt_end }}</div>
|
||||||
{% if !recurrence_display.is_empty() %}
|
|
||||||
<div style="margin-bottom:4px;">
|
|
||||||
<b>Repeats:</b> {{ recurrence_display }}
|
|
||||||
</div>
|
|
||||||
{% endif %}
|
|
||||||
{% if !organizer_cn.is_empty() %}
|
{% if !organizer_cn.is_empty() %}
|
||||||
<div style="margin-bottom:4px;"><b>Organizer:</b> {{ organizer_cn }}</div>
|
<div style="margin-bottom:4px;"><b>Organizer:</b> {{ organizer_cn }}</div>
|
||||||
{% elif !organizer.is_empty() %}
|
{% elif !organizer.is_empty() %}
|
||||||
@ -74,9 +69,13 @@
|
|||||||
{% for week in all_days|batch(7) %}
|
{% for week in all_days|batch(7) %}
|
||||||
<tr>
|
<tr>
|
||||||
{% for day in week %}
|
{% for day in week %}
|
||||||
{% if event_days.contains(day) %}
|
{% if event_days.contains(day) && today.is_some() && today.unwrap() == day %}
|
||||||
|
<td
|
||||||
|
style="background:#ffd700; color:#222; font-weight:bold; border:2px solid #2196f3; border-radius:4px; text-align:center; box-shadow:0 0 0 2px #2196f3;">
|
||||||
|
{{ day.day() }}
|
||||||
|
</td>
|
||||||
|
{% elif event_days.contains(day) %}
|
||||||
<td
|
<td
|
||||||
data-event-day="{{ day.format("%Y-%m-%d") }}"
|
|
||||||
style="background:#ffd700; color:#222; font-weight:bold; border:1px solid #aaa; border-radius:4px; text-align:center;">
|
style="background:#ffd700; color:#222; font-weight:bold; border:1px solid #aaa; border-radius:4px; text-align:center;">
|
||||||
{{ day.day() }}
|
{{ day.day() }}
|
||||||
</td>
|
</td>
|
||||||
|
|||||||
167
server/testdata/google-calendar-example-2.eml
vendored
167
server/testdata/google-calendar-example-2.eml
vendored
@ -1,167 +0,0 @@
|
|||||||
Return-Path: <couchmoney+caf_=gmail=xinu.tv@gmail.com>
|
|
||||||
Delivered-To: bill@xinu.tv
|
|
||||||
Received: from phx.xinu.tv [74.207.253.222]
|
|
||||||
by nixos-01.h.xinu.tv with IMAP (fetchmail-6.5.1)
|
|
||||||
for <wathiede@localhost> (single-drop); Mon, 25 Aug 2025 14:29:47 -0700 (PDT)
|
|
||||||
Received: from phx.xinu.tv
|
|
||||||
by phx.xinu.tv with LMTP
|
|
||||||
id TPD3E8vVrGjawyMAJR8clQ
|
|
||||||
(envelope-from <couchmoney+caf_=gmail=xinu.tv@gmail.com>)
|
|
||||||
for <bill@xinu.tv>; Mon, 25 Aug 2025 14:29:47 -0700
|
|
||||||
X-Original-To: gmail@xinu.tv
|
|
||||||
Received-SPF: Pass (mailfrom) identity=mailfrom; client-ip=2a00:1450:4864:20::12e; helo=mail-lf1-x12e.google.com; envelope-from=couchmoney+caf_=gmail=xinu.tv@gmail.com; receiver=xinu.tv
|
|
||||||
Authentication-Results: phx.xinu.tv;
|
|
||||||
dkim=pass (2048-bit key; unprotected) header.d=google.com header.i=@google.com header.a=rsa-sha256 header.s=20230601 header.b=4sz9KOqm
|
|
||||||
Received: from mail-lf1-x12e.google.com (mail-lf1-x12e.google.com [IPv6:2a00:1450:4864:20::12e])
|
|
||||||
by phx.xinu.tv (Postfix) with ESMTPS id 2F9058B007
|
|
||||||
for <gmail@xinu.tv>; Mon, 25 Aug 2025 14:29:45 -0700 (PDT)
|
|
||||||
Received: by mail-lf1-x12e.google.com with SMTP id 2adb3069b0e04-55f4969c95aso994593e87.0
|
|
||||||
for <gmail@xinu.tv>; Mon, 25 Aug 2025 14:29:45 -0700 (PDT)
|
|
||||||
ARC-Seal: i=2; a=rsa-sha256; t=1756157384; cv=pass;
|
|
||||||
d=google.com; s=arc-20240605;
|
|
||||||
b=Y2CP7y9twLnWB5v8iyzZCw0vp33wQBS0qzltdtzX2NIWFhHu6MEp2XH8cONssaGrEN
|
|
||||||
kyjXajT7uaEpn6G8H6/NB9v9Vo2yk5Lq2f+RhODMYoocYs9YY9NJI4ZxMph0UeMO6RkQ
|
|
||||||
m+HH0iIeC2Mzgj1Bzq4qFEwb397YIijoxx+1RxyA2D3cwSuZtERSvFOEkHqv9ziWxBcD
|
|
||||||
u3tvySEuzjyQFU6bxfkax6sZljSRGzfj0iZJAl/Fw5tUgrhndQ55O5RDe4NfPNj0cw/3
|
|
||||||
XDELzsnepBgnW8Jpqpnh7iK6XMFSf4sPQmyiMCMDNVYtmm6hYFNo3/dOpgaPn/ImRr8j
|
|
||||||
d9lw==
|
|
||||||
ARC-Message-Signature: i=2; a=rsa-sha256; c=relaxed/relaxed; d=google.com; s=arc-20240605;
|
|
||||||
h=to:from:subject:date:message-id:auto-submitted:reply-to
|
|
||||||
:mime-version:dkim-signature:delivered-to;
|
|
||||||
bh=RJDaNO07yMMdVMfY1VnSbfmQtoKb6bs6XzWwF6+91ZY=;
|
|
||||||
fh=xB02AmI2fnPF5rMnM90IwqQ6Il76V+xMgSnSW+E42fE=;
|
|
||||||
b=H7Ze4a8zoCYB77xcnUnFTogJ/utYS/USzTL/7eS3nA6OPbD+zWRiiVmbSfQcNK7d25
|
|
||||||
LapXyYnRJKgc8sqqQ6XO26STA8xx/9G620pdTytChIzKsmm/T5cdlf1M8DJ+NlwkzzSG
|
|
||||||
6Xe5I0MuXSKzBDMmcBcMlY9+mp61eZNo/cGT34MfZvLDS7JCs5uQYy2gRyajCKzRddEP
|
|
||||||
NBfMgnP1Ag9B5KkpJr4QfA2IWoNlj/qom/bRcdcdjwQ3gwDeiG8rdrEwBt9juwqk8d95
|
|
||||||
C0LnVKfrXAZgolmJpljyIFb1IMMyBUIQhK+7cXFhV1AD6Laz0df9gmPWp5mGZz9qlYaY
|
|
||||||
BqJA==;
|
|
||||||
darn=xinu.tv
|
|
||||||
ARC-Authentication-Results: i=2; mx.google.com;
|
|
||||||
dkim=pass header.i=@google.com header.s=20230601 header.b=4sz9KOqm;
|
|
||||||
spf=pass (google.com: domain of 3odssaaoscuanoeqnnkpiuugcvvnguejqqnu.qtieqwejoqpgaiockn.eqo@calendar-server.bounces.google.com designates 209.85.220.73 as permitted sender) smtp.mailfrom=3OdSsaAoSCuANOEQNNKPIUUGCVVNGUEJQQNU.QTIEQWEJOQPGaIOCKN.EQO@calendar-server.bounces.google.com;
|
|
||||||
dmarc=pass (p=REJECT sp=REJECT dis=NONE) header.from=google.com;
|
|
||||||
dara=pass header.i=@gmail.com
|
|
||||||
X-Google-DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed;
|
|
||||||
d=1e100.net; s=20230601; t=1756157384; x=1756762184;
|
|
||||||
h=to:from:subject:date:message-id:auto-submitted:reply-to
|
|
||||||
:mime-version:dkim-signature:delivered-to:x-forwarded-for
|
|
||||||
:x-forwarded-to:x-gm-message-state:from:to:cc:subject:date
|
|
||||||
:message-id:reply-to;
|
|
||||||
bh=RJDaNO07yMMdVMfY1VnSbfmQtoKb6bs6XzWwF6+91ZY=;
|
|
||||||
b=m95okwnmqNvW4GhCfY8yZvCu5NxuhHCL2+A54SlIrRudednXK05YGzjZ5LOuCAaY1g
|
|
||||||
htpRv2cGHBj2mEnHh+3GIX5vQCmXw2ptzOGzfYe9TwavuKPkkKPiSD5wA1fk8quqHDOD
|
|
||||||
4XDM7dsn3xewJ+6GQyc6NPBQq53hmpAojbLXnmNtAIyfAvuxtHP1G+GSO+ZIApgg56K6
|
|
||||||
TaYrwqnRx66P8B2Ze111LCdnmOOLzweJ1muYyavPdCtTG5BbJgqzaI67bQhuUNZDhVbP
|
|
||||||
FdtT4Q7WzNt30JHCVIAkkHejD9Fh/mYSmETXpD+ISvZJ47DNnLP4RXjmmAWcHJkKsh+q
|
|
||||||
v3QQ==
|
|
||||||
X-Forwarded-Encrypted: i=2; AJvYcCUeIjyIxPoWuMqg9l5aomQv7Z9wLYkwDIS1FYz7bNmHs1Cs0CSHG8Y5B0iU/nlo9xRenTW/Xw==@xinu.tv
|
|
||||||
X-Gm-Message-State: AOJu0Yznjr5TC7UpZJk74jrsJzMBwx6/39s9e5ufIA5/FmHZ6I1bEdTc
|
|
||||||
vqpeeLdzSZTI2uZiR7zzKHiwmNJHt/LncR9kDR5f0I6b3MZuXpAgr0aKYdXw7B+b+h7D7uMM3Tm
|
|
||||||
JF9ccf09JxIzRzeRI9Vb52PUs4SIeiIU9J80QY53UqN/Rx8XMF+ncRSX5d4V4pQ==
|
|
||||||
X-Received: by 2002:a05:6512:110e:b0:55f:3bab:f204 with SMTP id 2adb3069b0e04-55f3babf35emr3087055e87.31.1756156987711;
|
|
||||||
Mon, 25 Aug 2025 14:23:07 -0700 (PDT)
|
|
||||||
X-Forwarded-To: gmail@xinu.tv
|
|
||||||
X-Forwarded-For: couchmoney@gmail.com gmail@xinu.tv
|
|
||||||
Delivered-To: couchmoney@gmail.com
|
|
||||||
Received: by 2002:a05:6504:6116:b0:2b8:eb6f:82ec with SMTP id i22csp44357ltt;
|
|
||||||
Mon, 25 Aug 2025 14:23:06 -0700 (PDT)
|
|
||||||
X-Received: by 2002:a05:6e02:164e:b0:3ed:94a6:2edb with SMTP id e9e14a558f8ab-3ed94a63097mr41416195ab.21.1756156986122;
|
|
||||||
Mon, 25 Aug 2025 14:23:06 -0700 (PDT)
|
|
||||||
ARC-Seal: i=1; a=rsa-sha256; t=1756156986; cv=none;
|
|
||||||
d=google.com; s=arc-20240605;
|
|
||||||
b=Nu0W/67J2nYqDAXf27QdfmUyuA6TGJwusKLaHRaE05YdEu/FWLfUk2ATV+g3iUQ19b
|
|
||||||
wh7awaA5kemxwiBqAy5kjjlXqlDrkK0Ow2fANdc6lRKvlRNJRYUnojMkP8w/v4Nv8YQj
|
|
||||||
Wci0HMhL4ni/yeqXeoaj1yKtwJU5MvRMxZZC7TinlCHKF5+MqgD8VNax8OTDOqxYvSDi
|
|
||||||
aIlyUBTial0AiP/K+3bsoIWEc2RoyBBBNIe88C4s1fcv17GCGn5RkN3lYtr+nwvp5wNE
|
|
||||||
fKxPCYMtXkNyv8jgjmgxKLcYBDK0B4Zo+ghMWXZneDWo3qotDVkr0GBC3J2N7BcZpjCA
|
|
||||||
XEDA==
|
|
||||||
ARC-Message-Signature: i=1; a=rsa-sha256; c=relaxed/relaxed; d=google.com; s=arc-20240605;
|
|
||||||
h=to:from:subject:date:message-id:auto-submitted:reply-to
|
|
||||||
:mime-version:dkim-signature;
|
|
||||||
bh=RJDaNO07yMMdVMfY1VnSbfmQtoKb6bs6XzWwF6+91ZY=;
|
|
||||||
fh=mbzrMIWIgWMC0ni1xEx+ViW4J0RLAdLdPT2cX81nTlk=;
|
|
||||||
b=NvhrlkKGEVx63UMsx510U8ePUo7OgRQBWxZ4BIpQWg6Fk0jJPaZgRoEpUdZ747et1P
|
|
||||||
rWTx/yVaEUHBqWtt0I4ktiD8Hr4cVqAwKvtiN32JpkGCsVBjYBWqxEalWIOg6abn8xLE
|
|
||||||
7x9j4GqD/cQhd3DiS6UtADsJ67MjjzLpGkskvxo67vKRGCfSLCKdbna2LO5TtoZ7fKO7
|
|
||||||
i+dhDol6IIgA2Sg+PZlzq6gbZTaFbglUNI7uOwz0fNWjhHH4ZfmPEycYxJ9bTuPISrqS
|
|
||||||
BkXxGQFkvlg42NHWt5L8aPzrx8OMoYfTniIqU19GeEFEVUbmzYCg/twZ0f5nxugHWDbD
|
|
||||||
PMvQ==;
|
|
||||||
dara=google.com
|
|
||||||
ARC-Authentication-Results: i=1; mx.google.com;
|
|
||||||
dkim=pass header.i=@google.com header.s=20230601 header.b=4sz9KOqm;
|
|
||||||
spf=pass (google.com: domain of 3odssaaoscuanoeqnnkpiuugcvvnguejqqnu.qtieqwejoqpgaiockn.eqo@calendar-server.bounces.google.com designates 209.85.220.73 as permitted sender) smtp.mailfrom=3OdSsaAoSCuANOEQNNKPIUUGCVVNGUEJQQNU.QTIEQWEJOQPGaIOCKN.EQO@calendar-server.bounces.google.com;
|
|
||||||
dmarc=pass (p=REJECT sp=REJECT dis=NONE) header.from=google.com;
|
|
||||||
dara=pass header.i=@gmail.com
|
|
||||||
Received: from mail-sor-f73.google.com (mail-sor-f73.google.com. [209.85.220.73])
|
|
||||||
by mx.google.com with SMTPS id ca18e2360f4ac-886c8fc41ebsor461233039f.7.2025.08.25.14.23.05
|
|
||||||
for <couchmoney@gmail.com>
|
|
||||||
(Google Transport Security);
|
|
||||||
Mon, 25 Aug 2025 14:23:06 -0700 (PDT)
|
|
||||||
Received-SPF: pass (google.com: domain of 3odssaaoscuanoeqnnkpiuugcvvnguejqqnu.qtieqwejoqpgaiockn.eqo@calendar-server.bounces.google.com designates 209.85.220.73 as permitted sender) client-ip=209.85.220.73;
|
|
||||||
Authentication-Results: mx.google.com;
|
|
||||||
dkim=pass header.i=@google.com header.s=20230601 header.b=4sz9KOqm;
|
|
||||||
spf=pass (google.com: domain of 3odssaaoscuanoeqnnkpiuugcvvnguejqqnu.qtieqwejoqpgaiockn.eqo@calendar-server.bounces.google.com designates 209.85.220.73 as permitted sender) smtp.mailfrom=3OdSsaAoSCuANOEQNNKPIUUGCVVNGUEJQQNU.QTIEQWEJOQPGaIOCKN.EQO@calendar-server.bounces.google.com;
|
|
||||||
dmarc=pass (p=REJECT sp=REJECT dis=NONE) header.from=google.com;
|
|
||||||
dara=pass header.i=@gmail.com
|
|
||||||
DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed;
|
|
||||||
d=google.com; s=20230601; t=1756156985; x=1756761785; dara=google.com;
|
|
||||||
h=to:from:subject:date:message-id:auto-submitted:reply-to
|
|
||||||
:mime-version:from:to:cc:subject:date:message-id:reply-to;
|
|
||||||
bh=RJDaNO07yMMdVMfY1VnSbfmQtoKb6bs6XzWwF6+91ZY=;
|
|
||||||
b=4sz9KOqmGGwObcaR0iSSMVeeMvZHqMzvY4cw++RddJd0V48WoyPPI5q1oMeGiVZ6fm
|
|
||||||
eEWVr8xH9/T1JUqUZXJHY6CPixN9nTpLvZlpikG1KOFv5+I5DNVX/O5i6M5C/yIPRVGv
|
|
||||||
ja0ygA7WTL48IkHV7+PTPwHmhF8zv1/BeNdko4BSywfql64J6NMM5RnOAejTIf5AR/IL
|
|
||||||
CW7H2IcmiOGBHfgMApQljg3wB+WgUel7RXZfMnHCbSlmynJ6bDJ4tq7uU16GLpnI6qAe
|
|
||||||
s9w8cOpFPiQk8uKEqdc682XxKlwqYdh07RWO/EdlZ8WeSoxMfU6YZL7c1s6xxK2c9sT7
|
|
||||||
8Xxg==
|
|
||||||
X-Google-Smtp-Source: AGHT+IFJwttd47Uo06h0EKkogFtVf4poWcHfmodh4dZqSviwYROSgnnyI2ZJSibXGnOUHiLIfAwFn6KP9CzXMoyncWSb
|
|
||||||
MIME-Version: 1.0
|
|
||||||
X-Received: by 2002:a05:6602:14c9:b0:884:47f0:b89f with SMTP id
|
|
||||||
ca18e2360f4ac-886bd0f2960mr1726062839f.3.1756156985586; Mon, 25 Aug 2025
|
|
||||||
14:23:05 -0700 (PDT)
|
|
||||||
Reply-To: tconvertino@gmail.com
|
|
||||||
Auto-Submitted: auto-generated
|
|
||||||
Message-ID: <calendar-43033c42-cc1e-4014-a5e8-c4552d41247e@google.com>
|
|
||||||
Date: Mon, 25 Aug 2025 21:23:05 +0000
|
|
||||||
Subject: New event: McClure BLT @ Monthly from 7:30am to 8:30am on the second
|
|
||||||
Thursday from Thu Sep 11 to Fri Jan 30, 2026 (PDT) (tconvertino@gmail.com)
|
|
||||||
From: "lmcollings@seattleschools.org (Google Calendar)" <calendar-notification@google.com>
|
|
||||||
To: couchmoney@gmail.com
|
|
||||||
Content-Type: multipart/alternative; boundary="0000000000004bc1be063d372904"
|
|
||||||
|
|
||||||
--0000000000004bc1be063d372904
|
|
||||||
Content-Type: text/plain; charset="UTF-8"; format=flowed; delsp=yes
|
|
||||||
Content-Transfer-Encoding: base64
|
|
||||||
|
|
||||||
TWNDbHVyZSBCTFQNCk1vbnRobHkgZnJvbSA3OjMwYW0gdG8gODozMGFtIG9uIHRoZSBzZWNvbmQg
|
|
||||||
VGh1cnNkYXkgZnJvbSBUaHVyc2RheSBTZXAgMTEgIA0KdG8gRnJpZGF5IEphbiAzMCwgMjAyNg0K
|
|
||||||
UGFjaWZpYyBUaW1lIC0gTG9zIEFuZ2VsZXMNCg0KTG9jYXRpb24NCk1jQ2x1cmUgTGlicmFyeQkN
|
|
||||||
Cmh0dHBzOi8vd3d3Lmdvb2dsZS5jb20vbWFwcy9zZWFyY2gvTWNDbHVyZStMaWJyYXJ5P2hsPWVu
|
|
||||||
DQoNCg0KDQpCTFQgd2lsbCBtZWV0IG9uIHRoZSAybmQgVGh1cnNkYXkgb2YgZXZlcnkgbW9udGgg
|
|
||||||
dW50aWwgSmFudWFyeSB3aGVuIHdlICANCmJlZ2luIGxvb2tpbmcgYXQgYnVkZ2V0LiBBZGRpdGlv
|
|
||||||
bmFsIG1lZXRpbmdzIG1heSBhbHNvIGJlIHNjaGVkdWxlZCBlYXJsaWVyICANCmlmIG5lZWRlZC4N
|
|
||||||
ClRoYW5rcywNCk1jQ2x1cmUgQkxUDQoNCg0KDQpPcmdhbml6ZXINCmxtY29sbGluZ3NAc2VhdHRs
|
|
||||||
ZXNjaG9vbHMub3JnDQpsbWNvbGxpbmdzQHNlYXR0bGVzY2hvb2xzLm9yZw0KDQpHdWVzdHMNCmxt
|
|
||||||
Y29sbGluZ3NAc2VhdHRsZXNjaG9vbHMub3JnIC0gb3JnYW5pemVyDQp0Y29udmVydGlub0BnbWFp
|
|
||||||
bC5jb20gLSBjcmVhdG9yDQptYW5kcy5hbmRydXNAZ21haWwuY29tDQphbXNjaHVtZXJAc2VhdHRs
|
|
||||||
ZXNjaG9vbHMub3JnDQphcGplbm5pbmdzQHNlYXR0bGVzY2hvbHMub3JnDQpsbWJsYXVAc2VhdHRs
|
|
||||||
ZXNjaG9vbHMub3JnDQptbmxhbmRpc0BzZWF0dGxlc2Nob29scy5vcmcNCnRtYnVyY2hhcmR0QHNl
|
|
||||||
YXR0bGVzY2hvb2xzLm9yZw0KbWNjbHVyZWFsbHN0YWZmQHNlYXR0bGVzY2hvbHMub3JnIC0gb3B0
|
|
||||||
aW9uYWwNClZpZXcgYWxsIGd1ZXN0IGluZm8gIA0KaHR0cHM6Ly9jYWxlbmRhci5nb29nbGUuY29t
|
|
||||||
L2NhbGVuZGFyL3I/ZWlkPVh6WXdjVE13WXpGbk5qQnZNekJsTVdrMk1HODBZV016WnpZd2NtbzRa
|
|
||||||
M0JzT0RoeWFqSmpNV2c0TkhNelpHZzVae1l3Y3pNd1l6Rm5OakJ2TXpCak1XYzNORG96T0dkb2Fq
|
|
||||||
WXhNR3RoWjNFeE5qUnhhemhuY0djMk5HOHpNR014WnpZd2J6TXdZekZuTmpCdk16QmpNV2MyTUc4
|
|
||||||
ek1tTXhaell3YnpNd1l6Rm5PR2R4TTJGalNXODNOSUF6YVdReGJUY3hNbXBqWkRGck5qVXhNamhq
|
|
||||||
TVcwM01USnFNbWRvYnpnMGN6TTJaSEJwTmprek1DQjBZMjl1ZG1WeWRHbHViMEJ0JmVzPTENCg0K
|
|
||||||
fn4vL35+DQpJbnZpdGF0aW9uIGZyb20gR29vZ2xlIENhbGVuZGFyOiBodHRwczovL2NhbGVuZGFy
|
|
||||||
Lmdvb2dsZS5jb20vY2FsZW5kYXIvDQoNCllvdSBhcmUgcmVjZWl2aW5nIHRoaXMgZW1haWwgYmVj
|
|
||||||
YXVzZSB5b3UgYXJlIHN1YnNjcmliZWQgdG8gY2FsZW5kYXIgIA0Kbm90aWZpY2F0aW9ucy4gVG8g
|
|
||||||
c3RvcCByZWNlaXZpbmcgdGhlc2UgZW1haWxzLCBnbyB0byAgDQpodHRwczovL2NhbGVuZGFyLmdv
|
|
||||||
b2dsZS5jb20vY2FsZW5kYXIvci9zZXR0aW5ncywgc2VsZWN0IHRoaXMgY2FsZW5kYXIsIGFuZCANCmNoYW5nZSAiT3RoZXIgbm90aWZpY2F0aW9ucyIuDQoNCkZvcndhcmRpbmcgdGhpcyBpbnZp
|
|
||||||
dGF0aW9uIGNvdWxkIGFsbG93IGFueSByZWNpcGllbnQgdG8gc2VuZCBhIHJlc3BvbnNlIHRvICAN
|
|
||||||
CnRoZSBvcmdhbml6ZXIsIGJlIGFkZGVkIHRvIHRoZSBndWVzdCBsaXN0LCBpbnZpdGUgb3RoZXJz
|
|
||||||
IHJlZ2FyZGxlc3Mgb2YgIA0KdGhlaXIgb3duIGludml0YXRpb24gc3RhdHVzLCBvciBtb2RpZnkg
|
|
||||||
eW91ciBSU1ZQLg0KDQpMZWFybiBtb3JlIGh0dHBzOi8vc3VwcG9ydC5nb29nbGUuY29tL2NhbGVu
|
|
||||||
ZGFyL2Fuc3dlci8zNzEzNSNmb3J3YXJkaW5nDQo=
|
|
||||||
--0000000000004bc1be063d372904--
|
|
||||||
206
server/testdata/google-calendar-example-3.eml
vendored
206
server/testdata/google-calendar-example-3.eml
vendored
@ -1,206 +0,0 @@
|
|||||||
Return-Path: <couchmoney+caf_=gmail=xinu.tv@gmail.com>
|
|
||||||
Delivered-To: bill@xinu.tv
|
|
||||||
Received: from phx.xinu.tv [74.207.253.222]
|
|
||||||
by nixos-01.h.xinu.tv with IMAP (fetchmail-6.5.1)
|
|
||||||
for <wathiede@localhost> (single-drop); Thu, 28 Aug 2025 12:11:15 -0700 (PDT)
|
|
||||||
Received: from phx.xinu.tv
|
|
||||||
by phx.xinu.tv with LMTP
|
|
||||||
id 1gVrANOpsGg9TSQAJR8clQ
|
|
||||||
(envelope-from <couchmoney+caf_=gmail=xinu.tv@gmail.com>)
|
|
||||||
for <bill@xinu.tv>; Thu, 28 Aug 2025 12:11:15 -0700
|
|
||||||
X-Original-To: gmail@xinu.tv
|
|
||||||
Received-SPF: Pass (mailfrom) identity=mailfrom; client-ip=2a00:1450:4864:20::230; helo=mail-lj1-x230.google.com; envelope-from=couchmoney+caf_=gmail=xinu.tv@gmail.com; receiver=xinu.tv
|
|
||||||
Authentication-Results: phx.xinu.tv;
|
|
||||||
dkim=pass (2048-bit key; unprotected) header.d=google.com header.i=@google.com header.a=rsa-sha256 header.s=20230601 header.b=RjBRlfFL;
|
|
||||||
dkim=pass (2048-bit key; unprotected) header.d=gmail.com header.i=@gmail.com header.a=rsa-sha256 header.s=20230601 header.b=HaiL0lRL
|
|
||||||
Received: from mail-lj1-x230.google.com (mail-lj1-x230.google.com [IPv6:2a00:1450:4864:20::230])
|
|
||||||
by phx.xinu.tv (Postfix) with ESMTPS id B4E848B007
|
|
||||||
for <gmail@xinu.tv>; Thu, 28 Aug 2025 12:11:13 -0700 (PDT)
|
|
||||||
Received: by mail-lj1-x230.google.com with SMTP id 38308e7fff4ca-336a85b8fc5so8142611fa.3
|
|
||||||
for <gmail@xinu.tv>; Thu, 28 Aug 2025 12:11:13 -0700 (PDT)
|
|
||||||
ARC-Seal: i=2; a=rsa-sha256; t=1756408272; cv=pass;
|
|
||||||
d=google.com; s=arc-20240605;
|
|
||||||
b=Nq93fJSEgPuxWsaf3dc6cCKbOP/bXMQJfmuZJBvrid99GipahJY/Ka4SGoLc8HBMH2
|
|
||||||
Ip9YDLG2Lblqz/N1KOud9gnAmQ6Zg4hfPZGvhUfCGaXbCi2lOhRlfx6QM0lM1B8rAXaA
|
|
||||||
S3Lt2qFFXrVBlvaJePwI+wVpc1wPbvd5PblaaUTYUVJeYSfdPtgNAy0Aehty9TF0Jo2h
|
|
||||||
9yrzCWMJ6kMTpsDw7sfDSnv7s43Q3jOPzXDjHdJfrK8aUXGQenwT+1acJkIw78wBFt3R
|
|
||||||
IG5CBLIKmwDpjquJzRPkEjHiNDRxhaKaCShTCVLTjmrYgbHXPM/gUewaKLfeIuTzOVuA
|
|
||||||
mnkw==
|
|
||||||
ARC-Message-Signature: i=2; a=rsa-sha256; c=relaxed/relaxed; d=google.com; s=arc-20240605;
|
|
||||||
h=to:from:subject:date:message-id:auto-submitted:sender:reply-to
|
|
||||||
:mime-version:dkim-signature:dkim-signature:delivered-to;
|
|
||||||
bh=lgr/fFBrye/qM438Us9TAp1/DYWNuYxn2NUL4vzX/SU=;
|
|
||||||
fh=twOWSYT+4sbeBuT1oeA5xzauBIj0SLZH5qI1YanOQio=;
|
|
||||||
b=FBstDUezbqJRRRxTwlKY4UXNSJ4z9aZdvb9KOlxXfFLCzUh3r5w+9P4+a/uH1Uw65g
|
|
||||||
xbxzPRgMduPWgKDAweqXk9SGX3mjqF0oyd5yhGTiU/jpHg6ZLXf//g45zJqRjfMnRi8I
|
|
||||||
vbEEAxUKyhPfbrQ8/byfq/isJHFiR0Vjr2U0HOqcctRgCTfrZr1b14jRVopjVqhk37ef
|
|
||||||
KapCbmTbBLznJLQH6jfi4LvKpSlJDW6l7R/CC4WtAzgcmHyA9nfjM4+egLg15giMpn3a
|
|
||||||
549c+jYBFgsjblhmyFw05dGSpUvP+jJeKTcFnlZe6yU7Qjnqhs6TlV/Jm8HAkPH1zdS5
|
|
||||||
XDAw==;
|
|
||||||
darn=xinu.tv
|
|
||||||
ARC-Authentication-Results: i=2; mx.google.com;
|
|
||||||
dkim=pass header.i=@google.com header.s=20230601 header.b=RjBRlfFL;
|
|
||||||
dkim=pass header.i=@gmail.com header.s=20230601 header.b=HaiL0lRL;
|
|
||||||
spf=pass (google.com: domain of tconvertino@gmail.com designates 209.85.220.73 as permitted sender) smtp.mailfrom=tconvertino@gmail.com;
|
|
||||||
dmarc=pass (p=NONE sp=QUARANTINE dis=NONE) header.from=gmail.com;
|
|
||||||
dara=pass header.i=@gmail.com
|
|
||||||
X-Google-DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed;
|
|
||||||
d=1e100.net; s=20230601; t=1756408272; x=1757013072;
|
|
||||||
h=to:from:subject:date:message-id:auto-submitted:sender:reply-to
|
|
||||||
:mime-version:dkim-signature:dkim-signature:delivered-to
|
|
||||||
:x-forwarded-for:x-forwarded-to:x-gm-message-state:from:to:cc
|
|
||||||
:subject:date:message-id:reply-to;
|
|
||||||
bh=lgr/fFBrye/qM438Us9TAp1/DYWNuYxn2NUL4vzX/SU=;
|
|
||||||
b=VJaqGIpPE1gxGhbAl1Np3yZR/0QPEs/C6KtFdnsaH9ubxFrDOeF4uIygqAUN9YFmll
|
|
||||||
YZsN4G0iexB097atKRIXLrreE3pH3cOY56ym94fWRZGythS0MRZlw40QoHLLf3joTC6D
|
|
||||||
WHtaNcea0hO3V6l/6gKlOffJ/cv2GnyPi0Sv7neOC5v18VTxZwZn+Wp+pTPpWFcmvQ4J
|
|
||||||
IMSV0vNgIRrYJaItUt1d59B9Ah+0bcyd7jJ0TDRVvN97S8iSlSIw6NMwxjZMuyJSWO7X
|
|
||||||
5zm8xA+H+L8+pLMmGKfdBYxhNo/ibdwda+w/ECKIjdnFtbreGbYLsUnkLdPeumQ6LXs/
|
|
||||||
Q2mg==
|
|
||||||
X-Forwarded-Encrypted: i=2; AJvYcCXpJ2X9EF2q2d4efhhe9B8o7LcuPPe25tZZwgkhfxerDzSbY0obB8Eik41xltO5i7k4ANaJKQ==@xinu.tv
|
|
||||||
X-Gm-Message-State: AOJu0Yz5+coY8ftW9IS5OD7ZbkwXnD43Mcp5BZjn5I2cv4v+u+ilxOi+
|
|
||||||
0DKABW1HVFh3MqQ/Z9nU+svpDl4kHa5lTr5siCXHTf0Wpo4LT3UsILyLUvwua0tsx9da14Gl6Fb
|
|
||||||
R1xVSmax6VR4PgZzrnOKZZx1x1re2RaTFGMAaA0Ei5ua3bZpn8axccwggYc94Jw==
|
|
||||||
X-Received: by 2002:a2e:a984:0:b0:336:7b24:2af7 with SMTP id 38308e7fff4ca-3367b242dd2mr36540291fa.17.1756408271464;
|
|
||||||
Thu, 28 Aug 2025 12:11:11 -0700 (PDT)
|
|
||||||
X-Forwarded-To: gmail@xinu.tv
|
|
||||||
X-Forwarded-For: couchmoney@gmail.com gmail@xinu.tv
|
|
||||||
Delivered-To: couchmoney@gmail.com
|
|
||||||
Received: by 2002:a05:6504:955:b0:2b8:eb6f:82ec with SMTP id k21csp1133490lts;
|
|
||||||
Thu, 28 Aug 2025 12:11:10 -0700 (PDT)
|
|
||||||
X-Received: by 2002:a05:6602:3c3:b0:86d:9ec7:267e with SMTP id ca18e2360f4ac-886bd155520mr3955796839f.4.1756408269941;
|
|
||||||
Thu, 28 Aug 2025 12:11:09 -0700 (PDT)
|
|
||||||
ARC-Seal: i=1; a=rsa-sha256; t=1756408269; cv=none;
|
|
||||||
d=google.com; s=arc-20240605;
|
|
||||||
b=Gvk+jquchLt+hySEph55datOhigiuAMXW4mgi5vTVp51rzJ7PB+rH7vx23tj1QAB+0
|
|
||||||
RIOZTaB67H8yFXwAUNZWd1GMnpocZR+tI4bMxbKzDYd7zgaTzSSa2InDROhqOhHqBpX8
|
|
||||||
eWD23F+xRon/qEYQd0YEjZVt20WvKzpvjbpvCyWpq7Z4y376KoJArxsspsKZlALrCfKq
|
|
||||||
cyt9B/EKr3ZmAzRiswiH7KY/iHd1qYgtYy0tYGNtjU0nZ+5fK/tVlw+lJuLtt+aA+ZCy
|
|
||||||
o5y8Y5/thdSJsT159u+bV5eICZWC5kGnztNsXg0Nr2H22XzUC1epWZvJkZW2j+SXQm5k
|
|
||||||
Wdew==
|
|
||||||
ARC-Message-Signature: i=1; a=rsa-sha256; c=relaxed/relaxed; d=google.com; s=arc-20240605;
|
|
||||||
h=to:from:subject:date:message-id:auto-submitted:sender:reply-to
|
|
||||||
:mime-version:dkim-signature:dkim-signature;
|
|
||||||
bh=lgr/fFBrye/qM438Us9TAp1/DYWNuYxn2NUL4vzX/SU=;
|
|
||||||
fh=mbzrMIWIgWMC0ni1xEx+ViW4J0RLAdLdPT2cX81nTlk=;
|
|
||||||
b=hra/E01IWuIFrWtk3uTcoj04apbHeQcQBSINqYDpr3cO7rXknIvpeXoWLvk0EIJI5y
|
|
||||||
syt60ekwVnsX/qb2F1HbN896dm97QrEGIwAiJyN2oTFauLoYObpcuhPS317hU4+YubO+
|
|
||||||
RLUntXsPK2qiifmPCOMPD6wACQB9YXpOPHrrl5x/yZlria1Tfg3XQcZIYsWcU/Qil94x
|
|
||||||
GtK+i82uzPXEQ0fVieEgJaZtmrW7OFEpPjd1KGp6sYtGvOxUfxVKl5MhLrCqfcLN9fd7
|
|
||||||
Xren0S32b/IsZA8ASdFca3CNjaAL2Ajlatb39XN17txnKrpQje/ReiVkm9wwo194NwCp
|
|
||||||
3dfQ==;
|
|
||||||
dara=google.com
|
|
||||||
ARC-Authentication-Results: i=1; mx.google.com;
|
|
||||||
dkim=pass header.i=@google.com header.s=20230601 header.b=RjBRlfFL;
|
|
||||||
dkim=pass header.i=@gmail.com header.s=20230601 header.b=HaiL0lRL;
|
|
||||||
spf=pass (google.com: domain of tconvertino@gmail.com designates 209.85.220.73 as permitted sender) smtp.mailfrom=tconvertino@gmail.com;
|
|
||||||
dmarc=pass (p=NONE sp=QUARANTINE dis=NONE) header.from=gmail.com;
|
|
||||||
dara=pass header.i=@gmail.com
|
|
||||||
Received: from mail-sor-f73.google.com (mail-sor-f73.google.com. [209.85.220.73])
|
|
||||||
by mx.google.com with SMTPS id ca18e2360f4ac-88711b2248fsor90547939f.5.2025.08.28.12.11.09
|
|
||||||
for <couchmoney@gmail.com>
|
|
||||||
(Google Transport Security);
|
|
||||||
Thu, 28 Aug 2025 12:11:09 -0700 (PDT)
|
|
||||||
Received-SPF: pass (google.com: domain of tconvertino@gmail.com designates 209.85.220.73 as permitted sender) client-ip=209.85.220.73;
|
|
||||||
Authentication-Results: mx.google.com;
|
|
||||||
dkim=pass header.i=@google.com header.s=20230601 header.b=RjBRlfFL;
|
|
||||||
dkim=pass header.i=@gmail.com header.s=20230601 header.b=HaiL0lRL;
|
|
||||||
spf=pass (google.com: domain of tconvertino@gmail.com designates 209.85.220.73 as permitted sender) smtp.mailfrom=tconvertino@gmail.com;
|
|
||||||
dmarc=pass (p=NONE sp=QUARANTINE dis=NONE) header.from=gmail.com;
|
|
||||||
dara=pass header.i=@gmail.com
|
|
||||||
DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed;
|
|
||||||
d=google.com; s=20230601; t=1756408269; x=1757013069; dara=google.com;
|
|
||||||
h=to:from:subject:date:message-id:auto-submitted:sender:reply-to
|
|
||||||
:mime-version:from:to:cc:subject:date:message-id:reply-to;
|
|
||||||
bh=lgr/fFBrye/qM438Us9TAp1/DYWNuYxn2NUL4vzX/SU=;
|
|
||||||
b=RjBRlfFLVsAeeTCwo5Z3c1Y5G+pvz4XSTyHiVKUHmxClmpM30ZeHTVLl36njuM/7rx
|
|
||||||
mFwbzGk80zXgGpZyc7qnhSIVxXeMv4iex2UIc1D7Rcw3CF4q/HPlulcD9uVnsxRvng5Z
|
|
||||||
6PVcBQH3qGn0zvDDb0QHEcuDed4sNd/4wkYMOchxlp1TfdrbMZdCI+EXwTyvGgbVjd+/
|
|
||||||
erPyF5JZL/UJx7+gWoXSE7yJkPQrKYiv4LApu0STV4iSOEL8XsTQ4nZiZHSLeeKr0y7w
|
|
||||||
TUWhjfOCgD/YTZW5PTuFBW+lI03Ny19iGHbQNwKrLLcGwW7TJ2PYBR90vsIfaJtG5RM6
|
|
||||||
MP1w==
|
|
||||||
DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed;
|
|
||||||
d=gmail.com; s=20230601; t=1756408269; x=1757013069; dara=google.com;
|
|
||||||
h=to:from:subject:date:message-id:auto-submitted:sender:reply-to
|
|
||||||
:mime-version:from:to:cc:subject:date:message-id:reply-to;
|
|
||||||
bh=lgr/fFBrye/qM438Us9TAp1/DYWNuYxn2NUL4vzX/SU=;
|
|
||||||
b=HaiL0lRLeUjb1Rw8g5U5npEElUjhuKY2dPzOaldvum7ZqfY26X35u8SQTxCXWcSsGp
|
|
||||||
RKrlHykB6fjjPSjSGBB+uKe98anrorlvgkhUluES0LzmAZ6STVlPUfPHb/RreJQ7Ol1r
|
|
||||||
N7oNIEg5EnGia1g6rWliSMHY7Fb4sQzMaS2P+qhtq0OFzB6F57atJAwTUWaspDHycfdh
|
|
||||||
S8ji+q7DEiLq1LfXIxj+WwenT/iRFIJsfmvXsHgQiKMoYGdENfAGZPdo7W0sTEK3TkWz
|
|
||||||
xFOny/4bQmx/49F4C1HnLsHoBi0j6sezIQsc+U83vvChFXXrELQrK5PiJL+UOCLZo48R
|
|
||||||
RJDQ==
|
|
||||||
X-Google-Smtp-Source: AGHT+IG3ta6ofCYBa0SfJ7K3lq1EjsCnjr+BZDRz/SVLQfyo54CcUFgE5iTTB5E+h//QXT9iTojhKpMp6QZ4QB+5HAcs
|
|
||||||
MIME-Version: 1.0
|
|
||||||
X-Received: by 2002:a05:6602:1544:b0:887:6a2:6054 with SMTP id
|
|
||||||
ca18e2360f4ac-88706a263famr584022039f.9.1756408269509; Thu, 28 Aug 2025
|
|
||||||
12:11:09 -0700 (PDT)
|
|
||||||
Reply-To: tconvertino@gmail.com
|
|
||||||
Sender: Google Calendar <calendar-notification@google.com>
|
|
||||||
Auto-Submitted: auto-generated
|
|
||||||
Message-ID: <calendar-8ecdd8ef-29ed-4f61-857d-1215ab585aba@google.com>
|
|
||||||
Date: Thu, 28 Aug 2025 19:11:09 +0000
|
|
||||||
Subject: New event: Dentist appt @ Tue Sep 23, 2025 3pm - 4pm (PDT) (tconvertino@gmail.com)
|
|
||||||
From: tconvertino@gmail.com
|
|
||||||
To: couchmoney@gmail.com
|
|
||||||
Content-Type: multipart/alternative; boundary="000000000000fc1bff063d71aa4b"
|
|
||||||
X-Spamd-Result: default: False [-0.80 / 15.00];
|
|
||||||
ARC_ALLOW(-1.00)[google.com:s=arc-20240605:i=2];
|
|
||||||
URI_COUNT_ODD(1.00)[1];
|
|
||||||
DMARC_POLICY_ALLOW(-0.50)[gmail.com,none];
|
|
||||||
R_DKIM_ALLOW(-0.20)[google.com:s=20230601,gmail.com:s=20230601];
|
|
||||||
R_SPF_ALLOW(-0.20)[+ip6:2a00:1450:4000::/36];
|
|
||||||
MIME_BASE64_TEXT(0.10)[];
|
|
||||||
MANY_INVISIBLE_PARTS(0.10)[2];
|
|
||||||
MIME_GOOD(-0.10)[multipart/alternative,text/plain];
|
|
||||||
FREEMAIL_TO(0.00)[gmail.com];
|
|
||||||
RCVD_COUNT_THREE(0.00)[3];
|
|
||||||
FORGED_SENDER(0.00)[tconvertino@gmail.com,couchmoney@gmail.com];
|
|
||||||
FROM_NEQ_ENVFROM(0.00)[tconvertino@gmail.com,couchmoney@gmail.com];
|
|
||||||
MIME_TRACE(0.00)[0:+,1:+,2:~];
|
|
||||||
FREEMAIL_ENVFROM(0.00)[gmail.com];
|
|
||||||
RCPT_COUNT_ONE(0.00)[1];
|
|
||||||
FREEMAIL_REPLYTO(0.00)[gmail.com];
|
|
||||||
FREEMAIL_FROM(0.00)[gmail.com];
|
|
||||||
URIBL_BLOCKED(0.00)[mail-lj1-x230.google.com:rdns,mail-lj1-x230.google.com:helo];
|
|
||||||
TAGGED_FROM(0.00)[caf_=gmail=xinutv];
|
|
||||||
HAS_REPLYTO(0.00)[tconvertino@gmail.com];
|
|
||||||
NEURAL_HAM(-0.00)[-0.995];
|
|
||||||
FWD_GOOGLE(0.00)[couchmoney@gmail.com];
|
|
||||||
TO_DN_NONE(0.00)[];
|
|
||||||
FORGED_SENDER_FORWARDING(0.00)[];
|
|
||||||
RCVD_TLS_LAST(0.00)[];
|
|
||||||
TO_DOM_EQ_FROM_DOM(0.00)[];
|
|
||||||
FROM_NO_DN(0.00)[];
|
|
||||||
ASN(0.00)[asn:15169, ipnet:2a00:1450::/32, country:US];
|
|
||||||
DKIM_TRACE(0.00)[google.com:+,gmail.com:+];
|
|
||||||
MISSING_XM_UA(0.00)[];
|
|
||||||
REPLYTO_EQ_FROM(0.00)[]
|
|
||||||
X-Rspamd-Server: phx
|
|
||||||
X-Rspamd-Action: no action
|
|
||||||
X-Rspamd-Queue-Id: B4E848B007
|
|
||||||
X-TUID: eMNiZ49uiDPB
|
|
||||||
|
|
||||||
--000000000000fc1bff063d71aa4b
|
|
||||||
Content-Type: text/plain; charset="UTF-8"; format=flowed; delsp=yes
|
|
||||||
Content-Transfer-Encoding: base64
|
|
||||||
|
|
||||||
RGVudGlzdCBhcHB0DQpUdWVzZGF5IFNlcCAyMywgMjAyNSDii4UgM3BtIOKAkyA0cG0NClBhY2lm
|
|
||||||
aWMgVGltZSAtIExvcyBBbmdlbGVzDQoNCg0KDQpPcmdhbml6ZXINCnRjb252ZXJ0aW5vQGdtYWls
|
|
||||||
LmNvbQ0KdGNvbnZlcnRpbm9AZ21haWwuY29tDQoNCn5+Ly9+fg0KSW52aXRhdGlvbiBmcm9tIEdv
|
|
||||||
b2dsZSBDYWxlbmRhcjogaHR0cHM6Ly9jYWxlbmRhci5nb29nbGUuY29tL2NhbGVuZGFyLw0KDQpZ
|
|
||||||
b3UgYXJlIHJlY2VpdmluZyB0aGlzIGVtYWlsIGJlY2F1c2UgeW91IGFyZSBzdWJzY3JpYmVkIHRv
|
|
||||||
IGNhbGVuZGFyICANCm5vdGlmaWNhdGlvbnMuIFRvIHN0b3AgcmVjZWl2aW5nIHRoZXNlIGVtYWls
|
|
||||||
cywgZ28gdG8gIA0KaHR0cHM6Ly9jYWxlbmRhci5nb29nbGUuY29tL2NhbGVuZGFyL3Ivc2V0dGlu
|
|
||||||
Z3MsIHNlbGVjdCB0aGlzIGNhbGVuZGFyLCBhbmQgIA0KY2hhbmdlICJPdGhlciBub3RpZmljYXRp
|
|
||||||
b25zIi4NCg0KRm9yd2FyZGluZyB0aGlzIGludml0YXRpb24gY291bGQgYWxsb3cgYW55IHJlY2lw
|
|
||||||
aWVudCB0byBzZW5kIGEgcmVzcG9uc2UgdG8gIA0KdGhlIG9yZ2FuaXplciwgYmUgYWRkZWQgdG8g
|
|
||||||
dGhlIGd1ZXN0IGxpc3QsIGludml0ZSBvdGhlcnMgcmVnYXJkbGVzcyBvZiAgDQp0aGVpciBvd24g
|
|
||||||
aW52aXRhdGlvbiBzdGF0dXMsIG9yIG1vZGlmeSB5b3VyIFJTVlAuDQoNCkxlYXJuIG1vcmUgaHR0
|
|
||||||
cHM6Ly9zdXBwb3J0Lmdvb2dsZS5jb20vY2FsZW5kYXIvYW5zd2VyLzM3MTM1I2ZvcndhcmRpbmcN
|
|
||||||
Cg==
|
|
||||||
--000000000000fc1bff063d71aa4b
|
|
||||||
Content-Type: text/html; charset="UTF-8"
|
|
||||||
Content-Transfer-Encoding: quoted-printable
|
|
||||||
|
|
||||||
<!doctype html><html xmlns=3D"http://www.w3.org/1999/xhtml" xmlns:v=3D"urn:="...truncated for brevity...
|
|
||||||
175
server/testdata/google-calendar-example-thursday.eml
vendored
175
server/testdata/google-calendar-example-thursday.eml
vendored
@ -1,175 +0,0 @@
|
|||||||
Return-Path: <couchmoney+caf_=gmail=xinu.tv@gmail.com>
|
|
||||||
Delivered-To: bill@xinu.tv
|
|
||||||
Received: from phx.xinu.tv [74.207.253.222]
|
|
||||||
by nixos-01.h.xinu.tv with IMAP (fetchmail-6.5.1)
|
|
||||||
for <wathiede@localhost> (single-drop); Thu, 11 Sep 2025 12:27:35 -0700 (PDT)
|
|
||||||
Received: from phx.xinu.tv
|
|
||||||
by phx.xinu.tv with LMTP
|
|
||||||
id CqRrBqciw2hiKicAJR8clQ
|
|
||||||
(envelope-from <couchmoney+caf_=gmail=xinu.tv@gmail.com>)
|
|
||||||
for <bill@xinu.tv>; Thu, 11 Sep 2025 12:27:35 -0700
|
|
||||||
X-Original-To: gmail@xinu.tv
|
|
||||||
Received-SPF: Pass (mailfrom) identity=mailfrom; client-ip=2a00:1450:4864:20::130; helo=mail-lf1-x130.google.com; envelope-from=couchmoney+caf_=gmail=xinu.tv@gmail.com; receiver=xinu.tv
|
|
||||||
Authentication-Results: phx.xinu.tv;
|
|
||||||
dkim=pass (2048-bit key; unprotected) header.d=google.com header.i=@google.com header.a=rsa-sha256 header.s=20230601 header.b=dc+iKaXd;
|
|
||||||
dkim=pass (2048-bit key; unprotected) header.d=gmail.com header.i=@gmail.com header.a=rsa-sha256 header.s=20230601 header.b=kf8o8wAd
|
|
||||||
Received: from mail-lf1-x130.google.com (mail-lf1-x130.google.com [IPv6:2a00:1450:4864:20::130])
|
|
||||||
by phx.xinu.tv (Postfix) with ESMTPS id D7E2D80037
|
|
||||||
for <gmail@xinu.tv>; Thu, 11 Sep 2025 12:27:33 -0700 (PDT)
|
|
||||||
Received: by mail-lf1-x130.google.com with SMTP id 2adb3069b0e04-55f716e25d9so1141446e87.1
|
|
||||||
for <gmail@xinu.tv>; Thu, 11 Sep 2025 12:27:33 -0700 (PDT)
|
|
||||||
ARC-Seal: i=2; a=rsa-sha256; t=1757618852; cv=pass;
|
|
||||||
d=google.com; s=arc-20240605;
|
|
||||||
b=MZ+1JfQuPR9luCCxiZNUeqSEpjt1vLuM3bTRCaal/W0NBxkCH0y5v9WfPR0KJ2BPb1
|
|
||||||
Rtnt/5ayDtmsLf8l6yTTVsBlFYW70ehqXWMD10MMcDEMvnib4KKDAacGaSmijAK4cYGq
|
|
||||||
FOU9CGNY986OMXMk54TD9NF3fkKDIKcAoh81D6at5/DE3Puuxofq0vZmtmVqQBNKG169
|
|
||||||
REkhcDpkXTMs/4rJpmZwXp2HbjD84avusBwSlYIQUWsBgO4g7THHjoR4Uk56cek9aEds
|
|
||||||
ip8IkTO6KRFe6u8FebQsZ/Q9sSAK3pheMExWFVMha9Y0XhACVOZiV600zRCPS9MNHhYw
|
|
||||||
XEaA==
|
|
||||||
ARC-Message-Signature: i=2; a=rsa-sha256; c=relaxed/relaxed; d=google.com; s=arc-20240605;
|
|
||||||
h=to:from:subject:date:message-id:auto-submitted:sender:reply-to
|
|
||||||
:mime-version:dkim-signature:dkim-signature:delivered-to;
|
|
||||||
bh=mVNsDGUAhSGrAIoTy8PIfvCBxBB4yaBy/VZH8i3gPl4=;
|
|
||||||
fh=WnbwIlqFRbBot/H7TyqablNBDgXRuegsgjC3piothTI=;
|
|
||||||
b=aYMo5f7VI2b4CiAvLELRJ9zM3dF7ZH8FEqmoAtCcfPHrT9kLLCnriuyXG1R6sC3eoR
|
|
||||||
++boT29xoScVroIlfcI77Ty7N5X1fawOABkVDWWt7z5w4WhiesT0klxw5nINj9hnLBiK
|
|
||||||
22nrMevpRpFtmuDO7cle78lSAFZoZuyv+aXCK9RnLKvIm2JuXRrvU8LivxbbpNB4gNl0
|
|
||||||
hE1jsGuZm1SOJ54SRLwwa4HpSiOJV2x2txTtPCzmvE/LZvNESPjfi3Y2u7gaR87OzkNs
|
|
||||||
gNi5Xoc+D908zBsmcYKpUYiQcPL79s3DfNwYFIs/rR8Z2xgaHbFD/YmqRUmCEeNLv7o2
|
|
||||||
RR8g==;
|
|
||||||
darn=xinu.tv
|
|
||||||
ARC-Authentication-Results: i=2; mx.google.com;
|
|
||||||
dkim=pass header.i=@google.com header.s=20230601 header.b=dc+iKaXd;
|
|
||||||
dkim=pass header.i=@gmail.com header.s=20230601 header.b=kf8o8wAd;
|
|
||||||
spf=pass (google.com: domain of tconvertino@gmail.com designates 209.85.220.73 as permitted sender) smtp.mailfrom=tconvertino@gmail.com;
|
|
||||||
dmarc=pass (p=NONE sp=QUARANTINE dis=NONE) header.from=gmail.com;
|
|
||||||
dara=pass header.i=@gmail.com
|
|
||||||
X-Google-DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed;
|
|
||||||
d=1e100.net; s=20230601; t=1757618852; x=1758223652;
|
|
||||||
h=to:from:subject:date:message-id:auto-submitted:sender:reply-to
|
|
||||||
:mime-version:dkim-signature:dkim-signature:delivered-to
|
|
||||||
:x-forwarded-for:x-forwarded-to:x-gm-message-state:from:to:cc
|
|
||||||
:subject:date:message-id:reply-to;
|
|
||||||
bh=mVNsDGUAhSGrAIoTy8PIfvCBxBB4yaBy/VZH8i3gPl4=;
|
|
||||||
b=GKJkb+LmE79XIMEhHRvoCodKS+GBTOCShzMe06Q+zKxUZFHi6XMg8GqteuXQO9LVbw
|
|
||||||
nPUVN4QO2Hvqch0xzjbc0ryyMOD0u7HqpDUAEZCzamFXIfsX6hZXKLhFqy4YomtsG3os
|
|
||||||
TCOWBGLqwu7KalfOVg2p+csOR68i0mGyBII1sKcL9vUv9kIQJZxQKHGkuIc48cf6tbUB
|
|
||||||
L+mkVbMwXLSbpuTJszPmIVZV5o0K52KN+2QoLcmXGfw0mUOnjNI0oSovdbPg4SSDZ3cw
|
|
||||||
iIsC9vjvtCSFS3pf+Fp807s+Zjh5P6xeSxGU57qhC+HT9kTzIioh5EqKnGqcskDTqrI1
|
|
||||||
uCiQ==
|
|
||||||
X-Forwarded-Encrypted: i=2; AJvYcCUfSSA2sT31daRt2+W7dAD9YPx1gqa4JFpVuqCtxVtjqbKfKhOX/EcDQiECQ4BEWjmAP+IqTQ==@xinu.tv
|
|
||||||
X-Gm-Message-State: AOJu0Ywn7D0BjTaGiM/UFG0WhGuyYGfpLijg+ouhrOaGZzSREyTcRa37
|
|
||||||
XA3bzQ/LKTpzWhhh01GMwnigmELbWdIVr/BeRLVCuJdh+m+JBMgnAjBTIDs9RF3/xfR7rpG7VOB
|
|
||||||
6k+ugF+8QRKB4BcL2t8MvfJD03CkrzuhhvUtFTRHopcSZrkqzh8GOJayq42VveQ==
|
|
||||||
X-Received: by 2002:a05:6512:3b24:b0:55f:6580:818c with SMTP id 2adb3069b0e04-57050fe2fa3mr165340e87.46.1757618851553;
|
|
||||||
Thu, 11 Sep 2025 12:27:31 -0700 (PDT)
|
|
||||||
X-Forwarded-To: gmail@xinu.tv
|
|
||||||
X-Forwarded-For: couchmoney@gmail.com gmail@xinu.tv
|
|
||||||
Delivered-To: couchmoney@gmail.com
|
|
||||||
Received: by 2002:a05:6504:d09:b0:2c3:f6c4:ad72 with SMTP id c9csp3388833lty;
|
|
||||||
Thu, 11 Sep 2025 12:27:29 -0700 (PDT)
|
|
||||||
X-Received: by 2002:a05:6602:36ce:b0:889:b536:779b with SMTP id ca18e2360f4ac-8903378d714mr78653239f.7.1757618849269;
|
|
||||||
Thu, 11 Sep 2025 12:27:29 -0700 (PDT)
|
|
||||||
ARC-Seal: i=1; a=rsa-sha256; t=1757618849; cv=none;
|
|
||||||
d=google.com; s=arc-20240605;
|
|
||||||
b=Ln2bufZfSNhR/NmMPrG2QFdtvupjJtLDQnFvsL8HTPn+Dlrt5ff+6k6Wpupab/5mS7
|
|
||||||
hXjtVD0jnryGUiM5h+SNjxwzNPM3PBoueTpAzzBkjHQqMxJVpspgsGJUVOWAVRBWtWo
|
|
||||||
39qFyoP0vhzGRWDAuAFV+4VDhsvH7GL8lTrZCSMzrngTadmEdJ5haUIQOa50KFUn5HrK
|
|
||||||
1r12gayb+TaGaWfQfDo0Me689T8MQnS0ITUuzgvFxfgHZBz3h+IPnC0hrlhdziGovETo
|
|
||||||
GvHzgCCtiVzu6rop6VMLjLuAYmmT9+jZ3GjSRb+078C9cJR17YpguOC14Cyv4od1Tf7y
|
|
||||||
RFiQ==;
|
|
||||||
dara=google.com
|
|
||||||
ARC-Message-Signature: i=1; a=rsa-sha256; c=relaxed/relaxed; d=google.com; s=arc-20240605;
|
|
||||||
h=to:from:subject:date:message-id:auto-submitted:sender:reply-to
|
|
||||||
:mime-version:dkim-signature:dkim-signature;
|
|
||||||
bh=mVNsDGUAhSGrAIoTy8PIfvCBxBB4yaBy/VZH8i3gPl4=;
|
|
||||||
fh=mbzrMIWIgWMC0ni1xEx+ViW4J0RLAdLdPT2cX81nTlk=;
|
|
||||||
b=JRkHr3CKSkCrafdLzBRtaBOGNl3/0ZSTtgubaNXtvhAiIqRqiQYocfLnVM6N/9sH7O
|
|
||||||
byTXYaRoaRLw/35WM+QTFGP3zUGRkM3eO4UVS/utVIss1IVLDjfmZHalqLYl8RokW5br
|
|
||||||
89Z/xYIyjTE7WUdy6uMSrExCNm5VWjO/qcMKsE5s5oDbXdSLaUYxLTurICM3LQksGkCY
|
|
||||||
wiAWaDDqK14+uhEhW5AyEnebDSYhL9U8UadIv+eK6Ng9q1kwOUzxICRQXEyUtnKhaDKJ
|
|
||||||
eZ1Qe1mp1CjCulr+I15fz3VwUJ6W1cv6cytcxPbu4p5GPn2gb2hS1eR81HVTL6V1Sp5G
|
|
||||||
NdDQ==;
|
|
||||||
dara=google.com
|
|
||||||
ARC-Authentication-Results: i=1; mx.google.com;
|
|
||||||
dkim=pass header.i=@google.com header.s=20230601 header.b=dc+iKaXd;
|
|
||||||
dkim=pass header.i=@gmail.com header.s=20230601 header.b=kf8o8wAd;
|
|
||||||
spf=pass (google.com: domain of tconvertino@gmail.com designates 209.85.220.73 as permitted sender) smtp.mailfrom=tconvertino@gmail.com;
|
|
||||||
dmarc=pass (p=NONE sp=QUARANTINE dis=NONE) header.from=gmail.com;
|
|
||||||
dara=pass header.i=@gmail.com
|
|
||||||
Received: from mail-sor-f73.google.com (mail-sor-f73.google.com. [209.85.220.73])
|
|
||||||
by mx.google.com with SMTPS id ca18e2360f4ac-88f2ea1122asor117632339f.3.2025.09.11.12.27.29
|
|
||||||
for <couchmoney@gmail.com>
|
|
||||||
(Google Transport Security);
|
|
||||||
Thu, 11 Sep 2025 12:27:29 -0700 (PDT)
|
|
||||||
Received-SPF: pass (google.com: domain of tconvertino@gmail.com designates 209.85.220.73 as permitted sender) client-ip=209.85.220.73;
|
|
||||||
Authentication-Results: mx.google.com;
|
|
||||||
dkim=pass header.i=@google.com header.s=20230601 header.b=dc+iKaXd;
|
|
||||||
dkim=pass header.i=@gmail.com header.s=20230601 header.b=kf8o8wAd;
|
|
||||||
spf=pass (google.com: domain of tconvertino@gmail.com designates 209.85.220.73 as permitted sender) smtp.mailfrom=tconvertino@gmail.com;
|
|
||||||
dmarc=pass (p=NONE sp=QUARANTINE dis=NONE) header.from=gmail.com;
|
|
||||||
dara=pass header.i=@gmail.com
|
|
||||||
DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed;
|
|
||||||
d=google.com; s=20230601; t=1757618849; x=1758223649; dara=google.com;
|
|
||||||
h=to:from:subject:date:message-id:auto-submitted:sender:reply-to
|
|
||||||
:mime-version:from:to:cc:subject:date:message-id:reply-to;
|
|
||||||
bh=mVNsDGUAhSGrAIoTy8PIfvCBxBB4yaBy/VZH8i3gPl4=;
|
|
||||||
b=dc+iKaXdFyqu6K0MIgk848QuwpQXvwzwlEVkxmjuCWvn9DzanMbYn5QJRyRTKilRna
|
|
||||||
BZ7gJSPriHUHcJd4fVKgGuCaQg0TxenCwm+0R64oB1xcDLfonayo/nCrFqEcCLHNmi7x
|
|
||||||
lTyWGJ0rLw6nKazxtcCdIbDhVgiE7/fXNI89w6XFp6pcKLl48yFIoCG1f6uY4iQ7QqNU
|
|
||||||
hLHzjmlzjTi58xFLao7SizZ0lr7E5cHXKHp1Ls/hkDzzcY0Y+O5+3r+NQw4MtpHTcY6/
|
|
||||||
kQlg6OhyMx8PTu4cuepQKXLHV4aFaNJbDQTp8wew4xPIgi7pm2p6hb6C3GgwY6ptOvLd
|
|
||||||
wuag==
|
|
||||||
DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed;
|
|
||||||
d=gmail.com; s=20230601; t=1757618849; x=1758223649; dara=google.com;
|
|
||||||
h=to:from:subject:date:message-id:auto-submitted:sender:reply-to
|
|
||||||
:mime-version:from:to:cc:subject:date:message-id:reply-to;
|
|
||||||
bh=mVNsDGUAhSGrAIoTy8PIfvCBxBB4yaBy/VZH8i3gPl4=;
|
|
||||||
b=kf8o8wAd5DSU/NC7SDiuIoohCu+/7wTjWyQqDYbBjUFGaBaYdj6aD5JWNQ1KEA2W8o
|
|
||||||
E+Qy2ymyrzodKa1eOsQX2UDAYKOKpdxMWvx1u19+SC3Dp8DP4puRMrL2ObiSEMLCuOvz
|
|
||||||
Mxmkd+ZUP72EhVuQwK1iSm04/cjQaMsSiPhvSBaxXMaaarwlKeOoCoIo+qC/Z9emiBBv
|
|
||||||
Gk0sQcLA+CByvsxuvD9GInSA0rdoZ0ijhSb0Y475Hieam1QQqy/fhe8lgujzhXNFoIbR
|
|
||||||
5EA9GE0VV9PDoNanaT+u954YeOFBL2YZ5gm2gHltw8tBI98LKnC42Pa3qyMznBa2dI2Q
|
|
||||||
A0RQ==
|
|
||||||
X-Google-Smtp-Source: AGHT+IGmC5/03nTVMeYJBoq1R/BiA19iH0DFaZyyImB3W8mtgjdn+XqIFK1fC8aTwWRXQmsr71Xo0cmkgx6hjPvicQ/d
|
|
||||||
MIME-Version: 1.0
|
|
||||||
X-Received: by 2002:a05:6602:380d:b0:887:4c93:f12c with SMTP id
|
|
||||||
ca18e2360f4ac-8903596aca3mr58994639f.17.1757618848817; Thu, 11 Sep 2025
|
|
||||||
12:27:28 -0700 (PDT)
|
|
||||||
Reply-To: tconvertino@gmail.com
|
|
||||||
Sender: Google Calendar <calendar-notification@google.com>
|
|
||||||
Auto-Submitted: auto-generated
|
|
||||||
Message-ID: <calendar-01d5e8a0-fad7-450b-9758-a16472bf2aa8@google.com>
|
|
||||||
Date: Thu, 11 Sep 2025 19:27:28 +0000
|
|
||||||
Subject: Canceled event: Scout Babysits @ Thu Sep 11, 2025 6pm - 9pm (PDT) (Family)
|
|
||||||
From: tconvertino@gmail.com
|
|
||||||
To: couchmoney@gmail.com
|
|
||||||
Content-Type: multipart/mixed; boundary="000000000000226b77063e8b878d"
|
|
||||||
|
|
||||||
--000000000000226b77063e8b878d
|
|
||||||
Content-Type: text/calendar; charset="UTF-8"; method=CANCEL
|
|
||||||
Content-Transfer-Encoding: 7bit
|
|
||||||
|
|
||||||
BEGIN:VCALENDAR
|
|
||||||
PRODID:-//Google Inc//Google Calendar 70.9054//EN
|
|
||||||
VERSION:2.0
|
|
||||||
CALSCALE:GREGORIAN
|
|
||||||
METHOD:CANCEL
|
|
||||||
X-GOOGLE-CALID:g66m0feuqsao8l1c767pvvcg4k@group.calendar.google.com
|
|
||||||
BEGIN:VEVENT
|
|
||||||
DTSTART:20250912T010000Z
|
|
||||||
DTEND:20250912T040000Z
|
|
||||||
DTSTAMP:20250911T192728Z
|
|
||||||
UID:4ang6172d1t7782sn2hmi30fgi@google.com
|
|
||||||
CREATED:20250901T224707Z
|
|
||||||
DESCRIPTION:
|
|
||||||
LAST-MODIFIED:20250911T192728Z
|
|
||||||
LOCATION:
|
|
||||||
SEQUENCE:1
|
|
||||||
STATUS:CANCELLED
|
|
||||||
SUMMARY:Scout Babysits
|
|
||||||
TRANSP:OPAQUE
|
|
||||||
END:VEVENT
|
|
||||||
END:VCALENDAR
|
|
||||||
|
|
||||||
--000000000000226b77063e8b878d--
|
|
||||||
12
server/testdata/ical-straddle.ics
vendored
12
server/testdata/ical-straddle.ics
vendored
@ -1,13 +1,9 @@
|
|||||||
|
|
||||||
BEGIN:VCALENDAR
|
BEGIN:VCALENDAR
|
||||||
VERSION:2.0
|
VERSION:2.0
|
||||||
PRODID:-//Test Recurring Event//EN
|
|
||||||
BEGIN:VEVENT
|
BEGIN:VEVENT
|
||||||
UID:recurring-test-1@example.com
|
SUMMARY:Straddle Month Event
|
||||||
DTSTART;VALUE=DATE:20250804
|
DTSTART;VALUE=DATE:20250830
|
||||||
DTEND;VALUE=DATE:20250805
|
DTEND;VALUE=DATE:20250903
|
||||||
RRULE:FREQ=WEEKLY;BYDAY=MO,WE,FR;UNTIL=20250825T000000Z
|
DESCRIPTION:This event straddles two months.
|
||||||
SUMMARY:Test Recurring Event (Mon, Wed, Fri)
|
|
||||||
DESCRIPTION:This event recurs every Monday, Wednesday, and Friday in August 2025.
|
|
||||||
END:VEVENT
|
END:VEVENT
|
||||||
END:VCALENDAR
|
END:VCALENDAR
|
||||||
|
|||||||
@ -11,8 +11,8 @@ version.workspace = true
|
|||||||
# See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html
|
# See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html
|
||||||
|
|
||||||
[dependencies]
|
[dependencies]
|
||||||
build-info = "0.0.42"
|
build-info = "0.0.41"
|
||||||
letterbox-notmuch = { path = "../notmuch", version = "0.17", registry = "xinu" }
|
letterbox-notmuch = { path = "../notmuch", version = "0.17.37", registry = "xinu" }
|
||||||
regex = "1.11.1"
|
regex = "1.11.1"
|
||||||
serde = { version = "1.0.219", features = ["derive"] }
|
serde = { version = "1.0.219", features = ["derive"] }
|
||||||
sqlx = "0.8.5"
|
sqlx = "0.8.5"
|
||||||
|
|||||||
@ -9,10 +9,10 @@ repository.workspace = true
|
|||||||
version.workspace = true
|
version.workspace = true
|
||||||
|
|
||||||
[build-dependencies]
|
[build-dependencies]
|
||||||
build-info-build = "0.0.42"
|
build-info-build = "0.0.41"
|
||||||
|
|
||||||
[dev-dependencies]
|
[dev-dependencies]
|
||||||
#wasm-bindgen-test = "0.3.50"
|
wasm-bindgen-test = "0.3.50"
|
||||||
|
|
||||||
[dependencies]
|
[dependencies]
|
||||||
console_error_panic_hook = "0.1.7"
|
console_error_panic_hook = "0.1.7"
|
||||||
@ -24,16 +24,16 @@ serde = { version = "1.0.219", features = ["derive"] }
|
|||||||
itertools = "0.14.0"
|
itertools = "0.14.0"
|
||||||
serde_json = { version = "1.0.140", features = ["unbounded_depth"] }
|
serde_json = { version = "1.0.140", features = ["unbounded_depth"] }
|
||||||
chrono = "0.4.40"
|
chrono = "0.4.40"
|
||||||
graphql_client = "0.15.0"
|
graphql_client = "0.14.0"
|
||||||
thiserror = "2.0.12"
|
thiserror = "2.0.12"
|
||||||
gloo-net = { version = "0.6.0", features = ["json", "serde_json"] }
|
gloo-net = { version = "0.6.0", features = ["json", "serde_json"] }
|
||||||
human_format = "1.1.0"
|
human_format = "1.1.0"
|
||||||
build-info = "0.0.42"
|
build-info = "0.0.41"
|
||||||
wasm-bindgen = "=0.2.100"
|
wasm-bindgen = "=0.2.100"
|
||||||
uuid = { version = "1.16.0", features = [
|
uuid = { version = "1.16.0", features = [
|
||||||
"js",
|
"js",
|
||||||
] } # direct dep to set js feature, prevents Rng issues
|
] } # direct dep to set js feature, prevents Rng issues
|
||||||
letterbox-shared = { path = "../shared/", version = "0.17", registry = "xinu" }
|
letterbox-shared = { path = "../shared/", version = "0.17.37", registry = "xinu" }
|
||||||
seed_hooks = { version = "0.4.1", registry = "xinu" }
|
seed_hooks = { version = "0.4.1", registry = "xinu" }
|
||||||
strum_macros = "0.27.1"
|
strum_macros = "0.27.1"
|
||||||
gloo-console = "0.3.0"
|
gloo-console = "0.3.0"
|
||||||
|
|||||||
@ -51,7 +51,7 @@
|
|||||||
},
|
},
|
||||||
{
|
{
|
||||||
"args": [],
|
"args": [],
|
||||||
"description": "Indicates that an Input Object is a OneOf Input Object (and thus requires exactly one of its field be provided)",
|
"description": "Indicates that an Input Object is a OneOf Input Object (and thus requires\n exactly one of its field be provided)",
|
||||||
"locations": [
|
"locations": [
|
||||||
"INPUT_OBJECT"
|
"INPUT_OBJECT"
|
||||||
],
|
],
|
||||||
@ -107,14 +107,12 @@
|
|||||||
}
|
}
|
||||||
],
|
],
|
||||||
"mutationType": {
|
"mutationType": {
|
||||||
"name": "MutationRoot"
|
"name": "Mutation"
|
||||||
},
|
},
|
||||||
"queryType": {
|
"queryType": {
|
||||||
"name": "QueryRoot"
|
"name": "QueryRoot"
|
||||||
},
|
},
|
||||||
"subscriptionType": {
|
"subscriptionType": null,
|
||||||
"name": "SubscriptionRoot"
|
|
||||||
},
|
|
||||||
"types": [
|
"types": [
|
||||||
{
|
{
|
||||||
"description": null,
|
"description": null,
|
||||||
@ -316,16 +314,6 @@
|
|||||||
"name": "Corpus",
|
"name": "Corpus",
|
||||||
"possibleTypes": null
|
"possibleTypes": null
|
||||||
},
|
},
|
||||||
{
|
|
||||||
"description": "Implement the DateTime<Utc> scalar\n\nThe input/output is a string in RFC3339 format.",
|
|
||||||
"enumValues": null,
|
|
||||||
"fields": null,
|
|
||||||
"inputFields": null,
|
|
||||||
"interfaces": null,
|
|
||||||
"kind": "SCALAR",
|
|
||||||
"name": "DateTime",
|
|
||||||
"possibleTypes": null
|
|
||||||
},
|
|
||||||
{
|
{
|
||||||
"description": null,
|
"description": null,
|
||||||
"enumValues": [
|
"enumValues": [
|
||||||
@ -981,51 +969,6 @@
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
},
|
},
|
||||||
{
|
|
||||||
"args": [
|
|
||||||
{
|
|
||||||
"defaultValue": null,
|
|
||||||
"description": null,
|
|
||||||
"name": "query",
|
|
||||||
"type": {
|
|
||||||
"kind": "NON_NULL",
|
|
||||||
"name": null,
|
|
||||||
"ofType": {
|
|
||||||
"kind": "SCALAR",
|
|
||||||
"name": "String",
|
|
||||||
"ofType": null
|
|
||||||
}
|
|
||||||
}
|
|
||||||
},
|
|
||||||
{
|
|
||||||
"defaultValue": null,
|
|
||||||
"description": null,
|
|
||||||
"name": "wakeTime",
|
|
||||||
"type": {
|
|
||||||
"kind": "NON_NULL",
|
|
||||||
"name": null,
|
|
||||||
"ofType": {
|
|
||||||
"kind": "SCALAR",
|
|
||||||
"name": "DateTime",
|
|
||||||
"ofType": null
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
],
|
|
||||||
"deprecationReason": null,
|
|
||||||
"description": null,
|
|
||||||
"isDeprecated": false,
|
|
||||||
"name": "snooze",
|
|
||||||
"type": {
|
|
||||||
"kind": "NON_NULL",
|
|
||||||
"name": null,
|
|
||||||
"ofType": {
|
|
||||||
"kind": "SCALAR",
|
|
||||||
"name": "Boolean",
|
|
||||||
"ofType": null
|
|
||||||
}
|
|
||||||
}
|
|
||||||
},
|
|
||||||
{
|
{
|
||||||
"args": [],
|
"args": [],
|
||||||
"deprecationReason": null,
|
"deprecationReason": null,
|
||||||
@ -1046,7 +989,7 @@
|
|||||||
"inputFields": null,
|
"inputFields": null,
|
||||||
"interfaces": [],
|
"interfaces": [],
|
||||||
"kind": "OBJECT",
|
"kind": "OBJECT",
|
||||||
"name": "MutationRoot",
|
"name": "Mutation",
|
||||||
"possibleTypes": null
|
"possibleTypes": null
|
||||||
},
|
},
|
||||||
{
|
{
|
||||||
@ -1531,33 +1474,6 @@
|
|||||||
"name": "String",
|
"name": "String",
|
||||||
"possibleTypes": null
|
"possibleTypes": null
|
||||||
},
|
},
|
||||||
{
|
|
||||||
"description": null,
|
|
||||||
"enumValues": null,
|
|
||||||
"fields": [
|
|
||||||
{
|
|
||||||
"args": [],
|
|
||||||
"deprecationReason": null,
|
|
||||||
"description": null,
|
|
||||||
"isDeprecated": false,
|
|
||||||
"name": "values",
|
|
||||||
"type": {
|
|
||||||
"kind": "NON_NULL",
|
|
||||||
"name": null,
|
|
||||||
"ofType": {
|
|
||||||
"kind": "SCALAR",
|
|
||||||
"name": "Int",
|
|
||||||
"ofType": null
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
],
|
|
||||||
"inputFields": null,
|
|
||||||
"interfaces": [],
|
|
||||||
"kind": "OBJECT",
|
|
||||||
"name": "SubscriptionRoot",
|
|
||||||
"possibleTypes": null
|
|
||||||
},
|
|
||||||
{
|
{
|
||||||
"description": null,
|
"description": null,
|
||||||
"enumValues": null,
|
"enumValues": null,
|
||||||
|
|||||||
@ -1,4 +0,0 @@
|
|||||||
|
|
||||||
mutation SnoozeMutation($query: String!, $wakeTime: DateTime!) {
|
|
||||||
snooze(query: $query, wakeTime: $wakeTime)
|
|
||||||
}
|
|
||||||
@ -1,4 +1,4 @@
|
|||||||
DEV_HOST=localhost
|
DEV_HOST=localhost
|
||||||
DEV_PORT=9345
|
DEV_PORT=9345
|
||||||
graphql-client introspect-schema http://${DEV_HOST:?}:${DEV_PORT:?}/api/graphql/ --output schema.json
|
graphql-client introspect-schema http://${DEV_HOST:?}:${DEV_PORT:?}/api/graphql --output schema.json
|
||||||
git diff schema.json
|
git diff schema.json
|
||||||
|
|||||||
@ -4,8 +4,8 @@
|
|||||||
<head>
|
<head>
|
||||||
<meta charset="utf-8">
|
<meta charset="utf-8">
|
||||||
<meta name="viewport" content="width=device-width, initial-scale=1, shrink-to-fit=no">
|
<meta name="viewport" content="width=device-width, initial-scale=1, shrink-to-fit=no">
|
||||||
<link rel="stylesheet" href="https://cdnjs.cloudflare.com/ajax/libs/font-awesome/7.0.1/css/all.min.css"
|
<link rel="stylesheet" href="https://cdnjs.cloudflare.com/ajax/libs/font-awesome/6.7.2/css/all.min.css"
|
||||||
integrity="sha512-2SwdPD6INVrV/lHTZbO2nodKhrnDdJK9/kg2XD1r9uGqPo1cUbujc+IYdlYdEErWNu69gVcYgdxlmVmzTWnetw=="
|
integrity="sha512-Evv84Mr4kqVGRNSgIGL/F/aIDqQb7xQ2vcrdIwxfjThSH8CSR7PBEakCr51Ck+w+/U6swU2Im1vVX0SVk9ABhg=="
|
||||||
crossorigin="anonymous" referrerpolicy="no-referrer" />
|
crossorigin="anonymous" referrerpolicy="no-referrer" />
|
||||||
<link rel="icon" href="https://static.xinu.tv/favicon/letterbox.svg" />
|
<link rel="icon" href="https://static.xinu.tv/favicon/letterbox.svg" />
|
||||||
<!-- tall thin font for user icon -->
|
<!-- tall thin font for user icon -->
|
||||||
|
|||||||
@ -1,9 +1,7 @@
|
|||||||
use chrono::Utc;
|
|
||||||
use gloo_net::{http::Request, Error};
|
use gloo_net::{http::Request, Error};
|
||||||
use graphql_client::GraphQLQuery;
|
use graphql_client::GraphQLQuery;
|
||||||
use serde::{de::DeserializeOwned, Serialize};
|
use serde::{de::DeserializeOwned, Serialize};
|
||||||
|
|
||||||
type DateTime = chrono::DateTime<Utc>;
|
|
||||||
// The paths are relative to the directory where your `Cargo.toml` is located.
|
// The paths are relative to the directory where your `Cargo.toml` is located.
|
||||||
// Both json and the GraphQL schema language are supported as sources for the schema
|
// Both json and the GraphQL schema language are supported as sources for the schema
|
||||||
#[derive(GraphQLQuery)]
|
#[derive(GraphQLQuery)]
|
||||||
@ -54,14 +52,6 @@ pub struct AddTagMutation;
|
|||||||
)]
|
)]
|
||||||
pub struct RemoveTagMutation;
|
pub struct RemoveTagMutation;
|
||||||
|
|
||||||
#[derive(GraphQLQuery)]
|
|
||||||
#[graphql(
|
|
||||||
schema_path = "graphql/schema.json",
|
|
||||||
query_path = "graphql/snooze.graphql",
|
|
||||||
response_derives = "Debug"
|
|
||||||
)]
|
|
||||||
pub struct SnoozeMutation;
|
|
||||||
|
|
||||||
#[derive(GraphQLQuery)]
|
#[derive(GraphQLQuery)]
|
||||||
#[graphql(
|
#[graphql(
|
||||||
schema_path = "graphql/schema.json",
|
schema_path = "graphql/schema.json",
|
||||||
|
|||||||
@ -1,6 +1,5 @@
|
|||||||
use std::collections::HashSet;
|
use std::collections::HashSet;
|
||||||
|
|
||||||
use chrono::{DateTime, Utc};
|
|
||||||
use graphql_client::GraphQLQuery;
|
use graphql_client::GraphQLQuery;
|
||||||
use letterbox_shared::WebsocketMessage;
|
use letterbox_shared::WebsocketMessage;
|
||||||
use log::{debug, error, info, warn};
|
use log::{debug, error, info, warn};
|
||||||
@ -260,29 +259,6 @@ pub fn update(msg: Msg, model: &mut Model, orders: &mut impl Orders<Msg>) {
|
|||||||
Msg::GoToSearchResults
|
Msg::GoToSearchResults
|
||||||
});
|
});
|
||||||
}
|
}
|
||||||
Msg::Snooze(query, wake_time) => {
|
|
||||||
let is_catchup = model.catchup.is_some();
|
|
||||||
orders.skip().perform_cmd(async move {
|
|
||||||
let res: Result<
|
|
||||||
graphql_client::Response<graphql::snooze_mutation::ResponseData>,
|
|
||||||
gloo_net::Error,
|
|
||||||
> = send_graphql(graphql::SnoozeMutation::build_query(
|
|
||||||
graphql::snooze_mutation::Variables {
|
|
||||||
query: query.clone(),
|
|
||||||
wake_time,
|
|
||||||
},
|
|
||||||
))
|
|
||||||
.await;
|
|
||||||
if let Err(e) = res {
|
|
||||||
error!("Failed to snooze {query} until {wake_time}: {e}");
|
|
||||||
}
|
|
||||||
if is_catchup {
|
|
||||||
Msg::CatchupMarkAsRead
|
|
||||||
} else {
|
|
||||||
Msg::GoToSearchResults
|
|
||||||
}
|
|
||||||
});
|
|
||||||
}
|
|
||||||
|
|
||||||
Msg::FrontPageRequest {
|
Msg::FrontPageRequest {
|
||||||
query,
|
query,
|
||||||
@ -291,7 +267,6 @@ pub fn update(msg: Msg, model: &mut Model, orders: &mut impl Orders<Msg>) {
|
|||||||
first,
|
first,
|
||||||
last,
|
last,
|
||||||
} => {
|
} => {
|
||||||
model.refreshing_state = RefreshingState::Loading;
|
|
||||||
let (after, before, first, last) = match (after.as_ref(), before.as_ref(), first, last)
|
let (after, before, first, last) = match (after.as_ref(), before.as_ref(), first, last)
|
||||||
{
|
{
|
||||||
// If no pagination set, set reasonable defaults
|
// If no pagination set, set reasonable defaults
|
||||||
@ -317,32 +292,25 @@ pub fn update(msg: Msg, model: &mut Model, orders: &mut impl Orders<Msg>) {
|
|||||||
});
|
});
|
||||||
}
|
}
|
||||||
Msg::FrontPageResult(Err(e)) => {
|
Msg::FrontPageResult(Err(e)) => {
|
||||||
let msg = format!("error FrontPageResult: {e:?}");
|
error!("error FrontPageResult: {e:?}");
|
||||||
error!("{msg}");
|
|
||||||
model.refreshing_state = RefreshingState::Error(msg);
|
|
||||||
}
|
}
|
||||||
Msg::FrontPageResult(Ok(graphql_client::Response {
|
Msg::FrontPageResult(Ok(graphql_client::Response {
|
||||||
data: None,
|
data: None,
|
||||||
errors: None,
|
errors: None,
|
||||||
..
|
..
|
||||||
})) => {
|
})) => {
|
||||||
let msg = format!("FrontPageResult no data or errors, should not happen");
|
error!("FrontPageResult no data or errors, should not happen");
|
||||||
error!("{msg}");
|
|
||||||
model.refreshing_state = RefreshingState::Error(msg);
|
|
||||||
}
|
}
|
||||||
Msg::FrontPageResult(Ok(graphql_client::Response {
|
Msg::FrontPageResult(Ok(graphql_client::Response {
|
||||||
data: None,
|
data: None,
|
||||||
errors: Some(e),
|
errors: Some(e),
|
||||||
..
|
..
|
||||||
})) => {
|
})) => {
|
||||||
let msg = format!("FrontPageResult error: {e:?}");
|
error!("FrontPageResult error: {e:?}");
|
||||||
error!("{msg}");
|
|
||||||
model.refreshing_state = RefreshingState::Error(msg);
|
|
||||||
}
|
}
|
||||||
Msg::FrontPageResult(Ok(graphql_client::Response {
|
Msg::FrontPageResult(Ok(graphql_client::Response {
|
||||||
data: Some(data), ..
|
data: Some(data), ..
|
||||||
})) => {
|
})) => {
|
||||||
model.refreshing_state = RefreshingState::None;
|
|
||||||
model.tags = Some(
|
model.tags = Some(
|
||||||
data.tags
|
data.tags
|
||||||
.into_iter()
|
.into_iter()
|
||||||
@ -382,7 +350,6 @@ pub fn update(msg: Msg, model: &mut Model, orders: &mut impl Orders<Msg>) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
Msg::ShowThreadRequest { thread_id } => {
|
Msg::ShowThreadRequest { thread_id } => {
|
||||||
model.refreshing_state = RefreshingState::Loading;
|
|
||||||
orders.skip().perform_cmd(async move {
|
orders.skip().perform_cmd(async move {
|
||||||
Msg::ShowThreadResult(
|
Msg::ShowThreadResult(
|
||||||
send_graphql(graphql::ShowThreadQuery::build_query(
|
send_graphql(graphql::ShowThreadQuery::build_query(
|
||||||
@ -395,7 +362,6 @@ pub fn update(msg: Msg, model: &mut Model, orders: &mut impl Orders<Msg>) {
|
|||||||
Msg::ShowThreadResult(Ok(graphql_client::Response {
|
Msg::ShowThreadResult(Ok(graphql_client::Response {
|
||||||
data: Some(data), ..
|
data: Some(data), ..
|
||||||
})) => {
|
})) => {
|
||||||
model.refreshing_state = RefreshingState::None;
|
|
||||||
model.tags = Some(
|
model.tags = Some(
|
||||||
data.tags
|
data.tags
|
||||||
.into_iter()
|
.into_iter()
|
||||||
@ -435,12 +401,9 @@ pub fn update(msg: Msg, model: &mut Model, orders: &mut impl Orders<Msg>) {
|
|||||||
orders.send_msg(Msg::WindowScrolled);
|
orders.send_msg(Msg::WindowScrolled);
|
||||||
}
|
}
|
||||||
Msg::ShowThreadResult(bad) => {
|
Msg::ShowThreadResult(bad) => {
|
||||||
let msg = format!("show_thread_query error: {bad:#?}");
|
error!("show_thread_query error: {bad:#?}");
|
||||||
error!("{msg}");
|
|
||||||
model.refreshing_state = RefreshingState::Error(msg);
|
|
||||||
}
|
}
|
||||||
Msg::CatchupRequest { query } => {
|
Msg::CatchupRequest { query } => {
|
||||||
model.refreshing_state = RefreshingState::Loading;
|
|
||||||
orders.perform_cmd(async move {
|
orders.perform_cmd(async move {
|
||||||
Msg::CatchupResult(
|
Msg::CatchupResult(
|
||||||
send_graphql::<_, graphql::catchup_query::ResponseData>(
|
send_graphql::<_, graphql::catchup_query::ResponseData>(
|
||||||
@ -455,7 +418,6 @@ pub fn update(msg: Msg, model: &mut Model, orders: &mut impl Orders<Msg>) {
|
|||||||
Msg::CatchupResult(Ok(graphql_client::Response {
|
Msg::CatchupResult(Ok(graphql_client::Response {
|
||||||
data: Some(data), ..
|
data: Some(data), ..
|
||||||
})) => {
|
})) => {
|
||||||
model.refreshing_state = RefreshingState::None;
|
|
||||||
let items = data.catchup;
|
let items = data.catchup;
|
||||||
if items.is_empty() {
|
if items.is_empty() {
|
||||||
orders.send_msg(Msg::GoToSearchResults);
|
orders.send_msg(Msg::GoToSearchResults);
|
||||||
@ -471,9 +433,7 @@ pub fn update(msg: Msg, model: &mut Model, orders: &mut impl Orders<Msg>) {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
Msg::CatchupResult(bad) => {
|
Msg::CatchupResult(bad) => {
|
||||||
let msg = format!("catchup_query error: {bad:#?}");
|
error!("catchup_query error: {bad:#?}");
|
||||||
error!("{msg}");
|
|
||||||
model.refreshing_state = RefreshingState::Error(msg);
|
|
||||||
}
|
}
|
||||||
Msg::SelectionSetNone => {
|
Msg::SelectionSetNone => {
|
||||||
if let Context::SearchResult {
|
if let Context::SearchResult {
|
||||||
@ -853,7 +813,6 @@ pub enum Msg {
|
|||||||
SetUnread(String, bool),
|
SetUnread(String, bool),
|
||||||
AddTag(String, String),
|
AddTag(String, String),
|
||||||
RemoveTag(String, String),
|
RemoveTag(String, String),
|
||||||
Snooze(String, DateTime<Utc>),
|
|
||||||
|
|
||||||
FrontPageRequest {
|
FrontPageRequest {
|
||||||
query: String,
|
query: String,
|
||||||
|
|||||||
@ -78,16 +78,13 @@ mod tw_classes {
|
|||||||
}
|
}
|
||||||
|
|
||||||
pub fn view(model: &Model) -> Node<Msg> {
|
pub fn view(model: &Model) -> Node<Msg> {
|
||||||
let is_loading = match model.refreshing_state {
|
|
||||||
RefreshingState::Loading => true,
|
|
||||||
_ => false,
|
|
||||||
};
|
|
||||||
match &model.context {
|
match &model.context {
|
||||||
Context::None => normal_view(
|
Context::None => normal_view(
|
||||||
div![h1!["Loading"]],
|
div![h1!["Loading"]],
|
||||||
&model.versions,
|
&model.versions,
|
||||||
&model.query,
|
&model.query,
|
||||||
&model.refreshing_state,
|
&model.refreshing_state,
|
||||||
|
model.read_completion_ratio,
|
||||||
&model.tags,
|
&model.tags,
|
||||||
),
|
),
|
||||||
Context::ThreadResult {
|
Context::ThreadResult {
|
||||||
@ -96,23 +93,17 @@ pub fn view(model: &Model) -> Node<Msg> {
|
|||||||
} => {
|
} => {
|
||||||
if let Some(catchup) = &model.catchup {
|
if let Some(catchup) = &model.catchup {
|
||||||
catchup_view(
|
catchup_view(
|
||||||
thread(thread_data, open_messages, &model.content_el, true, 0.),
|
thread(thread_data, open_messages, &model.content_el, true),
|
||||||
&catchup.items,
|
&catchup.items,
|
||||||
is_loading,
|
|
||||||
model.read_completion_ratio,
|
model.read_completion_ratio,
|
||||||
)
|
)
|
||||||
} else {
|
} else {
|
||||||
normal_view(
|
normal_view(
|
||||||
thread(
|
thread(thread_data, open_messages, &model.content_el, false),
|
||||||
thread_data,
|
|
||||||
open_messages,
|
|
||||||
&model.content_el,
|
|
||||||
false,
|
|
||||||
model.read_completion_ratio,
|
|
||||||
),
|
|
||||||
&model.versions,
|
&model.versions,
|
||||||
&model.query,
|
&model.query,
|
||||||
&model.refreshing_state,
|
&model.refreshing_state,
|
||||||
|
model.read_completion_ratio,
|
||||||
&model.tags,
|
&model.tags,
|
||||||
)
|
)
|
||||||
}
|
}
|
||||||
@ -123,17 +114,17 @@ pub fn view(model: &Model) -> Node<Msg> {
|
|||||||
} => {
|
} => {
|
||||||
if let Some(catchup) = &model.catchup {
|
if let Some(catchup) = &model.catchup {
|
||||||
catchup_view(
|
catchup_view(
|
||||||
news_post(post, &model.content_el, true, 0.),
|
news_post(post, &model.content_el, true),
|
||||||
&catchup.items,
|
&catchup.items,
|
||||||
is_loading,
|
|
||||||
model.read_completion_ratio,
|
model.read_completion_ratio,
|
||||||
)
|
)
|
||||||
} else {
|
} else {
|
||||||
normal_view(
|
normal_view(
|
||||||
news_post(post, &model.content_el, false, model.read_completion_ratio),
|
news_post(post, &model.content_el, false),
|
||||||
&model.versions,
|
&model.versions,
|
||||||
&model.query,
|
&model.query,
|
||||||
&model.refreshing_state,
|
&model.refreshing_state,
|
||||||
|
model.read_completion_ratio,
|
||||||
&model.tags,
|
&model.tags,
|
||||||
)
|
)
|
||||||
}
|
}
|
||||||
@ -149,6 +140,7 @@ pub fn view(model: &Model) -> Node<Msg> {
|
|||||||
&model.versions,
|
&model.versions,
|
||||||
&model.query,
|
&model.query,
|
||||||
&model.refreshing_state,
|
&model.refreshing_state,
|
||||||
|
model.read_completion_ratio,
|
||||||
&model.tags,
|
&model.tags,
|
||||||
),
|
),
|
||||||
}
|
}
|
||||||
@ -159,6 +151,7 @@ fn normal_view(
|
|||||||
versions: &Version,
|
versions: &Version,
|
||||||
query: &str,
|
query: &str,
|
||||||
refreshing_state: &RefreshingState,
|
refreshing_state: &RefreshingState,
|
||||||
|
read_completion_ratio: f64,
|
||||||
tags: &Option<Vec<Tag>>,
|
tags: &Option<Vec<Tag>>,
|
||||||
) -> Node<Msg> {
|
) -> Node<Msg> {
|
||||||
div![
|
div![
|
||||||
@ -185,13 +178,13 @@ fn normal_view(
|
|||||||
content,
|
content,
|
||||||
view_header(query, refreshing_state, false),
|
view_header(query, refreshing_state, false),
|
||||||
],
|
],
|
||||||
|
reading_progress(read_completion_ratio),
|
||||||
]
|
]
|
||||||
}
|
}
|
||||||
|
|
||||||
fn catchup_view(
|
fn catchup_view(
|
||||||
content: Node<Msg>,
|
content: Node<Msg>,
|
||||||
items: &[CatchupItem],
|
items: &[CatchupItem],
|
||||||
is_loading: bool,
|
|
||||||
read_completion_ratio: f64,
|
read_completion_ratio: f64,
|
||||||
) -> Node<Msg> {
|
) -> Node<Msg> {
|
||||||
div![
|
div![
|
||||||
@ -207,35 +200,14 @@ fn catchup_view(
|
|||||||
"border-gray-500",
|
"border-gray-500",
|
||||||
"bg-black/50",
|
"bg-black/50",
|
||||||
],
|
],
|
||||||
div![
|
|
||||||
C!["absolute", "top-0", "left-4", "text-green-200", "p-4"],
|
|
||||||
IF!(is_loading=>span![i![C!["animate-spin", "fas", "fa-spinner"]]])
|
|
||||||
],
|
|
||||||
h1![
|
|
||||||
C!["text-center"],
|
|
||||||
format!("{} left ", items.iter().filter(|i| !i.seen).count(),)
|
|
||||||
],
|
|
||||||
div![
|
div![
|
||||||
C!["absolute", "top-0", "right-4", "text-gray-500", "p-4"],
|
C!["absolute", "top-0", "right-4", "text-gray-500", "p-4"],
|
||||||
span![i![C!["fas", "fa-x"]]],
|
span![i![C!["fas", "fa-x"]]],
|
||||||
ev(Ev::Click, move |_| Msg::CatchupExit)
|
ev(Ev::Click, move |_| Msg::CatchupExit)
|
||||||
],
|
],
|
||||||
div![
|
h1![
|
||||||
C![
|
C!["text-center"],
|
||||||
"absolute",
|
format!("{} left ", items.iter().filter(|i| !i.seen).count(),)
|
||||||
"left-0",
|
|
||||||
"right-0",
|
|
||||||
"bottom-0",
|
|
||||||
"w-full",
|
|
||||||
"h-1",
|
|
||||||
"bg-gray-200"
|
|
||||||
],
|
|
||||||
div![
|
|
||||||
C!["h-1", "bg-green-500"],
|
|
||||||
style! {
|
|
||||||
St::Width => format!("{}%", read_completion_ratio*100.)
|
|
||||||
}
|
|
||||||
]
|
|
||||||
]
|
]
|
||||||
],
|
],
|
||||||
div![C!["mt-12", "mb-20"], content],
|
div![C!["mt-12", "mb-20"], content],
|
||||||
@ -275,6 +247,7 @@ fn catchup_view(
|
|||||||
ev(Ev::Click, |_| Msg::CatchupMarkAsRead)
|
ev(Ev::Click, |_| Msg::CatchupMarkAsRead)
|
||||||
]
|
]
|
||||||
],
|
],
|
||||||
|
reading_progress(read_completion_ratio)
|
||||||
]
|
]
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -351,8 +324,8 @@ fn search_results(
|
|||||||
attrs! {
|
attrs! {
|
||||||
At::Href => urls::thread(&tid)
|
At::Href => urls::thread(&tid)
|
||||||
},
|
},
|
||||||
div![C!["line-clamp-2"], title_break, &r.subject],
|
div![title_break, &r.subject],
|
||||||
span![C!["line-clamp-2", "text-xs"], pretty_authors(&r.authors)],
|
span![C!["text-xs"], pretty_authors(&r.authors)],
|
||||||
div![
|
div![
|
||||||
C!["flex", "flex-wrap", "justify-between"],
|
C!["flex", "flex-wrap", "justify-between"],
|
||||||
span![tags_chiclet(&tags)],
|
span![tags_chiclet(&tags)],
|
||||||
@ -754,19 +727,15 @@ fn render_open_header(msg: &ShowThreadQueryThreadOnEmailThreadMessages) -> Node<
|
|||||||
C!["flex", "p-4", "bg-neutral-800"],
|
C!["flex", "p-4", "bg-neutral-800"],
|
||||||
div![avatar],
|
div![avatar],
|
||||||
div![
|
div![
|
||||||
C!["px-4", "flex-1"],
|
C!["px-4", "mr-auto"],
|
||||||
div![
|
span![
|
||||||
C!["flex"],
|
C!["font-semibold", "text-sm"],
|
||||||
div![
|
from_detail.as_ref().map(|addr| attrs! {
|
||||||
C!["font-semibold", "text-sm", "flex-1"],
|
At::Title => addr
|
||||||
from_detail.as_ref().map(|addr| attrs! {
|
}),
|
||||||
At::Title => addr
|
&from,
|
||||||
}),
|
" ",
|
||||||
&from,
|
from_detail.as_ref().map(|text| copy_text_widget(&text))
|
||||||
" ",
|
|
||||||
from_detail.as_ref().map(|text| copy_text_widget(&text))
|
|
||||||
],
|
|
||||||
snooze_buttons(msg.timestamp, &id),
|
|
||||||
],
|
],
|
||||||
IF!(!msg.to.is_empty() =>div![
|
IF!(!msg.to.is_empty() =>div![
|
||||||
C!["text-xs"],
|
C!["text-xs"],
|
||||||
@ -1089,8 +1058,6 @@ fn message_render(msg: &ShowThreadQueryThreadOnEmailThreadMessages, open: bool)
|
|||||||
},
|
},
|
||||||
) => div![
|
) => div![
|
||||||
C!["view-part-text-html"],
|
C!["view-part-text-html"],
|
||||||
// If there isn't any HTML tags, treat more like plain text
|
|
||||||
IF!(!(contents.contains('<') && contents.contains('>')) => C!["whitespace-pre-line"]),
|
|
||||||
raw![contents],
|
raw![contents],
|
||||||
IF!(!msg.attachments.is_empty() => render_attachements(&msg.attachments)),
|
IF!(!msg.attachments.is_empty() => render_attachements(&msg.attachments)),
|
||||||
view_content_tree(&content_tree),
|
view_content_tree(&content_tree),
|
||||||
@ -1175,7 +1142,6 @@ fn thread(
|
|||||||
open_messages: &HashSet<String>,
|
open_messages: &HashSet<String>,
|
||||||
content_el: &ElRef<HtmlElement>,
|
content_el: &ElRef<HtmlElement>,
|
||||||
catchup_mode: bool,
|
catchup_mode: bool,
|
||||||
read_completion_ratio: f64,
|
|
||||||
) -> Node<Msg> {
|
) -> Node<Msg> {
|
||||||
// TODO(wathiede): show per-message subject if it changes significantly from top-level subject
|
// TODO(wathiede): show per-message subject if it changes significantly from top-level subject
|
||||||
let subject = if thread.subject.is_empty() {
|
let subject = if thread.subject.is_empty() {
|
||||||
@ -1260,8 +1226,7 @@ fn thread(
|
|||||||
el_ref(content_el),
|
el_ref(content_el),
|
||||||
messages,
|
messages,
|
||||||
IF!(!catchup_mode => click_to_top())
|
IF!(!catchup_mode => click_to_top())
|
||||||
],
|
]
|
||||||
reading_progress(read_completion_ratio)
|
|
||||||
]
|
]
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -1404,7 +1369,7 @@ pub fn view_tags(tags: &Option<Vec<Tag>>) -> Node<Msg> {
|
|||||||
},
|
},
|
||||||
],
|
],
|
||||||
a![
|
a![
|
||||||
C![indent_cls, "grow", "truncate"],
|
C!["grow", "truncate"],
|
||||||
attrs! {
|
attrs! {
|
||||||
At::Href => href
|
At::Href => href
|
||||||
},
|
},
|
||||||
@ -1505,7 +1470,6 @@ fn news_post(
|
|||||||
post: &ShowThreadQueryThreadOnNewsPost,
|
post: &ShowThreadQueryThreadOnNewsPost,
|
||||||
content_el: &ElRef<HtmlElement>,
|
content_el: &ElRef<HtmlElement>,
|
||||||
catchup_mode: bool,
|
catchup_mode: bool,
|
||||||
read_completion_ratio: f64,
|
|
||||||
) -> Node<Msg> {
|
) -> Node<Msg> {
|
||||||
let subject = &post.title;
|
let subject = &post.title;
|
||||||
set_title(subject);
|
set_title(subject);
|
||||||
@ -1593,7 +1557,6 @@ fn news_post(
|
|||||||
]
|
]
|
||||||
],
|
],
|
||||||
IF!(!catchup_mode => click_to_top()),
|
IF!(!catchup_mode => click_to_top()),
|
||||||
reading_progress(read_completion_ratio)
|
|
||||||
]
|
]
|
||||||
}
|
}
|
||||||
fn render_news_post_header(post: &ShowThreadQueryThreadOnNewsPost) -> Node<Msg> {
|
fn render_news_post_header(post: &ShowThreadQueryThreadOnNewsPost) -> Node<Msg> {
|
||||||
@ -1629,13 +1592,9 @@ fn render_news_post_header(post: &ShowThreadQueryThreadOnNewsPost) -> Node<Msg>
|
|||||||
C!["flex", "p-4", "bg-neutral-800"],
|
C!["flex", "p-4", "bg-neutral-800"],
|
||||||
div![favicon],
|
div![favicon],
|
||||||
div![
|
div![
|
||||||
C!["px-4", "mr-auto", "flex-1"],
|
C!["px-4", "mr-auto"],
|
||||||
div![
|
div![
|
||||||
div![
|
div![C!["font-semibold", "text-sm"], from],
|
||||||
C!["flex"],
|
|
||||||
div![C!["font-semibold", "text-sm", "flex-1"], from],
|
|
||||||
snooze_buttons(Some(post.timestamp), &id),
|
|
||||||
],
|
|
||||||
div![
|
div![
|
||||||
C!["flex", "gap-2", "pt-2", "text-sm"],
|
C!["flex", "gap-2", "pt-2", "text-sm"],
|
||||||
a![
|
a![
|
||||||
@ -1730,47 +1689,3 @@ fn click_to_top() -> Node<Msg> {
|
|||||||
ev(Ev::Click, |_| Msg::ScrollToTop)
|
ev(Ev::Click, |_| Msg::ScrollToTop)
|
||||||
]
|
]
|
||||||
}
|
}
|
||||||
|
|
||||||
fn snooze_buttons(timestamp: Option<i64>, id: &str) -> Node<Msg> {
|
|
||||||
div![
|
|
||||||
span![C!["px-2"], "⏰"],
|
|
||||||
button![
|
|
||||||
tw_classes::button(),
|
|
||||||
C!["rounded-r-none"],
|
|
||||||
"1d",
|
|
||||||
ev(Ev::Click, {
|
|
||||||
let id = id.to_string();
|
|
||||||
move |e| {
|
|
||||||
e.stop_propagation();
|
|
||||||
Msg::Snooze(id, Utc::now() + chrono::Days::new(1))
|
|
||||||
}
|
|
||||||
})
|
|
||||||
],
|
|
||||||
button![
|
|
||||||
tw_classes::button(),
|
|
||||||
C!["rounded-none"],
|
|
||||||
"7d",
|
|
||||||
ev(Ev::Click, {
|
|
||||||
let id = id.to_string();
|
|
||||||
move |e| {
|
|
||||||
e.stop_propagation();
|
|
||||||
Msg::Snooze(id, Utc::now() + chrono::Days::new(7))
|
|
||||||
}
|
|
||||||
})
|
|
||||||
],
|
|
||||||
timestamp.map(
|
|
||||||
|ts| chrono::DateTime::from_timestamp(ts, 0).map(|ts| button![
|
|
||||||
tw_classes::button(),
|
|
||||||
C!["rounded-l-none"],
|
|
||||||
"+6m",
|
|
||||||
ev(Ev::Click, {
|
|
||||||
let id = id.to_string();
|
|
||||||
move |e| {
|
|
||||||
e.stop_propagation();
|
|
||||||
Msg::Snooze(id, ts + chrono::Days::new(180))
|
|
||||||
}
|
|
||||||
})
|
|
||||||
])
|
|
||||||
),
|
|
||||||
]
|
|
||||||
}
|
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user