rsa_msg_packets/file/chunk/
index.rs1use anyhow::anyhow;
2
3use openssl::pkey::{Public, Private};
4use openssl::rsa::Rsa;
5use uuid::Uuid;
6
7use crate::encryption::sign::validate_signature;
8use crate::other::key_iv::KeyIVPair;
9use crate::util::tools::{u64_from_vec, usize_to_vec};
10use crate::util::{tools::{vec_to_usize, uuid_from_vec}, vec::extract_vec};
11
12
13#[derive(Debug, Clone)]
14pub struct ChunkMsg {
15 pub signature: Vec<u8>,
16 pub encrypted: Vec<u8>,
17 pub key: KeyIVPair,
18 pub uuid: Uuid,
19 pub chunk_index: u64
20}
21
22
23impl ChunkMsg {
24 pub fn serialize(&self, receiver_key: &Rsa<Public>) -> anyhow::Result<Vec<u8>> {
25 let mut merged = Vec::new();
26 let mut b_encrypted = self.encrypted.clone();
27 let mut b_key = self.key.serialize(receiver_key)?;
28
29 let signature_size = usize_to_vec(self.signature.len())?;
30 let mut b_uuid = self.uuid.clone().as_bytes().to_vec();
31
32 let mut b_chunk_index = self.chunk_index.clone().to_le_bytes().to_vec();
33
34 merged.append(&mut signature_size.clone());
35 merged.append(&mut self.signature.clone());
36 merged.append(&mut b_uuid);
37 merged.append(&mut b_chunk_index);
38 merged.append(&mut b_key);
39 merged.append(&mut b_encrypted);
40
41 return Ok(merged);
42 }
43
44 pub fn deserialize(data: &Vec<u8>, sender_pubkey: &Rsa<Public>, receiver_key: &Rsa<Private>) -> anyhow::Result<Self> {
45 let mut data = data.clone();
46
47 let signature_size = vec_to_usize(&mut data)?;
48 let signature = extract_vec(0..signature_size, &mut data)?;
49
50 let uuid = uuid_from_vec(&mut data)?;
51 let chunk_index = u64_from_vec(&mut data)?;
52
53 let key = KeyIVPair::deserialize_mut(&mut data, receiver_key)?;
54
55 let valid = validate_signature(&data, &signature, sender_pubkey)?;
56 if !valid {
57 return Err(anyhow!("Invalid signature in ChunkByteMsg"));
58 }
59
60 return Ok(ChunkMsg {
61 signature,
62 encrypted: data,
63 uuid,
64 chunk_index,
65 key
66 });
67 }
68}