From 575003107fec4317847e768cdcd6e1d1650b8ae0 Mon Sep 17 00:00:00 2001 From: Brandon Thomas Date: Tue, 9 Mar 2021 01:25:26 -0500 Subject: [PATCH] redis publishing from last night --- src/main_chat_gateway.rs | 2 ++ src/twitch_client.rs | 4 ++-- 2 files changed, 4 insertions(+), 2 deletions(-) diff --git a/src/main_chat_gateway.rs b/src/main_chat_gateway.rs index 99ac10c7bc..a55e5ca785 100644 --- a/src/main_chat_gateway.rs +++ b/src/main_chat_gateway.rs @@ -32,6 +32,8 @@ async fn main() -> anyhow::Result<()> { let secrets = Secrets::from_file("secrets.toml")?; let mut redis_client = RedisClient::new(&secrets.redis); + redis_client.connect().await?; + let mut twitch_client = TwitchClient::new(&secrets.twitch, redis_client); loop { diff --git a/src/twitch_client.rs b/src/twitch_client.rs index f2e2e253cc..8941ff00d1 100644 --- a/src/twitch_client.rs +++ b/src/twitch_client.rs @@ -93,8 +93,8 @@ impl TwitchClient { let channel = command.to_lowercase(); let username = msg.name().trim(); let command_payload= format!("{}|{}", username, remaining_message); // Payload: USERNAME|DATA - println!("Publish: {} - {}", channel, command_payload); - let _r = self.redis_client.publish(&channel, &command_payload).await; + println!("Publish: '{}' - '{}'", channel, command_payload); + let _r = self.redis_client.publish(&channel, &command_payload).await.expect("Should work"); } },