sigil-node · dex_durable

pub struct DurableDexStore {

}

pub fn open(path: &Path) -> Result<Self, NodeError>;

pub fn get_pool(&self, pool_id: &str) -> Result<Option<DexPool>, NodeError>;

pub fn put_pool(&self, pool: &DexPool) -> Result<(), NodeError>;

pub fn list_pools(&self) -> Result<Vec<DexPool>, NodeError>;

pub fn get_position(
        &self,
        pool_id: &str,
        owner_did: &str,
    ) -> Result<Option<DexPosition>, NodeError>;

pub fn put_position(&self, position: &DexPosition) -> Result<(), NodeError>;

pub fn list_positions(
        &self,
        owner_did: Option<&str>,
        pool_id: Option<&str>,
    ) -> Result<Vec<DexPosition>, NodeError>;

pub fn get_asset_balance(&self, asset_id: &str, owner_did: &str) -> Result<u64, NodeError>;

pub fn put_asset_balance(
        &self,
        asset_id: &str,
        owner_did: &str,
        amount: u64,
    ) -> Result<(), NodeError>;

pub fn get_token_class(&self, token_id: &str) -> Result<Option<CustomTokenClass>, NodeError>;

pub fn put_token_class(&self, class: &CustomTokenClass) -> Result<(), NodeError>;

pub fn list_token_classes(&self) -> Result<Vec<CustomTokenClass>, NodeError>;

pub fn list_asset_balances(&self) -> Result<Vec<(String, String, u64)>, NodeError>;

pub fn list_events(
        &self,
        pool_id: Option<&str>,
        limit: usize,
    ) -> Result<Vec<DexEvent>, NodeError>;

pub fn commit_batch(&self, batch: &DexWriteBatch) -> Result<(), NodeError>;

pub type ArcDexStore = Arc<DurableDexStore>;

#[derive(Clone)]
pub enum DexBatchOp {
    PutTokenClass(CustomTokenClass),
    PutPool(DexPool),
    PutPosition(DexPosition),
    PutAssetBalance {
        asset_id: String,
        owner_did: String,
        amount: u64,
    },
    AppendEvent(DexEvent),
}

#[derive(Default)]
pub struct DexWriteBatch {

}

pub fn new() -> Self;

pub fn put_pool(&mut self, pool: DexPool);

pub fn put_token_class(&mut self, class: CustomTokenClass);

pub fn put_position(&mut self, position: DexPosition);

pub fn put_asset_balance(
        &mut self,
        asset_id: impl Into<String>,
        owner_did: impl Into<String>,
        amount: u64,
    );

pub fn append_event(&mut self, event: DexEvent);