chunk-streamer 0.5.0

Chunk Streamer library streams Autonomi data as a futures::stream
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

use std::time::Instant;
use autonomi::Chunk;
use autonomi::chunk::DataMapChunk;
use autonomi::client::PutError;
use autonomi::self_encryption::encrypt;
use bytes::Bytes;
use log::debug;

pub struct ChunkEncrypter {
}

impl ChunkEncrypter {
    pub fn new() -> Self {
        Self {}
    }

    pub async fn encrypt(
        &self,
        is_public: bool,
        bytes: Bytes
    ) -> Result<(Vec<Chunk>, DataMapChunk), PutError> {
        let start = Instant::now();
        let (data_map_chunk, mut chunks) = encrypt(bytes)?;

        if is_public {
            chunks.push(data_map_chunk.clone());
        }

        debug!("Encryption took: {:.2?}", start.elapsed());
        Ok((chunks, DataMapChunk(data_map_chunk)))
    }
}