Build out Rust unit tests/coverage reporting

.flox/env/manifest.toml

@@ -17,7 +17,7 @@ mask.pkg-path = "mask"
 bacon.pkg-path = "bacon"
 cargo-watch.pkg-path = "cargo-watch"
 cargo-nextest.pkg-path = "cargo-nextest"
-cargo-tarpaulin.pkg-path = "cargo-tarpaulin"
+cargo-llvm-cov.pkg-path = "cargo-llvm-cov"
 cargo.pkg-path = "cargo"
 cargo.pkg-group = "rust-toolchain"
 rustc.pkg-path = "rustc"

.github/workflows/run_python_code_checks.yaml

@@ -39,4 +39,6 @@ jobs:
         uses: coverallsapp/github-action@v2
         with:
           github-token: ${{ secrets.GITHUB_TOKEN }}
-          file: coverage/.python.xml
+          file: .coverage_output/python.xml
+          flag-name: python
+          parallel: false

.github/workflows/run_rust_code_checks.yaml

@@ -34,3 +34,10 @@ jobs:
         uses: flox/activate-action@v1
         with:
           command: mask development rust all
+      - name: Upload Rust coverage to Coveralls
+        uses: coverallsapp/github-action@v2
+        with:
+          github-token: ${{ secrets.GITHUB_TOKEN }}
+          file: .coverage_output/rust.xml
+          flag-name: rust
+          parallel: false

.gitignore

@@ -9,7 +9,7 @@
 __pycache__/
 .envrc
 .env.nu
-coverage/
+.coverage_output/
 .coverage
 *.csv
 *.egg-info/

README.md

@@ -3,7 +3,7 @@
 > The open source capital management company  
 
 <!-- markdownlint-disable-next-line MD013 -->
-[![Python code checks](https://github.com/oscmcompany/fund/actions/workflows/run_python_code_checks.yaml/badge.svg)](https://github.com/oscmcompany/fund/actions/workflows/run_python_code_checks.yaml) [![Rust code checks](https://github.com/oscmcompany/fund/actions/workflows/run_rust_code_checks.yaml/badge.svg)](https://github.com/oscmcompany/fund/actions/workflows/run_rust_code_checks.yaml)  
+[![Python code checks](https://github.com/oscmcompany/fund/actions/workflows/run_python_code_checks.yaml/badge.svg)](https://github.com/oscmcompany/fund/actions/workflows/run_python_code_checks.yaml) [![Rust code checks](https://github.com/oscmcompany/fund/actions/workflows/run_rust_code_checks.yaml/badge.svg)](https://github.com/oscmcompany/fund/actions/workflows/run_rust_code_checks.yaml) [![Test coverage](https://coveralls.io/repos/github/oscmcompany/fund/badge.svg?branch=master)](https://coveralls.io/github/oscmcompany/fund?branch=master)
 
 ## About
 

applications/datamanager/Cargo.toml

@@ -3,6 +3,10 @@ name = "datamanager"
 version = "0.1.0"
 edition = "2021"
 
+[lib]
+name = "datamanager"
+path = "src/lib.rs"
+
 [[bin]]
 name = "datamanager"
 path = "src/main.rs"
@@ -43,3 +47,6 @@ tower = { version = "0.5", features = ["util"] }
 hyper = { version = "1.0", features = ["full"] }
 http-body-util = "0.1"
 reqwest = { version = "0.12", features = ["json"] }
+mockito = "1.7"
+tempfile = "3.24"
+serial_test = "3.3"

applications/datamanager/src/errors.rs

@@ -14,3 +14,47 @@ pub enum Error {
     #[error("Other error: {0}")]
     Other(String),
 }
+
+#[cfg(test)]
+mod tests {
+    use super::*;
+
+    #[test]
+    fn test_other_error_display() {
+        let err = Error::Other("Test error message".to_string());
+        let display = format!("{}", err);
+        assert_eq!(display, "Other error: Test error message");
+    }
+
+    #[test]
+    fn test_other_error_debug() {
+        let err = Error::Other("Debug test".to_string());
+        let debug = format!("{:?}", err);
+        assert!(debug.contains("Other"));
+        assert!(debug.contains("Debug test"));
+    }
+
+    #[test]
+    fn test_duckdb_error_conversion() {
+        let duck_err = DuckError::ExecuteReturnedResults;
+        let err: Error = duck_err.into();
+        let display = format!("{}", err);
+        assert!(display.starts_with("DuckDB error:"));
+    }
+
+    #[test]
+    fn test_polars_error_conversion() {
+        let polars_err = PolarsError::NoData("test data".into());
+        let err: Error = polars_err.into();
+        let display = format!("{}", err);
+        assert!(display.starts_with("Polars error:"));
+    }
+
+    #[test]
+    fn test_credentials_error_conversion() {
+        let cred_err = CredentialsError::not_loaded("test credentials error");
+        let err: Error = cred_err.into();
+        let display = format!("{}", err);
+        assert!(display.starts_with("Credentials error:"));
+    }
+}

applications/datamanager/src/lib.rs

@@ -0,0 +1,10 @@
+pub mod data;
+pub mod equity_bars;
+pub mod equity_details;
+pub mod errors;
+pub mod health;
+pub mod portfolios;
+pub mod predictions;
+pub mod router;
+pub mod state;
+pub mod storage;

applications/datamanager/src/main.rs

@@ -1,15 +1,4 @@
-mod data;
-mod equity_bars;
-mod equity_details;
-mod errors;
-mod health;
-mod portfolios;
-mod predictions;
-mod router;
-mod state;
-mod storage;
-
-use router::create_app;
+use datamanager::router::create_app;
 use std::env;
 use tracing_subscriber::{layer::SubscriberExt, util::SubscriberInitExt};