2020-06-13 12:43:43 +00:00
|
|
|
|
import json
|
2020-08-12 16:01:34 +00:00
|
|
|
|
import re
|
2021-01-08 12:30:59 +00:00
|
|
|
|
import traceback
|
2020-08-12 16:01:34 +00:00
|
|
|
|
|
2020-09-19 10:35:13 +00:00
|
|
|
|
import aiohttp
|
2020-08-12 16:01:34 +00:00
|
|
|
|
|
2021-02-01 15:13:11 +00:00
|
|
|
|
|
|
|
|
|
async def server(address, raw=False):
|
2020-08-15 06:57:00 +00:00
|
|
|
|
matchObj = re.match(r'(.*):(.*)', address, re.M | re.I)
|
2020-07-18 12:58:39 +00:00
|
|
|
|
servers = []
|
2020-08-12 16:01:34 +00:00
|
|
|
|
|
2021-01-09 11:42:03 +00:00
|
|
|
|
if matchObj:
|
|
|
|
|
serip = matchObj.group(1)
|
|
|
|
|
port1 = matchObj.group(2)
|
|
|
|
|
port2 = matchObj.group(2)
|
|
|
|
|
else:
|
|
|
|
|
serip = address
|
|
|
|
|
port1 = '25565'
|
|
|
|
|
port2 = '19132'
|
2021-02-10 11:49:57 +00:00
|
|
|
|
matchserip = re.match(r'(.*?).(.*?).(.*?).(.*?)', serip)
|
|
|
|
|
if matchserip:
|
2021-02-10 11:51:19 +00:00
|
|
|
|
try:
|
|
|
|
|
if matchserip.group(1) == '192':
|
|
|
|
|
if matchserip.group(2) == '168':
|
|
|
|
|
return '¿'
|
|
|
|
|
if matchserip.group(1) == '172':
|
|
|
|
|
if 16 <= int(matchserip.group(2)) <= 31:
|
|
|
|
|
return '¿'
|
|
|
|
|
if matchserip.group(1) == '10':
|
|
|
|
|
if 0 <= int(matchserip.group(2)) <= 255:
|
|
|
|
|
return '¿'
|
|
|
|
|
except:
|
|
|
|
|
traceback.print_exc()
|
2021-01-09 11:42:03 +00:00
|
|
|
|
|
2020-06-13 12:43:43 +00:00
|
|
|
|
try:
|
2021-01-09 11:42:03 +00:00
|
|
|
|
url = 'http://motd.wd-api.com/java?ip=' + serip + '&port=' + port1
|
|
|
|
|
async with aiohttp.ClientSession() as session:
|
|
|
|
|
async with session.get(url, timeout=aiohttp.ClientTimeout(total=20)) as req:
|
|
|
|
|
if req.status != 200:
|
|
|
|
|
print(await req.text())
|
|
|
|
|
print(f"请求时发生错误:{req.status}")
|
|
|
|
|
else:
|
|
|
|
|
motd = await req.text()
|
|
|
|
|
file = json.loads(motd)
|
|
|
|
|
try:
|
|
|
|
|
if file['code'] == 200:
|
|
|
|
|
servers.append('[JE]')
|
|
|
|
|
jejson = file['data']
|
|
|
|
|
if 'description' in jejson:
|
|
|
|
|
description = jejson['description']
|
|
|
|
|
if 'text' in description:
|
2021-02-01 15:13:11 +00:00
|
|
|
|
servers.append(str(description['text']))
|
2021-01-09 11:42:03 +00:00
|
|
|
|
elif 'extra' in description:
|
|
|
|
|
extra = description['extra']
|
|
|
|
|
text = []
|
|
|
|
|
qwq = ''
|
|
|
|
|
for item in extra[:]:
|
2021-02-01 15:13:11 +00:00
|
|
|
|
text.append(str(item['text']))
|
2021-01-09 11:42:03 +00:00
|
|
|
|
servers.append(qwq.join(text))
|
|
|
|
|
else:
|
2021-02-01 15:13:11 +00:00
|
|
|
|
servers.append(str(description))
|
2020-08-12 16:01:34 +00:00
|
|
|
|
|
2021-01-09 11:42:03 +00:00
|
|
|
|
if 'players' in jejson:
|
|
|
|
|
onlinesplayer = f"在线玩家:{str(jejson['players']['online'])} / {str(jejson['players']['max'])}"
|
|
|
|
|
servers.append(onlinesplayer)
|
|
|
|
|
if 'version' in jejson:
|
|
|
|
|
versions = "游戏版本:" + file['data']['version']['name']
|
|
|
|
|
servers.append(versions)
|
|
|
|
|
servers.append(serip + ':' + port1)
|
2021-01-08 12:30:59 +00:00
|
|
|
|
else:
|
2021-01-09 11:42:03 +00:00
|
|
|
|
print('获取JE服务器信息失败。')
|
|
|
|
|
except Exception:
|
|
|
|
|
traceback.print_exc()
|
|
|
|
|
servers.append("[JE]\n发生错误:调用API时发生错误。")
|
|
|
|
|
except Exception:
|
|
|
|
|
print('获取JE服务器信息失败。')
|
|
|
|
|
traceback.print_exc()
|
|
|
|
|
try:
|
|
|
|
|
beurl = 'http://motd.wd-api.com/bedrock?ip=' + serip + '&port=' + port2
|
|
|
|
|
print(beurl)
|
2021-01-09 11:51:23 +00:00
|
|
|
|
async with aiohttp.ClientSession() as session2:
|
|
|
|
|
async with session2.get(url, timeout=aiohttp.ClientTimeout(total=20)) as req:
|
2021-01-09 11:42:03 +00:00
|
|
|
|
if req.status != 200:
|
|
|
|
|
print(await req.text())
|
|
|
|
|
print(f"请求时发生错误:{req.status}")
|
2020-06-13 12:43:43 +00:00
|
|
|
|
else:
|
2021-01-09 11:42:03 +00:00
|
|
|
|
bemotd = await req.text()
|
|
|
|
|
bejson = json.loads(bemotd)
|
|
|
|
|
edition, motd_1, protocol, version_name, player_count, max_players, unique_id, motd_2, \
|
|
|
|
|
game_mode, game_mode_num, port_v4, port_v6, nothing_here = bejson['motd'].split(';')
|
2021-02-01 15:13:11 +00:00
|
|
|
|
bemsg = '[BE]\n' + \
|
|
|
|
|
motd_1 + ' - ' + motd_2 + \
|
|
|
|
|
'\n在线玩家:' + player_count + '/' + max_players + \
|
|
|
|
|
'\n游戏版本:' + edition + version_name + \
|
|
|
|
|
'\n游戏模式:' + game_mode
|
2021-01-09 11:42:03 +00:00
|
|
|
|
servers.append(bemsg)
|
2021-01-08 12:30:59 +00:00
|
|
|
|
|
2021-01-09 11:42:03 +00:00
|
|
|
|
except Exception:
|
|
|
|
|
print('获取BE服务器信息失败。')
|
|
|
|
|
traceback.print_exc()
|
|
|
|
|
if str(servers) == '[]':
|
|
|
|
|
return ('连接失败,没有检测到任何服务器。')
|
|
|
|
|
else:
|
|
|
|
|
awa = '\n'
|
|
|
|
|
servers.append("[30秒后撤回本消息]")
|
2021-02-01 15:13:11 +00:00
|
|
|
|
print(servers)
|
|
|
|
|
if raw:
|
|
|
|
|
return awa.join(servers)
|
2021-01-09 11:42:03 +00:00
|
|
|
|
return re.sub(r'§\w', "", awa.join(servers))
|