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
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81

#![allow(dead_code)]

use std::{collections::{BTreeMap, BTreeSet}, sync::Arc};
use serde::{Serialize,Deserialize};


#[derive(Debug,Clone,Eq,PartialEq,Ord,PartialOrd,Hash,Default,Serialize,Deserialize)]
pub struct Brevet;

#[derive(Debug,Clone,Eq,PartialEq,Ord,PartialOrd,Hash,Serialize,Deserialize)]
pub struct BrevetResult(Result<brevet::Expr, brevet::Error>);

impl Default for BrevetResult {
    fn default() -> Self {
        Self(Ok(brevet::Expr::default()))
    }
}

impl clepsydra::Lang for Brevet {
    type Key = String;
    type Val = BrevetResult;
    type Stmt = brevet::Expr;
    type Expr = brevet::Expr;
    fn get_write_set(_s: &Self::Stmt) -> BTreeMap<Self::Key, Self::Expr> {
        BTreeMap::new()
    }
    fn get_read_set(_e: &Self::Expr) -> BTreeSet<Self::Key> {
        BTreeSet::new()
    }
    fn get_eval_set(_s: &Self::Stmt) -> BTreeSet<Self::Key> {
        BTreeSet::new()
    }

    fn eval_expr(
        e: &Self::Expr,
        _vals: &[Self::Val],
        env: &BTreeMap<Self::Key, clepsydra::ExtVal<Self>>,
    ) -> clepsydra::ExtVal<Self> {
        let mut benv = brevet::Expr::Top;
        for (_k, v) in env.iter() {
            if let clepsydra::ExtVal::Defined(BrevetResult(v)) = v {
                match v {
                    Ok(vgood) => benv = brevet::Expr::Merge(Arc::new(benv.clone()), Arc::new(vgood.clone())),
                    Err(bad) => return clepsydra::ExtVal::Defined(BrevetResult(Err(bad.clone())))
                }
            }
        }
        let mut ev = e.clone();
        while !ev.is_val() {
            match brevet::step(&benv, &ev) {
                Ok(good) => ev = good,
                Err(err) => return clepsydra::ExtVal::Defined(BrevetResult(Err(err)))
            }
        }
        clepsydra::ExtVal::Defined(BrevetResult(Ok(ev)))
    }
}

pub struct TieredStore {
    hot: redb::Database,
    // TODO: newel
    cold: BTreeMap<String, std::fs::File>,
}

impl clepsydra::Store<Brevet> for TieredStore {
    fn get_key_at_or_before_time(&self, _kv: &clepsydra::KeyVer<Brevet>) -> Option<(clepsydra::GlobalTime, clepsydra::Entry<Brevet>)> {
        todo!()
    }

    fn put_key_at_time(&mut self, _kv: &clepsydra::KeyVer<Brevet>, _v: &clepsydra::Entry<Brevet>) {
        todo!()
    }

    fn get_delayed_watermark(&self) -> Option<clepsydra::Sdw> {
        todo!()
    }
}

pub struct System {
    db: clepsydra::Database<Brevet, TieredStore>
}