offtopic implemented

delta/mod.ts

@@ -1,11 +1,9 @@
-import which from "./which.ts";
 import { Bot } from "../deps.ts";
 import trigger from "./trigger.ts";
 import useful from "./useful.ts";
 
 export default async (bot: Bot) => {
   await bot
-    .use(which)
     .use(useful)
     .use(trigger)
 };

src/functions/groups.rs

@@ -11,7 +11,6 @@ use teloxide::{
 static TEXT: &str = "<b>Telegramdagi Rust Hamjamiyatlari yoki Guruhlari:</b>\nAgar o'zingizni guruhingizni qo'shmoqchi bo'lsangiz, bizni <a href='https://github.com/rust-lang-uz/rustina/blob/main/communities.json'>community.json</a> ni yangilang!";
 
 pub async fn command(bot: &Bot, msg: &Message, groups: &Groups) -> ResponseResult<()> {
-
     bot.send_message(msg.chat.id, TEXT)
         .parse_mode(ParseMode::Html)
         .reply_markup(keyboard_list(&groups, 1))
@@ -20,7 +19,12 @@ pub async fn command(bot: &Bot, msg: &Message, groups: &Groups) -> ResponseResul
     Ok(())
 }
 
-pub async fn callback_list(bot: &Bot, q: &CallbackQuery, args: &Vec<&str>, groups: &Groups) -> ResponseResult<()> {
+pub async fn callback_list(
+    bot: &Bot,
+    q: &CallbackQuery,
+    args: &Vec<&str>,
+    groups: &Groups,
+) -> ResponseResult<()> {
     if !args.is_empty() {
         if let Some(Message { id, chat, .. }) = q.message.clone() {
             bot.edit_message_text(chat.id, id, TEXT)

src/functions/mod.rs

@@ -3,21 +3,23 @@ pub mod groups;
 pub mod help;
 pub mod inline;
 pub mod latest;
+pub mod offtop;
 pub mod rules;
 pub mod start;
 pub mod version;
 
 pub use inline::inline;
 
 use crate::utils::github::GitHub;
-use crate::Command;
 use crate::utils::group_manager::Groups;
+use crate::Command;
 use std::error::Error;
 use teloxide::prelude::*;
+use teloxide::types::*;
 
 pub async fn commands(
     bot: Bot,
-    _me: teloxide::types::Me,
+    me: Me,
     msg: Message,
     cmd: Command,
     github: GitHub,
@@ -31,6 +33,7 @@ pub async fn commands(
         Command::Groups => crate::functions::groups::command(&bot, &msg, &groups).await,
         Command::Latest => crate::functions::latest::command(&bot, github, &msg).await,
         Command::Version => crate::functions::version::command(&bot, github, &msg).await,
+        Command::Off => crate::functions::offtop::command(&bot, &msg, &me).await,
     };
 
     Ok(())
@@ -55,25 +58,24 @@ pub async fn callback(
             "group" => crate::functions::groups::callback_list(&bot, &q, &args, &groups).await,
             "detail" => crate::functions::groups::callback_detail(&bot, &q, &args).await,
             "version" => crate::functions::version::callback_list(&bot, &q, &args, github).await,
-            "changelog" => crate::functions::version::callback_detail(&bot, &q, &args, github).await,
+            "changelog" => {
+                crate::functions::version::callback_detail(&bot, &q, &args, github).await
+            }
             _ => Ok(()),
         };
     }
 
     Ok(())
 }
 
-pub async fn triggers(
-    bot: Bot,
-    msg: Message,
-) -> Result<(), Box<dyn Error + Send + Sync>> {
+pub async fn triggers(bot: Bot, msg: Message) -> Result<(), Box<dyn Error + Send + Sync>> {
     if let Some(user) = msg.from() {
         if let Some(username) = user.username.clone() {
             if username == "Channel_Bot" {
                 // try to delete message and ignore error
                 match bot.delete_message(msg.chat.id, msg.id).await {
-                    Ok(_) => {},
-                    Err(_) => {},
+                    Ok(_) => {}
+                    Err(_) => {}
                 }
             }
         }

src/functions/offtop.rs

@@ -0,0 +1,47 @@
+use teloxide::{prelude::*, types::*};
+
+static TEXT_FAIL: &str = "Ha-ha... yaxshi urinish!";
+static TEXT_NON_REPLY: &str = "↪ Reply bilan ko'rsatingchi habarni!";
+
+pub async fn command(bot: &Bot, msg: &Message, me: &Me) -> ResponseResult<()> {
+    if msg.reply_to_message().is_none() {
+        return {
+            bot.send_message(msg.chat.id, TEXT_NON_REPLY).await?;
+            Ok(())
+        };
+    }
+
+    // if replied person is bot itself, send fail message
+    if let Some(user) = msg.reply_to_message().as_ref().unwrap().from() {
+        if user.username.clone().unwrap() == me.username() {
+            return {
+                bot.send_message(msg.chat.id, TEXT_FAIL).await?;
+                Ok(())
+            };
+        }
+    }
+
+    bot.delete_message(msg.chat.id, msg.id).await?;
+    bot.delete_message(msg.chat.id, msg.reply_to_message().unwrap().id)
+        .await?;
+
+    bot.send_message(msg.chat.id, view(msg.reply_to_message().unwrap()))
+        .parse_mode(ParseMode::Html)
+        .await?;
+
+    Ok(())
+}
+
+pub fn view(msg: &Message) -> String {
+    format!(
+        "<b>Hurmatli <a href=\"tg://user?id={}\">{}</a>,</b>\
+        \n\n\
+        Tushunishim bo'yicha siz mavzudan chetlayashayabsiz. Iltimos, \
+        quyidagi tugmachani bosish orqali bizning offtop guruhga o'tib oling! \
+        Offtopic guruhimizda istalgan mavzuda suhbatlashish ruxsat etiladi. Boshqalarga halaqit qilmayliga 😉\
+        \n\n\
+        <b>Hurmat ila, Rustina (Rastina)</b>",
+        msg.from().unwrap().id,
+        msg.from().unwrap().first_name
+    )
+}

src/functions/version.rs

@@ -45,8 +45,12 @@ pub async fn callback_list(
     Ok(())
 }
 
-
-pub async fn callback_detail(bot: &Bot, q: &CallbackQuery, args: &Vec<&str>, github: GitHub) -> ResponseResult<()> {
+pub async fn callback_detail(
+    bot: &Bot,
+    q: &CallbackQuery,
+    args: &Vec<&str>,
+    github: GitHub,
+) -> ResponseResult<()> {
     let page = args[0].parse::<u32>().unwrap();
     let version: Release = github.get_detail(args[1]).await.unwrap();
 
@@ -88,7 +92,10 @@ pub fn keyboard_list(
     let mut keyboard = Keyboard::new();
 
     for release in releases {
-        keyboard.text(&release.tag_name, &format!("changelog_{}_{}", page, release.tag_name));
+        keyboard.text(
+            &release.tag_name,
+            &format!("changelog_{}_{}", page, release.tag_name),
+        );
         keyboard.row();
     }
 
@@ -103,10 +110,7 @@ pub fn keyboard_list(
     keyboard.get()
 }
 
-pub fn keyboard_detail(
-    page: u32,
-    release: Release,
-) -> InlineKeyboardMarkup {
+pub fn keyboard_detail(page: u32, release: Release) -> InlineKeyboardMarkup {
     let mut keyboard = Keyboard::new();
 
     keyboard.url("📝 GitHub da o'qish", release.html_url.as_str());
@@ -115,4 +119,3 @@ pub fn keyboard_detail(
 
     keyboard.get()
 }
-

src/lib.rs

@@ -2,7 +2,11 @@ pub mod functions;
 pub mod hooks;
 pub mod utils;
 
-use teloxide::{dispatching::{UpdateHandler, UpdateFilterExt}, prelude::*, utils::command::BotCommands};
+use teloxide::{
+    dispatching::{UpdateFilterExt, UpdateHandler},
+    prelude::*,
+    utils::command::BotCommands,
+};
 
 #[derive(BotCommands, Clone, Debug)]
 #[command(rename_rule = "lowercase", parse_with = "split")]
@@ -28,6 +32,9 @@ pub enum Command {
 
     /// Specific version
     Version,
+
+    /// Report offtopic
+    Off,
 }
 
 pub fn handler() -> UpdateHandler<Box<dyn std::error::Error + Send + Sync + 'static>> {
@@ -42,8 +49,5 @@ pub fn handler() -> UpdateHandler<Box<dyn std::error::Error + Send + Sync + 'sta
                 .filter_command::<Command>()
                 .endpoint(functions::commands),
         )
-        .branch(
-            Update::filter_message()
-            .endpoint(functions::triggers),
-        )
+        .branch(Update::filter_message().endpoint(functions::triggers))
 }

src/main.rs

@@ -1,5 +1,8 @@
 use crates_io_api::AsyncClient;
-use rustina::{handler, utils::{github::GitHub, group_manager::Groups}};
+use rustina::{
+    handler,
+    utils::{github::GitHub, group_manager::Groups},
+};
 use std::error::Error;
 use teloxide::prelude::*;