msg_store_database_plugin 0.1.0

A toolkit for making database plugins for the msg-store
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
41
42
43
44
45
46
47
48
49
50

use bytes::Bytes;
use msg_store_uuid::Uuid;
use std::fmt::Display;
use std::sync::Arc;

#[derive(Debug)]
pub enum DatabaseErrorTy {
    CouldNotOpenDatabase,
    CouldNotAddMsg,
    CouldNotGetMsg,
    CouldNotDeleteMsg,
    CouldNotFetchData,
    MsgNotFound
}
impl Display for DatabaseErrorTy {
    fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
        match self {
            Self::CouldNotOpenDatabase |
            Self::CouldNotAddMsg |
            Self::CouldNotGetMsg |
            Self::CouldNotDeleteMsg |
            Self::CouldNotFetchData |
            Self::MsgNotFound => write!(f, "{}", self)
        }
    }
}

#[derive(Debug)]
pub struct DatabaseError {
    pub err_ty: DatabaseErrorTy,
    pub file: &'static str,
    pub line: u32,
    pub msg: Option<String>
}
impl Display for DatabaseError {
    fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
        if let Some(msg) = &self.msg {
            write!(f, "DATABASE_ERROR: {}. file: {}, line: {}, msg: {}", self.err_ty, self.file, self.line, msg)
        } else {
            write!(f, "DATABASE_ERROR: {}. file: {}, line: {}.", self.err_ty, self.file, self.line)
        }
    }   
}

pub trait Db: Send + Sync {
    fn get(&mut self, uuid: Arc<Uuid>) -> Result<Bytes, DatabaseError>;
    fn add(&mut self, uuid: Arc<Uuid>, msg: Bytes, msg_byte_size: u64) -> Result<(), DatabaseError>;
    fn del(&mut self, uuid: Arc<Uuid>) -> Result<(), DatabaseError>;
    fn fetch(&mut self) -> Result<Vec<(Arc<Uuid>, u64)>, DatabaseError>;
}