Added .rl, fixed some messages, removed liveness probe.

src/bot/handlers/fun/blyaficator.rs

@@ -2,7 +2,7 @@ use crate::{
     bot::handlers::Handler,
     utils::{inter_join::RandomIntersperse, messages::get_message},
 };
-use grammers_client::{Client, Update};
+use grammers_client::{Client, InputMessage, Update};
 
 const BLYA_WORDS: &[&str] = &[", бля,", ", сука,", ", ёбаный рот,", ", охуеть конечно,"];
 
@@ -32,7 +32,9 @@ impl Handler for Blyaficator {
 
             // If the text was blyaficated we send it as a reply.
             if let Some(blyficated) = maybe_blyaficated {
-                message.reply(blyficated).await?;
+                message
+                    .reply(InputMessage::from(blyficated).silent(true))
+                    .await?;
             }
         }
         Ok(())

src/bot/handlers/fun/mod.rs

@@ -1,2 +1,3 @@
 pub mod blyaficator;
 pub mod greeter;
+pub mod rotator;

src/bot/handlers/fun/rotator.rs

@@ -0,0 +1,49 @@
+use std::time::Duration;
+
+use grammers_client::{types::Message, Client, InputMessage, Update};
+
+use crate::{bot::handlers::Handler, utils::messages::get_message};
+
+#[derive(Clone)]
+pub struct Rotator;
+
+async fn rotator(replied_message: Message, text: String) {
+    let mut skip = 1;
+    let start = std::time::SystemTime::now();
+    let mut current = std::time::SystemTime::now();
+    while current
+        .duration_since(start)
+        .map(|dur| dur.as_secs())
+        .unwrap_or(100)
+        < 10
+    {
+        let rotated = text
+            .chars()
+            .cycle()
+            .skip(skip)
+            .take(text.len())
+            .collect::<String>();
+        skip += 1;
+        if skip == rotated.len() {
+            skip = 0;
+        }
+        replied_message.edit(rotated).await.ok();
+        current = std::time::SystemTime::now();
+        tokio::time::sleep(Duration::from_millis(200)).await;
+    }
+    replied_message.delete().await.ok();
+}
+
+#[async_trait::async_trait]
+impl Handler for Rotator {
+    async fn react(&self, _: &Client, update: &Update) -> anyhow::Result<()> {
+        let Some(message) = get_message(update) else{
+            return Ok(());
+        };
+        if let Some(text) = message.text().strip_prefix(".rl").map(str::trim) {
+            let replied_message = message.reply(InputMessage::from(text).silent(true)).await?;
+            tokio::spawn(rotator(replied_message, text.to_string()));
+        }
+        Ok(())
+    }
+}