bitview 0.12.0

A composition-agnostic daemon runner for Bitview plugins
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
51
52
53
54
55
56
57
58
59
60

#![cfg(not(any(
    feature = "bedrock",
    feature = "blocks",
    feature = "coinflow",
    feature = "cointime",
    feature = "distribution",
    feature = "inputs",
    feature = "mappings",
    feature = "mining",
    feature = "outputs",
    feature = "pools",
    feature = "price",
    feature = "transactions",
)))]

use bitview::{ComputePluginSet, Config, ImportContext, PluginSet, UpdateContext, run};
use bitview_plugin::ComputePlugin;
use bitview_plugin_indexer::{HasIndexer, Indexer};
use bitview_traversable::Traversable;
use brk_error::Result;
use brk_reader::Reader;
use vecdb::{Exit, Rw, StorageMode};

#[derive(PluginSet, Traversable)]
struct Plugins<M: StorageMode = Rw> {
    indexer: Indexer<M>,
}

impl Plugins {
    fn import(context: ImportContext<'_>, reader: &Reader) -> Result<Self> {
        Ok(Self {
            indexer: Indexer::import(context, reader)?,
        })
    }
}

impl<M: StorageMode> HasIndexer<M> for Plugins<M> {
    fn indexer(&self) -> &Indexer<M> {
        &self.indexer
    }
}

impl ComputePluginSet for Plugins {
    fn compute(&mut self, context: UpdateContext<'_>) -> Result<()> {
        self.indexer.compute((), context)
    }

    fn commit(&mut self) -> Result<()> {
        self.indexer.commit()
    }
}

fn custom_runner(config: Config, exit: Exit) -> Result<()> {
    run(config, exit, Plugins::import)
}

#[test]
fn runner_accepts_a_composition_without_default_plugins() {
    let _: fn(Config, Exit) -> Result<()> = custom_runner;
}