bd-resilient-kv: add versioned store

AGENTS.md

@@ -19,22 +19,32 @@
 - Make sure to run `cargo +nightly fmt` after making changes to apply default formatting rules.
 - Use pattern matching with if-let and match expressions for error handling
 
+## Documentation Guidelines
+- Avoid redundant documentation for the sake of convention. For example
+    - Don't include an Errors section if the only errors are generic failures.
+    - Don't include an Arguments section if the arguments are obvious based on the function signature.
+
 ## Test File Conventions
 1. Test files should be placed adjacent to the implementation file they're testing
 2. Test files should be named with a `_test.rs` suffix (e.g., `network_quality_test.rs`)
-3. Link test files in the implementation file using:
+3. Link test files in the implementation file using the following pattern at the top of the file, right below the license header and optional module-level docs.
    ```rust
    #[cfg(test)]
    #[path = "./file_name_test.rs"]
    mod tests;
    ```
 4. Tests in the same file as the implementation code should be avoided
 5. Test names should *not* start with `test_`, as this is redundant
+6. Use module-level clippy allow blocks instead of per-test allows:
+   ```rust
+   #![allow(clippy::unwrap_used)]
+   ```
+   This should be placed at the top of the test file, after the license header and before imports.
 
 ## Code Quality Checks
 - After generating or modifying code, always run clippy to check for static lint violations:
   `SKIP_PROTO_GEN=1 cargo clippy --workspace --bins --examples --tests -- --no-deps`
 - For automatic fixing of some linting issues, use the `--fix` flag:
   `SKIP_PROTO_GEN=1 cargo clippy --workspace --bins --examples --tests --fix -- --no-deps`
 - Fix any remaining warnings before committing code
-- Running clippy is especially important after code generation or modification to catch any potential issues
+- Running clippy is especially important after code generation or modification to catch any potential issues

Cargo.toml

@@ -62,6 +62,7 @@ arbitrary         = { version = "1.4.2", features = ["derive"] }
 arc-swap          = "1.7.1"
 assert_matches    = "1.5.0"
 assert_no_alloc   = "1.1.2"
+async-compression = { version = "0.4.20", features = ["tokio", "zlib"] }
 async-trait       = "0.1.89"
 axum              = { version = "0.8.6", features = ["http2", "macros"] }
 axum-server       = { version = "0.7.2", features = ["tls-rustls-no-provider"] }

bd-proto/build.rs

@@ -117,6 +117,20 @@ fn main() {
     .out_dir("src/protos/logging/")
     .capture_stderr()
     .run_from_script();
+  std::fs::create_dir_all("src/protos/state").unwrap();
+  protobuf_codegen::Codegen::new()
+    .protoc()
+    .customize(
+      Customize::default()
+        .gen_mod_rs(false)
+        .oneofs_non_exhaustive(false)
+        .file_header(GENERATED_HEADER.to_string()),
+    )
+    .includes(["../api/thirdparty", "../api/src"])
+    .inputs(["../api/src/bitdrift_public/protobuf/state/v1/payload.proto"])
+    .out_dir("src/protos/state/")
+    .capture_stderr()
+    .run_from_script();
   std::fs::create_dir_all("src/protos/log_matcher").unwrap();
   protobuf_codegen::Codegen::new()
     .protoc()

bd-proto/src/protos/mod.rs

@@ -17,4 +17,5 @@ pub mod logging;
 pub mod mme;
 pub mod prometheus;
 pub mod pulse;
+pub mod state;
 pub mod workflow;

bd-proto/src/protos/state/mod.rs

@@ -0,0 +1 @@
+pub mod payload;