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
use super::*; use lazy_static::lazy_static; use sha3::{ digest::{ExtendableOutputDirty, Reset, Update}, Shake256, }; use std::io::Read; use std::sync::{Arc, Mutex}; #[derive(Queryable, Insertable, Serialize, Deserialize, Clone, Debug, Default, PartialEq)] #[table_name = "blobs"] pub struct Blob { pub hash: i64, pub blob: Vec<u8>, } impl Blob { pub fn new(blob: Vec<u8>) -> Self { Self { hash: Self::get_hash(&blob), blob, } } fn get_hash(data: &[u8]) -> i64 { lazy_static! { static ref HASHER: Arc<Mutex<Shake256>> = Arc::new(Mutex::new(Shake256::default())); } i64::from_ne_bytes( { let mut hasher = HASHER.lock().unwrap(); hasher.update(data); let mut ret = hasher.clone(); hasher.reset(); let mut buf = vec![0u8; 8]; if ret.finalize_xof_dirty().read(&mut buf).is_err() { buf = vec![0u8, 8]; } buf } .as_slice() .try_into() .expect("slice with incorrect length"), ) } }