cloud-sdk-reqwest 0.15.0

Optional provider-neutral reqwest transport boundary for cloud-sdk.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51

use bytes::Bytes;
use cloud_sdk_sanitization::sanitize_bytes;
use std::vec::Vec;

pub(super) struct SanitizedBuffer {
    bytes: Vec<u8>,
}

impl SanitizedBuffer {
    pub(super) fn copy_from(source: &[u8]) -> Result<Self, ()> {
        let mut bytes = Vec::new();
        bytes.try_reserve_exact(source.len()).map_err(|_| ())?;
        bytes.extend_from_slice(source);
        Ok(Self { bytes })
    }

    pub(super) fn with_capacity(capacity: usize) -> Result<Self, ()> {
        let mut bytes = Vec::new();
        bytes.try_reserve_exact(capacity).map_err(|_| ())?;
        Ok(Self { bytes })
    }

    pub(super) fn extend_bounded(&mut self, source: &[u8], limit: usize) -> Result<(), ()> {
        let new_len = self.bytes.len().checked_add(source.len()).ok_or(())?;
        if new_len > limit || new_len > self.bytes.capacity() {
            return Err(());
        }
        self.bytes.extend_from_slice(source);
        Ok(())
    }

    pub(super) fn len(&self) -> usize {
        self.bytes.len()
    }

    pub(super) fn into_bytes(self) -> Bytes {
        Bytes::from_owner(self)
    }
}

impl AsRef<[u8]> for SanitizedBuffer {
    fn as_ref(&self) -> &[u8] {
        &self.bytes
    }
}

impl Drop for SanitizedBuffer {
    fn drop(&mut self) {
        sanitize_bytes(&mut self.bytes);
    }
}