feat(p2p-04): add client p2p module shell

Author: 80347547

curvine-client/src/lib.rs

@@ -17,6 +17,7 @@ use orpc::sys::DataSlice;
 
 pub mod block;
 pub mod file;
+pub mod p2p;
 pub mod rpc;
 pub mod unified;
 

curvine-client/src/p2p/discovery.rs

@@ -0,0 +1,26 @@
+// Copyright 2025 OPPO.
+//
+// Licensed 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.
+
+#[derive(Debug, Clone, PartialEq, Eq)]
+pub struct DiscoveryPeerSnapshot {
+    pub peer_id: String,
+    pub addrs: Vec<String>,
+}
+
+#[derive(Debug, Clone, Default, PartialEq, Eq)]
+pub struct DiscoverySnapshot {
+    pub mdns_peers: Vec<DiscoveryPeerSnapshot>,
+    pub dht_peers: Vec<DiscoveryPeerSnapshot>,
+    pub bootstrap_peers: Vec<DiscoveryPeerSnapshot>,
+}

curvine-client/src/p2p/mod.rs

@@ -0,0 +1,19 @@
+// Copyright 2025 OPPO.
+//
+// Licensed 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.
+
+mod discovery;
+pub use self::discovery::{DiscoveryPeerSnapshot, DiscoverySnapshot};
+
+mod transfer;
+pub use self::transfer::{ChunkId, TransferRequest, TransferResponse};

curvine-client/src/p2p/transfer.rs

@@ -0,0 +1,50 @@
+// Copyright 2025 OPPO.
+//
+// Licensed 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.
+
+use bytes::Bytes;
+
+#[derive(Debug, Clone, Copy, PartialEq, Eq, Hash)]
+pub struct ChunkId {
+    pub file_id: i64,
+    pub version_epoch: i64,
+    pub block_id: i64,
+    pub off: i64,
+}
+
+impl ChunkId {
+    pub fn new(block_id: i64, off: i64) -> Self {
+        Self::with_version(0, 0, block_id, off)
+    }
+
+    pub fn with_version(file_id: i64, version_epoch: i64, block_id: i64, off: i64) -> Self {
+        Self {
+            file_id,
+            version_epoch,
+            block_id,
+            off,
+        }
+    }
+}
+
+#[derive(Debug, Clone, PartialEq, Eq)]
+pub struct TransferRequest {
+    pub chunk_id: ChunkId,
+    pub len: usize,
+}
+
+#[derive(Debug, Clone, PartialEq, Eq)]
+pub struct TransferResponse {
+    pub chunk_id: ChunkId,
+    pub data: Bytes,
+}