ps2.live/saerro
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

revert: add a long heartbeat for slower listeners

Browse source
This commit is contained in:
41666 2022-11-28 00:28:29 -05:00
parent acef78cbef
commit 9e1e2ad1f5
1 changed files with 18 additions and 12 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

30
services/websocket/src/main.rs
View file

@ -242,17 +242,23 @@ struct Payload {
payload: Event, payload: Event,
} }
/// Send a longer heartbeat in case this is PS4EU and gets like one event per hour // /// Send a longer heartbeat in case this is PS4EU and gets like one event per hour
async fn heartbeat() { // async fn heartbeat() {
let mut interval = tokio::time::interval(Duration::from_secs(150)); // let mut interval = tokio::time::interval(Duration::from_secs(150));
loop { // loop {
interval.tick().await; // interval.tick().await;
let mut con = REDIS_CLIENT.get_connection().unwrap(); // let mut con = REDIS_CLIENT.get_connection().unwrap();
let role: String = ROLE.parse().unwrap(); // let role: String = ROLE.parse().unwrap();
let heartbeat_key = format!("heartbeat:{}:{}", PAIR.to_string(), role); // let heartbeat_key = format!("heartbeat:{}:{}", PAIR.to_string(), role);
let _: () = con.set_ex(heartbeat_key, "1", 300).unwrap(); // let response: Option<String> = con.get(heartbeat_key.clone()).unwrap();
} // match response {
} // None => {
// let _: () = con.set_ex(heartbeat_key, "1", 300).unwrap();
// }
// _ => (),
// }
// }
// }
#[tokio::main] #[tokio::main]
async fn main() { async fn main() {
@ -305,7 +311,7 @@ async fn main() {
_ = fused_writer => {} _ = fused_writer => {}
} }
tokio::spawn(heartbeat()); // tokio::spawn(heartbeat());
init.await.unwrap(); init.await.unwrap();
} }