36 cross process cli for aimdb introspection (#42)

* optimize timestamp generation

* change timestamp type to f64 for accurate Unix timestamp representation

* initial implementation aimdb cli

* update dependencies and enhance security checks in Makefile and deny.toml

* Update examples/remote-access-demo/src/server.rs

Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com>

* fix clippy error

---------

Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com>

Author: lxsaah

Cargo.lock

@@ -1,7 +1,7 @@
 # AimDB Makefile
 # Simple automation for common development tasks
 
-.PHONY: help build test clean fmt fmt-check clippy doc all check test-embedded examples
+.PHONY: help build test clean fmt fmt-check clippy doc all check test-embedded examples deny audit security
 .DEFAULT_GOAL := help
 
 # Colors for output
@@ -29,6 +29,11 @@ help:
 	@printf "    check                Comprehensive development check (fmt + clippy + all tests)\n"
 	@printf "    test-embedded        Test embedded/MCU cross-compilation compatibility\n"
 	@printf "\n"
+	@printf "  $(YELLOW)Security & Quality:$(NC)\n"
+	@printf "    deny                 Check dependencies (licenses, advisories, bans)\n"
+	@printf "    audit                Audit dependencies for known vulnerabilities\n"
+	@printf "    security             Run all security checks (deny + audit)\n"
+	@printf "\n"
 	@printf "  $(YELLOW)Convenience:$(NC)\n"
 	@printf "    all           Build everything\n"
 
@@ -146,13 +151,40 @@ examples:
 	cargo build --package embassy-mqtt-connector-demo --target thumbv7em-none-eabihf
 	@printf "$(GREEN)All examples built successfully!$(NC)\n"
 
+## Security & Quality commands
+deny:
+	@printf "$(GREEN)Checking dependencies with cargo-deny...$(NC)\n"
+	@if ! command -v cargo-deny >/dev/null 2>&1; then \
+		printf "$(YELLOW)  ⚠ cargo-deny not found, installing...$(NC)\n"; \
+		cargo install cargo-deny --locked; \
+	fi
+	@printf "$(YELLOW)  → Checking licenses$(NC)\n"
+	@printf "$(YELLOW)  → Checking security advisories$(NC)\n"
+	@printf "$(YELLOW)  → Checking banned dependencies$(NC)\n"
+	@printf "$(YELLOW)  → Checking dependency sources$(NC)\n"
+	cargo deny check
+
+audit:
+	@printf "$(GREEN)Auditing dependencies for vulnerabilities...$(NC)\n"
+	@if ! command -v cargo-audit >/dev/null 2>&1; then \
+		printf "$(YELLOW)  ⚠ cargo-audit not found, installing...$(NC)\n"; \
+		cargo install cargo-audit --locked; \
+	fi
+	cargo audit
+
+security: deny audit
+	@printf "$(GREEN)All security checks completed!$(NC)\n"
+	@printf "$(BLUE)✓ Dependencies verified (licenses, advisories, bans)$(NC)\n"
+	@printf "$(BLUE)✓ Known vulnerabilities checked$(NC)\n"
+
 ## Convenience commands
-check: fmt-check clippy test test-embedded
+check: fmt-check clippy test test-embedded deny
 	@printf "$(GREEN)Comprehensive development checks completed!$(NC)\n"
 	@printf "$(BLUE)✓ Code formatting verified$(NC)\n"
 	@printf "$(BLUE)✓ Linter passed$(NC)\n"
 	@printf "$(BLUE)✓ All valid feature combinations tested$(NC)\n"
 	@printf "$(BLUE)✓ Embedded target compatibility verified$(NC)\n"
+	@printf "$(BLUE)✓ Dependencies verified (deny)$(NC)\n"
 
 all: build test examples
 	@printf "$(GREEN)Build and test completed!$(NC)\n"

Makefile

@@ -1059,12 +1059,10 @@ async fn stream_subscription_events(
 
     while let Some(json_value) = value_rx.recv().await {
         // Generate timestamp in "secs.nanosecs" format
-        let timestamp = format!(
-            "{:?}",
-            std::time::SystemTime::now()
-                .duration_since(std::time::UNIX_EPOCH)
-                .unwrap_or_default()
-        );
+        let duration = std::time::SystemTime::now()
+            .duration_since(std::time::UNIX_EPOCH)
+            .unwrap_or_default();
+        let timestamp = format!("{}.{:09}", duration.as_secs(), duration.subsec_nanos());
 
         // Create event
         let event = Event {

aimdb-core/src/remote/handler.rs

@@ -41,7 +41,7 @@ mod protocol;
 pub use config::{AimxConfig, SecurityPolicy};
 pub use error::{RemoteError, RemoteResult};
 pub use metadata::RecordMetadata;
-pub use protocol::{Event, HelloMessage, Request, Response, WelcomeMessage};
+pub use protocol::{ErrorObject, Event, HelloMessage, Request, Response, WelcomeMessage};
 
 // Internal exports for implementation
 pub(crate) mod handler;

aimdb-core/src/remote/mod.rs

@@ -8,6 +8,7 @@ allow = [
     "ISC",          # ISC License - used by ring, rustls-webpki, untrusted
     "0BSD",         # BSD Zero Clause License - used by embassy-net dependencies
     "Unicode-3.0",
+    "MPL-2.0",      # Mozilla Public License 2.0 - used by colored crate (CLI only)
 ]
 
 confidence-threshold = 0.8

deny.toml

@@ -24,7 +24,7 @@ use tracing::info;
 struct Temperature {
     sensor_id: String,
     celsius: f64,
-    timestamp: u64,
+    timestamp: f64, // Unix timestamp as f64 (seconds since epoch with fractional nanoseconds, e.g., 1730379296.123456789)
 }
 
 /// System status information
@@ -130,11 +130,17 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
 
     // Produce some initial data
     let temp_producer = db.producer::<Temperature>();
+    let initial_duration = std::time::SystemTime::now()
+        .duration_since(std::time::UNIX_EPOCH)
+        .unwrap();
+    let initial_timestamp = initial_duration.as_secs() as f64
+        + initial_duration.subsec_nanos() as f64 / 1_000_000_000.0;
+
     temp_producer
         .produce(Temperature {
             sensor_id: "sensor-01".to_string(),
             celsius: 22.5,
-            timestamp: 1698764400,
+            timestamp: initial_timestamp,
         })
         .await?;
 
@@ -180,13 +186,16 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
             counter += 1;
             let temp = 20.0 + (counter as f64 * 0.5) + (counter as f64 % 10.0);
 
+            let duration = std::time::SystemTime::now()
+                .duration_since(std::time::UNIX_EPOCH)
+                .unwrap();
+            let timestamp =
+                duration.as_secs() as f64 + duration.subsec_nanos() as f64 / 1_000_000_000.0;
+
             let reading = Temperature {
                 sensor_id: format!("sensor-{:02}", (counter % 3) + 1),
                 celsius: temp,
-                timestamp: std::time::SystemTime::now()
-                    .duration_since(std::time::UNIX_EPOCH)
-                    .unwrap()
-                    .as_secs(),
+                timestamp,
             };
 
             if let Err(e) = temp_producer_clone.produce(reading.clone()).await {

examples/remote-access-demo/src/server.rs

@@ -5,4 +5,46 @@ edition.workspace = true
 license.workspace = true
 description = "Command-line interface for AimDB - development and administration tool"
 
+[[bin]]
+name = "aimdb"
+path = "src/main.rs"
+
 [dependencies]
+# Core dependencies - reuse protocol types from aimdb-core
+aimdb-core = { path = "../../aimdb-core", features = ["std"] }
+serde = { version = "1", features = ["derive"] }
+serde_json = "1"
+
+# CLI framework
+clap = { version = "4", features = ["derive", "cargo"] }
+
+# Async runtime (must match AimDB runtime)
+tokio = { version = "1", features = [
+    "net",
+    "io-util",
+    "rt-multi-thread",
+    "signal",
+    "macros",
+    "time",
+    "fs",
+] }
+
+# Error handling
+anyhow = "1"
+thiserror = "1"
+
+# Output formatting
+tabled = "0.20"
+colored = "3"
+chrono = "0.4"
+
+# Optional: YAML output
+serde_yaml = { version = "0.9", optional = true }
+
+[features]
+default = []
+yaml = ["serde_yaml"]
+
+[dev-dependencies]
+tokio-test = "0.4"
+tempfile = "3"