[ci] Fix Publication Order (#47)

Author: patrick-ogrady

.github/workflows/publish.yml

@@ -33,13 +33,13 @@ jobs:
       continue-on-error: true
       env:
         CARGO_REGISTRY_TOKEN: ${{ secrets.CARGO_REGISTRY_TOKEN }}
-    - name: Publish exoware-qmdb
-      run: cargo publish --manifest-path qmdb/Cargo.toml
+    - name: Publish exoware-simulator
+      run: cargo publish --manifest-path examples/simulator/Cargo.toml
       continue-on-error: true
       env:
         CARGO_REGISTRY_TOKEN: ${{ secrets.CARGO_REGISTRY_TOKEN }}
-    - name: Publish exoware-simulator
-      run: cargo publish --manifest-path examples/simulator/Cargo.toml
+    - name: Publish exoware-qmdb
+      run: cargo publish --manifest-path qmdb/Cargo.toml
       continue-on-error: true
       env:
         CARGO_REGISTRY_TOKEN: ${{ secrets.CARGO_REGISTRY_TOKEN }}

Cargo.lock

@@ -25,7 +25,6 @@ tower-http = { workspace = true }
 [dev-dependencies]
 commonware-codec = { workspace = true }
 connectrpc = { workspace = true }
-exoware-qmdb = { workspace = true }
 exoware-sdk = { workspace = true }
 http = { workspace = true }
 tempfile = { workspace = true }

examples/simulator/Cargo.toml

@@ -1,10 +1,10 @@
 use std::time::Duration;
 
 use bytes::Bytes;
-use exoware_qmdb::prune::{drop_all_batches, keep_latest_batches};
 use exoware_sdk::keys::{Key, KeyCodec};
 use exoware_sdk::kv_codec::Utf8;
 use exoware_sdk::match_key::MatchKey;
+use exoware_sdk::prune_policy::{PolicyScope, PrunePolicy, RetainPolicy};
 use exoware_sdk::stream_filter::StreamFilter;
 use exoware_sdk::{RetryConfig, StoreClient};
 use tempfile::tempdir;
@@ -39,6 +39,20 @@ fn filter(family: u16) -> StreamFilter {
     }
 }
 
+fn keep_latest_batches(count: usize) -> PrunePolicy {
+    PrunePolicy {
+        scope: PolicyScope::Sequence,
+        retain: RetainPolicy::KeepLatest { count },
+    }
+}
+
+fn drop_all_batches() -> PrunePolicy {
+    PrunePolicy {
+        scope: PolicyScope::Sequence,
+        retain: RetainPolicy::DropAll,
+    }
+}
+
 async fn next_with_timeout(
     sub: &mut exoware_sdk::StreamSubscription,
     ms: u64,