2021-10-24 10:55:45 +00:00
|
|
|
|
import asyncio
|
2021-08-07 07:56:48 +00:00
|
|
|
|
import re
|
2021-08-02 15:35:45 +00:00
|
|
|
|
import traceback
|
2021-08-30 18:53:39 +00:00
|
|
|
|
from typing import List
|
2021-08-02 15:35:45 +00:00
|
|
|
|
|
|
|
|
|
import discord
|
2021-08-07 07:56:48 +00:00
|
|
|
|
|
2021-08-02 15:35:45 +00:00
|
|
|
|
from core.bots.discord.client import client
|
2021-10-24 10:55:45 +00:00
|
|
|
|
from core.elements import Plain, Image, MessageSession as MS, MsgInfo, Session, FetchTarget as FT, ExecutionLockList
|
2021-08-02 15:35:45 +00:00
|
|
|
|
from core.elements.others import confirm_command
|
2021-08-30 18:53:39 +00:00
|
|
|
|
from database import BotDBUtil
|
2021-08-02 15:35:45 +00:00
|
|
|
|
|
|
|
|
|
|
2021-09-10 18:05:27 +00:00
|
|
|
|
def convert2lst(s) -> list:
|
|
|
|
|
if isinstance(s, str):
|
|
|
|
|
return [Plain(s)]
|
|
|
|
|
elif isinstance(s, list):
|
|
|
|
|
return s
|
|
|
|
|
elif isinstance(s, tuple):
|
|
|
|
|
return list(s)
|
|
|
|
|
|
|
|
|
|
|
2021-08-07 07:56:48 +00:00
|
|
|
|
class MessageSession(MS):
|
2021-08-02 15:35:45 +00:00
|
|
|
|
class Feature:
|
|
|
|
|
image = True
|
|
|
|
|
voice = False
|
2021-10-11 14:45:28 +00:00
|
|
|
|
forward = False
|
2021-11-16 14:19:48 +00:00
|
|
|
|
delete = True
|
2021-08-02 15:35:45 +00:00
|
|
|
|
|
|
|
|
|
async def sendMessage(self, msgchain, quote=True):
|
|
|
|
|
if isinstance(msgchain, str):
|
|
|
|
|
if msgchain == '':
|
2021-08-24 06:49:35 +00:00
|
|
|
|
msgchain = '发生错误:机器人尝试发送空文本消息,请联系机器人开发者解决问题。\n错误汇报地址:https://github.com/Teahouse-Studios/bot/issues/new?assignees=OasisAkari&labels=bug&template=5678.md&title='
|
2021-08-23 12:44:31 +00:00
|
|
|
|
send = await self.session.target.send(msgchain,
|
|
|
|
|
reference=self.session.message if quote and self.session.message else None)
|
2021-10-09 13:32:54 +00:00
|
|
|
|
elif isinstance(msgchain, (list, tuple)):
|
2021-08-02 15:35:45 +00:00
|
|
|
|
count = 0
|
2021-10-09 13:32:54 +00:00
|
|
|
|
send = []
|
2021-08-02 15:35:45 +00:00
|
|
|
|
for x in msgchain:
|
|
|
|
|
if isinstance(x, Plain):
|
2021-10-09 13:32:54 +00:00
|
|
|
|
send_ = await self.session.target.send(x.text,
|
|
|
|
|
reference=self.session.message if quote and count == 0
|
|
|
|
|
and self.session.message else None)
|
|
|
|
|
elif isinstance(x, Image):
|
|
|
|
|
send_ = await self.session.target.send(file=discord.File(await x.get()),
|
|
|
|
|
reference=self.session.message if quote and count == 0
|
|
|
|
|
and self.session.message else None)
|
|
|
|
|
else:
|
|
|
|
|
send_ = False
|
|
|
|
|
if send_:
|
|
|
|
|
send.append(send_)
|
2021-08-14 13:10:52 +00:00
|
|
|
|
count += 1
|
2021-10-09 13:32:54 +00:00
|
|
|
|
else:
|
|
|
|
|
msgchain = '发生错误:机器人尝试发送非法消息链,请联系机器人开发者解决问题。\n错误汇报地址:https://github.com/Teahouse-Studios/bot/issues/new?assignees=OasisAkari&labels=bug&template=5678.md&title='
|
|
|
|
|
send = await self.session.target.send(msgchain,
|
|
|
|
|
reference=self.session.message if quote and self.session.message else None)
|
|
|
|
|
return MessageSession(target=MsgInfo(targetId=0, senderId=0, senderName='', targetFrom='Discord|Bot',
|
|
|
|
|
senderFrom='Discord|Bot'),
|
2021-10-16 05:15:55 +00:00
|
|
|
|
session=Session(message=send, target=self.session.target, sender=self.session.sender))
|
2021-08-02 15:35:45 +00:00
|
|
|
|
|
2021-09-10 18:05:27 +00:00
|
|
|
|
async def waitConfirm(self, msgchain=None, quote=True):
|
2021-10-24 10:55:45 +00:00
|
|
|
|
ExecutionLockList.remove(self)
|
2021-11-12 14:25:53 +00:00
|
|
|
|
|
2021-08-02 15:35:45 +00:00
|
|
|
|
def check(m):
|
|
|
|
|
return m.channel == self.session.message.channel and m.author == self.session.message.author
|
2021-10-09 13:32:54 +00:00
|
|
|
|
|
2021-09-10 18:05:27 +00:00
|
|
|
|
send = None
|
|
|
|
|
if msgchain is not None:
|
|
|
|
|
msgchain = convert2lst(msgchain)
|
|
|
|
|
msgchain.append(Plain('(发送“是”或符合确认条件的词语来确认)'))
|
|
|
|
|
send = await self.sendMessage(msgchain, quote)
|
2021-08-02 15:35:45 +00:00
|
|
|
|
msg = await client.wait_for('message', check=check)
|
2021-10-07 15:54:37 +00:00
|
|
|
|
if send is not None:
|
2021-09-10 18:05:27 +00:00
|
|
|
|
await send.delete()
|
2021-08-02 15:35:45 +00:00
|
|
|
|
return True if msg.content in confirm_command else False
|
|
|
|
|
|
2021-08-14 15:26:10 +00:00
|
|
|
|
async def checkPermission(self):
|
2021-08-07 07:56:48 +00:00
|
|
|
|
if self.session.message.channel.permissions_for(self.session.message.author).administrator \
|
|
|
|
|
or isinstance(self.session.message.channel, discord.DMChannel) \
|
2021-08-02 15:35:45 +00:00
|
|
|
|
or self.target.senderInfo.query.isSuperUser \
|
|
|
|
|
or self.target.senderInfo.check_TargetAdmin(self.target.targetId):
|
|
|
|
|
return True
|
|
|
|
|
return False
|
|
|
|
|
|
|
|
|
|
def checkSuperUser(self):
|
|
|
|
|
return True if self.target.senderInfo.query.isSuperUser else False
|
|
|
|
|
|
|
|
|
|
def asDisplay(self):
|
|
|
|
|
return self.session.message.content
|
|
|
|
|
|
2021-10-24 10:55:45 +00:00
|
|
|
|
async def sleep(self, s):
|
|
|
|
|
ExecutionLockList.remove(self)
|
|
|
|
|
await asyncio.sleep(s)
|
|
|
|
|
|
2021-08-02 15:35:45 +00:00
|
|
|
|
async def delete(self):
|
|
|
|
|
try:
|
|
|
|
|
if isinstance(self.session.message, list):
|
|
|
|
|
for x in self.session.message:
|
|
|
|
|
await x.delete()
|
|
|
|
|
else:
|
|
|
|
|
await self.session.message.delete()
|
2021-08-23 12:44:31 +00:00
|
|
|
|
except Exception:
|
2021-08-02 15:35:45 +00:00
|
|
|
|
traceback.print_exc()
|
|
|
|
|
|
|
|
|
|
class Typing:
|
2021-08-07 07:56:48 +00:00
|
|
|
|
def __init__(self, msg: MS):
|
2021-08-02 15:35:45 +00:00
|
|
|
|
self.msg = msg
|
|
|
|
|
|
|
|
|
|
async def __aenter__(self):
|
|
|
|
|
async with self.msg.session.target.typing() as typing:
|
|
|
|
|
return typing
|
|
|
|
|
|
|
|
|
|
async def __aexit__(self, exc_type, exc_val, exc_tb):
|
2021-08-07 07:56:48 +00:00
|
|
|
|
pass
|
|
|
|
|
|
|
|
|
|
|
2021-08-21 15:58:07 +00:00
|
|
|
|
class FetchTarget(FT):
|
2021-08-07 07:56:48 +00:00
|
|
|
|
@staticmethod
|
2021-08-30 18:53:39 +00:00
|
|
|
|
async def fetch_target(targetId) -> MessageSession:
|
2021-08-22 14:55:25 +00:00
|
|
|
|
matchChannel = re.match(r'^(Discord\|(?:DM\||)Channel)\|(.*)', targetId)
|
2021-08-07 07:56:48 +00:00
|
|
|
|
if matchChannel:
|
2021-08-22 14:55:25 +00:00
|
|
|
|
getChannel = await client.fetch_channel(int(matchChannel.group(2)))
|
2021-08-07 07:56:48 +00:00
|
|
|
|
return MessageSession(MsgInfo(targetId=targetId, senderId=targetId, senderName='',
|
|
|
|
|
targetFrom=matchChannel.group(1), senderFrom=matchChannel.group(1)),
|
|
|
|
|
Session(message=False, target=getChannel, sender=getChannel))
|
|
|
|
|
else:
|
|
|
|
|
return False
|
2021-08-30 18:53:39 +00:00
|
|
|
|
|
2021-10-08 11:54:27 +00:00
|
|
|
|
@staticmethod
|
|
|
|
|
async def fetch_target_list(targetList: list) -> List[MessageSession]:
|
|
|
|
|
lst = []
|
|
|
|
|
for x in targetList:
|
|
|
|
|
fet = await FetchTarget.fetch_target(x)
|
|
|
|
|
if fet:
|
|
|
|
|
lst.append(fet)
|
|
|
|
|
return lst
|
|
|
|
|
|
2021-08-30 18:53:39 +00:00
|
|
|
|
@staticmethod
|
|
|
|
|
async def post_message(module_name, message, user_list: List[MessageSession] = None):
|
|
|
|
|
send_list = []
|
|
|
|
|
if user_list is not None:
|
|
|
|
|
for x in user_list:
|
|
|
|
|
try:
|
|
|
|
|
send = await x.sendMessage(message)
|
|
|
|
|
send_list.append(send)
|
|
|
|
|
except Exception:
|
|
|
|
|
traceback.print_exc()
|
|
|
|
|
else:
|
|
|
|
|
get_target_id = BotDBUtil.Module.get_enabled_this(module_name)
|
|
|
|
|
for x in get_target_id:
|
|
|
|
|
fetch = await FetchTarget.fetch_target(x)
|
|
|
|
|
if fetch:
|
|
|
|
|
try:
|
|
|
|
|
send = await fetch.sendMessage(message, quote=False)
|
|
|
|
|
send_list.append(send)
|
|
|
|
|
except Exception:
|
2021-09-03 19:19:07 +00:00
|
|
|
|
traceback.print_exc()
|
|
|
|
|
return send_list
|