feat: add InterestedAllPiecesRequest message

Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "dragonfly-api"
-version = "2.0.32"
+version = "2.0.33"
 authors = ["Gaius <[email protected]>"]
 edition = "2021"
 license = "Apache-2.0"

pkg/apis/dfdaemon/v2/dfdaemon.proto

@@ -47,6 +47,12 @@ message SyncPiecesRequest{
   }
 }
 
+// InterestedPiecesResponse represents all pieces response of SyncPiecesResponse.
+message InterestedAllPiecesResponse {
+  // All of the pieces in task.
+  repeated common.v2.Piece pieces = 1 [(validate.rules).repeated = {min_items: 1, ignore_empty: true}];
+}
+
 // InterestedPiecesResponse represents interested pieces response of SyncPiecesResponse.
 message InterestedPiecesResponse {
   // Interested pieces of task.
@@ -58,7 +64,8 @@ message SyncPiecesResponse {
   oneof response {
     option (validate.required) = true;
 
-    InterestedPiecesResponse interested_pieces_response = 1;
+    InterestedAllPiecesResponse interested_all_pieces_response = 1;
+    InterestedPiecesResponse interested_pieces_response = 2;
   }
 }
 

proto/dfdaemon.proto

@@ -42,6 +42,12 @@ message SyncPiecesRequest{
   }
 }
 
+// InterestedPiecesResponse represents all pieces response of SyncPiecesResponse.
+message InterestedAllPiecesResponse {
+  // All of the pieces in task.
+  repeated common.v2.Piece pieces = 1;
+}
+
 // InterestedPiecesResponse represents interested pieces response of SyncPiecesResponse.
 message InterestedPiecesResponse {
   // Interested pieces of task.
@@ -51,7 +57,8 @@ message InterestedPiecesResponse {
 // SyncPiecesResponse represents response of SyncPieces.
 message SyncPiecesResponse {
   oneof response {
-    InterestedPiecesResponse interested_pieces_response = 1;
+    InterestedAllPiecesResponse interested_all_pieces_response = 1;
+    InterestedPiecesResponse interested_pieces_response = 2;
   }
 }
 

src/dfdaemon.v2.rs

@@ -35,6 +35,15 @@ pub mod sync_pieces_request {
         InterestedPiecesRequest(super::InterestedPiecesRequest),
     }
 }
+/// InterestedPiecesResponse represents all pieces response of SyncPiecesResponse.
+#[derive(serde::Serialize, serde::Deserialize)]
+#[allow(clippy::derive_partial_eq_without_eq)]
+#[derive(Clone, PartialEq, ::prost::Message)]
+pub struct InterestedAllPiecesResponse {
+    /// All of the pieces in task.
+    #[prost(message, repeated, tag = "1")]
+    pub pieces: ::prost::alloc::vec::Vec<super::super::common::v2::Piece>,
+}
 /// InterestedPiecesResponse represents interested pieces response of SyncPiecesResponse.
 #[derive(serde::Serialize, serde::Deserialize)]
 #[allow(clippy::derive_partial_eq_without_eq)]
@@ -49,7 +58,7 @@ pub struct InterestedPiecesResponse {
 #[allow(clippy::derive_partial_eq_without_eq)]
 #[derive(Clone, PartialEq, ::prost::Message)]
 pub struct SyncPiecesResponse {
-    #[prost(oneof = "sync_pieces_response::Response", tags = "1")]
+    #[prost(oneof = "sync_pieces_response::Response", tags = "1, 2")]
     pub response: ::core::option::Option<sync_pieces_response::Response>,
 }
 /// Nested message and enum types in `SyncPiecesResponse`.
@@ -59,6 +68,8 @@ pub mod sync_pieces_response {
     #[derive(Clone, PartialEq, ::prost::Oneof)]
     pub enum Response {
         #[prost(message, tag = "1")]
+        InterestedAllPiecesResponse(super::InterestedAllPiecesResponse),
+        #[prost(message, tag = "2")]
         InterestedPiecesResponse(super::InterestedPiecesResponse),
     }
 }