anni-provider 0.1.3

Storage providers for Project Anni.
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

use crate::{Range, ResourceReader};
use anni_flac::blocks::BlockStreamInfo;
use anni_flac::prelude::{AsyncDecode, Encode, Result};
use std::io::Cursor;
use tokio::io::{AsyncRead, AsyncReadExt, AsyncWriteExt};

async fn read_header<R>(mut reader: R) -> Result<(BlockStreamInfo, ResourceReader)>
where
    R: AsyncRead + Unpin + Send + 'static,
{
    let first = reader.read_u32().await.unwrap();
    let second = reader.read_u32().await.unwrap();
    let info = BlockStreamInfo::from_async_reader(&mut reader).await?;

    let mut header = Cursor::new(Vec::with_capacity(4 + 4 + 34));
    header.write_u32(first).await.unwrap();
    header.write_u32(second).await.unwrap();
    info.write_to(&mut header).unwrap();
    header.set_position(0);

    Ok((info, Box::pin(header.chain(reader))))
}

pub(crate) async fn read_duration(
    reader: ResourceReader,
    range: Range,
) -> Result<(u64, ResourceReader)> {
    if !range.contains_flac_header() {
        return Ok((0, reader));
    }

    let (info, reader) = read_header(reader).await?;
    let duration = info.total_samples / info.sample_rate as u64;
    Ok((duration, Box::pin(reader)))
}