turbocafe 0.0.1

A content-addressable file store
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
52
53
54

// Turbocafe, the content-addressable file store

use multihash::{Code::Blake3_256, MultihashDigest};
use turbosql::{select, Blob, Turbosql};

#[derive(thiserror::Error, Debug)]
pub enum TurbocafeError {
 #[error("TurbosqlError")]
 TurbosqlError(#[from] turbosql::Error),
 #[error("Utf8Error")]
 Utf8Error(#[from] std::str::Utf8Error),
 #[error("Data not available for hash")]
 DataNotAvailable,
}

#[derive(Turbosql, Default)]
struct TurbocafeEntry {
 rowid: Option<i64>,
 hash: Option<String>,
 data: Option<Blob>,
}

fn hash_impl<T: AsRef<[u8]>>(content: T) -> Vec<u8> {
 Blake3_256.digest(content.as_ref()).to_bytes()
}

pub fn hash<T: AsRef<[u8]>>(content: T) -> String {
 bs58::encode(hash_impl(content)).into_string()
}

pub fn put<T: AsRef<[u8]>>(content: T) -> Result<String, TurbocafeError> {
 let hash = hash(&content);

 TurbocafeEntry {
  hash: Some(hash.clone()),
  data: Some(content.as_ref().to_owned()),
  ..Default::default()
 }
 .insert()?;

 Ok(hash)
}

pub fn get<T: AsRef<str>>(hash: T) -> Result<Vec<u8>, TurbocafeError> {
 Ok(
  select!(TurbocafeEntry "WHERE hash = ?", hash.as_ref())?
   .data
   .ok_or(TurbocafeError::DataNotAvailable)?,
 )
}

pub fn get_string<T: AsRef<str>>(hash: T) -> Result<String, TurbocafeError> {
 Ok(std::str::from_utf8(&get(hash)?)?.to_string())
}