Add sqlite implementation

Signed-off-by: James Rhodes <[email protected]>

Author: jarhodes314

Cargo.lock

@@ -55,7 +55,7 @@ tedge_config_macros-impl = { path = "crates/common/tedge_config_macros/impl" }
 tedge_config_manager = { path = "crates/extensions/tedge_config_manager" }
 tedge_downloader_ext = { path = "crates/extensions/tedge_downloader_ext" }
 tedge_file_system_ext = { path = "crates/extensions/tedge_file_system_ext" }
-tedge_flows = { path = "crates/extensions/tedge_flows" }
+tedge_flows = { path = "crates/extensions/tedge_flows", default-features = false }
 tedge_health_ext = { path = "crates/extensions/tedge_health_ext" }
 tedge_http_ext = { path = "crates/extensions/tedge_http_ext" }
 tedge_log_manager = { path = "crates/extensions/tedge_log_manager" }
@@ -93,6 +93,7 @@ base64 = "0.22"
 bytes = "1.4"
 camino = "1.1"
 cap = "0.1"
+cfg-if = "1.0"
 clap = { version = "4.5", features = [
     "cargo",
     "derive",
@@ -184,6 +185,7 @@ serde_json = "1.0"
 sha1 = "0.10"
 sha256 = "1.1"
 shell-words = "1.1"
+sqlx = { version = "0.8", default-features = false }
 strum = "0.24"
 strum_macros = "0.24"
 syn = { version = "2", features = ["full", "extra-traits"] }

Cargo.toml

@@ -54,7 +54,7 @@ tedge-watchdog = { workspace = true }
 tedge-write = { workspace = true }
 tedge_api = { workspace = true }
 tedge_config = { workspace = true }
-tedge_flows = { workspace = true, optional = true }
+tedge_flows = { workspace = true, optional = true, default-features = false }
 tedge_utils = { workspace = true }
 thiserror = { workspace = true }
 time = { workspace = true }
@@ -84,11 +84,13 @@ x509-parser = { workspace = true }
 
 
 [features]
-default = ["aws", "azure", "c8y", "tedge-flows"]
+default = ["aws", "azure", "c8y", "tedge-flows-fjall"]
 aws = ["tedge-mapper/aws"]
 azure = ["tedge-mapper/azure"]
 c8y = ["tedge-mapper/c8y"]
 tedge-flows = ["dep:tedge_flows", "tedge-mapper/tedge-flows"]
+tedge-flows-fjall = ["tedge-flows", "tedge_flows/fjall-db"]
+tedge-flows-sqlite = ["tedge-flows", "tedge_flows/sqlite-db"]
 integration-test = []
 
 

crates/core/tedge/Cargo.toml

@@ -57,7 +57,7 @@ impl TestCommand {
         timestamp: DateTime,
     ) {
         processor
-            .on_message(MessageSource::MQTT, timestamp, message)
+            .on_message(MessageSource::Mqtt, timestamp, message)
             .await
             .into_iter()
             .map(|(_, v)| v)