btdt-server 0.4.4

Server component for "been there, done that" - a tool for flexible CI caching
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

use btdt::cache::CacheHit;
use btdt_server_lib::asyncio::StreamAdapter;
use poem::Body;
use poem_openapi::ApiResponse;
use poem_openapi::payload::Binary;
use std::io::Read;

#[derive(ApiResponse)]
#[allow(clippy::enum_variant_names)]
pub enum GetFromCacheResponse {
    /// No matching key was found in the cache.
    #[oai(status = 204)]
    CacheMiss,
    /// The cache with the given ID does not exist.
    #[oai(status = 404)]
    CacheNotFound,
    /// The data was found in the cache and is returned as a binary response.
    #[oai(status = 200)]
    CacheHit(
        Binary<Body>,
        /// The cache key that was used to retrieve the data.
        #[oai(header = "Btdt-Cache-Key")]
        String,
    ),
}

impl<'a, R> From<CacheHit<'a, R>> for GetFromCacheResponse
where
    R: Read + Send + 'static,
{
    fn from(hit: CacheHit<R>) -> Self {
        GetFromCacheResponse::CacheHit(
            Binary(Body::from_bytes_stream(StreamAdapter::new(
                Box::new(hit.reader),
                hit.size_hint,
            ))),
            hit.key.to_string(),
        )
    }
}