ci(rust): add test coverage ci (#489)

* ci(rust): add test coverage ci

* ci(rust): use actions-rs/cargo install llvm-cov

* ci(rust): fix working directory

* ci(rust): optimize codecov

.codecov.yml

@@ -26,3 +26,7 @@ flags:
     carryforward: true
     paths:
       - "golang/**"
+  rust:
+    carryforward: true
+    paths:
+      - "rust/**"

.github/workflows/rust_build.yml

@@ -23,7 +23,6 @@ jobs:
       - name: Build
         working-directory: ./rust
         run: cargo build
-
       - name: Unit Test
         working-directory: ./rust
         run: cargo test -- --nocapture

.github/workflows/rust_coverage.yaml

@@ -0,0 +1,47 @@
+name: Rust Coverage
+on:
+  pull_request:
+    types: [opened, reopened, synchronize]
+    paths:
+      - 'rust/**'
+  push:
+    branches:
+      - master
+jobs:
+  calculate-coverage:
+    runs-on: ubuntu-latest
+    steps:
+      - name: Checkout repository
+        uses: actions/checkout@v2
+        with:
+          submodules: true
+
+      - name: Install rust toolchain
+        uses: actions-rs/toolchain@v1
+        with:
+          toolchain: stable
+          override: true
+
+      - name: Install Protoc
+        uses: arduino/setup-protoc@v1
+        with:
+          version: '3.x'
+          repo-token: ${{ secrets.GITHUB_TOKEN }}
+
+      - name: Install cargo-llvm-cov
+        uses: actions-rs/cargo@v1
+        with:
+          command: install
+          args: cargo-llvm-cov
+
+      - name: Generate code coverage
+        working-directory: ./rust
+        run: cargo llvm-cov --all-features --workspace --ignore-filename-regex pb/ --codecov --output-path codecov.json
+
+      - name: Upload to codecov.io
+        uses: codecov/codecov-action@v3
+        with:
+          files: ./rust/codecov.json
+          flags: rust
+          verbose: true
+          fail_ci_if_error: true

rust/src/model/common.rs

@@ -199,8 +199,8 @@ pub enum FilterType {
 
 /// Filter expression for message filtering.
 pub struct FilterExpression {
-    pub(crate) filter_type: FilterType,
-    pub(crate) expression: String,
+    filter_type: FilterType,
+    expression: String,
 }
 
 impl FilterExpression {
@@ -231,8 +231,8 @@ impl FilterExpression {
 /// Send result returned by producer.
 #[derive(Clone, Debug)]
 pub struct SendReceipt {
-    pub(crate) message_id: String,
-    pub(crate) transaction_id: String,
+    message_id: String,
+    transaction_id: String,
 }
 
 impl SendReceipt {

rust/src/producer.rs

@@ -390,12 +390,15 @@ mod tests {
             }))
         });
         producer.client.expect_send_message().returning(|_, _| {
-            Ok(vec![SendReceipt {
-                message_id: "".to_string(),
-                transaction_id: "".to_string(),
-            }])
+            Ok(vec![SendReceipt::from_pb_send_result(
+                &pb::SendResultEntry {
+                    message_id: "message_id".to_string(),
+                    transaction_id: "transaction_id".to_string(),
+                    ..pb::SendResultEntry::default()
+                },
+            )])
         });
-        producer
+        let result = producer
             .send_one(
                 MessageBuilder::builder()
                     .set_topic("test_topic")
@@ -404,6 +407,8 @@ mod tests {
                     .unwrap(),
             )
             .await?;
+        assert_eq!(result.message_id(), "message_id");
+        assert_eq!(result.transaction_id(), "transaction_id");
         Ok(())
     }
 }

rust/src/simple_consumer.rs

@@ -144,8 +144,8 @@ impl SimpleConsumer {
                 &endpoints,
                 message_queue,
                 pb::FilterExpression {
-                    r#type: expression.filter_type as i32,
-                    expression: expression.expression.clone(),
+                    r#type: expression.filter_type() as i32,
+                    expression: expression.expression().to_string(),
                 },
                 batch_size,
                 prost_types::Duration::try_from(invisible_duration).unwrap(),