summaryrefslogtreecommitdiff
path: root/ATRI/plugins
diff options
context:
space:
mode:
Diffstat (limited to 'ATRI/plugins')
-rw-r--r--ATRI/plugins/anime_search.py35
-rw-r--r--ATRI/plugins/broadcast.py134
-rw-r--r--ATRI/plugins/chat/__init__.py58
-rw-r--r--ATRI/plugins/code_runner/__init__.py9
-rw-r--r--ATRI/plugins/curse.py62
-rw-r--r--ATRI/plugins/essential.py90
-rw-r--r--ATRI/plugins/funny/__init__.py42
-rw-r--r--ATRI/plugins/funny/data_source.py6
-rw-r--r--ATRI/plugins/help/__init__.py11
-rw-r--r--ATRI/plugins/help/data_source.py6
-rw-r--r--ATRI/plugins/manage/__init__.py150
-rw-r--r--ATRI/plugins/repo.py48
-rw-r--r--ATRI/plugins/rich/__init__.py4
-rw-r--r--ATRI/plugins/saucenao/__init__.py31
-rw-r--r--ATRI/plugins/setu/__init__.py91
-rw-r--r--ATRI/plugins/setu/data_source.py23
-rw-r--r--ATRI/plugins/setu/tf_dealer.py10
-rw-r--r--ATRI/plugins/status/__init__.py6
-rw-r--r--ATRI/plugins/util/__init__.py97
-rw-r--r--ATRI/plugins/wife/__init__.py38
-rw-r--r--ATRI/plugins/wife/data_source.py2
21 files changed, 518 insertions, 435 deletions
diff --git a/ATRI/plugins/anime_search.py b/ATRI/plugins/anime_search.py
index 5b4e212..7436aa2 100644
--- a/ATRI/plugins/anime_search.py
+++ b/ATRI/plugins/anime_search.py
@@ -1,9 +1,9 @@
import re
from random import choice
-from nonebot.typing import T_State
-from nonebot.adapters.cqhttp import Bot, MessageEvent
-from nonebot.adapters.cqhttp.message import Message, MessageSegment
+from nonebot.matcher import Matcher
+from nonebot.params import ArgPlainText, CommandArg
+from nonebot.adapters.onebot.v11 import Bot, MessageEvent, Message, MessageSegment
from ATRI.service import Service
from ATRI.rule import is_in_service
@@ -80,34 +80,25 @@ class Anime(Service):
anime_search = Anime().on_command("以图搜番", "发送一张图以搜索可能的番剧")
-@anime_search.args_parser # type: ignore
-async def _get_anime(bot: Bot, event: MessageEvent, state: T_State):
- msg = str(event.message).strip()
- quit_list = ["算了", "罢了", "不搜了", "取消"]
- if msg in quit_list:
- await anime_search.finish("好吧...")
- if not msg:
- await anime_search.reject("图呢？")
- else:
- state["anime"] = msg
-
-
@anime_search.handle()
-async def _ready_sear(bot: Bot, event: MessageEvent, state: T_State):
+async def _ready_sear(
+ matcher: Matcher, event: MessageEvent, args: Message = CommandArg()
+):
user_id = event.get_user_id()
if not _anime_flmt.check(user_id):
await anime_search.finish(_anime_flmt_notice)
- msg = str(event.message).strip()
+ msg = args.extract_plain_text()
if msg:
- state["anime"] = msg
+ matcher.set_arg("anime_pic", args)
-@anime_search.got("anime", "图呢？")
-async def _deal_sear(bot: Bot, event: MessageEvent, state: T_State):
+@anime_search.got("anime_pic", "图呢？")
+async def _deal_sear(
+ bot: Bot, event: MessageEvent, pic: str = ArgPlainText("anime_pic")
+):
user_id = event.get_user_id()
- msg = state["anime"]
- img = re.findall(r"url=(.*?)]", msg)
+ img = re.findall(r"url=(.*?)]", pic)
if not img:
await anime_search.reject("请发送图片而不是其它东西！！")
diff --git a/ATRI/plugins/broadcast.py b/ATRI/plugins/broadcast.py
new file mode 100644
index 0000000..0948e31
--- /dev/null
+++ b/ATRI/plugins/broadcast.py
@@ -0,0 +1,134 @@
+import os
+import json
+import random
+import asyncio
+from pathlib import Path
+
+from nonebot.matcher import Matcher
+from nonebot.permission import SUPERUSER
+from nonebot.params import CommandArg, ArgPlainText
+from nonebot.adapters.onebot.v11 import Bot, Message, MessageEvent
+from nonebot.adapters.onebot.v11 import GROUP_OWNER, GROUP_ADMIN
+from nonebot.adapters.onebot.v11 import GroupMessageEvent, PrivateMessageEvent
+
+
+from ATRI.service import Service
+from ATRI.rule import to_bot
+
+
+BC_PATH = Path(".") / "data" / "database" / "broadcast"
+os.makedirs(BC_PATH, exist_ok=True)
+
+_BROADCAST_BACK = """
+广播报告：
+信息：{msg}
+预计推送个数（群）：{len_g}
+成功：{su_g}
+失败：{fl_g}
+失败列表：{f_g}
+""".strip()
+
+
+class BroadCast(Service):
+ def __init__(self):
+ Service.__init__(self, "广播", "向bot所在的所有群发送信息", True, to_bot())
+
+ @staticmethod
+ def load_rej_list() -> list:
+ data = list()
+ path = BC_PATH / "rej_list.json"
+ if not path.is_file():
+ with open(path, "w", encoding="utf-8") as w:
+ w.write(json.dumps(data))
+ return data
+
+ return json.loads(path.read_bytes())
+
+ @classmethod
+ def store_rej_list(cls, data: list):
+ path = BC_PATH/ "rej_list.json"
+ if not path.is_file():
+ cls.load_rej_list()
+
+ with open(path, "w", encoding="utf-8") as w:
+ w.write(json.dumps(data))
+
+
+caster = BroadCast().on_command("广播", "向bot所在的所有群发送信息，有防寄延迟", aliases={"/bc","bc"}, permission=SUPERUSER)
+
+
[email protected]()
+async def _(matcher: Matcher, args: Message = CommandArg()):
+ msg = args.extract_plain_text()
+ if msg:
+ matcher.set_arg("bc_msg", args)
+
+
[email protected]("bc_msg", "想要咱群发什么呢？")
+async def _(bot: Bot, event: MessageEvent, s_msg: str = ArgPlainText("bc_msg")):
+ w_group = await bot.get_group_list()
+
+ await bot.send(event, "正在推送...（每个群延迟1～3s）")
+
+ w_msg = f" 来自维护者的信息：\n{s_msg}"
+
+ su_g = list()
+ fl_g = list()
+ for i in w_group:
+ group_id = i["group_id"]
+ try:
+ await bot.send_group_msg(group_id=group_id, message=w_msg)
+ su_g.append(group_id)
+ except:
+ fl_g.append(group_id)
+
+ await asyncio.sleep(random.randint(2, 3))
+
+ repo_msg = _BROADCAST_BACK.format(
+ msg=s_msg,
+ len_g=len(w_group),
+ su_g=su_g,
+ fl_g=fl_g,
+ f_g="、".join(map(str, fl_g))
+ )
+ await caster.finish(repo_msg)
+
+
+rej_broadcast = BroadCast().on_command("拒绝广播", "拒绝来自开发者的广播推送", permission=GROUP_OWNER | GROUP_ADMIN)
+
+
+@rej_broadcast.handle()
+async def _(bot: Bot, event: GroupMessageEvent):
+ group_id = str(event.group_id)
+
+ rej_g = BroadCast().load_rej_list()
+ if group_id in rej_g:
+ await rej_broadcast.finish("本群已在推送黑名单内辣！")
+ else:
+ rej_g.append(group_id)
+ BroadCast().store_rej_list(rej_g)
+ await rej_broadcast.finish("完成～！已将本群列入推送黑名单")
+
+@rej_broadcast.handle()
+async def _(event: PrivateMessageEvent):
+ await rej_broadcast.finish("该功能仅在群聊中触发...")
+
+
+acc_broadcast = BroadCast().on_command("接受广播", "接受来自开发者的广播推送", permission=GROUP_OWNER | GROUP_ADMIN)
+
+
+@acc_broadcast.handle()
+async def _(bot: Bot, event: GroupMessageEvent):
+ group_id = str(event.group_id)
+
+ rej_g = BroadCast().load_rej_list()
+ if group_id in rej_g:
+ rej_g.remove(group_id)
+ BroadCast().store_rej_list(rej_g)
+ await rej_broadcast.finish("已将本群移除推送黑名单！")
+ else:
+ await rej_broadcast.finish("本群不在推送黑名单里呢...")
+
+@acc_broadcast.handle()
+async def _(event: PrivateMessageEvent):
+ await rej_broadcast.finish("该功能仅在群聊中触发...")
diff --git a/ATRI/plugins/chat/__init__.py b/ATRI/plugins/chat/__init__.py
index f401f3f..217c71e 100644
--- a/ATRI/plugins/chat/__init__.py
+++ b/ATRI/plugins/chat/__init__.py
@@ -1,9 +1,9 @@
from random import choice
-from nonebot.typing import T_State
-from nonebot.adapters.cqhttp import Bot, MessageEvent
+from nonebot.matcher import Matcher
+from nonebot.params import ArgPlainText, CommandArg
+from nonebot.adapters.onebot.v11 import Bot, MessageEvent, Message
-from ATRI.utils import CoolqCodeChecker
from ATRI.utils.limit import FreqLimiter
from ATRI.utils.apscheduler import scheduler
from .data_source import Chat
@@ -17,7 +17,6 @@ chat = Chat().on_message("文爱", "闲聊（文爱")
@chat.handle()
async def _chat(bot: Bot, event: MessageEvent):
- print(1)
user_id = event.get_user_id()
if not _chat_flmt.check(user_id):
await chat.finish(_chat_flmt_notice)
@@ -34,33 +33,20 @@ async def _chat(bot: Bot, event: MessageEvent):
my_name_is = Chat().on_command("叫我", "更改闲聊（文爱）时的称呼", aliases={"我是"}, priority=1)
-@my_name_is.args_parser # type: ignore
-async def _get_name(bot: Bot, event: MessageEvent, state: T_State):
- msg = str(event.message).strip()
- quit_list = ["算了", "罢了", "取消"]
- if msg in quit_list:
- await my_name_is.finish("好吧...")
- if not msg:
- await my_name_is.reject("欧尼酱想让咱如何称呼呢！0w0")
- else:
- state["name"] = msg
-
-
@my_name_is.handle()
-async def _name(bot: Bot, event: MessageEvent, state: T_State):
+async def _name(matcher: Matcher, event: MessageEvent, args: Message = CommandArg()):
user_id = event.get_user_id()
if not _chat_flmt.check(user_id):
await my_name_is.finish(_chat_flmt_notice)
- msg = str(event.message).strip()
+ msg = args.extract_plain_text()
if msg:
- state["name"] = msg
+ matcher.set_arg("name", args)
@my_name_is.got("name", "欧尼酱想让咱如何称呼呢！0w0")
-async def _deal_name(bot: Bot, event: MessageEvent, state: T_State):
+async def _deal_name(event: MessageEvent, new_name: str = ArgPlainText("name")):
user_id = event.get_user_id()
- new_name = state["name"]
repo = choice(
[
f"好~w 那咱以后就称呼你为{new_name}！",
@@ -77,37 +63,21 @@ async def _deal_name(bot: Bot, event: MessageEvent, state: T_State):
say = Chat().on_command("说", "别人让我说啥就说啥（", priority=1)
[email protected]_parser # type: ignore
-async def _get_say(bot: Bot, event: MessageEvent, state: T_State):
- msg = str(event.message).strip()
- quit_list = ["算了", "罢了"]
- if msg in quit_list:
- await say.finish("好吧...")
- if not msg:
- await say.reject("阿！要咱说啥呢...")
- else:
- state["say"] = msg
-
-
@say.handle()
-async def _ready_say(bot: Bot, event: MessageEvent, state: T_State):
+async def _ready_say(
+ matcher: Matcher, event: MessageEvent, args: Message = CommandArg()
+):
user_id = event.get_user_id()
if not _chat_flmt.check(user_id):
await say.finish(_chat_flmt_notice)
- msg = str(event.message)
+ msg = args.extract_plain_text()
if msg:
- state["say"] = msg
-
+ matcher.set_arg("say", args)
[email protected]("say")
-async def _deal_say(bot: Bot, event: MessageEvent, state: T_State):
- msg = state["say"]
- check = CoolqCodeChecker(msg).check
- if not check:
- repo = choice(["不要...", "这个咱不想复读！", "不可以", "不好！"])
- await say.finish(repo)
[email protected]("say", "想要咱复读啥呢...")
+async def _deal_say(event: MessageEvent, msg: str = ArgPlainText("say")):
user_id = event.get_user_id()
_chat_flmt.start_cd(user_id)
await say.finish(msg)
diff --git a/ATRI/plugins/code_runner/__init__.py b/ATRI/plugins/code_runner/__init__.py
index 3f5697b..334c09a 100644
--- a/ATRI/plugins/code_runner/__init__.py
+++ b/ATRI/plugins/code_runner/__init__.py
@@ -1,7 +1,6 @@
from random import choice
-from nonebot.adapters.cqhttp import Bot, MessageEvent
-from nonebot.adapters.cqhttp.message import Message, MessageSegment
+from nonebot.adapters.onebot.v11 import MessageEvent, Message, MessageSegment, unescape
from ATRI.utils.limit import FreqLimiter
from .data_source import CodeRunner
@@ -15,7 +14,7 @@ code_runner = CodeRunner().on_command("/code", "在线运行一段代码，帮�
@code_runner.handle()
-async def _code_runner(bot: Bot, event: MessageEvent):
+async def _code_runner(event: MessageEvent):
user_id = event.get_user_id()
if not _flmt.check(user_id):
await code_runner.finish(_flmt_notice)
@@ -23,14 +22,14 @@ async def _code_runner(bot: Bot, event: MessageEvent):
msg = str(event.get_message())
args = msg.split("\n")
- if not args:
+ if not args[0]:
content = f"> {MessageSegment.at(user_id)}\n" + "请键入 /code help 以获取帮助~！"
elif args[0] == "help":
content = f"> {MessageSegment.at(user_id)}\n" + CodeRunner().help()
elif args[0] == "list":
content = f"> {MessageSegment.at(user_id)}\n" + CodeRunner().list_supp_lang()
else:
- content = MessageSegment.at(user_id) + await CodeRunner().runner(msg)
+ content = MessageSegment.at(user_id) + await CodeRunner().runner(unescape(msg))
_flmt.start_cd(user_id)
await code_runner.finish(Message(content))
diff --git a/ATRI/plugins/curse.py b/ATRI/plugins/curse.py
deleted file mode 100644
index d407b55..0000000
--- a/ATRI/plugins/curse.py
+++ /dev/null
@@ -1,62 +0,0 @@
-from random import choice
-
-from nonebot.adapters.cqhttp import Bot, MessageEvent
-
-from ATRI.rule import is_in_service, to_bot
-from ATRI.service import Service
-from ATRI.utils import request
-from ATRI.utils.limit import FreqLimiter
-
-
-URL = "https://zuanbot.com/api.php?level=min&lang=zh_cn"
-
-_curse_flmt = FreqLimiter(3)
-_curse_flmt_notice = choice(["我看你是找🔨是吧", "给我适可而止阿！？", "扎布多得了😅", "z？是m吗？我凑那也太恐怖了", "?"])
-
-
-__doc__ = """
-口臭！你急了你急了！
-"""
-
-
-class Curse(Service):
- def __init__(self):
- Service.__init__(self, "口臭", __doc__, rule=is_in_service("口臭"))
-
- @staticmethod
- async def now() -> str:
- res = await request.get(URL)
- result = res.text
- if "访问太频繁服务器受不了啦" in result:
- result = "爪巴，吃我一圈火箭拳——"
- return result
-
-
-normal_curse = Curse().on_command(
- "口臭一下", "主命令，骂你一下", aliases={"骂我", "口臭"}, rule=to_bot()
-)
-
-
-@normal_curse.handle()
-async def _deal_n_curse(bot: Bot, event: MessageEvent):
- user_id = event.get_user_id()
- if not _curse_flmt.check(user_id):
- await normal_curse.finish(_curse_flmt_notice)
-
- result = await Curse().now()
- _curse_flmt.start_cd(user_id)
- await normal_curse.finish(result)
-
-
-super_curse = Curse().on_regex(r"[来求有](.*?)骂我吗?", "有求必应")
-
-
-@super_curse.handle()
-async def _deal_s_curse(bot: Bot, event: MessageEvent):
- user_id = event.get_user_id()
- if not _curse_flmt.check(user_id):
- await normal_curse.finish(_curse_flmt_notice)
-
- result = await Curse().now()
- _curse_flmt.start_cd(user_id)
- await normal_curse.finish(result)
diff --git a/ATRI/plugins/essential.py b/ATRI/plugins/essential.py
index fb493a9..6d981aa 100644
--- a/ATRI/plugins/essential.py
+++ b/ATRI/plugins/essential.py
@@ -8,11 +8,10 @@ from random import choice, randint
from pathlib import Path
import nonebot
-from nonebot.typing import T_State
-from nonebot.matcher import Matcher
+from nonebot.permission import SUPERUSER
from nonebot.message import run_preprocessor
from nonebot.exception import IgnoredException
-from nonebot.adapters.cqhttp import (
+from nonebot.adapters.onebot.v11 import (
Bot,
MessageEvent,
GroupMessageEvent,
@@ -24,13 +23,15 @@ from nonebot.adapters.cqhttp import (
GroupBanNoticeEvent,
GroupRecallNoticeEvent,
FriendRecallNoticeEvent,
+ MessageSegment,
+ Message
)
import ATRI
from ATRI.service import Service
from ATRI.log import logger as log
from ATRI.config import BotSelfConfig
-from ATRI.utils import CoolqCodeChecker
+from ATRI.utils import MessageChecker
from ATRI.utils.apscheduler import scheduler
@@ -57,10 +58,8 @@ async def shutdown():
log.info("Thanks for using.")
-@run_preprocessor # type: ignore
-async def _check_block(
- matcher: Matcher, bot: Bot, event: MessageEvent, state: T_State
-) -> None:
+@run_preprocessor
+async def _check_block(event: MessageEvent):
user_file = "block_user.json"
path = MANEGE_DIR / user_file
if not path.is_file():
@@ -261,6 +260,9 @@ async def _group_ban_event(bot: Bot, event: GroupBanNoticeEvent):
await bot.send_private_msg(user_id=int(superuser), message=msg)
+_acc_recall = True
+
+
recall_event = Essential().on_notice("撤回事件", "撤回事件检测")
@@ -269,6 +271,9 @@ async def _recall_group_event(bot: Bot, event: GroupRecallNoticeEvent):
if event.is_tome():
return
+ if not _acc_recall:
+ return
+
try:
repo = await bot.get_msg(message_id=event.message_id)
except BaseException:
@@ -276,14 +281,13 @@ async def _recall_group_event(bot: Bot, event: GroupRecallNoticeEvent):
user = event.user_id
group = event.group_id
- repo = str(repo["message"])
- check = CoolqCodeChecker(repo).check
- if not check:
- repo = repo.replace("CQ", "QC")
+ repo: dict = repo["message"]
+
+ m = recall_msg_dealer(repo)
- msg = "主人，咱拿到了一条撤回信息！\n" f"{user}@[群:{group}]\n" "撤回了\n" f"{repo}"
+ msg = f"主人，咱拿到了一条撤回信息！\n{user}@[群:{group}]\n撤回了\n{m}"
for superuser in BotSelfConfig.superusers:
- await bot.send_private_msg(user_id=int(superuser), message=msg)
+ await bot.send_private_msg(user_id=int(superuser), message=Message(msg))
@recall_event.handle()
@@ -291,20 +295,40 @@ async def _recall_private_event(bot: Bot, event: FriendRecallNoticeEvent):
if event.is_tome():
return
+ if not _acc_recall:
+ return
+
try:
repo = await bot.get_msg(message_id=event.message_id)
except BaseException:
return
-
+
user = event.user_id
- repo = str(repo["message"])
- check = CoolqCodeChecker(repo).check
- if not check:
- repo = repo.replace("CQ", "QC")
+ repo: dict = repo["message"]
+
+ m = recall_msg_dealer(repo)
- msg = "主人，咱拿到了一条撤回信息！\n" f"{user}@[私聊]" "撤回了\n" f"{repo}"
+ msg = f"主人，咱拿到了一条撤回信息！\n{user}@[私聊]撤回了\n{m}"
for superuser in BotSelfConfig.superusers:
- await bot.send_private_msg(user_id=int(superuser), message=msg)
+ await bot.send_private_msg(user_id=int(superuser), message=Message(msg))
+
+
+rej_recall = Essential().on_command("拒绝撤回", "拒绝撤回信息", permission=SUPERUSER)
+
+@rej_recall.handle()
+async def _():
+ global _acc_recall
+ _acc_recall = False
+ await rej_recall.finish("已拒绝撤回信息...")
+
+
+acc_recall = Essential().on_command("接受撤回", "接受撤回信息", permission=SUPERUSER)
+
+@acc_recall.handle()
+async def _():
+ global _acc_recall
+ _acc_recall = True
+ await acc_recall.finish("现在可以接受撤回信息啦！")
@scheduler.scheduled_job("interval", name="清除缓存", minutes=30, misfire_grace_time=5)
@@ -314,3 +338,27 @@ async def _clear_cache():
os.makedirs(TEMP_PATH, exist_ok=True)
except Exception:
log.warning("清除缓存失败，请手动清除：data/temp")
+
+
+def recall_msg_dealer(msg: dict) -> str:
+ temp_m = list()
+
+ for i in msg:
+ _type = i["type"]
+ _data = i["data"]
+ if _type == "text":
+ temp_m.append(_data["text"])
+ elif _type == "image":
+ url = _data["url"]
+ check = MessageChecker(url).check_image_url
+ if check:
+ temp_m.append(MessageSegment.image(url))
+ else:
+ temp_m.append(f"[该图片可能包含非法内容，源url：{url}]")
+ elif _type == "face":
+ temp_m.append(MessageSegment.face(_data["id"]))
+ else:
+ temp_m.append(f"[未知类型信息：{_data}]")
+
+ repo = str().join(map(str, temp_m))
+ return repo
diff --git a/ATRI/plugins/funny/__init__.py b/ATRI/plugins/funny/__init__.py
index ea60375..8173f3b 100644
--- a/ATRI/plugins/funny/__init__.py
+++ b/ATRI/plugins/funny/__init__.py
@@ -1,8 +1,8 @@
from random import choice, randint
-from nonebot.typing import T_State
-from nonebot.adapters.cqhttp import Bot, MessageEvent, GroupMessageEvent
-from nonebot.adapters.cqhttp.message import Message
+from nonebot.matcher import Matcher
+from nonebot.params import ArgPlainText, CommandArg
+from nonebot.adapters.onebot.v11 import Bot, MessageEvent, GroupMessageEvent, Message
from ATRI.utils.limit import FreqLimiter, DailyLimiter
from .data_source import Funny
@@ -39,38 +39,36 @@ _fake_flmt = FreqLimiter(60)
_fake_flmt_notice = choice(["慢...慢一..点❤", "冷静1下", "歇会歇会~~"])
-@fake_msg.args_parser # type: ignore
-async def _perp_fake(bot: Bot, event: GroupMessageEvent, state: T_State):
- msg = str(event.message).strip()
- quit_list = ["算了", "罢了"]
- if msg in quit_list:
- await fake_msg.finish("好吧...")
- if not msg:
- await fake_msg.reject("内容呢？格式：qq-name-content\n可构造多条，以上仅为一条，使用空格隔开")
- else:
- state["content"] = msg
-
-
@fake_msg.handle()
-async def _ready_fake(bot: Bot, event: GroupMessageEvent, state: T_State):
+async def _ready_fake(
+ matcher: Matcher, event: GroupMessageEvent, args: Message = CommandArg()
+):
user_id = event.get_user_id()
if not _fake_daliy_max.check(user_id):
await fake_msg.finish(_fake_max_notice)
if not _fake_flmt.check(user_id):
await fake_msg.finish(_fake_flmt_notice)
- msg = str(event.message).strip()
+ msg = args.extract_plain_text()
if msg:
- state["content"] = msg
+ matcher.set_arg("content", args)
@fake_msg.got("content", "内容呢？格式：qq-name-content\n可构造多条，以上仅为一条，使用空格隔开")
-async def _deal_fake(bot: Bot, event: GroupMessageEvent, state: T_State):
- content = state["content"]
+async def _deal_fake(
+ bot: Bot, event: GroupMessageEvent, content: str = ArgPlainText("content")
+):
group_id = event.group_id
user_id = event.get_user_id()
- node = Funny().fake_msg(content)
- await bot.send_group_forward_msg(group_id=group_id, messages=node)
+ try:
+ node = Funny().fake_msg(content)
+ except Exception:
+ await fake_msg.finish("内容格式错误，请检查（")
+
+ try:
+ await bot.send_group_forward_msg(group_id=group_id, messages=node)
+ except Exception:
+ await fake_msg.finish("构造失败惹...可能是被制裁了（")
_fake_flmt.start_cd(user_id)
_fake_daliy_max.increase(user_id)
diff --git a/ATRI/plugins/funny/data_source.py b/ATRI/plugins/funny/data_source.py
index a1fce64..8edc88a 100644
--- a/ATRI/plugins/funny/data_source.py
+++ b/ATRI/plugins/funny/data_source.py
@@ -3,7 +3,7 @@ import os
from pathlib import Path
from random import choice, randint
-from nonebot.adapters.cqhttp.utils import unescape
+from nonebot.adapters.onebot.v11 import unescape
from ATRI.service import Service
from ATRI.log import logger
@@ -77,9 +77,9 @@ class Funny(Service):
EAT_URL = "https://wtf.hiigara.net/api/run/"
params = {"event": "ManualRun"}
pattern_0 = r"大?[今明后]天(.*?)吃[什啥]么?"
- pattern_1 = r"(今|明|后|大后)天"
+ pattern_1 = r"[今|明|后|大后]天"
arg = re.findall(pattern_0, msg)[0]
- day = re.match(pattern_1, msg).group(0) # type: ignore
+ day = re.findall(pattern_1, msg)[0]
if arg == "中午":
a = f"LdS4K6/{randint(0, 1145141919810)}"
diff --git a/ATRI/plugins/help/__init__.py b/ATRI/plugins/help/__init__.py
index 1d1102e..a8465bc 100644
--- a/ATRI/plugins/help/__init__.py
+++ b/ATRI/plugins/help/__init__.py
@@ -1,5 +1,4 @@
-from nonebot.typing import T_State
-from nonebot.adapters.cqhttp import Bot, MessageEvent
+from nonebot.adapters.onebot.v11 import MessageEvent
from ATRI.rule import to_bot
from .data_source import Helper
@@ -9,7 +8,7 @@ main_help = Helper().on_command("菜单", "获取食用bot的方法", rule=to_bo
@main_help.handle()
-async def _main_help(bot: Bot, event: MessageEvent):
+async def _main_help():
repo = Helper().menu()
await main_help.finish(repo)
@@ -18,7 +17,7 @@ about_me = Helper().on_command("关于", "获取关于bot的信息", rule=to_bot
@about_me.handle()
-async def _about_me(bot: Bot, event: MessageEvent):
+async def _about_me():
repo = Helper().about()
await about_me.finish(repo)
@@ -27,7 +26,7 @@ service_list = Helper().on_command("服务列表", "查看所有可用服务", r
@service_list.handle()
-async def _service_list(bot: Bot, event: MessageEvent):
+async def _service_list():
repo = Helper().service_list()
await service_list.finish(repo)
@@ -36,7 +35,7 @@ service_info = Helper().on_command("帮助", "获取服务详细帮助", aliases
@service_info.handle()
-async def _ready_service_info(bot: Bot, event: MessageEvent, state: T_State):
+async def _ready_service_info(event: MessageEvent):
msg = str(event.message).split(" ")
service = msg[0]
try:
diff --git a/ATRI/plugins/help/data_source.py b/ATRI/plugins/help/data_source.py
index 7b2f6f8..cfa0c62 100644
--- a/ATRI/plugins/help/data_source.py
+++ b/ATRI/plugins/help/data_source.py
@@ -34,7 +34,7 @@ class Helper(Service):
"关于 -查看bot基本信息\n"
"服务列表 -以查看所有可用服务\n"
"帮助 [服务] -以查看对应服务帮助\n"
- "Tip: 均需要at触发。菜单 以打开此页面"
+ "Tip: 均需要at触发。@bot 菜单 以打开此页面"
)
@staticmethod
@@ -59,10 +59,8 @@ class Helper(Service):
service = i.replace(".json", "")
temp_list.append(service)
- msg0 = "咱搭载了以下服务~\n"
services = "、".join(map(str, temp_list))
- msg0 = msg0 + services
- repo = msg0 + "\n@ 帮助 [服务] -以查看对应服务帮助"
+ repo = f"咱搭载了以下服务~\n{services}\n@bot 帮助 [服务] -以查看对应服务帮助"
return repo
@staticmethod
diff --git a/ATRI/plugins/manage/__init__.py b/ATRI/plugins/manage/__init__.py
index 77692fd..62ed378 100644
--- a/ATRI/plugins/manage/__init__.py
+++ b/ATRI/plugins/manage/__init__.py
@@ -1,25 +1,26 @@
import re
-from nonebot.typing import T_State
from nonebot.permission import SUPERUSER
-from nonebot.adapters.cqhttp import Bot, MessageEvent, GroupMessageEvent
-from nonebot.adapters.cqhttp.permission import GROUP_OWNER, GROUP_ADMIN
+from nonebot.matcher import Matcher
+from nonebot.params import ArgPlainText, CommandArg
+from nonebot.adapters.onebot.v11 import Bot, Message, MessageEvent, GroupMessageEvent
+from nonebot.adapters.onebot.v11 import GROUP_OWNER, GROUP_ADMIN
from .data_source import Manage
+
block_user = Manage().on_command("封禁用户", "对目标用户进行封禁", permission=SUPERUSER)
@block_user.handle()
-async def _ready_block_user(bot: Bot, event: MessageEvent, state: T_State):
- msg = str(event.message).strip()
+async def _ready_block_user(matcher: Matcher, args: Message = CommandArg()):
+ msg = args.extract_plain_text()
if msg:
- state["block_user"] = msg
+ matcher.set_arg("block_user", args)
@block_user.got("block_user", "哪位？GKD！")
-async def _deal_block_user(bot: Bot, event: MessageEvent, state: T_State):
- user_id = state["block_user"]
+async def _deal_block_user(user_id: str = ArgPlainText("block_user")):
quit_list = ["算了", "罢了"]
if user_id in quit_list:
await block_user.finish("...看来有人逃过一劫呢")
@@ -35,15 +36,14 @@ unblock_user = Manage().on_command("解封用户", "对目标用户进行解封"
@unblock_user.handle()
-async def _ready_unblock_user(bot: Bot, event: MessageEvent, state: T_State):
- msg = str(event.message).strip()
+async def _ready_unblock_user(matcher: Matcher, args: Message = CommandArg()):
+ msg = args.extract_plain_text()
if msg:
- state["unblock_user"] = msg
+ matcher.set_arg("unblock_user", args)
@unblock_user.got("unblock_user", "哪位？GKD！")
-async def _deal_unblock_user(bot: Bot, event: MessageEvent, state: T_State):
- user_id = state["unblock_user"]
+async def _deal_unblock_user(user_id: str = ArgPlainText("unblock_user")):
quit_list = ["算了", "罢了"]
if user_id in quit_list:
await unblock_user.finish("...有人又得继续在小黑屋呆一阵子了")
@@ -59,15 +59,14 @@ block_group = Manage().on_command("封禁群", "对目标群进行封禁", permi
@block_group.handle()
-async def _ready_block_group(bot: Bot, event: MessageEvent, state: T_State):
- msg = str(event.message).strip()
+async def _ready_block_group(matcher: Matcher, args: Message = CommandArg()):
+ msg = args.extract_plain_text()
if msg:
- state["block_group"] = msg
+ matcher.set_arg("block_group", args)
@block_group.got("block_group", "哪个群？GKD！")
-async def _deal_block_group(bot: Bot, event: MessageEvent, state: T_State):
- group_id = state["block_group"]
+async def _deal_block_group(group_id: str = ArgPlainText("block_group")):
quit_list = ["算了", "罢了"]
if group_id in quit_list:
await block_group.finish("...看来有一群逃过一劫呢")
@@ -83,15 +82,14 @@ unblock_group = Manage().on_command("解封群", "对目标群进行解封", per
@unblock_group.handle()
-async def _ready_unblock_group(bot: Bot, event: MessageEvent, state: T_State):
- msg = str(event.message).strip()
+async def _ready_unblock_group(matcher: Matcher, args: Message = CommandArg()):
+ msg = args.extract_plain_text()
if msg:
- state["unblock_group"] = msg
+ matcher.set_arg("unblock_group", args)
@unblock_group.got("unblock_group", "哪个群？GKD！")
-async def _deal_unblock_group(bot: Bot, event: MessageEvent, state: T_State):
- group_id = state["unblock_group"]
+async def _deal_unblock_group(group_id: str = ArgPlainText("unblock_group")):
quit_list = ["算了", "罢了"]
if group_id in quit_list:
await unblock_group.finish("...有一群又得继续在小黑屋呆一阵子了")
@@ -107,15 +105,16 @@ global_block_service = Manage().on_command("全局禁用", "全局禁用某服�
@global_block_service.handle()
-async def _ready_block_service(bot: Bot, event: MessageEvent, state: T_State):
- msg = str(event.message).strip()
+async def _ready_block_service(matcher: Matcher, args: Message = CommandArg()):
+ msg = args.extract_plain_text()
if msg:
- state["global_block_service"] = msg
+ matcher.set_arg("global_block_service", args)
@global_block_service.got("global_block_service", "阿...是哪个服务呢")
-async def _deal_global_block_service(bot: Bot, event: MessageEvent, state: T_State):
- block_service = state["global_block_service"]
+async def _deal_global_block_service(
+ block_service: str = ArgPlainText("global_block_service"),
+):
quit_list = ["算了", "罢了"]
if block_service in quit_list:
await global_block_service.finish("好吧...")
@@ -131,15 +130,18 @@ global_unblock_service = Manage().on_command("全局启用", "全局启用某服
@global_unblock_service.handle()
-async def _ready_unblock_service(bot: Bot, event: MessageEvent, state: T_State):
- msg = str(event.message).strip()
+async def _ready_unblock_service(
+ matcher: Matcher, event: MessageEvent, args: Message = CommandArg()
+):
+ msg = args.extract_plain_text()
if msg:
- state["global_unblock_service"] = msg
+ matcher.set_arg("global_unblock_service", args)
@global_unblock_service.got("global_unblock_service", "阿...是哪个服务呢")
-async def _deal_global_unblock_service(bot: Bot, event: MessageEvent, state: T_State):
- unblock_service = state["global_unblock_service"]
+async def _deal_global_unblock_service(
+ unblock_service: str = ArgPlainText("global_unblock_service"),
+):
quit_list = ["算了", "罢了"]
if unblock_service in quit_list:
await global_unblock_service.finish("好吧...")
@@ -157,7 +159,7 @@ user_block_service = Manage().on_regex(
@user_block_service.handle()
-async def _user_block_service(bot: Bot, event: MessageEvent):
+async def _user_block_service(event: MessageEvent):
msg = str(event.message).strip()
pattern = r"对用户(.*?)禁用(.*)"
reg = re.findall(pattern, msg)
@@ -176,7 +178,7 @@ user_unblock_service = Manage().on_regex(
@user_unblock_service.handle()
-async def _user_unblock_service(bot: Bot, event: MessageEvent):
+async def _user_unblock_service(event: MessageEvent):
msg = str(event.message).strip()
pattern = r"对用户(.*?)启用(.*)"
reg = re.findall(pattern, msg)
@@ -196,16 +198,17 @@ group_block_service = Manage().on_command(
@group_block_service.handle()
async def _ready_group_block_service(
- bot: Bot, event: GroupMessageEvent, state: T_State
+ matcher: Matcher, event: GroupMessageEvent, args: Message = CommandArg()
):
msg = str(event.message).strip()
if msg:
- state["group_block_service"] = msg
+ matcher.set_arg("group_block_service", args)
@group_block_service.got("group_block_service", "阿...是哪个服务呢")
-async def _deal_group_block_service(bot: Bot, event: GroupMessageEvent, state: T_State):
- aim_service = state["group_block_service"]
+async def _deal_group_block_service(
+ event: GroupMessageEvent, aim_service: str = ArgPlainText("group_block_service")
+):
group_id = str(event.group_id)
quit_list = ["算了", "罢了"]
if aim_service in quit_list:
@@ -224,18 +227,17 @@ group_unblock_service = Manage().on_command(
@group_unblock_service.handle()
async def _ready_group_unblock_service(
- bot: Bot, event: GroupMessageEvent, state: T_State
+ matcher: Matcher, event: GroupMessageEvent, args: Message = CommandArg()
):
- msg = str(event.message).strip()
+ msg = args.extract_plain_text()
if msg:
- state["group_unblock_service"] = msg
+ matcher.set_arg("group_unblock_service", args)
@group_unblock_service.got("group_unblock_service", "阿...是哪个服务呢")
async def _deal_group_unblock_service(
- bot: Bot, event: GroupMessageEvent, state: T_State
+ event: GroupMessageEvent, aim_service: str = ArgPlainText("group_unblock_service")
):
- aim_service = state["group_unblock_service"]
group_id = str(event.group_id)
quit_list = ["算了", "罢了"]
if aim_service in quit_list:
@@ -251,7 +253,7 @@ get_friend_add_list = Manage().on_command("获取好友申请", "获取好友申
@get_friend_add_list.handle()
-async def _get_friend_add_list(bot: Bot, event: MessageEvent):
+async def _get_friend_add_list():
data = Manage().load_friend_apply_list()
temp_list = list()
for i in data:
@@ -270,15 +272,18 @@ approve_friend_add = Manage().on_command("同意好友", "同意好友申请", p
@approve_friend_add.handle()
-async def _ready_approve_friend_add(bot: Bot, event: MessageEvent, state: T_State):
- msg = str(event.message).strip()
+async def _ready_approve_friend_add(
+ matcher: Matcher, event: MessageEvent, args: Message = CommandArg()
+):
+ msg = args.extract_plain_text()
if msg:
- state["approve_friend_add"] = msg
+ matcher.set_arg("approve_friend_add", args)
@approve_friend_add.got("approve_friend_add", "申请码GKD!")
-async def _deal_approve_friend_add(bot: Bot, event: MessageEvent, state: T_State):
- apply_code = state["approve_friend_add"]
+async def _deal_approve_friend_add(
+ bot: Bot, apply_code: str = ArgPlainText("approve_friend_add")
+):
quit_list = ["算了", "罢了"]
if apply_code in quit_list:
await approve_friend_add.finish("好吧...")
@@ -297,15 +302,18 @@ refuse_friend_add = Manage().on_command("拒绝好友", "拒绝好友申请", pe
@refuse_friend_add.handle()
-async def _ready_refuse_friend_add(bot: Bot, event: MessageEvent, state: T_State):
- msg = str(event.message).strip()
+async def _ready_refuse_friend_add(
+ matcher: Matcher, event: MessageEvent, args: Message = CommandArg()
+):
+ msg = args.extract_plain_text()
if msg:
- state["refuse_friend_add"] = msg
+ matcher.set_arg("refuse_friend_add", args)
@refuse_friend_add.got("refuse_friend_add", "申请码GKD!")
-async def _deal_refuse_friend_add(bot: Bot, event: MessageEvent, state: T_State):
- apply_code = state["refuse_friend_add"]
+async def _deal_refuse_friend_add(
+ bot: Bot, apply_code: str = ArgPlainText("refuse_friend_add")
+):
quit_list = ["算了", "罢了"]
if apply_code in quit_list:
await refuse_friend_add.finish("好吧...")
@@ -324,7 +332,7 @@ get_group_invite_list = Manage().on_command("获取邀请列表", "获取群邀�
@get_group_invite_list.handle()
-async def _get_group_invite_list(bot: Bot, event: MessageEvent):
+async def _get_group_invite_list():
data = Manage().load_invite_apply_list()
temp_list = list()
for i in data:
@@ -343,15 +351,18 @@ approve_group_invite = Manage().on_command("同意邀请", "同意群聊邀请",
@approve_group_invite.handle()
-async def _ready_approve_group_invite(bot: Bot, event: MessageEvent, state: T_State):
- msg = str(event.message).strip()
+async def _ready_approve_group_invite(
+ matcher: Matcher, event: MessageEvent, args: Message = CommandArg()
+):
+ msg = args.extract_plain_text()
if msg:
- state["approve_group_invite"] = msg
+ matcher.set_arg("approve_group_invite", args)
@approve_group_invite.got("approve_group_invite", "申请码GKD!")
-async def _deal_approve_group_invite(bot: Bot, event: MessageEvent, state: T_State):
- apply_code = state["approve_group_invite"]
+async def _deal_approve_group_invite(
+ bot: Bot, apply_code: str = ArgPlainText("approve_group_invite")
+):
quit_list = ["算了", "罢了"]
if apply_code in quit_list:
await approve_group_invite.finish("好吧...")
@@ -372,15 +383,18 @@ refuse_group_invite = Manage().on_command("拒绝邀请", "拒绝群聊邀请",
@refuse_group_invite.handle()
-async def _ready_refuse_group_invite(bot: Bot, event: MessageEvent, state: T_State):
- msg = str(event.message).strip()
+async def _ready_refuse_group_invite(
+ matcher: Matcher, event: MessageEvent, args: Message = CommandArg()
+):
+ msg = args.extract_plain_text()
if msg:
- state["refuse_group_invite"] = msg
+ matcher.set_arg("refuse_group_invite", args)
@refuse_group_invite.got("refuse_group_invite", "申请码GKD!")
-async def _deal_refuse_group_invite(bot: Bot, event: MessageEvent, state: T_State):
- apply_code = state["refuse_group_invite"]
+async def _deal_refuse_group_invite(
+ bot: Bot, apply_code: str = ArgPlainText("refuse_group_invite")
+):
quit_list = ["算了", "罢了"]
if apply_code in quit_list:
await refuse_group_invite.finish("好吧...")
@@ -390,7 +404,7 @@ async def _deal_refuse_group_invite(bot: Bot, event: MessageEvent, state: T_Stat
flag=apply_code, sub_type="invite", approve=False
)
except BaseException:
- await refuse_group_invite.finish("拒绝失败...尝试下手动？")
+ await refuse_group_invite.finish("拒绝失败...（可能是小群免验证）尝试下手动？")
data = Manage().load_invite_apply_list()
data.pop(apply_code)
Manage().save_invite_apply_list(data)
@@ -401,7 +415,7 @@ track_error = Manage().on_command("追踪", "获取报错信息，传入追踪�
@track_error.handle()
-async def _track_error(bot: Bot, event: MessageEvent):
+async def _track_error(event: MessageEvent):
track_id = str(event.message).strip()
repo = await Manage().track_error(track_id)
await track_error.finish(repo)
diff --git a/ATRI/plugins/repo.py b/ATRI/plugins/repo.py
index 9c52610..40869eb 100644
--- a/ATRI/plugins/repo.py
+++ b/ATRI/plugins/repo.py
@@ -1,7 +1,8 @@
from random import choice
-from nonebot.typing import T_State
-from nonebot.adapters.cqhttp import Bot, MessageEvent
+from nonebot.matcher import Matcher
+from nonebot.params import CommandArg, ArgPlainText
+from nonebot.adapters.onebot.v11 import Bot, MessageEvent, Message
from ATRI.service import Service
from ATRI.config import BotSelfConfig
@@ -25,46 +26,39 @@ class Repo(Service):
Service.__init__(self, "反馈", "向维护者发送消息")
-repo = Repo().on_command("来杯红茶", "向维护者发送消息", aliases={"反馈", "报告"})
+reporter = Repo().on_command("来杯红茶", "向维护者发送消息", aliases={"反馈", "报告"})
[email protected]_parser # type: ignore
-async def _get_repo(bot: Bot, event: MessageEvent, state: T_State):
- msg = str(event.message).strip()
- quit_list = ["算了", "罢了", "取消"]
- if msg in quit_list:
- await repo.finish("好吧...")
- if not msg:
- await repo.reject("需要反馈的内容呢？~")
- else:
- state["repo"] = msg
-
-
[email protected]()
-async def _ready_repo(bot: Bot, event: MessageEvent, state: T_State):
[email protected]()
+async def _ready_repo(
+ matcher: Matcher, event: MessageEvent, args: Message = CommandArg()
+):
user_id = event.get_user_id()
if not _repo_flmt.check(user_id):
- await repo.finish(_repo_flmt_notice)
+ await reporter.finish(_repo_flmt_notice)
if not _repo_dlmt.check(user_id):
- await repo.finish(_repo_dlmt_notice)
+ await reporter.finish(_repo_dlmt_notice)
- msg = str(event.message).strip()
+ msg = args.extract_plain_text()
if msg:
- state["repo"] = msg
+ matcher.set_arg("repo", args)
[email protected]("repo", "需要反馈的内容呢？~")
-async def _deal_repo(bot: Bot, event: MessageEvent, state: T_State):
- msg = state["repo"]
[email protected]("repo", "需要反馈的内容呢？~")
+async def _deal_repo(
+ bot: Bot,
+ event: MessageEvent,
+ repo_msg: str = ArgPlainText("repo"),
+):
user_id = event.get_user_id()
- repo_0 = REPO_FORMAT.format(user=user_id, msg=msg)
+ repo_0 = REPO_FORMAT.format(user=user_id, msg=repo_msg)
for superuser in BotSelfConfig.superusers:
try:
await bot.send_private_msg(user_id=superuser, message=repo_0)
except BaseException:
- await repo.finish("发送失败了呢...")
+ await reporter.finish("发送失败了呢...")
_repo_flmt.start_cd(user_id)
_repo_dlmt.increase(user_id)
- await repo.finish("吾辈的心愿已由咱转告维护者！")
+ await reporter.finish("吾辈的心愿已由咱转告维护者！")
diff --git a/ATRI/plugins/rich/__init__.py b/ATRI/plugins/rich/__init__.py
index bcd58f7..3b49750 100644
--- a/ATRI/plugins/rich/__init__.py
+++ b/ATRI/plugins/rich/__init__.py
@@ -1,4 +1,4 @@
-from nonebot.adapters.cqhttp import Bot, MessageEvent
+from nonebot.adapters.onebot.v11 import MessageEvent
from ATRI.utils.limit import FreqLimiter
from ATRI.log import logger as log
@@ -10,7 +10,7 @@ bili_rich = Rich().on_message("小程序检测", "小程序爪巴", block=False)
@bili_rich.handle()
-async def _fk_bili(bot: Bot, event: MessageEvent):
+async def _fk_bili(event: MessageEvent):
user_id = event.get_user_id()
if not _rich_flmt.check(user_id):
return
diff --git a/ATRI/plugins/saucenao/__init__.py b/ATRI/plugins/saucenao/__init__.py
index fed1096..092db50 100644
--- a/ATRI/plugins/saucenao/__init__.py
+++ b/ATRI/plugins/saucenao/__init__.py
@@ -1,9 +1,9 @@
from re import findall
from random import choice
-from nonebot.typing import T_State
-from nonebot.adapters.cqhttp import Bot, MessageEvent
-from nonebot.adapters.cqhttp.message import Message, MessageSegment
+from nonebot.matcher import Matcher
+from nonebot.params import ArgPlainText, CommandArg
+from nonebot.adapters.onebot.v11 import MessageEvent, Message, MessageSegment
from ATRI.config import SauceNAO
from ATRI.utils.limit import FreqLimiter
@@ -17,33 +17,22 @@ _search_flmt_notice = choice(["慢...慢一..点❤", "冷静1下", "歇会歇�
saucenao = SaouceNao().on_command("以图搜图", "透过一张图搜索可能的来源")
[email protected]_parser # type: ignore
-async def _get_img(bot: Bot, event: MessageEvent, state: T_State):
- msg = str(event.message).strip()
- quit_list = ["算了", "罢了", "不搜了"]
- if msg in quit_list:
- await saucenao.finish("好吧...")
- if not msg:
- await saucenao.reject("图呢？")
- else:
- state["img"] = msg
-
-
@saucenao.handle()
-async def _ready_search(bot: Bot, event: MessageEvent, state: T_State):
+async def _ready_search(
+ matcher: Matcher, event: MessageEvent, args: Message = CommandArg()
+):
user_id = event.get_user_id()
if not _search_flmt.check(user_id):
await saucenao.finish(_search_flmt_notice)
- msg = str(event.message).strip()
+ msg = args.extract_plain_text()
if msg:
- state["img"] = msg
+ matcher.set_arg("saucenao_img", args)
[email protected]("img", "图呢？")
-async def _deal_search(bot: Bot, event: MessageEvent, state: T_State):
[email protected]("saucenao_img", "图呢？")
+async def _deal_search(event: MessageEvent, msg: str = ArgPlainText("saucenao_img")):
user_id = event.get_user_id()
- msg = state["img"]
img = findall(r"url=(.*?)]", msg)
if not img:
await saucenao.reject("请发送图片而不是其他东西！！")
diff --git a/ATRI/plugins/setu/__init__.py b/ATRI/plugins/setu/__init__.py
index 244e030..6c135aa 100644
--- a/ATRI/plugins/setu/__init__.py
+++ b/ATRI/plugins/setu/__init__.py
@@ -1,10 +1,11 @@
import re
import asyncio
from random import choice
+
from nonebot.permission import SUPERUSER
-from nonebot.adapters.cqhttp import Bot, MessageEvent, Message
-from nonebot.adapters.cqhttp.message import MessageSegment
-from nonebot.typing import T_State
+from nonebot.matcher import Matcher
+from nonebot.params import CommandArg, ArgPlainText
+from nonebot.adapters.onebot.v11 import Bot, MessageEvent, Message, MessageSegment
from ATRI.config import BotSelfConfig
from ATRI.utils.limit import FreqLimiter, DailyLimiter
@@ -22,7 +23,7 @@ random_setu = Setu().on_command(
@random_setu.handle()
-async def _random_setu(bot: Bot, event: MessageEvent):
+async def _random_setu(bot: Bot, event: MessageEvent, matcher: Matcher, args: Message = CommandArg()):
user_id = event.get_user_id()
if not _setu_flmt.check(user_id):
await random_setu.finish()
@@ -44,12 +45,25 @@ async def _random_setu(bot: Bot, event: MessageEvent):
await asyncio.sleep(30)
await bot.delete_msg(message_id=event_id)
+ msg = args.extract_plain_text()
+ if msg:
+ matcher.set_arg("r_rush_after_think", args)
+
+@random_setu.got("r_rush_after_think")
+async def _(think: str = ArgPlainText("r_rush_after_think")):
+ is_repo = will_think(think)
+ if not is_repo:
+ await random_setu.finish()
+ else:
+ await random_setu.finish(is_repo)
+
+
tag_setu = Setu().on_regex(r"来[张点丶份](.*?)的[涩色🐍]图", "根据提供的tag查找涩图")
@tag_setu.handle()
-async def _tag_setu(bot: Bot, event: MessageEvent):
+async def _tag_setu(bot: Bot, event: MessageEvent, matcher: Matcher, args: Message = CommandArg()):
user_id = event.get_user_id()
if not _setu_flmt.check(user_id):
await random_setu.finish()
@@ -77,6 +91,19 @@ async def _tag_setu(bot: Bot, event: MessageEvent):
await asyncio.sleep(30)
await bot.delete_msg(message_id=event_id)
+ msg = args.extract_plain_text()
+ if msg:
+ matcher.set_arg("r_rush_after_think", args)
+
+
+@tag_setu.got("t_rush_after_think")
+async def _(think: str = ArgPlainText("t_rush_after_think")):
+ is_repo = will_think(think)
+ if not is_repo:
+ await random_setu.finish()
+ else:
+ await random_setu.finish(is_repo)
+
_catcher_max_file_size = 128
@@ -129,17 +156,16 @@ nsfw_checker = Setu().on_command("/nsfw", "涩值检测")
@nsfw_checker.handle()
-async def _nsfw_checker(bot: Bot, event: MessageEvent, state: T_State):
- msg = str(event.message).strip()
+async def _nsfw_checker(matcher: Matcher, args: Message = CommandArg()):
+ msg = args.extract_plain_text()
if msg:
- state["nsfw_img"] = msg
+ matcher.set_arg("nsfw_img", args)
@nsfw_checker.got("nsfw_img", "图呢？")
-async def _deal_check(bot: Bot, event: MessageEvent, state: T_State):
- msg = state["nsfw_img"]
+async def _deal_check(bot: Bot, img: str = ArgPlainText("nsfw_img")):
pattern = r"url=(.*?)]"
- args = re.findall(pattern, msg)
+ args = re.findall(pattern, img)
if not args:
await nsfw_checker.reject("请发送图片而不是其他东西！！")
@@ -167,16 +193,15 @@ catcher_setting = Setu().on_command("嗅探设置", "涩图检测图片文件大
@catcher_setting.handle()
-async def _catcher_setting(bot: Bot, event: MessageEvent, state: T_State):
- msg = str(event.message).strip()
+async def _catcher_setting(matcher: Matcher, args: Message = CommandArg()):
+ msg = args.extract_plain_text()
if msg:
- state["catcher_set"] = msg
+ matcher.set_arg("catcher_set", args)
@catcher_setting.got("catcher_set", "数值呢？（1对应1kb，默认128）")
-async def _deal_setting(bot: Bot, event: MessageEvent, state: T_State):
+async def _deal_setting(msg: str = ArgPlainText("catcher_set")):
global _catcher_max_file_size
- msg = state["catcher_set"]
try:
_catcher_max_file_size = int(msg)
except Exception:
@@ -205,3 +230,37 @@ async def _scheduler_setu(bot):
except Exception:
pass
+
+
+_ag_l = ["涩图来", "来点涩图", "来份涩图"]
+_ag_patt = r"来[张点丶份](.*?)的[涩色🐍]图"
+
+_nice_patt = r"[hH好][sS涩色][oO哦]|[嗯恩摁社蛇🐍射]了|(硬|石更)了|[牛🐂][牛🐂]要炸了|[炼恋]起来|开?导"
+_nope_patt = r"不够[涩色]|就这｜这也[是叫算]|[?？]"
+_again_patt = r"再来一张|不够"
+
+_nice_repo = ["w", "好诶！", "ohh", "(///w///)", "🥵", "我也"]
+_nope_repo = ["那你来发", "爱看不看", "你看不看吧", "看这种类型的涩图，是一件多么美妙的事情"]
+_again_repo = ["没了...", "自己找去"]
+
+
+def will_think(msg: str) -> str:
+ if msg in _ag_l:
+ return str()
+
+ ag_jud = re.findall(_ag_patt, msg)
+ if ag_jud:
+ return str()
+
+ nice_jud = re.findall(_nice_patt, msg)
+ nope_jud = re.findall(_nope_patt, msg)
+ again_jud = re.findall(_again_patt, msg)
+
+ if nice_jud:
+ return choice(_nice_repo)
+ elif nope_jud:
+ return choice(_nope_repo)
+ elif again_jud:
+ return choice(_again_repo)
+ else:
+ return str()
diff --git a/ATRI/plugins/setu/data_source.py b/ATRI/plugins/setu/data_source.py
index cca2767..a26bbef 100644
--- a/ATRI/plugins/setu/data_source.py
+++ b/ATRI/plugins/setu/data_source.py
@@ -1,16 +1,16 @@
-import base64
-
-# from pathlib import Path
from random import choice
-from nonebot.adapters.cqhttp import MessageSegment
+from nonebot.adapters.onebot.v11 import MessageSegment
from ATRI.service import Service
from ATRI.rule import is_in_service
from ATRI.utils import request
+from ATRI.config import Setu as ST
from .tf_dealer import detect_image
LOLICON_URL = "https://api.lolicon.app/setu/v2"
+DEFAULT_SETU = "https://i.pixiv.cat/img-original/img/2021/02/28/22/44/49/88124144_p0.jpg"
+
class Setu(Service):
@@ -31,9 +31,9 @@ class Setu(Service):
data: dict = temp_data[0]
title = data.get("title", "木陰のねこ")
p_id = data.get("pid", 88124144)
- url = data["urls"].get("original", "ignore")
+ url: str = data["urls"].get("original", "ignore")
- setu = MessageSegment.image(url, timeout=114514)
+ setu = MessageSegment.image(use_proxy(url), timeout=114514)
repo = f"Title: {title}\nPid: {p_id}"
return repo, setu
@@ -55,7 +55,7 @@ class Setu(Service):
p_id = data.get("pid", 88124144)
url = data["urls"].get(
"original",
- "https://i.pixiv.cat/img-original/img/2021/02/28/22/44/49/88124144_p0.jpg",
+ use_proxy(DEFAULT_SETU),
)
setu = MessageSegment.image(url, timeout=114514)
repo = f"Title: {title}\nPid: {p_id}"
@@ -87,8 +87,15 @@ class Setu(Service):
url = temp_data[0]["urls"].get(
"original",
- "https://i.pixiv.cat/img-original/img/2021/02/28/22/44/49/88124144_p0.jpg",
+ use_proxy(DEFAULT_SETU),
)
setu = MessageSegment.image(url, timeout=114514)
repo = f"是{tag}哦~❤\n{setu}"
return repo
+
+
+def use_proxy(url: str) -> str:
+ if ST.reverse_proxy:
+ return url.replace("i.pixiv.cat", ST.reverse_proxy_domain)
+ else:
+ return url
diff --git a/ATRI/plugins/setu/tf_dealer.py b/ATRI/plugins/setu/tf_dealer.py
index bf68020..f966636 100644
--- a/ATRI/plugins/setu/tf_dealer.py
+++ b/ATRI/plugins/setu/tf_dealer.py
@@ -1,7 +1,6 @@
import io
import os
import re
-import string
import asyncio
import skimage
import skimage.io
@@ -9,12 +8,8 @@ import numpy as np
from PIL import Image
from pathlib import Path
from sys import getsizeof
-from random import sample
-try:
- import tflite_runtime.interpreter as tf # type: ignore
-except Exception:
- import tensorflow as tf
+import tensorflow as tf
from ATRI.log import logger as log
from ATRI.utils import request
@@ -116,4 +111,5 @@ async def init_module():
raise WriteError("NSFW TF module init failed!")
-asyncio.get_event_loop().run_until_complete(init_module())
+loop = asyncio.get_event_loop()
+loop.create_task(init_module())
diff --git a/ATRI/plugins/status/__init__.py b/ATRI/plugins/status/__init__.py
index 359344b..06afa3b 100644
--- a/ATRI/plugins/status/__init__.py
+++ b/ATRI/plugins/status/__init__.py
@@ -1,5 +1,3 @@
-from nonebot.adapters.cqhttp import Bot, MessageEvent
-
from ATRI.utils.apscheduler import scheduler
from .data_source import IsSurvive
@@ -8,7 +6,7 @@ ping = IsSurvive().on_command("/ping", "检测bot简单信息处理速度")
@ping.handle()
-async def _ping(bot: Bot, event: MessageEvent):
+async def _ping():
await ping.finish(IsSurvive.ping())
@@ -16,7 +14,7 @@ status = IsSurvive().on_command("/status", "查看运行资源占用")
@status.handle()
-async def _status(bot: Bot, event: MessageEvent):
+async def _status():
msg, _ = IsSurvive.get_status()
await status.finish(msg)
diff --git a/ATRI/plugins/util/__init__.py b/ATRI/plugins/util/__init__.py
index 541ca1b..b67a988 100644
--- a/ATRI/plugins/util/__init__.py
+++ b/ATRI/plugins/util/__init__.py
@@ -1,8 +1,9 @@
import re
from random import choice, random
-from nonebot.typing import T_State
-from nonebot.adapters.cqhttp import Bot, MessageEvent
+from nonebot.matcher import Matcher
+from nonebot.params import CommandArg, ArgPlainText
+from nonebot.adapters.onebot.v11 import MessageEvent, Message
from ATRI.utils.limit import FreqLimiter
from .data_source import Encrypt, Utils, Yinglish
@@ -11,62 +12,36 @@ from .data_source import Encrypt, Utils, Yinglish
roll = Utils().on_command("/roll", "骰子~用法：1d10 或 2d10+2d10+more")
[email protected]_parser # type: ignore
-async def _get_roll(bot: Bot, event: MessageEvent, state: T_State):
- msg = str(event.message).strip()
- quit_list = ["算了", "罢了"]
- if msg in quit_list:
- await roll.finish("好吧...")
- if not msg:
- await roll.reject("参数呢？！格式：1d10 或 2d10+2d10+more")
- else:
- state["roll"] = msg
-
-
@roll.handle()
-async def _ready_roll(bot: Bot, event: MessageEvent, state: T_State):
- msg = str(event.message).strip()
+async def _ready_roll(matcher: Matcher, args: Message = CommandArg()):
+ msg = args.extract_plain_text()
if msg:
- state["roll"] = msg
+ matcher.set_arg("roll", args)
@roll.got("roll", "参数呢？！格式：1d10 或 2d10+2d10+more")
-async def _deal_roll(bot: Bot, event: MessageEvent, state: T_State):
- text = state["roll"]
- match = re.match(r"^([\dd+\s]+?)$", text)
+async def _deal_roll(roll_msg: str = ArgPlainText("roll")):
+ match = re.match(r"^([\dd+\s]+?)$", roll_msg)
if not match:
await roll.finish("阿——！参数不对！格式：1d10 或 2d10+2d10+more")
- msg = Utils().roll_dice(text)
+ msg = Utils().roll_dice(roll_msg)
await roll.finish(msg)
-encrypt_en = Utils().on_command("加密", "我们之前的秘密❤")
-
-
-@encrypt_en.args_parser # type: ignore
-async def _get_encr_en_text(bot: Bot, event: MessageEvent, state: T_State):
- msg = str(event.message).strip()
- quit_list = ["算了", "罢了"]
- if msg in quit_list:
- await roll.finish("好吧...")
- if not msg:
- await roll.reject("内容呢？！")
- else:
- state["encr_en_text"] = msg
+encrypt_en = Utils().on_command("加密", "我们之间的秘密❤")
@encrypt_en.handle()
-async def _ready_en(bot: Bot, event: MessageEvent, state: T_State):
- msg = str(event.message).strip()
+async def _ready_en(matcher: Matcher, args: Message = CommandArg()):
+ msg = args.extract_plain_text()
if msg:
- state["encr_en_text"] = msg
+ matcher.set_arg("encr_en_text", args)
@encrypt_en.got("encr_en_text", "内容呢？！")
-async def _deal_en(bot: Bot, event: MessageEvent, state: T_State):
- text = state["encr_en_text"]
+async def _deal_en(text: str = ArgPlainText("encr_en_text")):
is_ok = len(text)
if is_ok < 10:
await encrypt_en.reject("太短不加密！")
@@ -78,28 +53,15 @@ async def _deal_en(bot: Bot, event: MessageEvent, state: T_State):
encrypt_de = Utils().on_command("解密", "解开我们的秘密❤")
-@encrypt_de.args_parser # type: ignore
-async def _get_encr_de_text(bot: Bot, event: MessageEvent, state: T_State):
- msg = str(event.message).strip()
- quit_list = ["算了", "罢了"]
- if msg in quit_list:
- await encrypt_de.finish("好吧...")
- if not msg:
- await encrypt_de.reject("内容呢？！")
- else:
- state["encr_de_text"] = msg
-
-
@encrypt_de.handle()
-async def _ready_de(bot: Bot, event: MessageEvent, state: T_State):
- msg = str(event.message).strip()
+async def _ready_de(matcher: Matcher, args: Message = CommandArg()):
+ msg = args.extract_plain_text()
if msg:
- state["encr_de_text"] = msg
+ matcher.set_arg("encr_de_text", args)
@encrypt_de.got("encr_de_text", "内容呢？！")
-async def _deal_de(bot: Bot, event: MessageEvent, state: T_State):
- text = state["encr_de_text"]
+async def _deal_de(text: str = ArgPlainText("encr_de_text")):
en = Encrypt()
result = en.decode(text)
await encrypt_de.finish(result)
@@ -111,33 +73,22 @@ _sepi_flmt = FreqLimiter(3)
_sepi_flmt_notice = ["涩批爬", "✌🥵✌"]
[email protected]_parser # type: ignore
-async def _get_sepi(bot: Bot, event: MessageEvent, state: T_State):
- msg = str(event.message).strip()
- quit_list = ["算了", "罢了", "取消"]
- if msg in quit_list:
- await sepi.finish("好吧...")
- if not msg:
- await sepi.reject("内容呢？！")
- else:
- state["sepi_text"] = msg
-
-
@sepi.handle()
-async def _ready_sepi(bot: Bot, event: MessageEvent, state: T_State):
+async def _ready_sepi(
+ matcher: Matcher, event: MessageEvent, args: Message = CommandArg()
+):
user_id = event.get_user_id()
if not _sepi_flmt.check(user_id):
await sepi.finish(choice(_sepi_flmt_notice))
- msg = str(event.message).strip()
+ msg = args.extract_plain_text()
if msg:
- state["sepi_text"] = msg
+ matcher.set_arg("sepi_text", args)
@sepi.got("sepi_text", "内容呢？！")
-async def _deal_sepi(bot: Bot, event: MessageEvent, state: T_State):
+async def _deal_sepi(event: MessageEvent, msg: str = ArgPlainText("sepi_text")):
user_id = event.get_user_id()
- msg = state["sepi_text"]
if len(msg) < 4:
await sepi.finish("这么短？涩不起来！")
diff --git a/ATRI/plugins/wife/__init__.py b/ATRI/plugins/wife/__init__.py
index 57a5af2..b69315d 100644
--- a/ATRI/plugins/wife/__init__.py
+++ b/ATRI/plugins/wife/__init__.py
@@ -3,9 +3,10 @@ from random import choice
from pydantic import BaseModel
from nonebot.rule import Rule
-from nonebot.typing import T_State
+from nonebot.matcher import Matcher
+from nonebot.params import CommandArg, ArgPlainText
from nonebot.permission import SUPERUSER
-from nonebot.adapters.cqhttp import Bot, MessageEvent, GroupMessageEvent, Message
+from nonebot.adapters.onebot.v11 import Bot, MessageEvent, GroupMessageEvent, Message
from ATRI.utils.limit import FreqLimiter
from .data_source import Wife
@@ -25,7 +26,7 @@ tietie_superuser = Wife().on_message(
@tietie_superuser.handle()
-async def _tietie_superuser(bot: Bot, event: MessageEvent):
+async def _tietie_superuser(event: MessageEvent):
if not _is_tietie:
await tietie_superuser.finish()
@@ -38,25 +39,21 @@ async def _tietie_superuser(bot: Bot, event: MessageEvent):
await tietie_superuser.finish(Message(result))
-no_tietie = Wife().on_command(
- "不可以贴", docs="拒绝贴贴", rule=Rule(), permission=SUPERUSER, block=False
-)
+no_tietie = Wife().on_command("不可以贴", docs="拒绝贴贴", rule=Rule(), permission=SUPERUSER)
@no_tietie.handle()
-async def _no_tietie(bot: Bot, event: MessageEvent):
+async def _no_tietie():
global _is_tietie
_is_tietie = False
await no_tietie.finish("好吧...")
-yes_tietie = Wife().on_command(
- "来贴贴", docs="继续贴贴", rule=Rule(), permission=SUPERUSER, block=False
-)
+yes_tietie = Wife().on_command("来贴贴", docs="继续贴贴", rule=Rule(), permission=SUPERUSER)
@yes_tietie.handle()
-async def _yes_tietie(bot: Bot, event: MessageEvent):
+async def _yes_tietie():
global _is_tietie
_is_tietie = True
await yes_tietie.finish("好欸！")
@@ -117,7 +114,7 @@ async def _get_wife(bot: Bot, event: GroupMessageEvent):
name=req_user_card, sex=is_nick, wife=user_id
).dict()
data[user_id] = MarryInfo(
- name=lucky_user_card, sex=lucky_user_sex, wife=lucky_user
+ name=lucky_user_card, sex=lucky_user_sex, wife=str(lucky_user)
).dict()
Wife().save_marry_list(data)
@@ -133,7 +130,7 @@ call_wife = Wife().on_command("老婆", "呼唤老婆/老公！", aliases={"老�
@call_wife.handle()
-async def _call_wife(bot: Bot, event: MessageEvent):
+async def _call_wife(event: MessageEvent):
user_id = event.get_user_id()
if not _wife_flmt.check(user_id):
await call_wife.finish()
@@ -154,7 +151,9 @@ discard_wife = Wife().on_command("我要离婚", "离婚！")
@discard_wife.handle()
-async def _discard_wife(bot: Bot, event: GroupMessageEvent, state: T_State):
+async def _discard_wife(
+ matcher: Matcher, event: GroupMessageEvent, args: Message = CommandArg()
+):
user_id = event.get_user_id()
if not _wife_flmt.check(user_id):
await discard_wife.finish()
@@ -163,19 +162,20 @@ async def _discard_wife(bot: Bot, event: GroupMessageEvent, state: T_State):
if user_id not in data:
await discard_wife.finish("你还没对象呐...")
- msg = str(event.message).strip()
+ msg = args.extract_plain_text()
if msg:
- state["is_disc"] = msg
+ matcher.set_arg("is_disc", args)
@discard_wife.got("is_disc", "真的吗...（y/是）")
-async def _deal_discard(bot: Bot, event: GroupMessageEvent, state: T_State):
- msg = state["is_disc"]
+async def _deal_discard(
+ bot: Bot, event: GroupMessageEvent, is_disc: str = ArgPlainText("is_disc")
+):
rd_list = ["y", "Y", "是", "确认", "对"]
user_id = event.get_user_id()
group_id = event.group_id
- if msg not in rd_list:
+ if is_disc not in rd_list:
user_info = await bot.get_group_member_info(
group_id=group_id, user_id=int(user_id)
)
diff --git a/ATRI/plugins/wife/data_source.py b/ATRI/plugins/wife/data_source.py
index 670f862..29d58e7 100644
--- a/ATRI/plugins/wife/data_source.py
+++ b/ATRI/plugins/wife/data_source.py
@@ -2,7 +2,7 @@ import os
import json
from random import choice
from pathlib import Path
-from nonebot.adapters.cqhttp import MessageSegment
+from nonebot.adapters.onebot.v11 import MessageSegment
from ATRI.service import Service
from ATRI.rule import is_in_service
Powered by cgit, Theme cgit-dark created by Ted Yin, updated by Mole Shang.