fault-tolerance
This commit is contained in:
parent
caa659b2c7
commit
c24fee0011
14
src/data.rs
14
src/data.rs
|
@ -29,7 +29,7 @@ async fn get_shout_followers(shout_id: &str) -> Result<Vec<i32>, Box<dyn Error>>
|
||||||
let api_base = env::var("API_BASE")?;
|
let api_base = env::var("API_BASE")?;
|
||||||
let gql = format!(r#"
|
let gql = format!(r#"
|
||||||
query {{
|
query {{
|
||||||
shoutFollowers(shout: "{}") {{
|
shoutFollowers(shout: {}) {{
|
||||||
follower {{
|
follower {{
|
||||||
id
|
id
|
||||||
}}
|
}}
|
||||||
|
@ -84,9 +84,17 @@ pub async fn is_fitting(listener_id: i32, payload: HashMap<String, String>) -> R
|
||||||
let members = serde_json::from_str::<Vec<String>>(members_str).unwrap();
|
let members = serde_json::from_str::<Vec<String>>(members_str).unwrap();
|
||||||
Ok(members.contains(&listener_id.to_string()))
|
Ok(members.contains(&listener_id.to_string()))
|
||||||
},
|
},
|
||||||
_ => Err("Invalid kind"),
|
_ => {
|
||||||
|
eprintln!("unknown payload kind");
|
||||||
|
eprintln!("{:?}", payload);
|
||||||
|
Ok(false)
|
||||||
|
},
|
||||||
}
|
}
|
||||||
},
|
},
|
||||||
None => Err("No kind provided"),
|
None => {
|
||||||
|
eprintln!("payload has no kind");
|
||||||
|
eprintln!("{:?}", payload);
|
||||||
|
Ok(false)
|
||||||
|
},
|
||||||
}
|
}
|
||||||
}
|
}
|
Loading…
Reference in New Issue
Block a user