xtex/akari-bot
Archived
1
0
Fork 0
Code Issues Pull requests Activity

update subbot to graia

Browse source
This commit is contained in:
yzhh 2020-08-19 12:41:47 +08:00
parent 689f515700
commit 3fed576b5a
6 changed files with 75 additions and 38 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
.gitignore vendored
View file

@ -3,3 +3,5 @@
*.pyc
config/config.cfg
.idea
mcversion.txt
mcvrss.txt

48
mcvbot.py
View file

@ -1,31 +1,49 @@
from mirai import Mirai, Plain
import asyncio
import traceback
qq = 2052142661 # 字段 qq 的值
authKey = '1145141919810' # 字段 authKey 的值
mirai_api_http_locate = 'localhost:11919/ws' # httpapi所在主机的地址端口,如果 setting.yml 文件里字段 "enableWebsocket" 的值为 "true" 则需要将 "/" 换成 "/ws", 否则将接收不到消息.
from graia.application import GraiaMiraiApplication, Session
from graia.application.message.chain import MessageChain
from graia.application.message.elements.internal import Plain
from graia.broadcast import Broadcast
app = Mirai(f"mirai://{mirai_api_http_locate}?authKey={authKey}&qq={qq}", websocket=True)
loop = asyncio.get_event_loop()
bcc = Broadcast(loop=loop, debug_flag=True)
app = GraiaMiraiApplication(
broadcast=bcc,
connect_info=Session(
host="http://localhost:11919", # 填入 httpapi 服务运行的地址
authKey='1145141919810', # 填入 authKey
account=2052142661, # 你的机器人的 qq 号
websocket=True # Graia 已经可以根据所配置的消息接收的方式来保证消息接收部分的正常运作.
)
)
import aiohttp
async def get_data(url: str, fmt: str):
async with aiohttp.ClientSession() as session:
async with session.get(url, timeout=aiohttp.ClientTimeout(total=20)) as req:
if hasattr(req, fmt):
return await getattr(req, fmt)()
else:
raise ValueError(f"NoSuchMethod: {fmt}")
@app.subroutine
async def ver(app: Mirai):
@bcc.receiver("ApplicationLaunched")
async def ver(app: GraiaMiraiApplication):
from modules.mcvrss import mcvrss
for qqgroup in mcvrss():
try:
await app.sendGroupMessage(int(qqgroup), [Plain('已开启检测游戏版本。')])
await app.sendGroupMessage(int(qqgroup), MessageChain.create([Plain('已开启检测游戏版本。')]).asSendable())
except Exception as e:
traceback.print_exc()
print(str(e))
from mcversion import mcversion
import time
import requests
import json
url = 'http://launchermeta.mojang.com/mc/game/version_manifest.json'
while True:
try:
verlist = mcversion()
version_manifest = requests.get(url)
file = json.loads(version_manifest.text)
file = await get_data(url,'json')
release = file['latest']['release']
snapshot = file['latest']['snapshot']
if release in verlist:
@ -33,7 +51,7 @@ async def ver(app: Mirai):
else:
for qqgroup in mcvrss():
try:
await app.sendGroupMessage(int(qqgroup), [Plain('启动器已更新' + file['latest']['release'] + '正式版。')])
await app.sendGroupMessage(int(qqgroup), MessageChain.create([Plain('启动器已更新' + file['latest']['release'] + '正式版。')]).asSendable())
except Exception as e:
print(str(e))
addversion = open('mcversion.txt', 'a')
@ -44,7 +62,7 @@ async def ver(app: Mirai):
else:
for qqgroup in mcvrss():
try:
await app.sendGroupMessage(int(qqgroup), [Plain('启动器已更新' + file['latest']['snapshot'] + '快照。')])
await app.sendGroupMessage(int(qqgroup), MessageChain.create([Plain('启动器已更新' + file['latest']['snapshot'] + '快照。')]).asSendable())
except Exception as e:
print(str(e))
addversion = open('mcversion.txt', 'a')
@ -58,4 +76,4 @@ async def ver(app: Mirai):
if __name__ == "__main__":
app.run()
app.launch_blocking()

2
mcversion.txt
View file

@ -1,2 +0,0 @@
1.16.1
20w30a

1
mcvrss.txt
View file

@ -1 +0,0 @@
657876815

4
modules/mcvrss.py
View file

@ -1,9 +1,9 @@
import os
import re
from os.path import abspath
def mcvrss():
w = open('../mcvrss.txt', 'r')
w = open(abspath('./mcvrss.txt'), 'r')
s = w.read().split('\n')
if '' in s:
s.remove('')

56
newbiebot.py
View file

@ -1,28 +1,48 @@
import json
import requests
import asyncio
import time
import traceback
from mirai import Mirai, Plain
from graia.application import GraiaMiraiApplication, Session
from graia.application.message.chain import MessageChain
from graia.application.message.elements.internal import Plain
from graia.broadcast import Broadcast
from modules.UTC8 import UTC8
from modules.pbc import pbc1
qq = 2052142661 # 字段 qq 的值
authKey = '1145141919810' # 字段 authKey 的值
mirai_api_http_locate = 'localhost:11919/ws' # httpapi所在主机的地址端口,如果 setting.yml 文件里字段 "enableWebsocket" 的值为 "true" 则需要将 "/" 换成 "/ws", 否则将接收不到消息.
loop = asyncio.get_event_loop()
app = Mirai(f"mirai://{mirai_api_http_locate}?authKey={authKey}&qq={qq}", websocket=True)
bcc = Broadcast(loop=loop, debug_flag=True)
app = GraiaMiraiApplication(
broadcast=bcc,
connect_info=Session(
host="http://localhost:11919", # 填入 httpapi 服务运行的地址
authKey='1145141919810', # 填入 authKey
account=2052142661, # 你的机器人的 qq 号
websocket=True # Graia 已经可以根据所配置的消息接收的方式来保证消息接收部分的正常运作.
)
)
import aiohttp
@app.subroutine
async def newbie(app: Mirai):
async def get_data(url: str, fmt: str):
async with aiohttp.ClientSession() as session:
async with session.get(url, timeout=aiohttp.ClientTimeout(total=20)) as req:
if hasattr(req, fmt):
return await getattr(req, fmt)()
else:
raise ValueError(f"NoSuchMethod: {fmt}")
@bcc.receiver("ApplicationLaunched")
async def newbie(app: GraiaMiraiApplication):
try:
await app.sendGroupMessage(731397727, [Plain('开始检测新人。')])
await app.sendGroupMessage(731397727, MessageChain.create([Plain('开始检测新人。')]).asSendable())
url = 'https://minecraft-zh.gamepedia.com/api.php?action=query&list=logevents&letype=newusers&format=json'
while True:
try:
q = requests.get(url, timeout=10)
file = json.loads(q.text)
file = await get_data(url, 'json')
qq = []
for x in file['query']['logevents'][:]:
qq.append(x['title'])
@ -30,8 +50,7 @@ async def newbie(app: Mirai):
while True:
c = 'f'
try:
qqq = requests.get(url, timeout=10)
qqqq = json.loads(qqq.text)
qqqq = await get_data(url, 'json')
for xz in qqqq['query']['logevents'][:]:
if xz['title'] in qq:
pass
@ -39,10 +58,11 @@ async def newbie(app: Mirai):
s = await pbc1(UTC8(xz['timestamp'], 'onlytime') + '新增新人：' + xz['title'])
print(s)
if s[0].find("<吃掉了>") != -1 or s[0].find("<全部吃掉了>") != -1:
await app.sendGroupMessage(731397727, message=s[
0] + '\n检测到外来信息介入，请前往日志查看所有消息。Special:日志?type=newusers')
await app.sendGroupMessage(731397727, MessageChain.create([Plain(s[
0] + '\n检测到外来信息介入，请前往日志查看所有消息。Special:日志?type=newusers')]).asSendable())
else:
await app.sendGroupMessage(731397727, message=s[0])
await app.sendGroupMessage(731397727,
MessageChain.create([Plain(s[0])]).asSendable())
print(s)
c = 't'
except Exception:
@ -63,4 +83,4 @@ async def newbie(app: Mirai):
if __name__ == "__main__":
app.run()
app.launch_blocking()