feat: add support for Bluesky and Leaflet sources, including fetchers and configuration

* added configuration structures for Substack, Bluesky, and Leaflet sources

* enhanced error handling and output formatting using owo-colors.

.gitignore

···
 #  be found at https://github.com/github/gitignore/blob/main/Global/JetBrains.gitignore
 #  and can be added to the global gitignore or merged into this file.  For a more nuclear
 #  option (not recommended) you can uncomment the following to ignore the entire idea folder.
-#.idea/
+.idea/
+.vscode/

Cargo.lock

···
 version = 4
 
 [[package]]
+name = "aho-corasick"
+version = "1.1.4"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "ddd31a130427c27518df266943a5308ed92d4b226cc639f5a8f1002816174301"
+dependencies = [
+ "memchr",
+]
+
+[[package]]
 name = "android_system_properties"
 version = "0.1.5"
 source = "registry+https://github.com/rust-lang/crates.io-index"
···
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "40c48f72fd53cd289104fc64099abca73db4166ad86ea0b4341abe65af83dadc"
 dependencies = [
- "windows-sys",
+ "windows-sys 0.61.2",
 ]
 
 [[package]]
···
 dependencies = [
  "anstyle",
  "once_cell_polyfill",
- "windows-sys",
+ "windows-sys 0.61.2",
 ]
 
 [[package]]
+name = "atomic-waker"
+version = "1.1.2"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "1505bd5d3d116872e7271a6d4e16d81d0c8570876c8de68093a09ac269d8aac0"
+
+[[package]]
 name = "autocfg"
 version = "1.5.0"
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "c08606f8c3cbf4ce6ec8e28fb0014a2c086708fe954eaa885384a6165172e7e8"
 
 [[package]]
+name = "base64"
+version = "0.22.1"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "72b3254f16251a8381aa12e40e3c4d2f0199f8c6508fbecb9d91f575e0fbb8c6"
+
+[[package]]
 name = "bitflags"
 version = "2.10.0"
 source = "registry+https://github.com/rust-lang/crates.io-index"
···
 version = "3.19.0"
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "46c5e41b57b8bba42a04676d81cb89e9ee8e859a1a66f80a5a72e1cb76b34d43"
+
+[[package]]
+name = "bytes"
+version = "1.11.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "b35204fbdc0b3f4446b89fc1ac2cf84a8a68971995d0bf2e925ec7cd960f9cb3"
 
 [[package]]
 name = "cc"
···
  "iana-time-zone",
  "js-sys",
  "num-traits",
+ "serde",
  "wasm-bindgen",
  "windows-link",
 ]
···
 checksum = "b05b61dc5112cbb17e4b6cd61790d9845d13888356391624cbe7e41efeac1e75"
 
 [[package]]
+name = "core-foundation"
+version = "0.9.4"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "91e195e091a93c46f7102ec7818a2aa394e1e1771c3ab4825963fa03e45afb8f"
+dependencies = [
+ "core-foundation-sys",
+ "libc",
+]
+
+[[package]]
 name = "core-foundation-sys"
 version = "0.8.7"
 source = "registry+https://github.com/rust-lang/crates.io-index"
···
  "libc",
  "option-ext",
  "redox_users",
- "windows-sys",
+ "windows-sys 0.61.2",
+]
+
+[[package]]
+name = "displaydoc"
+version = "0.2.5"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "97369cbbc041bc366949bc74d34658d6cda5621039731c6310521892a3a20ae0"
+dependencies = [
+ "proc-macro2",
+ "quote",
+ "syn",
+]
+
+[[package]]
+name = "encoding_rs"
+version = "0.8.35"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "75030f3c4f45dafd7586dd6780965a8c7e8e285a5ecb86713e63a79c5b2766f3"
+dependencies = [
+ "cfg-if",
+]
+
+[[package]]
+name = "equivalent"
+version = "1.0.2"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "877a4ace8713b0bcf2a4e7eec82529c029f1d0619886d18145fea96c3ffe5c0f"
+
+[[package]]
+name = "errno"
+version = "0.3.14"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "39cab71617ae0d63f51a36d69f866391735b51691dbda63cf6f96d042b63efeb"
+dependencies = [
+ "libc",
+ "windows-sys 0.61.2",
 ]
 
 [[package]]
···
 checksum = "7360491ce676a36bf9bb3c56c1aa791658183a54d2744120f27285738d90465a"
 
 [[package]]
+name = "fastrand"
+version = "2.3.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "37909eebbb50d72f9059c3b6d82c0463f2ff062c9e95845c43a6c9c0355411be"
+
+[[package]]
+name = "feed-rs"
+version = "2.3.1"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "e4c0591d23efd0d595099af69a31863ac1823046b1b021e3b06ba3aae7e00991"
+dependencies = [
+ "chrono",
+ "mediatype",
+ "quick-xml",
+ "regex",
+ "serde",
+ "serde_json",
+ "siphasher",
+ "url",
+ "uuid",
+]
+
+[[package]]
 name = "find-msvc-tools"
 version = "0.1.5"
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "3a3076410a55c90011c298b04d0cfa770b00fa04e1e3c97d3f6c9de105a03844"
 
 [[package]]
+name = "fnv"
+version = "1.0.7"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "3f9eec918d3f24069decb9af1554cad7c880e2da24a9afd88aca000531ab82c1"
+
+[[package]]
 name = "foldhash"
 version = "0.1.5"
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "d9c4f5dac5e15c24eb999c26181a6ca40b39fe946cbe4c263c7209467bc83af2"
 
 [[package]]
+name = "foreign-types"
+version = "0.3.2"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "f6f339eb8adc052cd2ca78910fda869aefa38d22d5cb648e6485e4d3fc06f3b1"
+dependencies = [
+ "foreign-types-shared",
+]
+
+[[package]]
+name = "foreign-types-shared"
+version = "0.1.1"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "00b0228411908ca8685dba7fc2cdd70ec9990a6e753e89b6ac91a84c40fbaf4b"
+
+[[package]]
+name = "form_urlencoded"
+version = "1.2.2"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "cb4cb245038516f5f85277875cdaa4f7d2c9a0fa0468de06ed190163b1581fcf"
+dependencies = [
+ "percent-encoding",
+]
+
+[[package]]
+name = "futures-channel"
+version = "0.3.31"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "2dff15bf788c671c1934e366d07e30c1814a8ef514e1af724a602e8a2fbe1b10"
+dependencies = [
+ "futures-core",
+]
+
+[[package]]
+name = "futures-core"
+version = "0.3.31"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "05f29059c0c2090612e8d742178b0580d2dc940c837851ad723096f87af6663e"
+
+[[package]]
+name = "futures-sink"
+version = "0.3.31"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "e575fab7d1e0dcb8d0c7bcf9a63ee213816ab51902e6d244a95819acacf1d4f7"
+
+[[package]]
+name = "futures-task"
+version = "0.3.31"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "f90f7dce0722e95104fcb095585910c0977252f286e354b5e3bd38902cd99988"
+
+[[package]]
+name = "futures-util"
+version = "0.3.31"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "9fa08315bb612088cc391249efdc3bc77536f16c91f6cf495e6fbe85b20a4a81"
+dependencies = [
+ "futures-core",
+ "futures-task",
+ "pin-project-lite",
+ "pin-utils",
+]
+
+[[package]]
 name = "getrandom"
 version = "0.2.16"
 source = "registry+https://github.com/rust-lang/crates.io-index"
···
 ]
 
 [[package]]
+name = "getrandom"
+version = "0.3.4"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "899def5c37c4fd7b2664648c28120ecec138e4d395b459e5ca34f9cce2dd77fd"
+dependencies = [
+ "cfg-if",
+ "libc",
+ "r-efi",
+ "wasip2",
+]
+
+[[package]]
+name = "h2"
+version = "0.4.12"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "f3c0b69cfcb4e1b9f1bf2f53f95f766e4661169728ec61cd3fe5a0166f2d1386"
+dependencies = [
+ "atomic-waker",
+ "bytes",
+ "fnv",
+ "futures-core",
+ "futures-sink",
+ "http",
+ "indexmap",
+ "slab",
+ "tokio",
+ "tokio-util",
+ "tracing",
+]
+
+[[package]]
 name = "hashbrown"
 version = "0.15.5"
 source = "registry+https://github.com/rust-lang/crates.io-index"
···
 ]
 
 [[package]]
+name = "hashbrown"
+version = "0.16.1"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "841d1cc9bed7f9236f321df977030373f4a4163ae1a7dbfe1a51a2c1a51d9100"
+
+[[package]]
 name = "hashlink"
 version = "0.10.0"
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "7382cf6263419f2d8df38c55d7da83da5c18aef87fc7a7fc1fb1e344edfe14c1"
 dependencies = [
- "hashbrown",
+ "hashbrown 0.15.5",
 ]
 
 [[package]]
···
 checksum = "2304e00983f87ffb38b55b444b5e3b60a884b5d30c0fca7d82fe33449bbe55ea"
 
 [[package]]
+name = "http"
+version = "1.3.1"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "f4a85d31aea989eead29a3aaf9e1115a180df8282431156e533de47660892565"
+dependencies = [
+ "bytes",
+ "fnv",
+ "itoa",
+]
+
+[[package]]
+name = "http-body"
+version = "1.0.1"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "1efedce1fb8e6913f23e0c92de8e62cd5b772a67e7b3946df930a62566c93184"
+dependencies = [
+ "bytes",
+ "http",
+]
+
+[[package]]
+name = "http-body-util"
+version = "0.1.3"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "b021d93e26becf5dc7e1b75b1bed1fd93124b374ceb73f43d4d4eafec896a64a"
+dependencies = [
+ "bytes",
+ "futures-core",
+ "http",
+ "http-body",
+ "pin-project-lite",
+]
+
+[[package]]
+name = "httparse"
+version = "1.10.1"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "6dbf3de79e51f3d586ab4cb9d5c3e2c14aa28ed23d180cf89b4df0454a69cc87"
+
+[[package]]
+name = "hyper"
+version = "1.8.1"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "2ab2d4f250c3d7b1c9fcdff1cece94ea4e2dfbec68614f7b87cb205f24ca9d11"
+dependencies = [
+ "atomic-waker",
+ "bytes",
+ "futures-channel",
+ "futures-core",
+ "h2",
+ "http",
+ "http-body",
+ "httparse",
+ "itoa",
+ "pin-project-lite",
+ "pin-utils",
+ "smallvec",
+ "tokio",
+ "want",
+]
+
+[[package]]
+name = "hyper-rustls"
+version = "0.27.7"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "e3c93eb611681b207e1fe55d5a71ecf91572ec8a6705cdb6857f7d8d5242cf58"
+dependencies = [
+ "http",
+ "hyper",
+ "hyper-util",
+ "rustls",
+ "rustls-pki-types",
+ "tokio",
+ "tokio-rustls",
+ "tower-service",
+]
+
+[[package]]
+name = "hyper-tls"
+version = "0.6.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "70206fc6890eaca9fde8a0bf71caa2ddfc9fe045ac9e5c70df101a7dbde866e0"
+dependencies = [
+ "bytes",
+ "http-body-util",
+ "hyper",
+ "hyper-util",
+ "native-tls",
+ "tokio",
+ "tokio-native-tls",
+ "tower-service",
+]
+
+[[package]]
+name = "hyper-util"
+version = "0.1.18"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "52e9a2a24dc5c6821e71a7030e1e14b7b632acac55c40e9d2e082c621261bb56"
+dependencies = [
+ "base64",
+ "bytes",
+ "futures-channel",
+ "futures-core",
+ "futures-util",
+ "http",
+ "http-body",
+ "hyper",
+ "ipnet",
+ "libc",
+ "percent-encoding",
+ "pin-project-lite",
+ "socket2",
+ "system-configuration",
+ "tokio",
+ "tower-service",
+ "tracing",
+ "windows-registry",
+]
+
+[[package]]
 name = "iana-time-zone"
 version = "0.1.64"
 source = "registry+https://github.com/rust-lang/crates.io-index"
···
 ]
 
 [[package]]
+name = "icu_collections"
+version = "2.1.1"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "4c6b649701667bbe825c3b7e6388cb521c23d88644678e83c0c4d0a621a34b43"
+dependencies = [
+ "displaydoc",
+ "potential_utf",
+ "yoke",
+ "zerofrom",
+ "zerovec",
+]
+
+[[package]]
+name = "icu_locale_core"
+version = "2.1.1"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "edba7861004dd3714265b4db54a3c390e880ab658fec5f7db895fae2046b5bb6"
+dependencies = [
+ "displaydoc",
+ "litemap",
+ "tinystr",
+ "writeable",
+ "zerovec",
+]
+
+[[package]]
+name = "icu_normalizer"
+version = "2.1.1"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "5f6c8828b67bf8908d82127b2054ea1b4427ff0230ee9141c54251934ab1b599"
+dependencies = [
+ "icu_collections",
+ "icu_normalizer_data",
+ "icu_properties",
+ "icu_provider",
+ "smallvec",
+ "zerovec",
+]
+
+[[package]]
+name = "icu_normalizer_data"
+version = "2.1.1"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "7aedcccd01fc5fe81e6b489c15b247b8b0690feb23304303a9e560f37efc560a"
+
+[[package]]
+name = "icu_properties"
+version = "2.1.1"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "e93fcd3157766c0c8da2f8cff6ce651a31f0810eaa1c51ec363ef790bbb5fb99"
+dependencies = [
+ "icu_collections",
+ "icu_locale_core",
+ "icu_properties_data",
+ "icu_provider",
+ "zerotrie",
+ "zerovec",
+]
+
+[[package]]
+name = "icu_properties_data"
+version = "2.1.1"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "02845b3647bb045f1100ecd6480ff52f34c35f82d9880e029d329c21d1054899"
+
+[[package]]
+name = "icu_provider"
+version = "2.1.1"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "85962cf0ce02e1e0a629cc34e7ca3e373ce20dda4c4d7294bbd0bf1fdb59e614"
+dependencies = [
+ "displaydoc",
+ "icu_locale_core",
+ "writeable",
+ "yoke",
+ "zerofrom",
+ "zerotrie",
+ "zerovec",
+]
+
+[[package]]
+name = "idna"
+version = "1.1.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "3b0875f23caa03898994f6ddc501886a45c7d3d62d04d2d90788d47be1b1e4de"
+dependencies = [
+ "idna_adapter",
+ "smallvec",
+ "utf8_iter",
+]
+
+[[package]]
+name = "idna_adapter"
+version = "1.2.1"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "3acae9609540aa318d1bc588455225fb2085b9ed0c4f6bd0d9d5bcd86f1a0344"
+dependencies = [
+ "icu_normalizer",
+ "icu_properties",
+]
+
+[[package]]
+name = "indexmap"
+version = "2.12.1"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "0ad4bb2b565bca0645f4d68c5c9af97fba094e9791da685bf83cb5f3ce74acf2"
+dependencies = [
+ "equivalent",
+ "hashbrown 0.16.1",
+]
+
+[[package]]
+name = "ipnet"
+version = "2.11.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "469fb0b9cefa57e3ef31275ee7cacb78f2fdca44e4765491884a2b119d4eb130"
+
+[[package]]
+name = "iri-string"
+version = "0.7.9"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "4f867b9d1d896b67beb18518eda36fdb77a32ea590de864f1325b294a6d14397"
+dependencies = [
+ "memchr",
+ "serde",
+]
+
+[[package]]
 name = "is_terminal_polyfill"
 version = "1.70.2"
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "a6cb138bb79a146c1bd460005623e142ef0181e3d0219cb493e02f7d08a35695"
+
+[[package]]
+name = "itoa"
+version = "1.0.15"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "4a5f13b858c8d314ee3e8f639011f7ccefe71f97f96e50151fb991f267928e2c"
 
 [[package]]
 name = "js-sys"
···
 ]
 
 [[package]]
+name = "linux-raw-sys"
+version = "0.11.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "df1d3c3b53da64cf5760482273a98e575c651a67eec7f77df96b5b642de8f039"
+
+[[package]]
+name = "litemap"
+version = "0.8.1"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "6373607a59f0be73a39b6fe456b8192fcc3585f602af20751600e974dd455e77"
+
+[[package]]
 name = "log"
 version = "0.4.28"
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "34080505efa8e45a4b816c349525ebe327ceaa8559756f0356cba97ef3bf7432"
 
 [[package]]
+name = "mediatype"
+version = "0.19.20"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "33746aadcb41349ec291e7f2f0a3aa6834d1d7c58066fb4b01f68efc4c4b7631"
+dependencies = [
+ "serde",
+]
+
+[[package]]
+name = "memchr"
+version = "2.7.6"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "f52b00d39961fc5b2736ea853c9cc86238e165017a493d1d5c8eac6bdc4cc273"
+
+[[package]]
+name = "mime"
+version = "0.3.17"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "6877bb514081ee2a7ff5ef9de3281f14a4dd4bceac4c09388074a6b5df8a139a"
+
+[[package]]
+name = "mio"
+version = "1.1.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "69d83b0086dc8ecf3ce9ae2874b2d1290252e2a30720bea58a5c6639b0092873"
+dependencies = [
+ "libc",
+ "wasi",
+ "windows-sys 0.61.2",
+]
+
+[[package]]
+name = "native-tls"
+version = "0.2.14"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "87de3442987e9dbec73158d5c715e7ad9072fda936bb03d19d7fa10e00520f0e"
+dependencies = [
+ "libc",
+ "log",
+ "openssl",
+ "openssl-probe",
+ "openssl-sys",
+ "schannel",
+ "security-framework",
+ "security-framework-sys",
+ "tempfile",
+]
+
+[[package]]
 name = "num-traits"
 version = "0.2.19"
 source = "registry+https://github.com/rust-lang/crates.io-index"
···
 checksum = "384b8ab6d37215f3c5301a95a4accb5d64aa607f1fcb26a11b5303878451b4fe"
 
 [[package]]
+name = "openssl"
+version = "0.10.75"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "08838db121398ad17ab8531ce9de97b244589089e290a384c900cb9ff7434328"
+dependencies = [
+ "bitflags",
+ "cfg-if",
+ "foreign-types",
+ "libc",
+ "once_cell",
+ "openssl-macros",
+ "openssl-sys",
+]
+
+[[package]]
+name = "openssl-macros"
+version = "0.1.1"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "a948666b637a0f465e8564c73e89d4dde00d72d4d473cc972f390fc3dcee7d9c"
+dependencies = [
+ "proc-macro2",
+ "quote",
+ "syn",
+]
+
+[[package]]
+name = "openssl-probe"
+version = "0.1.6"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "d05e27ee213611ffe7d6348b942e8f942b37114c00cc03cec254295a4a17852e"
+
+[[package]]
+name = "openssl-sys"
+version = "0.9.111"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "82cab2d520aa75e3c58898289429321eb788c3106963d0dc886ec7a5f4adc321"
+dependencies = [
+ "cc",
+ "libc",
+ "pkg-config",
+ "vcpkg",
+]
+
+[[package]]
 name = "option-ext"
 version = "0.2.0"
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "04744f49eae99ab78e0d5c0b603ab218f515ea8cfe5a456d7629ad883a3b6e7d"
 
 [[package]]
+name = "owo-colors"
+version = "4.2.3"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "9c6901729fa79e91a0913333229e9ca5dc725089d1c363b2f4b4760709dc4a52"
+
+[[package]]
 name = "pai"
 version = "0.1.0"
 dependencies = [
  "chrono",
  "clap",
  "dirs",
+ "owo-colors",
  "pai-core",
  "rusqlite",
 ]
···
 name = "pai-core"
 version = "0.1.0"
 dependencies = [
+ "chrono",
+ "feed-rs",
+ "reqwest",
+ "serde",
+ "serde_json",
  "thiserror",
+ "tokio",
+ "toml",
 ]
 
 [[package]]
···
 version = "0.1.0"
 
 [[package]]
+name = "percent-encoding"
+version = "2.3.2"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "9b4f627cb1b25917193a259e49bdad08f671f8d9708acfd5fe0a8c1455d87220"
+
+[[package]]
+name = "pin-project-lite"
+version = "0.2.16"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "3b3cff922bd51709b605d9ead9aa71031d81447142d828eb4a6eba76fe619f9b"
+
+[[package]]
+name = "pin-utils"
+version = "0.1.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "8b870d8c151b6f2fb93e84a13146138f05d02ed11c7e7c54f8826aaaf7c9f184"
+
+[[package]]
 name = "pkg-config"
 version = "0.3.32"
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "7edddbd0b52d732b21ad9a5fab5c704c14cd949e5e9a1ec5929a24fded1b904c"
 
 [[package]]
+name = "potential_utf"
+version = "0.1.4"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "b73949432f5e2a09657003c25bca5e19a0e9c84f8058ca374f49e0ebe605af77"
+dependencies = [
+ "zerovec",
+]
+
+[[package]]
 name = "proc-macro2"
 version = "1.0.103"
 source = "registry+https://github.com/rust-lang/crates.io-index"
···
 ]
 
 [[package]]
+name = "quick-xml"
+version = "0.37.5"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "331e97a1af0bf59823e6eadffe373d7b27f485be8748f71471c662c1f269b7fb"
+dependencies = [
+ "encoding_rs",
+ "memchr",
+]
+
+[[package]]
 name = "quote"
 version = "1.0.42"
 source = "registry+https://github.com/rust-lang/crates.io-index"
···
 ]
 
 [[package]]
+name = "r-efi"
+version = "5.3.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "69cdb34c158ceb288df11e18b4bd39de994f6657d83847bdffdbd7f346754b0f"
+
+[[package]]
 name = "redox_users"
 version = "0.5.2"
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "a4e608c6638b9c18977b00b475ac1f28d14e84b27d8d42f70e0bf1e3dec127ac"
 dependencies = [
- "getrandom",
+ "getrandom 0.2.16",
  "libredox",
  "thiserror",
 ]
 
 [[package]]
+name = "regex"
+version = "1.12.2"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "843bc0191f75f3e22651ae5f1e72939ab2f72a4bc30fa80a066bd66edefc24d4"
+dependencies = [
+ "aho-corasick",
+ "memchr",
+ "regex-automata",
+ "regex-syntax",
+]
+
+[[package]]
+name = "regex-automata"
+version = "0.4.13"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "5276caf25ac86c8d810222b3dbb938e512c55c6831a10f3e6ed1c93b84041f1c"
+dependencies = [
+ "aho-corasick",
+ "memchr",
+ "regex-syntax",
+]
+
+[[package]]
+name = "regex-syntax"
+version = "0.8.8"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "7a2d987857b319362043e95f5353c0535c1f58eec5336fdfcf626430af7def58"
+
+[[package]]
+name = "reqwest"
+version = "0.12.24"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "9d0946410b9f7b082a427e4ef5c8ff541a88b357bc6c637c40db3a68ac70a36f"
+dependencies = [
+ "base64",
+ "bytes",
+ "encoding_rs",
+ "futures-core",
+ "h2",
+ "http",
+ "http-body",
+ "http-body-util",
+ "hyper",
+ "hyper-rustls",
+ "hyper-tls",
+ "hyper-util",
+ "js-sys",
+ "log",
+ "mime",
+ "native-tls",
+ "percent-encoding",
+ "pin-project-lite",
+ "rustls-pki-types",
+ "serde",
+ "serde_json",
+ "serde_urlencoded",
+ "sync_wrapper",
+ "tokio",
+ "tokio-native-tls",
+ "tower",
+ "tower-http",
+ "tower-service",
+ "url",
+ "wasm-bindgen",
+ "wasm-bindgen-futures",
+ "web-sys",
+]
+
+[[package]]
+name = "ring"
+version = "0.17.14"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "a4689e6c2294d81e88dc6261c768b63bc4fcdb852be6d1352498b114f61383b7"
+dependencies = [
+ "cc",
+ "cfg-if",
+ "getrandom 0.2.16",
+ "libc",
+ "untrusted",
+ "windows-sys 0.52.0",
+]
+
+[[package]]
 name = "rusqlite"
 version = "0.37.0"
 source = "registry+https://github.com/rust-lang/crates.io-index"
···
 ]
 
 [[package]]
+name = "rustix"
+version = "1.1.2"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "cd15f8a2c5551a84d56efdc1cd049089e409ac19a3072d5037a17fd70719ff3e"
+dependencies = [
+ "bitflags",
+ "errno",
+ "libc",
+ "linux-raw-sys",
+ "windows-sys 0.61.2",
+]
+
+[[package]]
+name = "rustls"
+version = "0.23.35"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "533f54bc6a7d4f647e46ad909549eda97bf5afc1585190ef692b4286b198bd8f"
+dependencies = [
+ "once_cell",
+ "rustls-pki-types",
+ "rustls-webpki",
+ "subtle",
+ "zeroize",
+]
+
+[[package]]
+name = "rustls-pki-types"
+version = "1.13.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "94182ad936a0c91c324cd46c6511b9510ed16af436d7b5bab34beab0afd55f7a"
+dependencies = [
+ "zeroize",
+]
+
+[[package]]
+name = "rustls-webpki"
+version = "0.103.8"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "2ffdfa2f5286e2247234e03f680868ac2815974dc39e00ea15adc445d0aafe52"
+dependencies = [
+ "ring",
+ "rustls-pki-types",
+ "untrusted",
+]
+
+[[package]]
 name = "rustversion"
 version = "1.0.22"
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "b39cdef0fa800fc44525c84ccb54a029961a8215f9619753635a9c0d2538d46d"
 
 [[package]]
+name = "ryu"
+version = "1.0.20"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "28d3b2b1366ec20994f1fd18c3c594f05c5dd4bc44d8bb0c1c632c8d6829481f"
+
+[[package]]
+name = "schannel"
+version = "0.1.28"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "891d81b926048e76efe18581bf793546b4c0eaf8448d72be8de2bbee5fd166e1"
+dependencies = [
+ "windows-sys 0.61.2",
+]
+
+[[package]]
+name = "security-framework"
+version = "2.11.1"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "897b2245f0b511c87893af39b033e5ca9cce68824c4d7e7630b5a1d339658d02"
+dependencies = [
+ "bitflags",
+ "core-foundation",
+ "core-foundation-sys",
+ "libc",
+ "security-framework-sys",
+]
+
+[[package]]
+name = "security-framework-sys"
+version = "2.15.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "cc1f0cbffaac4852523ce30d8bd3c5cdc873501d96ff467ca09b6767bb8cd5c0"
+dependencies = [
+ "core-foundation-sys",
+ "libc",
+]
+
+[[package]]
+name = "serde"
+version = "1.0.228"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "9a8e94ea7f378bd32cbbd37198a4a91436180c5bb472411e48b5ec2e2124ae9e"
+dependencies = [
+ "serde_core",
+ "serde_derive",
+]
+
+[[package]]
+name = "serde_core"
+version = "1.0.228"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "41d385c7d4ca58e59fc732af25c3983b67ac852c1a25000afe1175de458b67ad"
+dependencies = [
+ "serde_derive",
+]
+
+[[package]]
+name = "serde_derive"
+version = "1.0.228"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "d540f220d3187173da220f885ab66608367b6574e925011a9353e4badda91d79"
+dependencies = [
+ "proc-macro2",
+ "quote",
+ "syn",
+]
+
+[[package]]
+name = "serde_json"
+version = "1.0.145"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "402a6f66d8c709116cf22f558eab210f5a50187f702eb4d7e5ef38d9a7f1c79c"
+dependencies = [
+ "itoa",
+ "memchr",
+ "ryu",
+ "serde",
+ "serde_core",
+]
+
+[[package]]
+name = "serde_spanned"
+version = "1.0.3"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "e24345aa0fe688594e73770a5f6d1b216508b4f93484c0026d521acd30134392"
+dependencies = [
+ "serde_core",
+]
+
+[[package]]
+name = "serde_urlencoded"
+version = "0.7.1"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "d3491c14715ca2294c4d6a88f15e84739788c1d030eed8c110436aafdaa2f3fd"
+dependencies = [
+ "form_urlencoded",
+ "itoa",
+ "ryu",
+ "serde",
+]
+
+[[package]]
 name = "shlex"
 version = "1.3.0"
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "0fda2ff0d084019ba4d7c6f371c95d8fd75ce3524c3cb8fb653a3023f6323e64"
 
 [[package]]
+name = "siphasher"
+version = "1.0.1"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "56199f7ddabf13fe5074ce809e7d3f42b42ae711800501b5b16ea82ad029c39d"
+
+[[package]]
+name = "slab"
+version = "0.4.11"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "7a2ae44ef20feb57a68b23d846850f861394c2e02dc425a50098ae8c90267589"
+
+[[package]]
 name = "smallvec"
 version = "1.15.1"
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "67b1b7a3b5fe4f1376887184045fcf45c69e92af734b7aaddc05fb777b6fbd03"
 
 [[package]]
+name = "socket2"
+version = "0.6.1"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "17129e116933cf371d018bb80ae557e889637989d8638274fb25622827b03881"
+dependencies = [
+ "libc",
+ "windows-sys 0.60.2",
+]
+
+[[package]]
+name = "stable_deref_trait"
+version = "1.2.1"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "6ce2be8dc25455e1f91df71bfa12ad37d7af1092ae736f3a6cd0e37bc7810596"
+
+[[package]]
 name = "strsim"
 version = "0.11.1"
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "7da8b5736845d9f2fcb837ea5d9e2628564b3b043a70948a3f0b778838c5fb4f"
 
 [[package]]
+name = "subtle"
+version = "2.6.1"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "13c2bddecc57b384dee18652358fb23172facb8a2c51ccc10d74c157bdea3292"
+
+[[package]]
 name = "syn"
 version = "2.0.111"
 source = "registry+https://github.com/rust-lang/crates.io-index"
···
 ]
 
 [[package]]
+name = "sync_wrapper"
+version = "1.0.2"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "0bf256ce5efdfa370213c1dabab5935a12e49f2c58d15e9eac2870d3b4f27263"
+dependencies = [
+ "futures-core",
+]
+
+[[package]]
+name = "synstructure"
+version = "0.13.2"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "728a70f3dbaf5bab7f0c4b1ac8d7ae5ea60a4b5549c8a5914361c99147a709d2"
+dependencies = [
+ "proc-macro2",
+ "quote",
+ "syn",
+]
+
+[[package]]
+name = "system-configuration"
+version = "0.6.1"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "3c879d448e9d986b661742763247d3693ed13609438cf3d006f51f5368a5ba6b"
+dependencies = [
+ "bitflags",
+ "core-foundation",
+ "system-configuration-sys",
+]
+
+[[package]]
+name = "system-configuration-sys"
+version = "0.6.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "8e1d1b10ced5ca923a1fcb8d03e96b8d3268065d724548c0211415ff6ac6bac4"
+dependencies = [
+ "core-foundation-sys",
+ "libc",
+]
+
+[[package]]
+name = "tempfile"
+version = "3.23.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "2d31c77bdf42a745371d260a26ca7163f1e0924b64afa0b688e61b5a9fa02f16"
+dependencies = [
+ "fastrand",
+ "getrandom 0.3.4",
+ "once_cell",
+ "rustix",
+ "windows-sys 0.61.2",
+]
+
+[[package]]
 name = "thiserror"
 version = "2.0.17"
 source = "registry+https://github.com/rust-lang/crates.io-index"
···
 ]
 
 [[package]]
+name = "tinystr"
+version = "0.8.2"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "42d3e9c45c09de15d06dd8acf5f4e0e399e85927b7f00711024eb7ae10fa4869"
+dependencies = [
+ "displaydoc",
+ "zerovec",
+]
+
+[[package]]
+name = "tokio"
+version = "1.48.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "ff360e02eab121e0bc37a2d3b4d4dc622e6eda3a8e5253d5435ecf5bd4c68408"
+dependencies = [
+ "bytes",
+ "libc",
+ "mio",
+ "pin-project-lite",
+ "socket2",
+ "tokio-macros",
+ "windows-sys 0.61.2",
+]
+
+[[package]]
+name = "tokio-macros"
+version = "2.6.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "af407857209536a95c8e56f8231ef2c2e2aff839b22e07a1ffcbc617e9db9fa5"
+dependencies = [
+ "proc-macro2",
+ "quote",
+ "syn",
+]
+
+[[package]]
+name = "tokio-native-tls"
+version = "0.3.1"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "bbae76ab933c85776efabc971569dd6119c580d8f5d448769dec1764bf796ef2"
+dependencies = [
+ "native-tls",
+ "tokio",
+]
+
+[[package]]
+name = "tokio-rustls"
+version = "0.26.4"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "1729aa945f29d91ba541258c8df89027d5792d85a8841fb65e8bf0f4ede4ef61"
+dependencies = [
+ "rustls",
+ "tokio",
+]
+
+[[package]]
+name = "tokio-util"
+version = "0.7.17"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "2efa149fe76073d6e8fd97ef4f4eca7b67f599660115591483572e406e165594"
+dependencies = [
+ "bytes",
+ "futures-core",
+ "futures-sink",
+ "pin-project-lite",
+ "tokio",
+]
+
+[[package]]
+name = "toml"
+version = "0.9.8"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "f0dc8b1fb61449e27716ec0e1bdf0f6b8f3e8f6b05391e8497b8b6d7804ea6d8"
+dependencies = [
+ "indexmap",
+ "serde_core",
+ "serde_spanned",
+ "toml_datetime",
+ "toml_parser",
+ "toml_writer",
+ "winnow",
+]
+
+[[package]]
+name = "toml_datetime"
+version = "0.7.3"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "f2cdb639ebbc97961c51720f858597f7f24c4fc295327923af55b74c3c724533"
+dependencies = [
+ "serde_core",
+]
+
+[[package]]
+name = "toml_parser"
+version = "1.0.4"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "c0cbe268d35bdb4bb5a56a2de88d0ad0eb70af5384a99d648cd4b3d04039800e"
+dependencies = [
+ "winnow",
+]
+
+[[package]]
+name = "toml_writer"
+version = "1.0.4"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "df8b2b54733674ad286d16267dcfc7a71ed5c776e4ac7aa3c3e2561f7c637bf2"
+
+[[package]]
+name = "tower"
+version = "0.5.2"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "d039ad9159c98b70ecfd540b2573b97f7f52c3e8d9f8ad57a24b916a536975f9"
+dependencies = [
+ "futures-core",
+ "futures-util",
+ "pin-project-lite",
+ "sync_wrapper",
+ "tokio",
+ "tower-layer",
+ "tower-service",
+]
+
+[[package]]
+name = "tower-http"
+version = "0.6.6"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "adc82fd73de2a9722ac5da747f12383d2bfdb93591ee6c58486e0097890f05f2"
+dependencies = [
+ "bitflags",
+ "bytes",
+ "futures-util",
+ "http",
+ "http-body",
+ "iri-string",
+ "pin-project-lite",
+ "tower",
+ "tower-layer",
+ "tower-service",
+]
+
+[[package]]
+name = "tower-layer"
+version = "0.3.3"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "121c2a6cda46980bb0fcd1647ffaf6cd3fc79a013de288782836f6df9c48780e"
+
+[[package]]
+name = "tower-service"
+version = "0.3.3"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "8df9b6e13f2d32c91b9bd719c00d1958837bc7dec474d94952798cc8e69eeec3"
+
+[[package]]
+name = "tracing"
+version = "0.1.41"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "784e0ac535deb450455cbfa28a6f0df145ea1bb7ae51b821cf5e7927fdcfbdd0"
+dependencies = [
+ "pin-project-lite",
+ "tracing-core",
+]
+
+[[package]]
+name = "tracing-core"
+version = "0.1.34"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "b9d12581f227e93f094d3af2ae690a574abb8a2b9b7a96e7cfe9647b2b617678"
+dependencies = [
+ "once_cell",
+]
+
+[[package]]
+name = "try-lock"
+version = "0.2.5"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "e421abadd41a4225275504ea4d6566923418b7f05506fbc9c0fe86ba7396114b"
+
+[[package]]
 name = "unicode-ident"
 version = "1.0.22"
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "9312f7c4f6ff9069b165498234ce8be658059c6728633667c526e27dc2cf1df5"
 
 [[package]]
+name = "untrusted"
+version = "0.9.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "8ecb6da28b8a351d773b68d5825ac39017e680750f980f3a1a85cd8dd28a47c1"
+
+[[package]]
+name = "url"
+version = "2.5.7"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "08bc136a29a3d1758e07a9cca267be308aeebf5cfd5a10f3f67ab2097683ef5b"
+dependencies = [
+ "form_urlencoded",
+ "idna",
+ "percent-encoding",
+ "serde",
+]
+
+[[package]]
+name = "utf8_iter"
+version = "1.0.4"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "b6c140620e7ffbb22c2dee59cafe6084a59b5ffc27a8859a5f0d494b5d52b6be"
+
+[[package]]
 name = "utf8parse"
 version = "0.2.2"
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "06abde3611657adf66d383f00b093d7faecc7fa57071cce2578660c9f1010821"
 
 [[package]]
+name = "uuid"
+version = "1.18.1"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "2f87b8aa10b915a06587d0dec516c282ff295b475d94abf425d62b57710070a2"
+dependencies = [
+ "getrandom 0.3.4",
+ "js-sys",
+ "wasm-bindgen",
+]
+
+[[package]]
 name = "vcpkg"
 version = "0.2.15"
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "accd4ea62f7bb7a82fe23066fb0957d48ef677f6eeb8215f372f52e48bb32426"
 
 [[package]]
+name = "want"
+version = "0.3.1"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "bfa7760aed19e106de2c7c0b581b509f2f25d3dacaf737cb82ac61bc6d760b0e"
+dependencies = [
+ "try-lock",
+]
+
+[[package]]
 name = "wasi"
 version = "0.11.1+wasi-snapshot-preview1"
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "ccf3ec651a847eb01de73ccad15eb7d99f80485de043efb2f370cd654f4ea44b"
 
 [[package]]
+name = "wasip2"
+version = "1.0.1+wasi-0.2.4"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "0562428422c63773dad2c345a1882263bbf4d65cf3f42e90921f787ef5ad58e7"
+dependencies = [
+ "wit-bindgen",
+]
+
+[[package]]
 name = "wasm-bindgen"
 version = "0.2.105"
 source = "registry+https://github.com/rust-lang/crates.io-index"
···
 ]
 
 [[package]]
+name = "wasm-bindgen-futures"
+version = "0.4.55"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "551f88106c6d5e7ccc7cd9a16f312dd3b5d36ea8b4954304657d5dfba115d4a0"
+dependencies = [
+ "cfg-if",
+ "js-sys",
+ "once_cell",
+ "wasm-bindgen",
+ "web-sys",
+]
+
+[[package]]
 name = "wasm-bindgen-macro"
 version = "0.2.105"
 source = "registry+https://github.com/rust-lang/crates.io-index"
···
 ]
 
 [[package]]
+name = "web-sys"
+version = "0.3.82"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "3a1f95c0d03a47f4ae1f7a64643a6bb97465d9b740f0fa8f90ea33915c99a9a1"
+dependencies = [
+ "js-sys",
+ "wasm-bindgen",
+]
+
+[[package]]
 name = "windows-core"
 version = "0.62.2"
 source = "registry+https://github.com/rust-lang/crates.io-index"
···
 checksum = "f0805222e57f7521d6a62e36fa9163bc891acd422f971defe97d64e70d0a4fe5"
 
 [[package]]
+name = "windows-registry"
+version = "0.6.1"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "02752bf7fbdcce7f2a27a742f798510f3e5ad88dbe84871e5168e2120c3d5720"
+dependencies = [
+ "windows-link",
+ "windows-result",
+ "windows-strings",
+]
+
+[[package]]
 name = "windows-result"
 version = "0.4.1"
 source = "registry+https://github.com/rust-lang/crates.io-index"
···
 
 [[package]]
 name = "windows-sys"
+version = "0.52.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "282be5f36a8ce781fad8c8ae18fa3f9beff57ec1b52cb3de0789201425d9a33d"
+dependencies = [
+ "windows-targets 0.52.6",
+]
+
+[[package]]
+name = "windows-sys"
+version = "0.60.2"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "f2f500e4d28234f72040990ec9d39e3a6b950f9f22d3dba18416c35882612bcb"
+dependencies = [
+ "windows-targets 0.53.5",
+]
+
+[[package]]
+name = "windows-sys"
 version = "0.61.2"
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "ae137229bcbd6cdf0f7b80a31df61766145077ddf49416a728b02cb3921ff3fc"
 dependencies = [
  "windows-link",
 ]
+
+[[package]]
+name = "windows-targets"
+version = "0.52.6"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "9b724f72796e036ab90c1021d4780d4d3d648aca59e491e6b98e725b84e99973"
+dependencies = [
+ "windows_aarch64_gnullvm 0.52.6",
+ "windows_aarch64_msvc 0.52.6",
+ "windows_i686_gnu 0.52.6",
+ "windows_i686_gnullvm 0.52.6",
+ "windows_i686_msvc 0.52.6",
+ "windows_x86_64_gnu 0.52.6",
+ "windows_x86_64_gnullvm 0.52.6",
+ "windows_x86_64_msvc 0.52.6",
+]
+
+[[package]]
+name = "windows-targets"
+version = "0.53.5"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "4945f9f551b88e0d65f3db0bc25c33b8acea4d9e41163edf90dcd0b19f9069f3"
+dependencies = [
+ "windows-link",
+ "windows_aarch64_gnullvm 0.53.1",
+ "windows_aarch64_msvc 0.53.1",
+ "windows_i686_gnu 0.53.1",
+ "windows_i686_gnullvm 0.53.1",
+ "windows_i686_msvc 0.53.1",
+ "windows_x86_64_gnu 0.53.1",
+ "windows_x86_64_gnullvm 0.53.1",
+ "windows_x86_64_msvc 0.53.1",
+]
+
+[[package]]
+name = "windows_aarch64_gnullvm"
+version = "0.52.6"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "32a4622180e7a0ec044bb555404c800bc9fd9ec262ec147edd5989ccd0c02cd3"
+
+[[package]]
+name = "windows_aarch64_gnullvm"
+version = "0.53.1"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "a9d8416fa8b42f5c947f8482c43e7d89e73a173cead56d044f6a56104a6d1b53"
+
+[[package]]
+name = "windows_aarch64_msvc"
+version = "0.52.6"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "09ec2a7bb152e2252b53fa7803150007879548bc709c039df7627cabbd05d469"
+
+[[package]]
+name = "windows_aarch64_msvc"
+version = "0.53.1"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "b9d782e804c2f632e395708e99a94275910eb9100b2114651e04744e9b125006"
+
+[[package]]
+name = "windows_i686_gnu"
+version = "0.52.6"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "8e9b5ad5ab802e97eb8e295ac6720e509ee4c243f69d781394014ebfe8bbfa0b"
+
+[[package]]
+name = "windows_i686_gnu"
+version = "0.53.1"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "960e6da069d81e09becb0ca57a65220ddff016ff2d6af6a223cf372a506593a3"
+
+[[package]]
+name = "windows_i686_gnullvm"
+version = "0.52.6"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "0eee52d38c090b3caa76c563b86c3a4bd71ef1a819287c19d586d7334ae8ed66"
+
+[[package]]
+name = "windows_i686_gnullvm"
+version = "0.53.1"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "fa7359d10048f68ab8b09fa71c3daccfb0e9b559aed648a8f95469c27057180c"
+
+[[package]]
+name = "windows_i686_msvc"
+version = "0.52.6"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "240948bc05c5e7c6dabba28bf89d89ffce3e303022809e73deaefe4f6ec56c66"
+
+[[package]]
+name = "windows_i686_msvc"
+version = "0.53.1"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "1e7ac75179f18232fe9c285163565a57ef8d3c89254a30685b57d83a38d326c2"
+
+[[package]]
+name = "windows_x86_64_gnu"
+version = "0.52.6"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "147a5c80aabfbf0c7d901cb5895d1de30ef2907eb21fbbab29ca94c5b08b1a78"
+
+[[package]]
+name = "windows_x86_64_gnu"
+version = "0.53.1"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "9c3842cdd74a865a8066ab39c8a7a473c0778a3f29370b5fd6b4b9aa7df4a499"
+
+[[package]]
+name = "windows_x86_64_gnullvm"
+version = "0.52.6"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "24d5b23dc417412679681396f2b49f3de8c1473deb516bd34410872eff51ed0d"
+
+[[package]]
+name = "windows_x86_64_gnullvm"
+version = "0.53.1"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "0ffa179e2d07eee8ad8f57493436566c7cc30ac536a3379fdf008f47f6bb7ae1"
+
+[[package]]
+name = "windows_x86_64_msvc"
+version = "0.52.6"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "589f6da84c646204747d1270a2a5661ea66ed1cced2631d546fdfb155959f9ec"
+
+[[package]]
+name = "windows_x86_64_msvc"
+version = "0.53.1"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "d6bbff5f0aada427a1e5a6da5f1f98158182f26556f345ac9e04d36d0ebed650"
+
+[[package]]
+name = "winnow"
+version = "0.7.13"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "21a0236b59786fed61e2a80582dd500fe61f18b5dca67a4a067d0bc9039339cf"
+
+[[package]]
+name = "wit-bindgen"
+version = "0.46.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "f17a85883d4e6d00e8a97c586de764dabcc06133f7f1d55dce5cdc070ad7fe59"
+
+[[package]]
+name = "writeable"
+version = "0.6.2"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "9edde0db4769d2dc68579893f2306b26c6ecfbe0ef499b013d731b7b9247e0b9"
+
+[[package]]
+name = "yoke"
+version = "0.8.1"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "72d6e5c6afb84d73944e5cedb052c4680d5657337201555f9f2a16b7406d4954"
+dependencies = [
+ "stable_deref_trait",
+ "yoke-derive",
+ "zerofrom",
+]
+
+[[package]]
+name = "yoke-derive"
+version = "0.8.1"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "b659052874eb698efe5b9e8cf382204678a0086ebf46982b79d6ca3182927e5d"
+dependencies = [
+ "proc-macro2",
+ "quote",
+ "syn",
+ "synstructure",
+]
+
+[[package]]
+name = "zerofrom"
+version = "0.1.6"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "50cc42e0333e05660c3587f3bf9d0478688e15d870fab3346451ce7f8c9fbea5"
+dependencies = [
+ "zerofrom-derive",
+]
+
+[[package]]
+name = "zerofrom-derive"
+version = "0.1.6"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "d71e5d6e06ab090c67b5e44993ec16b72dcbaabc526db883a360057678b48502"
+dependencies = [
+ "proc-macro2",
+ "quote",
+ "syn",
+ "synstructure",
+]
+
+[[package]]
+name = "zeroize"
+version = "1.8.2"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "b97154e67e32c85465826e8bcc1c59429aaaf107c1e4a9e53c8d8ccd5eff88d0"
+
+[[package]]
+name = "zerotrie"
+version = "0.2.3"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "2a59c17a5562d507e4b54960e8569ebee33bee890c70aa3fe7b97e85a9fd7851"
+dependencies = [
+ "displaydoc",
+ "yoke",
+ "zerofrom",
+]
+
+[[package]]
+name = "zerovec"
+version = "0.11.5"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "6c28719294829477f525be0186d13efa9a3c602f7ec202ca9e353d310fb9a002"
+dependencies = [
+ "yoke",
+ "zerofrom",
+ "zerovec-derive",
+]
+
+[[package]]
+name = "zerovec-derive"
+version = "0.11.2"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "eadce39539ca5cb3985590102671f2567e659fca9666581ad3411d59207951f3"
+dependencies = [
+ "proc-macro2",
+ "quote",
+ "syn",
+]

LICENSE

···
+                    GNU AFFERO GENERAL PUBLIC LICENSE
+                       Version 3, 19 November 2007
+
+ Copyright (C) 2007 Free Software Foundation, Inc. <https://fsf.org/>
+ Everyone is permitted to copy and distribute verbatim copies
+ of this license document, but changing it is not allowed.
+
+                            Preamble
+
+  The GNU Affero General Public License is a free, copyleft license for
+software and other kinds of works, specifically designed to ensure
+cooperation with the community in the case of network server software.
+
+  The licenses for most software and other practical works are designed
+to take away your freedom to share and change the works.  By contrast,
+our General Public Licenses are intended to guarantee your freedom to
+share and change all versions of a program--to make sure it remains free
+software for all its users.
+
+  When we speak of free software, we are referring to freedom, not
+price.  Our General Public Licenses are designed to make sure that you
+have the freedom to distribute copies of free software (and charge for
+them if you wish), that you receive source code or can get it if you
+want it, that you can change the software or use pieces of it in new
+free programs, and that you know you can do these things.
+
+  Developers that use our General Public Licenses protect your rights
+with two steps: (1) assert copyright on the software, and (2) offer
+you this License which gives you legal permission to copy, distribute
+and/or modify the software.
+
+  A secondary benefit of defending all users' freedom is that
+improvements made in alternate versions of the program, if they
+receive widespread use, become available for other developers to
+incorporate.  Many developers of free software are heartened and
+encouraged by the resulting cooperation.  However, in the case of
+software used on network servers, this result may fail to come about.
+The GNU General Public License permits making a modified version and
+letting the public access it on a server without ever releasing its
+source code to the public.
+
+  The GNU Affero General Public License is designed specifically to
+ensure that, in such cases, the modified source code becomes available
+to the community.  It requires the operator of a network server to
+provide the source code of the modified version running there to the
+users of that server.  Therefore, public use of a modified version, on
+a publicly accessible server, gives the public access to the source
+code of the modified version.
+
+  An older license, called the Affero General Public License and
+published by Affero, was designed to accomplish similar goals.  This is
+a different license, not a version of the Affero GPL, but Affero has
+released a new version of the Affero GPL which permits relicensing under
+this license.
+
+  The precise terms and conditions for copying, distribution and
+modification follow.
+
+                       TERMS AND CONDITIONS
+
+  0. Definitions.
+
+  "This License" refers to version 3 of the GNU Affero General Public License.
+
+  "Copyright" also means copyright-like laws that apply to other kinds of
+works, such as semiconductor masks.
+
+  "The Program" refers to any copyrightable work licensed under this
+License.  Each licensee is addressed as "you".  "Licensees" and
+"recipients" may be individuals or organizations.
+
+  To "modify" a work means to copy from or adapt all or part of the work
+in a fashion requiring copyright permission, other than the making of an
+exact copy.  The resulting work is called a "modified version" of the
+earlier work or a work "based on" the earlier work.
+
+  A "covered work" means either the unmodified Program or a work based
+on the Program.
+
+  To "propagate" a work means to do anything with it that, without
+permission, would make you directly or secondarily liable for
+infringement under applicable copyright law, except executing it on a
+computer or modifying a private copy.  Propagation includes copying,
+distribution (with or without modification), making available to the
+public, and in some countries other activities as well.
+
+  To "convey" a work means any kind of propagation that enables other
+parties to make or receive copies.  Mere interaction with a user through
+a computer network, with no transfer of a copy, is not conveying.
+
+  An interactive user interface displays "Appropriate Legal Notices"
+to the extent that it includes a convenient and prominently visible
+feature that (1) displays an appropriate copyright notice, and (2)
+tells the user that there is no warranty for the work (except to the
+extent that warranties are provided), that licensees may convey the
+work under this License, and how to view a copy of this License.  If
+the interface presents a list of user commands or options, such as a
+menu, a prominent item in the list meets this criterion.
+
+  1. Source Code.
+
+  The "source code" for a work means the preferred form of the work
+for making modifications to it.  "Object code" means any non-source
+form of a work.
+
+  A "Standard Interface" means an interface that either is an official
+standard defined by a recognized standards body, or, in the case of
+interfaces specified for a particular programming language, one that
+is widely used among developers working in that language.
+
+  The "System Libraries" of an executable work include anything, other
+than the work as a whole, that (a) is included in the normal form of
+packaging a Major Component, but which is not part of that Major
+Component, and (b) serves only to enable use of the work with that
+Major Component, or to implement a Standard Interface for which an
+implementation is available to the public in source code form.  A
+"Major Component", in this context, means a major essential component
+(kernel, window system, and so on) of the specific operating system
+(if any) on which the executable work runs, or a compiler used to
+produce the work, or an object code interpreter used to run it.
+
+  The "Corresponding Source" for a work in object code form means all
+the source code needed to generate, install, and (for an executable
+work) run the object code and to modify the work, including scripts to
+control those activities.  However, it does not include the work's
+System Libraries, or general-purpose tools or generally available free
+programs which are used unmodified in performing those activities but
+which are not part of the work.  For example, Corresponding Source
+includes interface definition files associated with source files for
+the work, and the source code for shared libraries and dynamically
+linked subprograms that the work is specifically designed to require,
+such as by intimate data communication or control flow between those
+subprograms and other parts of the work.
+
+  The Corresponding Source need not include anything that users
+can regenerate automatically from other parts of the Corresponding
+Source.
+
+  The Corresponding Source for a work in source code form is that
+same work.
+
+  2. Basic Permissions.
+
+  All rights granted under this License are granted for the term of
+copyright on the Program, and are irrevocable provided the stated
+conditions are met.  This License explicitly affirms your unlimited
+permission to run the unmodified Program.  The output from running a
+covered work is covered by this License only if the output, given its
+content, constitutes a covered work.  This License acknowledges your
+rights of fair use or other equivalent, as provided by copyright law.
+
+  You may make, run and propagate covered works that you do not
+convey, without conditions so long as your license otherwise remains
+in force.  You may convey covered works to others for the sole purpose
+of having them make modifications exclusively for you, or provide you
+with facilities for running those works, provided that you comply with
+the terms of this License in conveying all material for which you do
+not control copyright.  Those thus making or running the covered works
+for you must do so exclusively on your behalf, under your direction
+and control, on terms that prohibit them from making any copies of
+your copyrighted material outside their relationship with you.
+
+  Conveying under any other circumstances is permitted solely under
+the conditions stated below.  Sublicensing is not allowed; section 10
+makes it unnecessary.
+
+  3. Protecting Users' Legal Rights From Anti-Circumvention Law.
+
+  No covered work shall be deemed part of an effective technological
+measure under any applicable law fulfilling obligations under article
+11 of the WIPO copyright treaty adopted on 20 December 1996, or
+similar laws prohibiting or restricting circumvention of such
+measures.
+
+  When you convey a covered work, you waive any legal power to forbid
+circumvention of technological measures to the extent such circumvention
+is effected by exercising rights under this License with respect to
+the covered work, and you disclaim any intention to limit operation or
+modification of the work as a means of enforcing, against the work's
+users, your or third parties' legal rights to forbid circumvention of
+technological measures.
+
+  4. Conveying Verbatim Copies.
+
+  You may convey verbatim copies of the Program's source code as you
+receive it, in any medium, provided that you conspicuously and
+appropriately publish on each copy an appropriate copyright notice;
+keep intact all notices stating that this License and any
+non-permissive terms added in accord with section 7 apply to the code;
+keep intact all notices of the absence of any warranty; and give all
+recipients a copy of this License along with the Program.
+
+  You may charge any price or no price for each copy that you convey,
+and you may offer support or warranty protection for a fee.
+
+  5. Conveying Modified Source Versions.
+
+  You may convey a work based on the Program, or the modifications to
+produce it from the Program, in the form of source code under the
+terms of section 4, provided that you also meet all of these conditions:
+
+    a) The work must carry prominent notices stating that you modified
+    it, and giving a relevant date.
+
+    b) The work must carry prominent notices stating that it is
+    released under this License and any conditions added under section
+    7.  This requirement modifies the requirement in section 4 to
+    "keep intact all notices".
+
+    c) You must license the entire work, as a whole, under this
+    License to anyone who comes into possession of a copy.  This
+    License will therefore apply, along with any applicable section 7
+    additional terms, to the whole of the work, and all its parts,
+    regardless of how they are packaged.  This License gives no
+    permission to license the work in any other way, but it does not
+    invalidate such permission if you have separately received it.
+
+    d) If the work has interactive user interfaces, each must display
+    Appropriate Legal Notices; however, if the Program has interactive
+    interfaces that do not display Appropriate Legal Notices, your
+    work need not make them do so.
+
+  A compilation of a covered work with other separate and independent
+works, which are not by their nature extensions of the covered work,
+and which are not combined with it such as to form a larger program,
+in or on a volume of a storage or distribution medium, is called an
+"aggregate" if the compilation and its resulting copyright are not
+used to limit the access or legal rights of the compilation's users
+beyond what the individual works permit.  Inclusion of a covered work
+in an aggregate does not cause this License to apply to the other
+parts of the aggregate.
+
+  6. Conveying Non-Source Forms.
+
+  You may convey a covered work in object code form under the terms
+of sections 4 and 5, provided that you also convey the
+machine-readable Corresponding Source under the terms of this License,
+in one of these ways:
+
+    a) Convey the object code in, or embodied in, a physical product
+    (including a physical distribution medium), accompanied by the
+    Corresponding Source fixed on a durable physical medium
+    customarily used for software interchange.
+
+    b) Convey the object code in, or embodied in, a physical product
+    (including a physical distribution medium), accompanied by a
+    written offer, valid for at least three years and valid for as
+    long as you offer spare parts or customer support for that product
+    model, to give anyone who possesses the object code either (1) a
+    copy of the Corresponding Source for all the software in the
+    product that is covered by this License, on a durable physical
+    medium customarily used for software interchange, for a price no
+    more than your reasonable cost of physically performing this
+    conveying of source, or (2) access to copy the
+    Corresponding Source from a network server at no charge.
+
+    c) Convey individual copies of the object code with a copy of the
+    written offer to provide the Corresponding Source.  This
+    alternative is allowed only occasionally and noncommercially, and
+    only if you received the object code with such an offer, in accord
+    with subsection 6b.
+
+    d) Convey the object code by offering access from a designated
+    place (gratis or for a charge), and offer equivalent access to the
+    Corresponding Source in the same way through the same place at no
+    further charge.  You need not require recipients to copy the
+    Corresponding Source along with the object code.  If the place to
+    copy the object code is a network server, the Corresponding Source
+    may be on a different server (operated by you or a third party)
+    that supports equivalent copying facilities, provided you maintain
+    clear directions next to the object code saying where to find the
+    Corresponding Source.  Regardless of what server hosts the
+    Corresponding Source, you remain obligated to ensure that it is
+    available for as long as needed to satisfy these requirements.
+
+    e) Convey the object code using peer-to-peer transmission, provided
+    you inform other peers where the object code and Corresponding
+    Source of the work are being offered to the general public at no
+    charge under subsection 6d.
+
+  A separable portion of the object code, whose source code is excluded
+from the Corresponding Source as a System Library, need not be
+included in conveying the object code work.
+
+  A "User Product" is either (1) a "consumer product", which means any
+tangible personal property which is normally used for personal, family,
+or household purposes, or (2) anything designed or sold for incorporation
+into a dwelling.  In determining whether a product is a consumer product,
+doubtful cases shall be resolved in favor of coverage.  For a particular
+product received by a particular user, "normally used" refers to a
+typical or common use of that class of product, regardless of the status
+of the particular user or of the way in which the particular user
+actually uses, or expects or is expected to use, the product.  A product
+is a consumer product regardless of whether the product has substantial
+commercial, industrial or non-consumer uses, unless such uses represent
+the only significant mode of use of the product.
+
+  "Installation Information" for a User Product means any methods,
+procedures, authorization keys, or other information required to install
+and execute modified versions of a covered work in that User Product from
+a modified version of its Corresponding Source.  The information must
+suffice to ensure that the continued functioning of the modified object
+code is in no case prevented or interfered with solely because
+modification has been made.
+
+  If you convey an object code work under this section in, or with, or
+specifically for use in, a User Product, and the conveying occurs as
+part of a transaction in which the right of possession and use of the
+User Product is transferred to the recipient in perpetuity or for a
+fixed term (regardless of how the transaction is characterized), the
+Corresponding Source conveyed under this section must be accompanied
+by the Installation Information.  But this requirement does not apply
+if neither you nor any third party retains the ability to install
+modified object code on the User Product (for example, the work has
+been installed in ROM).
+
+  The requirement to provide Installation Information does not include a
+requirement to continue to provide support service, warranty, or updates
+for a work that has been modified or installed by the recipient, or for
+the User Product in which it has been modified or installed.  Access to a
+network may be denied when the modification itself materially and
+adversely affects the operation of the network or violates the rules and
+protocols for communication across the network.
+
+  Corresponding Source conveyed, and Installation Information provided,
+in accord with this section must be in a format that is publicly
+documented (and with an implementation available to the public in
+source code form), and must require no special password or key for
+unpacking, reading or copying.
+
+  7. Additional Terms.
+
+  "Additional permissions" are terms that supplement the terms of this
+License by making exceptions from one or more of its conditions.
+Additional permissions that are applicable to the entire Program shall
+be treated as though they were included in this License, to the extent
+that they are valid under applicable law.  If additional permissions
+apply only to part of the Program, that part may be used separately
+under those permissions, but the entire Program remains governed by
+this License without regard to the additional permissions.
+
+  When you convey a copy of a covered work, you may at your option
+remove any additional permissions from that copy, or from any part of
+it.  (Additional permissions may be written to require their own
+removal in certain cases when you modify the work.)  You may place
+additional permissions on material, added by you to a covered work,
+for which you have or can give appropriate copyright permission.
+
+  Notwithstanding any other provision of this License, for material you
+add to a covered work, you may (if authorized by the copyright holders of
+that material) supplement the terms of this License with terms:
+
+    a) Disclaiming warranty or limiting liability differently from the
+    terms of sections 15 and 16 of this License; or
+
+    b) Requiring preservation of specified reasonable legal notices or
+    author attributions in that material or in the Appropriate Legal
+    Notices displayed by works containing it; or
+
+    c) Prohibiting misrepresentation of the origin of that material, or
+    requiring that modified versions of such material be marked in
+    reasonable ways as different from the original version; or
+
+    d) Limiting the use for publicity purposes of names of licensors or
+    authors of the material; or
+
+    e) Declining to grant rights under trademark law for use of some
+    trade names, trademarks, or service marks; or
+
+    f) Requiring indemnification of licensors and authors of that
+    material by anyone who conveys the material (or modified versions of
+    it) with contractual assumptions of liability to the recipient, for
+    any liability that these contractual assumptions directly impose on
+    those licensors and authors.
+
+  All other non-permissive additional terms are considered "further
+restrictions" within the meaning of section 10.  If the Program as you
+received it, or any part of it, contains a notice stating that it is
+governed by this License along with a term that is a further
+restriction, you may remove that term.  If a license document contains
+a further restriction but permits relicensing or conveying under this
+License, you may add to a covered work material governed by the terms
+of that license document, provided that the further restriction does
+not survive such relicensing or conveying.
+
+  If you add terms to a covered work in accord with this section, you
+must place, in the relevant source files, a statement of the
+additional terms that apply to those files, or a notice indicating
+where to find the applicable terms.
+
+  Additional terms, permissive or non-permissive, may be stated in the
+form of a separately written license, or stated as exceptions;
+the above requirements apply either way.
+
+  8. Termination.
+
+  You may not propagate or modify a covered work except as expressly
+provided under this License.  Any attempt otherwise to propagate or
+modify it is void, and will automatically terminate your rights under
+this License (including any patent licenses granted under the third
+paragraph of section 11).
+
+  However, if you cease all violation of this License, then your
+license from a particular copyright holder is reinstated (a)
+provisionally, unless and until the copyright holder explicitly and
+finally terminates your license, and (b) permanently, if the copyright
+holder fails to notify you of the violation by some reasonable means
+prior to 60 days after the cessation.
+
+  Moreover, your license from a particular copyright holder is
+reinstated permanently if the copyright holder notifies you of the
+violation by some reasonable means, this is the first time you have
+received notice of violation of this License (for any work) from that
+copyright holder, and you cure the violation prior to 30 days after
+your receipt of the notice.
+
+  Termination of your rights under this section does not terminate the
+licenses of parties who have received copies or rights from you under
+this License.  If your rights have been terminated and not permanently
+reinstated, you do not qualify to receive new licenses for the same
+material under section 10.
+
+  9. Acceptance Not Required for Having Copies.
+
+  You are not required to accept this License in order to receive or
+run a copy of the Program.  Ancillary propagation of a covered work
+occurring solely as a consequence of using peer-to-peer transmission
+to receive a copy likewise does not require acceptance.  However,
+nothing other than this License grants you permission to propagate or
+modify any covered work.  These actions infringe copyright if you do
+not accept this License.  Therefore, by modifying or propagating a
+covered work, you indicate your acceptance of this License to do so.
+
+  10. Automatic Licensing of Downstream Recipients.
+
+  Each time you convey a covered work, the recipient automatically
+receives a license from the original licensors, to run, modify and
+propagate that work, subject to this License.  You are not responsible
+for enforcing compliance by third parties with this License.
+
+  An "entity transaction" is a transaction transferring control of an
+organization, or substantially all assets of one, or subdividing an
+organization, or merging organizations.  If propagation of a covered
+work results from an entity transaction, each party to that
+transaction who receives a copy of the work also receives whatever
+licenses to the work the party's predecessor in interest had or could
+give under the previous paragraph, plus a right to possession of the
+Corresponding Source of the work from the predecessor in interest, if
+the predecessor has it or can get it with reasonable efforts.
+
+  You may not impose any further restrictions on the exercise of the
+rights granted or affirmed under this License.  For example, you may
+not impose a license fee, royalty, or other charge for exercise of
+rights granted under this License, and you may not initiate litigation
+(including a cross-claim or counterclaim in a lawsuit) alleging that
+any patent claim is infringed by making, using, selling, offering for
+sale, or importing the Program or any portion of it.
+
+  11. Patents.
+
+  A "contributor" is a copyright holder who authorizes use under this
+License of the Program or a work on which the Program is based.  The
+work thus licensed is called the contributor's "contributor version".
+
+  A contributor's "essential patent claims" are all patent claims
+owned or controlled by the contributor, whether already acquired or
+hereafter acquired, that would be infringed by some manner, permitted
+by this License, of making, using, or selling its contributor version,
+but do not include claims that would be infringed only as a
+consequence of further modification of the contributor version.  For
+purposes of this definition, "control" includes the right to grant
+patent sublicenses in a manner consistent with the requirements of
+this License.
+
+  Each contributor grants you a non-exclusive, worldwide, royalty-free
+patent license under the contributor's essential patent claims, to
+make, use, sell, offer for sale, import and otherwise run, modify and
+propagate the contents of its contributor version.
+
+  In the following three paragraphs, a "patent license" is any express
+agreement or commitment, however denominated, not to enforce a patent
+(such as an express permission to practice a patent or covenant not to
+sue for patent infringement).  To "grant" such a patent license to a
+party means to make such an agreement or commitment not to enforce a
+patent against the party.
+
+  If you convey a covered work, knowingly relying on a patent license,
+and the Corresponding Source of the work is not available for anyone
+to copy, free of charge and under the terms of this License, through a
+publicly available network server or other readily accessible means,
+then you must either (1) cause the Corresponding Source to be so
+available, or (2) arrange to deprive yourself of the benefit of the
+patent license for this particular work, or (3) arrange, in a manner
+consistent with the requirements of this License, to extend the patent
+license to downstream recipients.  "Knowingly relying" means you have
+actual knowledge that, but for the patent license, your conveying the
+covered work in a country, or your recipient's use of the covered work
+in a country, would infringe one or more identifiable patents in that
+country that you have reason to believe are valid.
+
+  If, pursuant to or in connection with a single transaction or
+arrangement, you convey, or propagate by procuring conveyance of, a
+covered work, and grant a patent license to some of the parties
+receiving the covered work authorizing them to use, propagate, modify
+or convey a specific copy of the covered work, then the patent license
+you grant is automatically extended to all recipients of the covered
+work and works based on it.
+
+  A patent license is "discriminatory" if it does not include within
+the scope of its coverage, prohibits the exercise of, or is
+conditioned on the non-exercise of one or more of the rights that are
+specifically granted under this License.  You may not convey a covered
+work if you are a party to an arrangement with a third party that is
+in the business of distributing software, under which you make payment
+to the third party based on the extent of your activity of conveying
+the work, and under which the third party grants, to any of the
+parties who would receive the covered work from you, a discriminatory
+patent license (a) in connection with copies of the covered work
+conveyed by you (or copies made from those copies), or (b) primarily
+for and in connection with specific products or compilations that
+contain the covered work, unless you entered into that arrangement,
+or that patent license was granted, prior to 28 March 2007.
+
+  Nothing in this License shall be construed as excluding or limiting
+any implied license or other defenses to infringement that may
+otherwise be available to you under applicable patent law.
+
+  12. No Surrender of Others' Freedom.
+
+  If conditions are imposed on you (whether by court order, agreement or
+otherwise) that contradict the conditions of this License, they do not
+excuse you from the conditions of this License.  If you cannot convey a
+covered work so as to satisfy simultaneously your obligations under this
+License and any other pertinent obligations, then as a consequence you may
+not convey it at all.  For example, if you agree to terms that obligate you
+to collect a royalty for further conveying from those to whom you convey
+the Program, the only way you could satisfy both those terms and this
+License would be to refrain entirely from conveying the Program.
+
+  13. Remote Network Interaction; Use with the GNU General Public License.
+
+  Notwithstanding any other provision of this License, if you modify the
+Program, your modified version must prominently offer all users
+interacting with it remotely through a computer network (if your version
+supports such interaction) an opportunity to receive the Corresponding
+Source of your version by providing access to the Corresponding Source
+from a network server at no charge, through some standard or customary
+means of facilitating copying of software.  This Corresponding Source
+shall include the Corresponding Source for any work covered by version 3
+of the GNU General Public License that is incorporated pursuant to the
+following paragraph.
+
+  Notwithstanding any other provision of this License, you have
+permission to link or combine any covered work with a work licensed
+under version 3 of the GNU General Public License into a single
+combined work, and to convey the resulting work.  The terms of this
+License will continue to apply to the part which is the covered work,
+but the work with which it is combined will remain governed by version
+3 of the GNU General Public License.
+
+  14. Revised Versions of this License.
+
+  The Free Software Foundation may publish revised and/or new versions of
+the GNU Affero General Public License from time to time.  Such new versions
+will be similar in spirit to the present version, but may differ in detail to
+address new problems or concerns.
+
+  Each version is given a distinguishing version number.  If the
+Program specifies that a certain numbered version of the GNU Affero General
+Public License "or any later version" applies to it, you have the
+option of following the terms and conditions either of that numbered
+version or of any later version published by the Free Software
+Foundation.  If the Program does not specify a version number of the
+GNU Affero General Public License, you may choose any version ever published
+by the Free Software Foundation.
+
+  If the Program specifies that a proxy can decide which future
+versions of the GNU Affero General Public License can be used, that proxy's
+public statement of acceptance of a version permanently authorizes you
+to choose that version for the Program.
+
+  Later license versions may give you additional or different
+permissions.  However, no additional obligations are imposed on any
+author or copyright holder as a result of your choosing to follow a
+later version.
+
+  15. Disclaimer of Warranty.
+
+  THERE IS NO WARRANTY FOR THE PROGRAM, TO THE EXTENT PERMITTED BY
+APPLICABLE LAW.  EXCEPT WHEN OTHERWISE STATED IN WRITING THE COPYRIGHT
+HOLDERS AND/OR OTHER PARTIES PROVIDE THE PROGRAM "AS IS" WITHOUT WARRANTY
+OF ANY KIND, EITHER EXPRESSED OR IMPLIED, INCLUDING, BUT NOT LIMITED TO,
+THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR
+PURPOSE.  THE ENTIRE RISK AS TO THE QUALITY AND PERFORMANCE OF THE PROGRAM
+IS WITH YOU.  SHOULD THE PROGRAM PROVE DEFECTIVE, YOU ASSUME THE COST OF
+ALL NECESSARY SERVICING, REPAIR OR CORRECTION.
+
+  16. Limitation of Liability.
+
+  IN NO EVENT UNLESS REQUIRED BY APPLICABLE LAW OR AGREED TO IN WRITING
+WILL ANY COPYRIGHT HOLDER, OR ANY OTHER PARTY WHO MODIFIES AND/OR CONVEYS
+THE PROGRAM AS PERMITTED ABOVE, BE LIABLE TO YOU FOR DAMAGES, INCLUDING ANY
+GENERAL, SPECIAL, INCIDENTAL OR CONSEQUENTIAL DAMAGES ARISING OUT OF THE
+USE OR INABILITY TO USE THE PROGRAM (INCLUDING BUT NOT LIMITED TO LOSS OF
+DATA OR DATA BEING RENDERED INACCURATE OR LOSSES SUSTAINED BY YOU OR THIRD
+PARTIES OR A FAILURE OF THE PROGRAM TO OPERATE WITH ANY OTHER PROGRAMS),
+EVEN IF SUCH HOLDER OR OTHER PARTY HAS BEEN ADVISED OF THE POSSIBILITY OF
+SUCH DAMAGES.
+
+  17. Interpretation of Sections 15 and 16.
+
+  If the disclaimer of warranty and limitation of liability provided
+above cannot be given local legal effect according to their terms,
+reviewing courts shall apply local law that most closely approximates
+an absolute waiver of all civil liability in connection with the
+Program, unless a warranty or assumption of liability accompanies a
+copy of the Program in return for a fee.
+
+                     END OF TERMS AND CONDITIONS
+
+            How to Apply These Terms to Your New Programs
+
+  If you develop a new program, and you want it to be of the greatest
+possible use to the public, the best way to achieve this is to make it
+free software which everyone can redistribute and change under these terms.
+
+  To do so, attach the following notices to the program.  It is safest
+to attach them to the start of each source file to most effectively
+state the exclusion of warranty; and each file should have at least
+the "copyright" line and a pointer to where the full notice is found.
+
+    <one line to give the program's name and a brief idea of what it does.>
+    Copyright (C) 2025  <name of author>
+
+    This program is free software: you can redistribute it and/or modify
+    it under the terms of the GNU Affero General Public License as published
+    by the Free Software Foundation, either version 3 of the License, or
+    (at your option) any later version.
+
+    This program is distributed in the hope that it will be useful,
+    but WITHOUT ANY WARRANTY; without even the implied warranty of
+    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+    GNU Affero General Public License for more details.
+
+    You should have received a copy of the GNU Affero General Public License
+    along with this program.  If not, see <https://www.gnu.org/licenses/>.
+
+Also add information on how to contact you by electronic and paper mail.
+
+  If your software can interact with users remotely through a computer
+network, you should also make sure that it provides a way for users to
+get its source.  For example, if your program is a web application, its
+interface could display a "Source" link that leads users to an archive
+of the code.  There are many ways you could offer source, and different
+solutions will be better for different programs; see section 13 for the
+specific requirements.
+
+  You should also get your employer (if you work as a programmer) or school,
+if any, to sign a "copyright disclaimer" for the program, if necessary.
+For more information on this, and how to apply and follow the GNU AGPL, see
+<https://www.gnu.org/licenses/>.

README.md

···
+<!-- markdownlint-disable MD033 -->
+
 # Personal Activity Index
 
 A CLI that ingests content from Substack, Bluesky, and Leaflet into SQLite, with an optional Cloudflare Worker + D1 deployment path.
+
+## Features
+
+- Fetch posts from multiple sources:
+    - **Substack** via RSS feeds
+    - **Bluesky** via AT Protocol
+    - **Leaflet** publications via RSS feeds
+- Local SQLite storage with full-text search
+- Flexible filtering and querying
+- Self-hostable or serverless (Cloudflare Workers)
+
+## Quick Start
+
+```bash
+# Install
+cargo install --path cli
+
+# Initialize config (creates ~/.config/pai/config.toml)
+pai init
+
+# Edit config with your sources
+$EDITOR ~/.config/pai/config.toml
+
+# Sync content
+pai sync
+
+# List items
+pai list -n 10
+
+# Check database
+pai db-check
+```
+
+## Configuration
+
+Configuration is loaded from `$XDG_CONFIG_HOME/pai/config.toml` or `$HOME/.config/pai/config.toml`.
+
+See [config.example.toml](./config.example.toml) for a complete example with all available options.
+
+## Architecture
+
+The project is organized as a Cargo workspace
+
+```sh
+.
+├── core    # Shared types, fetchers, and the storage trait
+├── cli     # CLI binary (POSIX-compliant)
+└── worker  # Cloudflare Worker deployment using workers-rs
+```
+
+<details>
+<summary><strong>Source Implementations</strong></summary>
+
+### Substack (RSS)
+
+Substack fetcher uses standard RSS 2.0 feeds available at `{base_url}/feed`.
+
+**Implementation:**
+
+- Fetches RSS feed using `feed-rs` parser
+- Maps RSS `<item>` elements to standardized `Item` struct
+- Uses GUID as item ID, falls back to link if GUID is missing
+- Normalizes `pubDate` to ISO 8601 format
+
+**Key mappings:**
+
+- `id` = RSS GUID or link
+- `source_kind` = `substack`
+- `source_id` = Domain extracted from base_url
+- `title` = RSS title
+- `summary` = RSS description
+- `url` = RSS link
+- `content_html` = RSS content (if available)
+- `published_at` = RSS pubDate (normalized to ISO 8601)
+
+**Example RSS structure:**
+
+```xml
+<item>
+    <title>Post Title</title>
+    <link>https://example.substack.com/p/post-slug</link>
+    <guid>https://example.substack.com/p/post-slug</guid>
+    <pubDate>Mon, 01 Jan 2024 12:00:00 +0000</pubDate>
+    <description>Post summary or excerpt</description>
+</item>
+```
+
+### AT Protocol Integration (Bluesky)
+
+#### Overview
+
+Bluesky is built on the AT Protocol (Authenticated Transfer Protocol), a decentralized social networking protocol.
+
+**Key Concepts:**
+
+- **DID (Decentralized Identifier)**: Unique identifier for users (e.g., `did:plc:xyz123`)
+- **Handle**: Human-readable identifier (e.g., `user.bsky.social`)
+- **AT URI**: Resource identifier (e.g., `at://did:plc:xyz/app.bsky.feed.post/abc123`)
+- **Lexicon**: Schema definition language for records and API methods
+- **XRPC**: HTTP API wrapper for AT Protocol methods
+- **PDS (Personal Data Server)**: Server that stores user data
+
+#### Implementation
+
+Bluesky uses standard `app.bsky.feed.post` records and provides a public API for fetching posts.
+
+**Endpoint:** `GET https://public.api.bsky.app/xrpc/app.bsky.feed.getAuthorFeed`
+
+**Parameters:**
+
+- `actor` - User handle or DID
+- `limit` - Number of posts to fetch (default: 50)
+- `cursor` - Pagination cursor (optional)
+
+**Implementation:**
+
+- Fetches author feed using `app.bsky.feed.getAuthorFeed`
+- Filters out reposts and quotes (only includes original posts)
+- Converts AT URIs to canonical Bluesky URLs
+- Truncates long post text to create titles
+
+**Key mappings:**
+
+- `id` = AT URI (e.g., `at://did:plc:xyz/app.bsky.feed.post/abc123`)
+- `source_kind` = `bluesky`
+- `source_id` = User handle
+- `title` = Truncated post text (first 100 chars)
+- `summary` = Full post text
+- `url` = Canonical URL (`https://bsky.app/profile/{handle}/post/{post_id}`)
+- `author` = Post author handle
+- `published_at` = Post `createdAt` timestamp
+
+**Filtering reposts:**
+Posts with a `reason` field (indicating repost or quote) are excluded to fetch only original content.
+
+### Leaflet (RSS)
+
+#### Overview
+
+Leaflet publications provide RSS feeds at `{base_url}/rss`, making them straightforward to fetch using standard RSS parsing.
+
+**Note:** While Leaflet is built on AT Protocol and uses custom `pub.leaflet.post` records, we use RSS feeds for simplicity and reliability. Leaflet's RSS implementation provides all necessary metadata without requiring AT Protocol PDS queries.
+
+**Implementation:**
+
+- Fetches RSS feed using `feed-rs` parser
+- Maps RSS `<item>` elements to standardized `Item` struct
+- Supports multiple publications via config array
+- Uses entry ID from feed, falls back to link if missing
+- Normalizes publication dates to ISO 8601 format
+
+**Key mappings:**
+
+- `id` = RSS entry ID or link
+- `source_kind` = `leaflet`
+- `source_id` = Publication ID from config (e.g., `desertthunder`, `stormlightlabs`)
+- `title` = RSS entry title
+- `summary` = RSS entry summary/description
+- `url` = RSS entry link
+- `content_html` = RSS content body (if available)
+- `author` = RSS entry author
+- `published_at` = RSS published date or updated date (normalized to ISO 8601)
+
+**Configuration:**
+
+Leaflet supports multiple publications through array configuration:
+
+```toml
+[[sources.leaflet]]
+enabled = true
+id = "desertthunder"
+base_url = "https://desertthunder.leaflet.pub"
+
+[[sources.leaflet]]
+enabled = true
+id = "stormlightlabs"
+base_url = "https://stormlightlabs.leaflet.pub"
+```
+
+**Example RSS structure:**
+
+```xml
+<item>
+    <title>Dev Log: 2025-11-22</title>
+    <link>https://desertthunder.leaflet.pub/3m6a7fuk7u22p</link>
+    <guid>https://desertthunder.leaflet.pub/3m6a7fuk7u22p</guid>
+    <pubDate>Fri, 22 Nov 2025 16:22:54 +0000</pubDate>
+    <description>Post summary or excerpt</description>
+</item>
+```
+
+</details>
+
+## References
+
+- [AT Protocol Documentation](https://atproto.com)
+- [Lexicon Guide](https://atproto.com/guides/lexicon) - Schema definition language
+- [XRPC Specification](https://atproto.com/specs/xrpc) - HTTP API wrapper
+- [Bluesky API Documentation](https://docs.bsky.app/)
+- [Leaflet](https://tangled.org/leaflet.pub/leaflet) - Leaflet source code
+- [Leaflet Manual](https://about.leaflet.pub/) - User-facing documentation
+
+## License
+
+See [LICENSE file](./LICENSE) for details.

cli/Cargo.toml

···
 rusqlite = { version = "0.37", features = ["bundled"] }
 chrono = "0.4"
 dirs = "6.0"
+owo-colors = "4.1"

cli/src/main.rs

···
 mod storage;
 
 use clap::{Parser, Subcommand};
+use owo_colors::OwoColorize;
 use pai_core::{Config, ListFilter, PaiError, SourceKind};
 use std::path::PathBuf;
 use storage::SqliteStorage;
···
     command: Commands,
 }
 
+#[derive(Parser, Debug)]
+struct ExportOpts {
+    /// Filter by source kind
+    #[arg(short = 'k', value_name = "KIND")]
+    kind: Option<SourceKind>,
+
+    /// Filter by specific source ID
+    #[arg(short = 'S', value_name = "ID")]
+    source_id: Option<String>,
+
+    /// Maximum number of items
+    #[arg(short = 'n', value_name = "NUMBER")]
+    limit: Option<usize>,
+
+    /// Only items published at or after this time
+    #[arg(short = 's', value_name = "TIME")]
+    since: Option<String>,
+
+    /// Filter items by substring
+    #[arg(short = 'q', value_name = "PATTERN")]
+    query: Option<String>,
+
+    /// Output format
+    #[arg(short = 'f', value_name = "FORMAT", default_value = "json")]
+    format: String,
+
+    /// Output file (default: stdout)
+    #[arg(short = 'o', value_name = "FILE")]
+    output: Option<PathBuf>,
+}
+
+impl From<ExportOpts> for ListFilter {
+    fn from(opts: ExportOpts) -> Self {
+        ListFilter {
+            source_kind: opts.kind,
+            source_id: opts.source_id,
+            limit: opts.limit,
+            since: opts.since,
+            query: opts.query,
+        }
+    }
+}
+
 #[derive(Subcommand, Debug)]
 enum Commands {
     /// Fetch and store content from configured sources
···
     },
 
     /// Produce feeds or export files
-    Export {
-        /// Filter by source kind
-        #[arg(short = 'k', value_name = "KIND")]
-        kind: Option<SourceKind>,
-
-        /// Filter by specific source ID
-        #[arg(short = 'S', value_name = "ID")]
-        source_id: Option<String>,
-
-        /// Maximum number of items
-        #[arg(short = 'n', value_name = "NUMBER")]
-        limit: Option<usize>,
-
-        /// Only items published at or after this time
-        #[arg(short = 's', value_name = "TIME")]
-        since: Option<String>,
-
-        /// Filter items by substring
-        #[arg(short = 'q', value_name = "PATTERN")]
-        query: Option<String>,
-
-        /// Output format
-        #[arg(short = 'f', value_name = "FORMAT", default_value = "json")]
-        format: String,
-
-        /// Output file (default: stdout)
-        #[arg(short = 'o', value_name = "FILE")]
-        output: Option<PathBuf>,
-    },
+    Export(ExportOpts),
 
     /// Self-host HTTP API
     Serve {
···
 
     /// Verify database schema and print statistics
     DbCheck,
+
+    /// Initialize configuration file
+    Init {
+        /// Force overwrite existing config
+        #[arg(short = 'f')]
+        force: bool,
+    },
 }
 
 fn main() {
···
         Commands::List { kind, source_id, limit, since, query } => {
             handle_list(cli.db_path, kind, source_id, limit, since, query)
         }
-        Commands::Export { kind, source_id, limit, since, query, format, output } => {
-            handle_export(cli.db_path, kind, source_id, limit, since, query, format, output)
-        }
+        Commands::Export(opts) => handle_export(cli.db_path, opts),
         Commands::Serve { address } => handle_serve(cli.db_path, address),
         Commands::DbCheck => handle_db_check(cli.db_path),
+        Commands::Init { force } => handle_init(cli.config_dir, force),
     };
 
     if let Err(e) = result {
-        eprintln!("Error: {e}");
+        eprintln!("{} {}", "Error:".red().bold(), e);
         std::process::exit(1);
     }
 }
 
 fn handle_sync(
-    config_dir: Option<PathBuf>, db_path: Option<PathBuf>, _all: bool, _kind: Option<SourceKind>,
-    _source_id: Option<String>,
+    config_dir: Option<PathBuf>, db_path: Option<PathBuf>, _all: bool, kind: Option<SourceKind>,
+    source_id: Option<String>,
 ) -> Result<(), PaiError> {
     let db_path = paths::resolve_db_path(db_path)?;
-    let _config_dir = paths::resolve_config_dir(config_dir)?;
+    let config_dir = paths::resolve_config_dir(config_dir)?;
 
     let storage = SqliteStorage::new(db_path)?;
-    let config = Config::default();
 
-    let count = pai_core::sync_all_sources(&config, &storage)?;
+    let config_path = config_dir.join("config.toml");
+    let config = if config_path.exists() {
+        Config::from_file(&config_path)?
+    } else {
+        println!(
+            "{} No config file found, using default configuration",
+            "Warning:".yellow()
+        );
+        Config::default()
+    };
 
-    println!("Synced {count} items");
+    let count = pai_core::sync_all_sources(&config, &storage, kind, source_id.as_deref())?;
+
+    if count == 0 {
+        println!("{} No sources synced (check your config or filters)", "Info:".cyan());
+    } else {
+        println!("{} Synced {}", "Success:".green(), format!("{count} source(s)").bold());
+    }
+
     Ok(())
 }
 
···
     let items = pai_core::Storage::list_items(&storage, &filter)?;
 
     if items.is_empty() {
-        println!("No items found");
+        println!("{}", "No items found".yellow());
         return Ok(());
     }
 
-    println!("Found {} items:\n", items.len());
+    println!("{} {}\n", "Found".cyan(), format!("{} items:", items.len()).bold());
     for item in items {
-        println!("ID: {}", item.id);
-        println!("Source: {} ({})", item.source_kind, item.source_id);
+        println!("{} {}", "ID:".bright_black(), item.id);
+        println!(
+            "{} {} {}",
+            "Source:".bright_black(),
+            item.source_kind.to_string().cyan(),
+            format!("({})", item.source_id).bright_black()
+        );
         if let Some(title) = &item.title {
-            println!("Title: {title}");
+            println!("{} {}", "Title:".bright_black(), title.bold());
         }
         if let Some(author) = &item.author {
-            println!("Author: {author}");
+            println!("{} {}", "Author:".bright_black(), author);
         }
-        println!("URL: {}", item.url);
-        println!("Published: {}", item.published_at);
+        println!("{} {}", "URL:".bright_black(), item.url.blue().underline());
+        println!("{} {}", "Published:".bright_black(), item.published_at);
         println!();
     }
 
     Ok(())
 }
 
-fn handle_export(
-    db_path: Option<PathBuf>, kind: Option<SourceKind>, source_id: Option<String>, limit: Option<usize>,
-    since: Option<String>, query: Option<String>, format: String, output: Option<PathBuf>,
-) -> Result<(), PaiError> {
+fn handle_export(db_path: Option<PathBuf>, opts: ExportOpts) -> Result<(), PaiError> {
     let db_path = paths::resolve_db_path(db_path)?;
     let _storage = SqliteStorage::new(db_path)?;
 
-    let filter = ListFilter { source_kind: kind, source_id, limit, since, query };
+    let format = opts.format.clone();
+    let output = opts.output.clone();
+    let filter: ListFilter = opts.into();
 
     println!("export command - format: {format}, output: {output:?}, filter: {filter:?}");
     Ok(())
···
     let db_path = paths::resolve_db_path(db_path)?;
     let storage = SqliteStorage::new(db_path)?;
 
-    println!("Verifying database schema...");
+    println!("{}", "Verifying database schema...".cyan());
     storage.verify_schema()?;
-    println!("Schema verification: OK\n");
+    println!("{} {}\n", "Schema verification:".green(), "OK".bold());
 
-    println!("Database statistics:");
+    println!("{}", "Database statistics:".cyan().bold());
     let total = storage.count_items()?;
-    println!("  Total items: {total}");
+    println!("  {}: {}", "Total items".bright_black(), total.to_string().bold());
 
     let stats = storage.get_stats()?;
     if !stats.is_empty() {
-        println!("\nItems by source:");
+        println!("\n{}", "Items by source:".cyan().bold());
         for (source_kind, count) in stats {
-            println!("  {source_kind}: {count}");
+            println!("  {}: {}", source_kind.bright_black(), count.to_string().bold());
         }
     }
 
     Ok(())
 }
+
+fn handle_init(config_dir: Option<PathBuf>, force: bool) -> Result<(), PaiError> {
+    let config_dir = paths::resolve_config_dir(config_dir)?;
+    let config_path = config_dir.join("config.toml");
+
+    if config_path.exists() && !force {
+        println!(
+            "{} Config file already exists at {}",
+            "Error:".red().bold(),
+            config_path.display()
+        );
+        println!("{} Use {} to overwrite", "Hint:".yellow(), "pai init -f".bold());
+        return Err(PaiError::Config("Config file already exists".to_string()));
+    }
+
+    std::fs::create_dir_all(&config_dir)
+        .map_err(|e| PaiError::Config(format!("Failed to create config directory: {e}")))?;
+
+    let default_config = include_str!("../../config.example.toml");
+    std::fs::write(&config_path, default_config)
+        .map_err(|e| PaiError::Config(format!("Failed to write config file: {e}")))?;
+
+    println!("{} Created configuration file", "Success:".green().bold());
+    println!(
+        "  {}: {}",
+        "Location".bright_black(),
+        config_path.display().to_string().bold()
+    );
+    println!();
+    println!("{}", "Next steps:".cyan().bold());
+    println!("  1. Edit the config file to add your sources:");
+    println!("     {}", format!("$EDITOR {}", config_path.display()).bright_black());
+    println!("  2. Run sync to fetch content:");
+    println!("     {}", "pai sync".bright_black());
+    println!("  3. List your items:");
+    println!("     {}", "pai list -n 10".bright_black());
+
+    Ok(())
+}

config.example.toml

···
+# Personal Activity Index Configuration Example
+# Copy this file to your config directory and customize as needed
+#
+# Default config location:
+#   - $XDG_CONFIG_HOME/pai/config.toml
+#   - $HOME/.config/pai/config.toml
+
+[database]
+# Path to SQLite database file (optional, defaults to $XDG_DATA_HOME/pai/pai.db)
+path = "/home/owais/.local/share/pai/pai.db"
+
+[deployment]
+# Deployment mode: "sqlite" for local, "cloudflare" for Workers
+mode = "sqlite"
+
+# Cloudflare deployment configuration (optional, only needed for Workers)
+[deployment.cloudflare]
+worker_name = "personal-activity-index"
+d1_binding = "DB"
+database_name = "personal_activity_db"
+
+# Substack RSS feed source
+[sources.substack]
+enabled = true
+base_url = "https://patternmatched.substack.com"
+
+# Bluesky AT Protocol source
+[sources.bluesky]
+enabled = true
+handle = "desertthunder.dev"
+
+# Leaflet publications (can have multiple)
+[[sources.leaflet]]
+enabled = true
+id = "desertthunder"
+base_url = "https://desertthunder.leaflet.pub"
+
+[[sources.leaflet]]
+enabled = true
+id = "stormlightlabs"
+base_url = "https://stormlightlabs.leaflet.pub"

core/Cargo.toml

···
 
 [dependencies]
 thiserror = "2.0.17"
+serde = { version = "1.0", features = ["derive"] }
+serde_json = "1.0"
+toml = "0.9"
+reqwest = { version = "0.12", features = ["json"] }
+tokio = { version = "1.0", features = ["rt-multi-thread", "macros"] }
+feed-rs = "2.2"
+chrono = "0.4"

core/src/fetchers/bluesky.rs

···
+use crate::{BlueskyConfig, Item, PaiError, Result, SourceFetcher, SourceKind, Storage};
+use chrono::Utc;
+use serde::Deserialize;
+
+const BLUESKY_API_BASE: &str = "https://public.api.bsky.app";
+
+/// Response from app.bsky.feed.getAuthorFeed
+#[derive(Debug, Deserialize)]
+struct AuthorFeedResponse {
+    feed: Vec<FeedViewPost>,
+    #[allow(dead_code)]
+    cursor: Option<String>,
+}
+
+/// A post in the author feed
+#[derive(Debug, Deserialize)]
+struct FeedViewPost {
+    post: PostView,
+    #[allow(dead_code)]
+    reason: Option<serde_json::Value>,
+}
+
+/// Post view with metadata
+#[derive(Debug, Deserialize)]
+struct PostView {
+    uri: String,
+    #[allow(dead_code)]
+    cid: String,
+    author: Author,
+    record: serde_json::Value,
+    #[allow(dead_code)]
+    #[serde(rename = "indexedAt")]
+    indexed_at: String,
+}
+
+/// Author information
+#[derive(Debug, Deserialize)]
+struct Author {
+    #[allow(dead_code)]
+    did: String,
+    handle: String,
+    #[allow(dead_code)]
+    #[serde(rename = "displayName")]
+    display_name: Option<String>,
+}
+
+/// Fetcher for Bluesky posts via AT Protocol
+///
+/// Retrieves posts from a Bluesky user by querying the public API.
+/// Filters out reposts and quotes to only include original posts.
+pub struct BlueskyFetcher {
+    config: BlueskyConfig,
+    client: reqwest::Client,
+}
+
+impl BlueskyFetcher {
+    /// Creates a new Bluesky fetcher with the given configuration
+    pub fn new(config: BlueskyConfig) -> Self {
+        Self { config, client: reqwest::Client::new() }
+    }
+
+    /// Fetches the author feed from the Bluesky public API
+    async fn fetch_author_feed(&self) -> Result<AuthorFeedResponse> {
+        let url = format!("{BLUESKY_API_BASE}/xrpc/app.bsky.feed.getAuthorFeed");
+
+        let response = self
+            .client
+            .get(&url)
+            .query(&[("actor", &self.config.handle), ("limit", &"50".to_string())])
+            .send()
+            .await
+            .map_err(|e| PaiError::Fetch(format!("Failed to fetch Bluesky feed: {e}")))?;
+
+        if !response.status().is_success() {
+            return Err(PaiError::Fetch(format!("Bluesky API error: {}", response.status())));
+        }
+
+        response
+            .json::<AuthorFeedResponse>()
+            .await
+            .map_err(|e| PaiError::Parse(format!("Failed to parse Bluesky response: {e}")))
+    }
+
+    /// Checks if a post is an original post (not a repost or quote)
+    fn is_original_post(feed_post: &FeedViewPost) -> bool {
+        feed_post.reason.is_none()
+    }
+
+    /// Converts an AT URI to a canonical Bluesky URL
+    ///
+    /// AT URI format: at://did:plc:xyz/app.bsky.feed.post/abc123
+    /// URL format: https://bsky.app/profile/{handle}/post/{post_id}
+    fn at_uri_to_url(uri: &str, handle: &str) -> Result<String> {
+        let parts: Vec<&str> = uri.split('/').collect();
+        if parts.len() >= 4 && parts[0] == "at:" {
+            let post_id = parts[parts.len() - 1];
+            Ok(format!("https://bsky.app/profile/{handle}/post/{post_id}"))
+        } else {
+            Err(PaiError::Parse(format!("Invalid AT URI: {uri}")))
+        }
+    }
+
+    /// Extracts text content from the post record
+    fn extract_text(record: &serde_json::Value) -> Option<String> {
+        record.get("text").and_then(|v| v.as_str()).map(String::from)
+    }
+
+    /// Creates a title from the post text (truncated to 100 chars)
+    fn create_title(text: &str) -> String {
+        if text.len() <= 100 {
+            text.to_string()
+        } else {
+            format!("{}...", &text[..97])
+        }
+    }
+}
+
+impl SourceFetcher for BlueskyFetcher {
+    fn sync(&self, storage: &dyn Storage) -> Result<()> {
+        let runtime =
+            tokio::runtime::Runtime::new().map_err(|e| PaiError::Fetch(format!("Failed to create runtime: {e}")))?;
+
+        runtime.block_on(async {
+            let response = self.fetch_author_feed().await?;
+
+            for feed_post in response.feed {
+                if !Self::is_original_post(&feed_post) {
+                    continue;
+                }
+
+                let post = feed_post.post;
+                let text = Self::extract_text(&post.record);
+
+                let title = text.as_ref().map(|t| Self::create_title(t));
+                let url = Self::at_uri_to_url(&post.uri, &post.author.handle)?;
+
+                let published_at = post
+                    .record
+                    .get("createdAt")
+                    .and_then(|v| v.as_str())
+                    .map(String::from)
+                    .unwrap_or_else(|| Utc::now().to_rfc3339());
+
+                let item = Item {
+                    id: post.uri.clone(),
+                    source_kind: SourceKind::Bluesky,
+                    source_id: self.config.handle.clone(),
+                    author: Some(post.author.handle.clone()),
+                    title,
+                    summary: text,
+                    url,
+                    content_html: None,
+                    published_at,
+                    created_at: Utc::now().to_rfc3339(),
+                };
+
+                storage.insert_or_replace_item(&item)?;
+            }
+
+            Ok(())
+        })
+    }
+}
+
+#[cfg(test)]
+mod tests {
+    use super::*;
+
+    #[test]
+    fn at_uri_to_url_valid() {
+        let uri = "at://did:plc:abc123/app.bsky.feed.post/xyz789";
+        let url = BlueskyFetcher::at_uri_to_url(uri, "user.bsky.social").unwrap();
+        assert_eq!(url, "https://bsky.app/profile/user.bsky.social/post/xyz789");
+    }
+
+    #[test]
+    fn at_uri_to_url_invalid() {
+        let uri = "invalid-uri";
+        assert!(BlueskyFetcher::at_uri_to_url(uri, "user.bsky.social").is_err());
+    }
+
+    #[test]
+    fn create_title_short_text() {
+        let text = "Short post";
+        assert_eq!(BlueskyFetcher::create_title(text), "Short post");
+    }
+
+    #[test]
+    fn create_title_long_text() {
+        let text = "This is a very long post that exceeds one hundred characters and should be truncated with ellipsis at the end";
+        let title = BlueskyFetcher::create_title(text);
+        assert!(title.ends_with("..."));
+        assert_eq!(title.len(), 100);
+    }
+
+    #[test]
+    fn extract_text_from_record() {
+        let record = serde_json::json!({
+            "text": "Hello world",
+            "createdAt": "2024-01-01T12:00:00Z"
+        });
+        let text = BlueskyFetcher::extract_text(&record).unwrap();
+        assert_eq!(text, "Hello world");
+    }
+
+    #[test]
+    fn extract_text_missing() {
+        let record = serde_json::json!({
+            "createdAt": "2024-01-01T12:00:00Z"
+        });
+        assert!(BlueskyFetcher::extract_text(&record).is_none());
+    }
+
+    #[test]
+    fn is_original_post_true() {
+        let feed_post = FeedViewPost {
+            post: PostView {
+                uri: "at://test".to_string(),
+                cid: "cid123".to_string(),
+                author: Author {
+                    did: "did:plc:test".to_string(),
+                    handle: "test.bsky.social".to_string(),
+                    display_name: None,
+                },
+                record: serde_json::json!({}),
+                indexed_at: "2024-01-01T12:00:00Z".to_string(),
+            },
+            reason: None,
+        };
+        assert!(BlueskyFetcher::is_original_post(&feed_post));
+    }
+
+    #[test]
+    fn is_original_post_false_repost() {
+        let feed_post = FeedViewPost {
+            post: PostView {
+                uri: "at://test".to_string(),
+                cid: "cid123".to_string(),
+                author: Author {
+                    did: "did:plc:test".to_string(),
+                    handle: "test.bsky.social".to_string(),
+                    display_name: None,
+                },
+                record: serde_json::json!({}),
+                indexed_at: "2024-01-01T12:00:00Z".to_string(),
+            },
+            reason: Some(serde_json::json!({"$type": "app.bsky.feed.defs#reasonRepost"})),
+        };
+        assert!(!BlueskyFetcher::is_original_post(&feed_post));
+    }
+}

core/src/fetchers/leaflet.rs

···
+use crate::{Item, LeafletConfig, PaiError, Result, SourceFetcher, SourceKind, Storage};
+use chrono::Utc;
+use feed_rs::parser;
+
+/// Fetcher for Leaflet publications via RSS
+///
+/// Retrieves posts from Leaflet publications by parsing their RSS feeds.
+/// Each Leaflet publication provides an RSS feed at {base_url}/rss.
+pub struct LeafletFetcher {
+    config: LeafletConfig,
+    client: reqwest::Client,
+}
+
+impl LeafletFetcher {
+    /// Creates a new Leaflet fetcher with the given configuration
+    pub fn new(config: LeafletConfig) -> Self {
+        Self { config, client: reqwest::Client::new() }
+    }
+
+    /// Fetches and parses the RSS feed
+    async fn fetch_feed(&self) -> Result<feed_rs::model::Feed> {
+        let feed_url = format!("{}/rss", self.config.base_url.trim_end_matches('/'));
+        let response = self
+            .client
+            .get(&feed_url)
+            .send()
+            .await
+            .map_err(|e| PaiError::Fetch(format!("Failed to fetch Leaflet RSS feed: {e}")))?;
+
+        let body = response
+            .text()
+            .await
+            .map_err(|e| PaiError::Fetch(format!("Failed to read response body: {e}")))?;
+
+        parser::parse(body.as_bytes()).map_err(|e| PaiError::Parse(format!("Failed to parse RSS feed: {e}")))
+    }
+}
+
+impl SourceFetcher for LeafletFetcher {
+    fn sync(&self, storage: &dyn Storage) -> Result<()> {
+        let runtime =
+            tokio::runtime::Runtime::new().map_err(|e| PaiError::Fetch(format!("Failed to create runtime: {e}")))?;
+
+        runtime.block_on(async {
+            let feed = self.fetch_feed().await?;
+
+            for entry in feed.entries {
+                let id = entry.id.clone();
+                let url = entry
+                    .links
+                    .first()
+                    .map(|link| link.href.clone())
+                    .unwrap_or_else(|| id.clone());
+
+                let title = entry.title.as_ref().map(|t| t.content.clone());
+                let summary = entry.summary.as_ref().map(|s| s.content.clone());
+                let author = entry.authors.first().map(|a| a.name.clone());
+                let content_html = entry.content.and_then(|c| c.body);
+
+                let published_at = entry
+                    .published
+                    .or(entry.updated)
+                    .map(|dt| dt.to_rfc3339())
+                    .unwrap_or_else(|| Utc::now().to_rfc3339());
+
+                let item = Item {
+                    id,
+                    source_kind: SourceKind::Leaflet,
+                    source_id: self.config.id.clone(),
+                    author,
+                    title,
+                    summary,
+                    url,
+                    content_html,
+                    published_at,
+                    created_at: Utc::now().to_rfc3339(),
+                };
+
+                storage.insert_or_replace_item(&item)?;
+            }
+
+            Ok(())
+        })
+    }
+}
+
+#[cfg(test)]
+mod tests {
+    use super::*;
+
+    #[test]
+    fn parse_valid_rss() {
+        let rss = r#"<?xml version="1.0" encoding="UTF-8"?>
+<rss version="2.0">
+<channel>
+    <title>Test Leaflet</title>
+    <link>https://test.leaflet.pub</link>
+    <description>Test publication</description>
+    <item>
+        <title>Test Post</title>
+        <link>https://test.leaflet.pub/test-post</link>
+        <guid>test-guid</guid>
+        <pubDate>Mon, 01 Jan 2024 12:00:00 +0000</pubDate>
+        <description>Test summary</description>
+    </item>
+</channel>
+</rss>"#;
+
+        let feed = parser::parse(rss.as_bytes()).unwrap();
+        assert_eq!(feed.entries.len(), 1);
+        assert_eq!(feed.entries[0].title.as_ref().unwrap().content, "Test Post");
+    }
+
+    #[test]
+    fn parse_invalid_rss() {
+        let invalid_rss = "this is not valid XML";
+        let result = parser::parse(invalid_rss.as_bytes());
+        assert!(result.is_err());
+    }
+
+    #[test]
+    fn parse_empty_rss() {
+        let rss = r#"<?xml version="1.0" encoding="UTF-8"?>
+<rss version="2.0">
+<channel>
+    <title>Empty Feed</title>
+</channel>
+</rss>"#;
+
+        let feed = parser::parse(rss.as_bytes()).unwrap();
+        assert_eq!(feed.entries.len(), 0);
+    }
+}

core/src/fetchers/mod.rs

···
+mod bluesky;
+mod leaflet;
+mod substack;
+
+pub use bluesky::BlueskyFetcher;
+pub use leaflet::LeafletFetcher;
+pub use substack::SubstackFetcher;

core/src/fetchers/substack.rs

···
+use crate::{Item, PaiError, Result, SourceFetcher, SourceKind, Storage, SubstackConfig};
+use chrono::Utc;
+use feed_rs::parser;
+
+/// Fetcher for Substack RSS feeds
+///
+/// Retrieves posts from a Substack publication by parsing its RSS feed.
+/// Maps RSS items to the standardized Item struct for storage.
+pub struct SubstackFetcher {
+    config: SubstackConfig,
+    client: reqwest::Client,
+}
+
+impl SubstackFetcher {
+    /// Creates a new Substack fetcher with the given configuration
+    pub fn new(config: SubstackConfig) -> Self {
+        Self { config, client: reqwest::Client::new() }
+    }
+
+    /// Fetches and parses the RSS feed
+    async fn fetch_feed(&self) -> Result<feed_rs::model::Feed> {
+        let feed_url = format!("{}/feed", self.config.base_url);
+        let response = self
+            .client
+            .get(&feed_url)
+            .send()
+            .await
+            .map_err(|e| PaiError::Fetch(format!("Failed to fetch RSS feed: {e}")))?;
+
+        let body = response
+            .text()
+            .await
+            .map_err(|e| PaiError::Fetch(format!("Failed to read response body: {e}")))?;
+
+        parser::parse(body.as_bytes()).map_err(|e| PaiError::Parse(format!("Failed to parse RSS feed: {e}")))
+    }
+
+    /// Extracts the source ID from the base URL (e.g., "patternmatched.substack.com")
+    fn extract_source_id(&self) -> String {
+        self.config
+            .base_url
+            .trim_start_matches("https://")
+            .trim_start_matches("http://")
+            .trim_end_matches('/')
+            .to_string()
+    }
+}
+
+impl SourceFetcher for SubstackFetcher {
+    fn sync(&self, storage: &dyn Storage) -> Result<()> {
+        let runtime =
+            tokio::runtime::Runtime::new().map_err(|e| PaiError::Fetch(format!("Failed to create runtime: {e}")))?;
+
+        runtime.block_on(async {
+            let feed = self.fetch_feed().await?;
+            let source_id = self.extract_source_id();
+
+            for entry in feed.entries {
+                let id = entry.id.clone();
+                let url = entry
+                    .links
+                    .first()
+                    .map(|link| link.href.clone())
+                    .unwrap_or_else(|| id.clone());
+
+                let title = entry.title.as_ref().map(|t| t.content.clone());
+                let summary = entry.summary.as_ref().map(|s| s.content.clone());
+                let author = entry.authors.first().map(|a| a.name.clone());
+                let content_html = entry.content.and_then(|c| c.body);
+
+                let published_at = entry
+                    .published
+                    .or(entry.updated)
+                    .map(|dt| dt.to_rfc3339())
+                    .unwrap_or_else(|| Utc::now().to_rfc3339());
+
+                let item = Item {
+                    id,
+                    source_kind: SourceKind::Substack,
+                    source_id: source_id.clone(),
+                    author,
+                    title,
+                    summary,
+                    url,
+                    content_html,
+                    published_at,
+                    created_at: Utc::now().to_rfc3339(),
+                };
+
+                storage.insert_or_replace_item(&item)?;
+            }
+
+            Ok(())
+        })
+    }
+}
+
+#[cfg(test)]
+mod tests {
+    use super::*;
+    use crate::ListFilter;
+    use std::sync::{Arc, Mutex};
+
+    #[derive(Clone)]
+    #[allow(dead_code)]
+    struct MockStorage {
+        items: Arc<Mutex<Vec<Item>>>,
+    }
+
+    #[allow(dead_code)]
+    impl MockStorage {
+        fn new() -> Self {
+            Self { items: Arc::new(Mutex::new(Vec::new())) }
+        }
+
+        fn get_items(&self) -> Vec<Item> {
+            self.items.lock().unwrap().clone()
+        }
+    }
+
+    impl Storage for MockStorage {
+        fn insert_or_replace_item(&self, item: &Item) -> Result<()> {
+            self.items.lock().unwrap().push(item.clone());
+            Ok(())
+        }
+
+        fn list_items(&self, _filter: &ListFilter) -> Result<Vec<Item>> {
+            Ok(self.items.lock().unwrap().clone())
+        }
+    }
+
+    #[test]
+    fn extract_source_id_https() {
+        let config = SubstackConfig { enabled: true, base_url: "https://patternmatched.substack.com".to_string() };
+        let fetcher = SubstackFetcher::new(config);
+        assert_eq!(fetcher.extract_source_id(), "patternmatched.substack.com");
+    }
+
+    #[test]
+    fn extract_source_id_http() {
+        let config = SubstackConfig { enabled: true, base_url: "http://test.substack.com/".to_string() };
+        let fetcher = SubstackFetcher::new(config);
+        assert_eq!(fetcher.extract_source_id(), "test.substack.com");
+    }
+
+    #[test]
+    fn parse_valid_rss() {
+        let rss = r#"<?xml version="1.0" encoding="UTF-8"?>
+<rss version="2.0">
+<channel>
+    <title>Test Feed</title>
+    <link>https://test.substack.com</link>
+    <description>Test</description>
+    <item>
+        <title>Test Post</title>
+        <link>https://test.substack.com/p/test-post</link>
+        <guid>test-guid</guid>
+        <pubDate>Mon, 01 Jan 2024 12:00:00 +0000</pubDate>
+        <description>Test summary</description>
+    </item>
+</channel>
+</rss>"#;
+
+        let feed = parser::parse(rss.as_bytes()).unwrap();
+        assert_eq!(feed.entries.len(), 1);
+        assert_eq!(feed.entries[0].title.as_ref().unwrap().content, "Test Post");
+    }
+
+    #[test]
+    fn parse_invalid_rss() {
+        let invalid_rss = "this is not valid XML";
+        let result = parser::parse(invalid_rss.as_bytes());
+        assert!(result.is_err());
+    }
+
+    #[test]
+    fn parse_empty_rss() {
+        let rss = r#"<?xml version="1.0" encoding="UTF-8"?>
+<rss version="2.0">
+<channel>
+    <title>Test Feed</title>
+</channel>
+</rss>"#;
+
+        let feed = parser::parse(rss.as_bytes()).unwrap();
+        assert_eq!(feed.entries.len(), 0);
+    }
+}

core/src/lib.rs

···
-use std::fmt;
+mod fetchers;
+
+use serde::{Deserialize, Serialize};
+use std::path::Path;
+use std::{fmt, str::FromStr};
 use thiserror::Error;
+
+pub use fetchers::{BlueskyFetcher, LeafletFetcher, SubstackFetcher};
 
 /// Errors that can occur in the Personal Activity Index
 #[derive(Error, Debug)]
···
 pub type Result<T> = std::result::Result<T, PaiError>;
 
 /// Represents the different source types supported by the indexer
-#[derive(Debug, Clone, Copy, PartialEq, Eq, Hash)]
+#[derive(Debug, Clone, Copy, PartialEq, Eq, Hash, Serialize, Deserialize)]
+#[serde(rename_all = "lowercase")]
 pub enum SourceKind {
     Substack,
     Bluesky,
···
     fn sync(&self, storage: &dyn Storage) -> Result<()>;
 }
 
+/// Configuration for Substack source
+#[derive(Debug, Clone, Deserialize, Serialize)]
+pub struct SubstackConfig {
+    #[serde(default)]
+    pub enabled: bool,
+    pub base_url: String,
+}
+
+/// Configuration for Bluesky source
+#[derive(Debug, Clone, Deserialize, Serialize)]
+pub struct BlueskyConfig {
+    #[serde(default)]
+    pub enabled: bool,
+    pub handle: String,
+}
+
+/// Configuration for a single Leaflet publication
+#[derive(Debug, Clone, Deserialize, Serialize)]
+pub struct LeafletConfig {
+    #[serde(default)]
+    pub enabled: bool,
+    pub id: String,
+    pub base_url: String,
+}
+
+/// Database configuration
+#[derive(Debug, Clone, Deserialize, Serialize, Default)]
+pub struct DatabaseConfig {
+    pub path: Option<String>,
+}
+
+/// Deployment mode configuration
+#[derive(Debug, Clone, Deserialize, Serialize, Default)]
+pub struct DeploymentConfig {
+    #[serde(default)]
+    pub mode: String,
+    pub cloudflare: Option<CloudflareConfig>,
+}
+
+/// Cloudflare deployment configuration
+#[derive(Debug, Clone, Deserialize, Serialize)]
+pub struct CloudflareConfig {
+    pub worker_name: String,
+    pub d1_binding: String,
+    pub database_name: String,
+}
+
+/// Sources configuration section
+#[derive(Debug, Clone, Deserialize, Serialize, Default)]
+pub struct SourcesConfig {
+    pub substack: Option<SubstackConfig>,
+    pub bluesky: Option<BlueskyConfig>,
+    #[serde(default)]
+    pub leaflet: Vec<LeafletConfig>,
+}
+
 /// Configuration for all sources
-#[derive(Debug, Default)]
-pub struct Config {}
+#[derive(Debug, Clone, Deserialize, Serialize, Default)]
+pub struct Config {
+    #[serde(default)]
+    pub database: DatabaseConfig,
+    #[serde(default)]
+    pub deployment: DeploymentConfig,
+    #[serde(default)]
+    pub sources: SourcesConfig,
+}
+
+impl Config {
+    /// Load configuration from a TOML file
+    ///
+    /// Reads and parses the config file, validating the structure and required fields.
+    pub fn from_file<P: AsRef<Path>>(path: P) -> Result<Self> {
+        let content =
+            std::fs::read_to_string(path).map_err(|e| PaiError::Config(format!("Failed to read config file: {e}")))?;
+        Self::from_str(&content)
+    }
+}
+
+impl FromStr for Config {
+    type Err = PaiError;
+
+    fn from_str(s: &str) -> Result<Self> {
+        toml::from_str(s).map_err(|e| PaiError::Config(format!("Failed to parse config: {e}")))
+    }
+}
 
 /// Synchronize all enabled sources
 ///
 /// Calls each configured source fetcher to retrieve and store content.
-pub fn sync_all_sources(_config: &Config, _storage: &dyn Storage) -> Result<usize> {
-    Ok(0)
+/// Returns the number of sources successfully synced.
+///
+/// Filters sources based on optional kind and source_id parameters.
+pub fn sync_all_sources(
+    config: &Config, storage: &dyn Storage, kind: Option<SourceKind>, source_id: Option<&str>,
+) -> Result<usize> {
+    let mut synced_count = 0;
+
+    if let Some(ref substack_config) = config.sources.substack {
+        let should_sync = substack_config.enabled
+            && match (kind, source_id) {
+                (Some(k), _) if k != SourceKind::Substack => false,
+                (_, Some(sid)) => {
+                    let substack_id = substack_config
+                        .base_url
+                        .trim_start_matches("https://")
+                        .trim_start_matches("http://")
+                        .trim_end_matches('/');
+                    substack_id == sid
+                }
+                _ => true,
+            };
+
+        if should_sync {
+            let fetcher = SubstackFetcher::new(substack_config.clone());
+            fetcher.sync(storage)?;
+            synced_count += 1;
+        }
+    }
+
+    if let Some(ref bluesky_config) = config.sources.bluesky {
+        let should_sync = bluesky_config.enabled
+            && match (kind, source_id) {
+                (Some(k), _) if k != SourceKind::Bluesky => false,
+                (_, Some(sid)) => bluesky_config.handle == sid,
+                _ => true,
+            };
+
+        if should_sync {
+            let fetcher = BlueskyFetcher::new(bluesky_config.clone());
+            fetcher.sync(storage)?;
+            synced_count += 1;
+        }
+    }
+
+    for leaflet_config in &config.sources.leaflet {
+        if !leaflet_config.enabled {
+            continue;
+        }
+
+        let should_sync = match (kind, source_id) {
+            (Some(k), _) if k != SourceKind::Leaflet => false,
+            (_, Some(sid)) => leaflet_config.id == sid,
+            _ => true,
+        };
+
+        if should_sync {
+            let fetcher = LeafletFetcher::new(leaflet_config.clone());
+            fetcher.sync(storage)?;
+            synced_count += 1;
+        }
+    }
+
+    Ok(synced_count)
 }
 
 #[cfg(test)]
···
         assert!(filter.limit.is_none());
         assert!(filter.since.is_none());
         assert!(filter.query.is_none());
+    }
+
+    #[test]
+    fn config_parse_empty() {
+        let config = Config::from_str("").unwrap();
+        assert!(config.sources.substack.is_none());
+        assert!(config.sources.bluesky.is_none());
+        assert!(config.sources.leaflet.is_empty());
+    }
+
+    #[test]
+    fn config_parse_substack() {
+        let toml = r#"
+[sources.substack]
+enabled = true
+base_url = "https://patternmatched.substack.com"
+"#;
+        let config = Config::from_str(toml).unwrap();
+        let substack = config.sources.substack.as_ref().unwrap();
+        assert!(substack.enabled);
+        assert_eq!(substack.base_url, "https://patternmatched.substack.com");
+    }
+
+    #[test]
+    fn config_parse_bluesky() {
+        let toml = r#"
+[sources.bluesky]
+enabled = true
+handle = "desertthunder.dev"
+"#;
+        let config = Config::from_str(toml).unwrap();
+        let bluesky = config.sources.bluesky.as_ref().unwrap();
+        assert!(bluesky.enabled);
+        assert_eq!(bluesky.handle, "desertthunder.dev");
+    }
+
+    #[test]
+    fn config_parse_leaflet_multiple() {
+        let toml = r#"
+[[sources.leaflet]]
+enabled = true
+id = "desertthunder"
+base_url = "https://desertthunder.leaflet.pub"
+
+[[sources.leaflet]]
+enabled = true
+id = "stormlightlabs"
+base_url = "https://stormlightlabs.leaflet.pub"
+"#;
+        let config = Config::from_str(toml).unwrap();
+        assert_eq!(config.sources.leaflet.len(), 2);
+        assert_eq!(config.sources.leaflet[0].id, "desertthunder");
+        assert_eq!(config.sources.leaflet[1].id, "stormlightlabs");
+    }
+
+    #[test]
+    fn config_parse_all_sources() {
+        let toml = r#"
+[database]
+path = "/tmp/test.db"
+
+[deployment]
+mode = "sqlite"
+
+[sources.substack]
+enabled = true
+base_url = "https://test.substack.com"
+
+[sources.bluesky]
+enabled = false
+handle = "test.bsky.social"
+
+[[sources.leaflet]]
+enabled = true
+id = "test"
+base_url = "https://test.leaflet.pub"
+"#;
+        let config = Config::from_str(toml).unwrap();
+        assert_eq!(config.database.path, Some("/tmp/test.db".to_string()));
+        assert_eq!(config.deployment.mode, "sqlite");
+        assert!(config.sources.substack.is_some());
+        assert!(config.sources.bluesky.is_some());
+        assert_eq!(config.sources.leaflet.len(), 1);
+    }
+
+    #[test]
+    fn config_parse_invalid_toml() {
+        let toml = "this is not valid toml {{{";
+        assert!(Config::from_str(toml).is_err());
+    }
+
+    #[test]
+    fn config_parse_missing_required_field() {
+        let toml = r#"
+[sources.substack]
+enabled = true
+"#;
+        let result = Config::from_str(toml);
+        assert!(result.is_err());
+    }
+
+    #[test]
+    fn config_default_enabled_false() {
+        let toml = r#"
+[sources.substack]
+base_url = "https://test.substack.com"
+"#;
+        let config = Config::from_str(toml).unwrap();
+        let substack = config.sources.substack.as_ref().unwrap();
+        assert!(!substack.enabled);
     }
 }