1
1
use crate :: builder:: NodeBuilder ;
2
+ use crate :: io:: sqlite_store:: { self , SqliteStore } ;
2
3
use crate :: io:: test_utils:: TestSyncStore ;
3
4
use crate :: io:: utils:: check_namespace_key_validity;
4
5
use crate :: { Config , Node } ;
@@ -276,7 +277,7 @@ pub fn setup_bitcoind_and_electrsd() -> (BitcoinD, ElectrsD) {
276
277
277
278
pub ( crate ) fn setup_two_nodes (
278
279
electrsd : & ElectrsD , allow_0conf : bool ,
279
- ) -> ( Node < TestSyncStore > , Node < TestSyncStore > ) {
280
+ ) -> ( Node < SqliteStore > , Node < SqliteStore > ) {
280
281
println ! ( "== Node A ==" ) ;
281
282
let config_a = random_config ( ) ;
282
283
let node_a = setup_node ( electrsd, config_a) ;
@@ -290,12 +291,20 @@ pub(crate) fn setup_two_nodes(
290
291
( node_a, node_b)
291
292
}
292
293
293
- pub ( crate ) fn setup_node ( electrsd : & ElectrsD , config : Config ) -> Node < TestSyncStore > {
294
+ pub ( crate ) fn setup_node ( electrsd : & ElectrsD , config : Config ) -> Node < SqliteStore > {
294
295
let esplora_url = format ! ( "http://{}" , electrsd. esplora_url. as_ref( ) . unwrap( ) ) ;
295
296
let mut builder = NodeBuilder :: from_config ( config. clone ( ) ) ;
296
297
builder. set_esplora_server ( esplora_url. clone ( ) ) ;
297
- let test_sync_store = Arc :: new ( TestSyncStore :: new ( config. storage_dir_path . into ( ) ) ) ;
298
- let node = builder. build_with_store ( test_sync_store) . unwrap ( ) ;
298
+
299
+ let mut sql_dir = PathBuf :: from ( config. storage_dir_path ) ;
300
+ sql_dir. push ( "sqlite_store" ) ;
301
+ let sqlite_store = Arc :: new ( SqliteStore :: new (
302
+ sql_dir,
303
+ Some ( "test_sync_db" . to_string ( ) ) ,
304
+ Some ( "test_sync_table" . to_string ( ) ) ,
305
+ )
306
+ . unwrap ( ) ) ;
307
+ let node = builder. build_with_store ( sqlite_store) . unwrap ( ) ;
299
308
node. start ( ) . unwrap ( ) ;
300
309
node
301
310
}
0 commit comments