[ISSUE #903] [Rust] Fix sync settings show an error after the connection is closed by the server side (#1025)

Author: EnableAsync

.github/workflows/java_coverage.yml

@@ -26,9 +26,9 @@ jobs:
           paths: "**/TEST-*.xml"
         if: always()
       - name: Upload to Codecov
-        uses: codecov/codecov-action@v3
+        uses: codecov/codecov-action@v4
         with:
           flags: java
           fail_ci_if_error: true
-          token: e7eb01be-398b-4f7f-a73e-dc35c428cb50
+          token: ${{ secrets.CODECOV_ACTION_KEY }}
           verbose: true

.github/workflows/rust_build.yml

@@ -3,7 +3,7 @@ on:
   workflow_call:
 jobs:
   fmt:
-    name: code style check    
+    name: Code style check    
     runs-on: ubuntu-latest
     defaults:
       run:
@@ -20,7 +20,7 @@ jobs:
       - name: Code format check
         run: cargo fmt --check
   clippy:
-    name: clippy
+    name: Clippy
     runs-on: ubuntu-latest
     defaults:
       run:
@@ -35,10 +35,10 @@ jobs:
           toolchain: stable
           components: clippy
       # Run clippy
-      - name: clippy check
+      - name: Clippy check
         run: cargo clippy --all-features -- -D warnings
   doc:
-    name: doc check    
+    name: Doc check    
     runs-on: ubuntu-latest
     defaults:
       run:
@@ -62,7 +62,7 @@ jobs:
         working-directory: ./rust
     strategy:
       matrix:
-        msrv: [1.70.0]
+        msrv: [1.74.0]
     name: MSRV ${{ matrix.msrv }} check
     steps:
       - uses: actions/checkout@v3
@@ -71,7 +71,7 @@ jobs:
       - name: Install cargo-msrv
         run: |
           cargo install cargo-msrv
-          cargo msrv --min ${{ matrix.msrv }}
+          cargo msrv verify --min ${{ matrix.msrv }}
   build:
     name: "${{ matrix.os }}"
     runs-on: ${{ matrix.os }}
@@ -82,8 +82,8 @@ jobs:
     strategy:
       fail-fast: false
       matrix:
-        os: [ubuntu-20.04, macos-12, windows-2022]
-        msrv: [1.70]
+        os: [Ubuntu-22.04, MacOS-15, Windows-2022]
+        msrv: [1.74]
     steps:
       - uses: actions/checkout@v2
         with:
@@ -93,9 +93,9 @@ jobs:
           toolchain: ${{ matrix.msrv }}
           components: clippy
       - name: Install protoc
-        uses: arduino/setup-protoc@v1
+        uses: arduino/setup-protoc@v3
         with:
-          version: "3.x"
+          version: "29.x"
           repo-token: ${{ secrets.GITHUB_TOKEN }}
       - name: Build
         env:

.github/workflows/rust_coverage.yaml

@@ -33,9 +33,10 @@ jobs:
         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
+        uses: codecov/codecov-action@v4
         with:
           files: ./rust/codecov.json
           flags: rust
           verbose: true
+          token: ${{ secrets.CODECOV_ACTION_KEY }}
           fail_ci_if_error: true

protos

@@ -18,7 +18,7 @@
 name = "rocketmq"
 version = "5.0.0"
 edition = "2021"
-rust-version = "1.70"
+rust-version = "1.74"
 authors = [
     "SSpirits <admin@lv5.moe>",
     "Zhanhui Li <lizhanhui@gmail.com>",
@@ -69,8 +69,8 @@ ring = "0.16.20"
 tokio-util = { version = "=0.7.10", features = ["rt"] }
 
 [build-dependencies]
-tonic-build = "0.9.0"
-which = "4.4.0"
+tonic-build = "0.10.2"
+which = "7.0.3"
 version_check = "0.9.4"
 regex = "1.7.3"
 

rust/Cargo.toml

@@ -35,12 +35,13 @@ fn main() {
         .out_dir("src/pb")
         .compile(
             &[
-                "../protos/apache/rocketmq/v2/service.proto",
-                "../protos/apache/rocketmq/v2/admin.proto",
+                "./proto/apache/rocketmq/v2/service.proto",
+                "./proto/apache/rocketmq/v2/admin.proto",
+                "./proto/apache/rocketmq/v2/definition.proto",
             ],
-            &["../protos"],
+            &["./proto"],
         )
-        .unwrap_or_else(|e| panic!("Failed to compile protos {:?}", e));
+        .unwrap_or_else(|e| panic!("Failed to compile proto {e:?}"));
 }
 
 fn check_protoc_version() {
@@ -57,12 +58,12 @@ fn check_protoc_version() {
     let result = cmd.output();
 
     if result.is_err() {
-        panic!("failed to invoke protoc: {:?}", result)
+        panic!("failed to invoke protoc: {result:?}")
     }
 
     let output = result.unwrap();
     if !output.status.success() {
-        panic!("protoc failed: {:?}", output)
+        panic!("protoc failed: {output:?}")
     }
 
     let version_regex = Regex::new(r"(?:(\d+)\.)?(?:(\d+)\.)?(\*|\d+)").unwrap();

rust/build.rs

@@ -0,0 +1,43 @@
+// Licensed to the Apache Software Foundation (ASF) under one or more
+// contributor license agreements.  See the NOTICE file distributed with
+// this work for additional information regarding copyright ownership.
+// The ASF licenses this file to You under the Apache License, Version 2.0
+// (the "License"); you may not use this file except in compliance with
+// the License.  You may obtain a copy of the License at
+//
+//     http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+
+syntax = "proto3";
+
+package apache.rocketmq.v2;
+
+option cc_enable_arenas = true;
+option csharp_namespace = "Apache.Rocketmq.V2";
+option java_multiple_files = true;
+option java_package = "apache.rocketmq.v2";
+option java_generate_equals_and_hash = true;
+option java_string_check_utf8 = true;
+option java_outer_classname = "MQAdmin";
+
+message ChangeLogLevelRequest {
+  enum Level {
+    TRACE = 0;
+    DEBUG = 1;
+    INFO = 2;
+    WARN = 3;
+    ERROR = 4;
+  }
+  Level level = 1;
+}
+
+message ChangeLogLevelResponse { string remark = 1; }
+
+service Admin {
+  rpc ChangeLogLevel(ChangeLogLevelRequest) returns (ChangeLogLevelResponse) {}
+}