discours.io/quoter
5
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

logs

Browse Source
This commit is contained in:
Tony Rewin 2023-10-06 15:09:31 +03:00
parent d99b01c0ac
commit 28a5aa15a7
1 changed files with 5 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
src/main.rs
View File

@ -38,12 +38,16 @@ async fn sse_handler(
let mut pubsub = conn.into_pubsub(); let mut pubsub = conn.into_pubsub();
pubsub.subscribe("new_follower").await.unwrap(); pubsub.subscribe("new_follower").await.unwrap();
println!("'new_follower' subscribed");
pubsub.subscribe("new_shout").await.unwrap(); pubsub.subscribe("new_shout").await.unwrap();
println!("'new_shout' subscribed");
pubsub.subscribe("new_reaction").await.unwrap(); pubsub.subscribe("new_reaction").await.unwrap();
println!("'new_reaction' subscribed");
for chat_id in &chats { for chat_id in &chats {
let channel_name = format!("chat:{}", chat_id); let channel_name = format!("chat:{}", chat_id);
pubsub.subscribe(&channel_name).await.unwrap(); pubsub.subscribe(&channel_name).await.unwrap();
println!(format!("'{}' subscribed", channel_name));
} }
while let Some(msg) = pubsub.on_message().next().await { while let Some(msg) = pubsub.on_message().next().await {
@ -71,6 +75,7 @@ async fn main() -> std::io::Result<()> {
let redis_url = env::var("REDIS_URL").unwrap_or_else(|_| String::from("redis://127.0.0.1/")); let redis_url = env::var("REDIS_URL").unwrap_or_else(|_| String::from("redis://127.0.0.1/"));
let client = redis::Client::open(redis_url).unwrap(); let client = redis::Client::open(redis_url).unwrap();
println!("Connecting to Redis: {}", redis_url);
HttpServer::new(move || { HttpServer::new(move || {
App::new() App::new()
.app_data(web::Data::new(client.clone())) .app_data(web::Data::new(client.clone()))