kylefang/bitcoin-indexer
1
0
Fork 0
mirror of https://github.com/alexgo-io/bitcoin-indexer.git synced 2026-01-12 22:43:06 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix: better redis error handling

Browse Source
This commit is contained in:
Ludo Galabru
2023-05-19 08:59:43 -04:00
parent 7dd362b4f5
commit debb06cd5c
1 changed files with 5 additions and 14 deletions
Download Patch File Download Diff File Expand all files Collapse all files

19
components/chainhook-cli/src/service/mod.rs
View File

@@ -363,20 +363,11 @@ fn load_predicates_from_redis(
ctx: &Context,
) -> Result<Vec<ChainhookSpecification>, String> {
let redis_config = config.expected_redis_config();
let client = redis::Client::open(redis_config.uri.clone()).unwrap();
let mut redis_con = match client.get_connection() {
Ok(con) => con,
Err(message) => {
error!(
ctx.expect_logger(),
"Unable to connect to redis server: {}",
message.to_string()
);
std::thread::sleep(std::time::Duration::from_secs(1));
std::process::exit(1);
}
};
let client = redis::Client::open(redis_config.uri.clone())
.map_err(|e| format!("unable to connect to redis: {}", e.to_string()))?;
let mut redis_con = client
.get_connection()
.map_err(|e| format!("unable to connect to redis: {}", e.to_string()))?;
let chainhooks_to_load: Vec<String> = redis_con
.scan_match("chainhook:*:*:*")
.map_err(|e| format!("unable to connect to redis: {}", e.to_string()))?