Compare commits
No commits in common. "main" and "check" have entirely different histories.
2
.gitignore
vendored
2
.gitignore
vendored
|
@ -2,4 +2,4 @@
|
||||||
config.toml
|
config.toml
|
||||||
.vs
|
.vs
|
||||||
.vscode
|
.vscode
|
||||||
__pycache__
|
.idea
|
|
@ -1,4 +1,4 @@
|
||||||
|
|
||||||
private_key = "" # 与 icalingua 客户端使用的 private_key 一致
|
private_key = "" # 与 icalingua 客户端使用的 private_key 一致
|
||||||
host = "" # docker 版 icalingua 服务的地址
|
host = " " # docker 版 icalingua 服务的地址
|
||||||
self_id = 0 # 机器人的 qq 号
|
self_id = 0 # 机器人的 qq 号
|
||||||
|
|
49
connect.py
49
connect.py
|
@ -15,8 +15,10 @@ from mcstatus import JavaServer
|
||||||
# 功能包引用处
|
# 功能包引用处
|
||||||
from module import hitokoto
|
from module import hitokoto
|
||||||
|
|
||||||
|
|
||||||
# 功能包结束引用
|
# 功能包结束引用
|
||||||
|
|
||||||
|
# 读取配置
|
||||||
def get_config() -> Tuple[str, str, int]:
|
def get_config() -> Tuple[str, str, int]:
|
||||||
with open('config.toml', 'r', encoding='utf-8') as f:
|
with open('config.toml', 'r', encoding='utf-8') as f:
|
||||||
config = qtoml.load(f)
|
config = qtoml.load(f)
|
||||||
|
@ -85,7 +87,7 @@ async def require_auth(salt: str, versions: Dict[str, str]):
|
||||||
# 准备数据
|
# 准备数据
|
||||||
sign = SigningKey(bytes.fromhex(KEY))
|
sign = SigningKey(bytes.fromhex(KEY))
|
||||||
signature = sign.sign(bytes.fromhex(salt))
|
signature = sign.sign(bytes.fromhex(salt))
|
||||||
|
|
||||||
# 发送数据
|
# 发送数据
|
||||||
print(f"{len(signature.signature)=} {type(signature.signature)=}")
|
print(f"{len(signature.signature)=} {type(signature.signature)=}")
|
||||||
await sio.emit('auth', signature.signature)
|
await sio.emit('auth', signature.signature)
|
||||||
|
@ -182,8 +184,10 @@ def safe_eval(code: str) -> str:
|
||||||
return result
|
return result
|
||||||
|
|
||||||
|
|
||||||
|
# 获取到新的消息
|
||||||
@sio.on('addMessage')
|
@sio.on('addMessage')
|
||||||
async def add_message(data: Dict[str, Any]):
|
async def add_message(data: Dict[str, Any]):
|
||||||
|
|
||||||
print(f"{Fore.MAGENTA}add_message: {data}{Style.RESET_ALL}")
|
print(f"{Fore.MAGENTA}add_message: {data}{Style.RESET_ALL}")
|
||||||
|
|
||||||
is_self = data['message']['senderId'] == SELF_ID
|
is_self = data['message']['senderId'] == SELF_ID
|
||||||
|
@ -194,33 +198,37 @@ async def add_message(data: Dict[str, Any]):
|
||||||
reply = ReplyMessage(id=data['message']['_id'])
|
reply = ReplyMessage(id=data['message']['_id'])
|
||||||
|
|
||||||
if not is_self:
|
if not is_self:
|
||||||
|
# /bot
|
||||||
if data.get('message').get('content') == '/bot':
|
if data.get('message').get('content') == '/bot':
|
||||||
message = Message(content='icalingua bot test',
|
message = Message(content='icalingua bot test',
|
||||||
room_id=data['roomId'])
|
room_id=data['roomId'])
|
||||||
await sio.emit('sendMessage', message.to_json())
|
await sio.emit('sendMessage', message.to_json())
|
||||||
|
|
||||||
|
# !!status
|
||||||
elif content == '!!status':
|
elif content == '!!status':
|
||||||
server = JavaServer.lookup("192.168.1.6:25565")
|
server = JavaServer.lookup("192.168.1.6:25565")
|
||||||
status=server.status()
|
status=server.status()
|
||||||
# query = server.query()
|
# query = server.query()
|
||||||
|
|
||||||
# if status.players.online != 0:
|
# if status.players.online != 0:
|
||||||
# message = Message(content=f"此服务器有 {status.players.online} 个玩家在线\n当前在线玩家有 {.join(query.players.names)}",room_id=data['roomId'])
|
# message = Message(content=f"此服务器有 {status.players.online} 个玩家在线\n当前在线玩家有 {.join(query.players.names)}",room_id=data['roomId'])
|
||||||
# else:
|
# else:
|
||||||
# message = Message(content=f"此服务器空无一人",room_id=data['roomId'])
|
# message = Message(content=f"此服务器空无一人",room_id=data['roomId'])
|
||||||
|
|
||||||
message = Message(content=f"此服务器有 {status.players.online} 个玩家在线",reply_to=reply,room_id=data['roomId'])
|
message = Message(content=f"此服务器有 {status.players.online} 个玩家在线",reply_to=reply,room_id=data['roomId'])
|
||||||
|
|
||||||
await sio.emit('sendMessage', message.to_json())
|
await sio.emit('sendMessage', message.to_json())
|
||||||
|
|
||||||
|
# !!players
|
||||||
elif content == '!!players':
|
elif content == '!!players':
|
||||||
server = JavaServer.lookup("192.168.1.6:25565")
|
server = JavaServer.lookup("192.168.1.6:25565")
|
||||||
query = server.query()
|
query = server.query()
|
||||||
players = query.players.names
|
players = query.players.names
|
||||||
message = Message(content=f"此服务器当前在线玩家有 {players}",reply_to=reply,room_id=data['roomId'])
|
message = Message(content=f"此服务器当前在线玩家有 {players}",reply_to=reply,room_id=data['roomId'])
|
||||||
|
|
||||||
await sio.emit('sendMessage', message.to_json())
|
await sio.emit('sendMessage', message.to_json())
|
||||||
|
|
||||||
|
# !!hitokoto
|
||||||
elif content.startswith("!!hitokoto"):
|
elif content.startswith("!!hitokoto"):
|
||||||
|
|
||||||
ctypet = content[len("!!hitokoto "):]
|
ctypet = content[len("!!hitokoto "):]
|
||||||
|
@ -242,6 +250,7 @@ async def add_message(data: Dict[str, Any]):
|
||||||
|
|
||||||
await sio.emit('sendMessage', message.to_json())
|
await sio.emit('sendMessage', message.to_json())
|
||||||
|
|
||||||
|
# 未知
|
||||||
elif data.get('message').get('content').startswith('=='):
|
elif data.get('message').get('content').startswith('=='):
|
||||||
|
|
||||||
evals: str = data.get('message').get('content')[2:]
|
evals: str = data.get('message').get('content')[2:]
|
||||||
|
@ -276,24 +285,18 @@ async def add_message(data: Dict[str, Any]):
|
||||||
|
|
||||||
await asyncio.sleep(random.random() * 2)
|
await asyncio.sleep(random.random() * 2)
|
||||||
await sio.emit('sendMessage', message.to_json())
|
await sio.emit('sendMessage', message.to_json())
|
||||||
|
|
||||||
|
# !!jrrp
|
||||||
elif data['message']['content'] == '!!jrrp':
|
elif data['message']['content'] == '!!jrrp':
|
||||||
examSet = False
|
randomer = random.Random(f'{sender_id}-{data["message"]["date"]}-jrrp-v2')
|
||||||
if examSet == True:
|
result = randomer.randint(0, 50) + randomer.randint(0, 50)
|
||||||
print('examSet参数被设定,替换人品值')
|
print(f'{sender_name} 今日人品值为 {result}')
|
||||||
message = Message(content=f'{sender_name} 今日人品值为 100\n为了让你安心备考,加油考试,今天你的人品值是100!',
|
message = Message(content=f'{sender_name} 今日人品值为 {result}',
|
||||||
reply_to=reply,
|
reply_to=reply,
|
||||||
room_id=room_id)
|
room_id=room_id)
|
||||||
await asyncio.sleep(0.5)
|
await asyncio.sleep(0.5)
|
||||||
await sio.emit('sendMessage', message.to_json())
|
await sio.emit('sendMessage', message.to_json())
|
||||||
else:
|
|
||||||
randomer = random.Random(f'{sender_id}-{data["message"]["date"]}-jrrp-v2')
|
|
||||||
result = randomer.randint(0, 50) + randomer.randint(0, 50)
|
|
||||||
print(f'{sender_name} 今日人品值为 {result}')
|
|
||||||
message = Message(content=f'{sender_name} 今日人品值为 {result}',
|
|
||||||
reply_to=reply,
|
|
||||||
room_id=room_id)
|
|
||||||
await asyncio.sleep(0.5)
|
|
||||||
await sio.emit('sendMessage', message.to_json())
|
|
||||||
# 如果只包括一个或多个 6
|
# 如果只包括一个或多个 6
|
||||||
# elif data['message']['content'].replace(' ', '') in ('6', '666', '六', '3+3', '5+1', '4+2', '2+4', '1+5'):
|
# elif data['message']['content'].replace(' ', '') in ('6', '666', '六', '3+3', '5+1', '4+2', '2+4', '1+5'):
|
||||||
# reply = ReplyMessage(id=data['message']['_id'])
|
# reply = ReplyMessage(id=data['message']['_id'])
|
||||||
|
|
BIN
module/hitokoto/__pycache__/__init__.cpython-311.pyc
Normal file
BIN
module/hitokoto/__pycache__/__init__.cpython-311.pyc
Normal file
Binary file not shown.
BIN
module/hitokoto/__pycache__/__init__.cpython-39.pyc
Normal file
BIN
module/hitokoto/__pycache__/__init__.cpython-39.pyc
Normal file
Binary file not shown.
Loading…
Reference in New Issue
Block a user