Support rqlite as a data store backend

README.md

@@ -58,12 +58,12 @@ Key features:
   - **Greylisting** to temporarily defer unknown senders.
   - **Spam traps** to set up decoy email addresses that catch and analyze spam.
 - **Flexible and scalable**:
-  - Pluggable storage backends with **RocksDB**, **FoundationDB**, **PostgreSQL**, **mySQL**, **SQLite**, **S3-Compatible**, **Azure**, **Redis** and **ElasticSearch** support.
+  - Pluggable storage backends with **RocksDB**, **FoundationDB**, **PostgreSQL**, **mySQL**, **SQLite**,, **rqlite**, **S3-Compatible**, **Azure**, **Redis** and **ElasticSearch** support.
   - **Clustering** support with node autodiscovery and partition-tolerant failure detection.
   - Full-text search available in 17 languages.
   - Sieve scripting language with support for all [registered extensions](https://www.iana.org/assignments/sieve-extensions/sieve-extensions.xhtml).
   - Email aliases, mailing lists, subaddressing and catch-all addresses support.
-  - Automatic account configuration and discovery with [autoconfig](https://www.ietf.org/id/draft-bucksch-autoconfig-02.html) and [autodiscover](https://learn.microsoft.com/en-us/exchange/architecture/client-access/autodiscover?view=exchserver-2019). 
+  - Automatic account configuration and discovery with [autoconfig](https://www.ietf.org/id/draft-bucksch-autoconfig-02.html) and [autodiscover](https://learn.microsoft.com/en-us/exchange/architecture/client-access/autodiscover?view=exchserver-2019).
   - Multi-tenancy support with domain and tenant isolation.
   - Disk quotas per user and tenant.
 - **Secure and robust**:
@@ -77,7 +77,7 @@ Key features:
   - **OpenID Connect** authentication.
   - OAuth 2.0 authorization with [authorization code](https://www.rfc-editor.org/rfc/rfc8628) and [device authorization](https://www.rfc-editor.org/rfc/rfc8628) flows.
   - **LDAP**, **OIDC**, **SQL** or built-in authentication backend support.
-  - Two-factor authentication with Time-based One-Time Passwords (`2FA-TOTP`) 
+  - Two-factor authentication with Time-based One-Time Passwords (`2FA-TOTP`)
   - Application passwords (App Passwords).
   - Roles and permissions.
   - Access Control Lists (ACLs).
@@ -145,8 +145,8 @@ If you find the project useful you can help by [becoming a sponsor](https://open
 
 This project is dual-licensed under the **GNU Affero General Public License v3.0** (AGPL-3.0; as published by the Free Software Foundation) and the **Stalwart Enterprise License v1 (SELv1)**:
 
-- The [GNU Affero General Public License v3.0](./LICENSES/AGPL-3.0-only.txt) is a free software license that ensures your freedom to use, modify, and distribute the software, with the condition that any modified versions of the software must also be distributed under the same license. 
-- The [Stalwart Enterprise License v1 (SELv1)](./LICENSES/LicenseRef-SEL.txt) is a proprietary license designed for commercial use. It offers additional features and greater flexibility for businesses that do not wish to comply with the AGPL-3.0 license requirements. 
+- The [GNU Affero General Public License v3.0](./LICENSES/AGPL-3.0-only.txt) is a free software license that ensures your freedom to use, modify, and distribute the software, with the condition that any modified versions of the software must also be distributed under the same license.
+- The [Stalwart Enterprise License v1 (SELv1)](./LICENSES/LicenseRef-SEL.txt) is a proprietary license designed for commercial use. It offers additional features and greater flexibility for businesses that do not wish to comply with the AGPL-3.0 license requirements.
 
 Each file in this project contains a license notice at the top, indicating the applicable license(s). The license notice follows the [REUSE guidelines](https://reuse.software/) to ensure clarity and consistency. The full text of each license is available in the [LICENSES](./LICENSES/) directory.
 

crates/main/Cargo.toml

@@ -34,9 +34,10 @@ tokio = { version = "1.23", features = ["full"] }
 jemallocator = "0.5.0"
 
 [features]
-#default = ["sqlite", "postgres", "mysql", "rocks", "elastic", "s3", "redis", "azure", "enterprise"]
+#default = ["sqlite", "rqlite", "postgres", "mysql", "rocks", "elastic", "s3", "redis", "azure", "enterprise"]
 default = ["rocks", "enterprise"]
 sqlite = ["store/sqlite"]
+rqlite = ["store/rqlite"]
 foundationdb = ["store/foundation", "common/foundation"]
 postgres = ["store/postgres"]
 mysql = ["store/mysql"]

crates/store/Cargo.toml

@@ -11,6 +11,7 @@ trc = { path = "../trc" }
 rocksdb = { version = "0.23", optional = true, features = ["multi-threaded-cf"] }
 foundationdb = { version = "0.9.0", features = ["embedded-fdb-include", "fdb-7_1"], optional = true }
 rusqlite = { version = "0.32", features = ["bundled"], optional = true }
+rqlite-rs = { version = "0.5.0", optional = true }
 rust-s3 = { version = "=0.35.0-alpha.2", default-features = false, features = ["tokio-rustls-tls", "no-verify-ssl"], optional = true }
 azure_core = { version = "0.21.0", optional = true }
 azure_storage = { version = "0.21.0", default-features = false, features = ["enable_reqwest_rustls", "hmac_rust"], optional = true }
@@ -56,6 +57,7 @@ tokio = { version = "1.23", features = ["full"] }
 [features]
 rocks = ["rocksdb", "rayon", "num_cpus"]
 sqlite = ["rusqlite", "rayon", "r2d2", "num_cpus", "lru-cache"]
+rqlite = ["rqlite-rs"]
 postgres = ["tokio-postgres", "deadpool-postgres", "tokio-rustls", "rustls", "ring", "rustls-pki-types", "futures", "bytes"]
 elastic = ["elasticsearch", "serde_json"]
 mysql = ["mysql_async", "futures"]
@@ -67,5 +69,3 @@ redis = ["dep:redis", "deadpool"]
 enterprise = []
 
 test_mode = []
-
-

crates/store/src/backend/composite/sharded_blob.rs

@@ -63,6 +63,8 @@ impl ShardedBlob {
                 BlobBackend::Store(store) => match store {
                     #[cfg(feature = "sqlite")]
                     Store::SQLite(store) => store.get_blob(key, read_range).await,
+                    #[cfg(feature = "rqlite")]
+                    Store::RQLite(store) => store.get_blob(key, read_range).await,
                     #[cfg(feature = "foundation")]
                     Store::FoundationDb(store) => store.get_blob(key, read_range).await,
                     #[cfg(feature = "postgres")]
@@ -95,6 +97,8 @@ impl ShardedBlob {
                 BlobBackend::Store(store) => match store {
                     #[cfg(feature = "sqlite")]
                     Store::SQLite(store) => store.put_blob(key, data).await,
+                    #[cfg(feature = "rqlite")]
+                    Store::RQLite(store) => store.put_blob(key, data).await,
                     #[cfg(feature = "foundation")]
                     Store::FoundationDb(store) => store.put_blob(key, data).await,
                     #[cfg(feature = "postgres")]
@@ -127,6 +131,8 @@ impl ShardedBlob {
                 BlobBackend::Store(store) => match store {
                     #[cfg(feature = "sqlite")]
                     Store::SQLite(store) => store.delete_blob(key).await,
+                    #[cfg(feature = "rqlite")]
+                    Store::RQLite(store) => store.delete_blob(key).await,
                     #[cfg(feature = "foundation")]
                     Store::FoundationDb(store) => store.delete_blob(key).await,
                     #[cfg(feature = "postgres")]

crates/store/src/backend/mod.rs

@@ -23,6 +23,8 @@ pub mod postgres;
 pub mod redis;
 #[cfg(feature = "rocks")]
 pub mod rocksdb;
+#[cfg(feature = "rqlite")]
+pub mod rqlite;
 #[cfg(feature = "s3")]
 pub mod s3;
 #[cfg(feature = "sqlite")]