Skip to content
Snippets Groups Projects
Commit 5c722eca authored by Éloïs's avatar Éloïs
Browse files

[ref] rename crate duniter-gva-db-writer -> duniter-gva-indexer

parent 6c6d1528
No related branches found
No related tags found
No related merge requests found
......@@ -1081,7 +1081,7 @@ dependencies = [
"dubp",
"duniter-dbs",
"duniter-dbs-write-ops",
"duniter-gva-db-writer",
"duniter-gva-indexer",
"fast-threadpool",
"flume",
"once_cell",
......@@ -1157,9 +1157,9 @@ dependencies = [
"duniter-conf",
"duniter-dbs",
"duniter-dbs-read-ops",
"duniter-gva-db-writer",
"duniter-gva-dbs-reader",
"duniter-gva-gql",
"duniter-gva-indexer",
"duniter-mempools",
"duniter-module",
"fast-threadpool",
......@@ -1177,19 +1177,6 @@ dependencies = [
"warp",
]
[[package]]
name = "duniter-gva-db-writer"
version = "0.1.0"
dependencies = [
"anyhow",
"dubp",
"duniter-dbs",
"maplit",
"once_cell",
"resiter",
"smallvec",
]
[[package]]
name = "duniter-gva-dbs-reader"
version = "0.1.0"
......@@ -1230,6 +1217,19 @@ dependencies = [
"unwrap",
]
[[package]]
name = "duniter-gva-indexer"
version = "0.1.0"
dependencies = [
"anyhow",
"dubp",
"duniter-dbs",
"maplit",
"once_cell",
"resiter",
"smallvec",
]
[[package]]
name = "duniter-integration-tests"
version = "0.1.0"
......
......@@ -43,8 +43,8 @@ members = [
"rust-libs/duniter-server",
"rust-libs/modules/gva",
"rust-libs/modules/gva/dbs-reader",
"rust-libs/modules/gva/db-writer",
"rust-libs/modules/gva/gql",
"rust-libs/modules/gva/indexer",
"rust-libs/tests/duniter-integration-tests",
"rust-libs/tools/kv_typed"
]
......
......@@ -25,7 +25,7 @@ dirs = "3.0.1"
dubp = { version = "0.34.0" }
duniter-dbs = { path = "../../rust-libs/duniter-dbs", default-features = false, features = ["explorer", "leveldb_backend", "sled_backend"] }
duniter-dbs-write-ops = { path = "../../rust-libs/duniter-dbs-write-ops", default-features = false, features = ["explorer", "leveldb_backend", "sled_backend"] }
duniter-gva-db-writer = { path = "../../rust-libs/modules/gva/db-writer" }
duniter-gva-indexer = { path = "../../rust-libs/modules/gva/indexer" }
fast-threadpool = "0.2.3"
flume = "0.10.0"
once_cell = "1.5.2"
......
......@@ -27,7 +27,7 @@ const CHUNK_SIZE: usize = 250;
pub(crate) fn migrate(profile_path: PathBuf) -> anyhow::Result<()> {
let start_time = Instant::now();
let (bc_db, shared_dbs) = duniter_dbs::open_dbs(Some(profile_path.as_path()))?;
let gva_db = duniter_gva_db_writer::get_gva_db_rw(Some(profile_path.as_path()));
let gva_db = duniter_gva_indexer::get_gva_db_rw(Some(profile_path.as_path()));
// Clear bc_db and gva_db
bc_db.clear()?;
......@@ -113,7 +113,7 @@ fn migrate_inner(
let gva_handle = dbs_pool
.launch(move |_| {
for block in chunk_arc_clone.deref() {
duniter_gva_db_writer::apply_block(block, gva_db)?;
duniter_gva_indexer::apply_block(block, gva_db)?;
}
Ok::<_, KvError>(())
})
......
......@@ -16,7 +16,7 @@ duniter-conf = { path = "../../duniter-conf" }
duniter-dbs = { path = "../../duniter-dbs" }
duniter-dbs-read-ops = { path = "../../duniter-dbs-read-ops" }
duniter-gva-dbs-reader = { path = "./dbs-reader" }
duniter-gva-db-writer = { path = "./db-writer" }
duniter-gva-indexer = { path = "./indexer" }
duniter-gva-gql = { path = "./gql" }
duniter-mempools = { path = "../../duniter-mempools" }
duniter-module = { path = "../../duniter-module" }
......
[package]
name = "duniter-gva-db-writer"
name = "duniter-gva-indexer"
version = "0.1.0"
authors = ["elois <elois@duniter.org>"]
description = "Duniter GVA DB writer"
......
......@@ -38,8 +38,8 @@ use duniter_dbs::databases::{
};
use duniter_dbs::prelude::*;
use duniter_dbs::{kv_typed::prelude::*, FileBackend, TxDbV2};
use duniter_gva_db_writer::{get_gva_db_ro, get_gva_db_rw};
use duniter_gva_gql::GvaSchema;
use duniter_gva_indexer::{get_gva_db_ro, get_gva_db_rw};
use duniter_mempools::Mempools;
use futures::{StreamExt, TryStreamExt};
use std::{convert::Infallible, path::Path};
......@@ -66,7 +66,7 @@ impl duniter_module::DuniterModule for GvaModule {
profile_path_opt: Option<&Path>,
) -> KvResult<()> {
let gva_db = get_gva_db_rw(profile_path_opt);
duniter_gva_db_writer::apply_block(&block, gva_db)
duniter_gva_indexer::apply_block(&block, gva_db)
}
fn revert_block(
block: &DubpBlockV10,
......@@ -74,7 +74,7 @@ impl duniter_module::DuniterModule for GvaModule {
profile_path_opt: Option<&Path>,
) -> KvResult<()> {
let gva_db = get_gva_db_rw(profile_path_opt);
duniter_gva_db_writer::revert_block(&block, gva_db)
duniter_gva_indexer::revert_block(&block, gva_db)
}
fn init(
conf: &duniter_conf::DuniterConf,
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment