fix: permission check

Cargo.toml

@@ -9,7 +9,7 @@ edition = "2018"
 # bot
 teloxide ={ version = "0.5.2",default-features = false,features = ["frunk", "macros", "auto-send","ctrlc_handler","rustls"] }
 teloxide-core = { version = "0.3.3",default-features = false, features = ["rustls"] }
-teloxide-macros  = "0.4"
+teloxide-macros  = "0.4.1"
 
 # logging
 env_logger = "0.9.0"

src/command.rs

@@ -1,6 +1,5 @@
 use crate::config::CONFIG;
 use std::sync::Arc;
-use arcstr::ArcStr;
 use teloxide::dispatching::UpdateWithCx;
 use teloxide::prelude::*;
 use teloxide::utils::command::BotCommand;
@@ -33,11 +32,25 @@ pub async fn answer(
       cx.answer("Mesagisto信使已禁用").await?;
     }
     Command::SetAddress { address } => {
-      // fixme check permission
-      CONFIG
-        .target_address_mapper
-        .insert(cx.chat_id(), ArcStr::from(address));
-      cx.answer("成功设置当前Group的信使地址").await?;
+      let sender_id = cx.update.from().unwrap().id;
+      let chat_id = cx.chat_id();
+      let admins =cx.requester.get_chat_administrators(chat_id).await?;
+      let mut is_admin = false;
+      for admin in admins {
+        if admin.user.id == sender_id {
+          is_admin = true;
+          break;
+        }
+      }
+      if is_admin {
+        CONFIG
+          .target_address_mapper
+          .insert(chat_id, address.into());
+        cx.answer("成功设置当前Group的信使地址").await?;
+      } else {
+        cx.answer("权限不足,拒绝设置信使频道").await?;
+      }
+
     }
   };
   Ok(())