如何为 Minecraft 服务器添加一名播报员（完）

  1
  2
  3
  4
  5
  6
  7
  8
  9
 10
 11
 12
 13
 14
 15
 16
 17
 18
 19
 20
 21
 22
 23
 24
 25
 26
 27
 28
 29
 30
 31
 32
 33
 34
 35
 36
 37
 38
 39
 40
 41
 42
 43
 44
 45
 46
 47
 48
 49
 50
 51
 52
 53
 54
 55
 56
 57
 58
 59
 60
 61
 62
 63
 64
 65
 66
 67
 68
 69
 70
 71
 72
 73
 74
 75
 76
 77
 78
 79
 80
 81
 82
 83
 84
 85
 86
 87
 88
 89
 90
 91
 92
 93
 94
 95
 96
 97
 98
 99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167

from graia.broadcast import Broadcast
from graia.application import GraiaMiraiApplication, Session
from graia.application.message.chain import MessageChain
from graia.application.group import Group, Member
from subprocess import Popen, PIPE
import select
import fcntl, os, time
import asyncio
import threading
import nest_asyncio

from graia.application.message.elements.internal import Plain, At

from graia.application.friend import Friend

class MCBackServer(object):

    def __init__(self, args, server_env = None):
        self.process = Popen(args, stdin=PIPE, stdout=PIPE)
        flags = fcntl.fcntl(self.process.stdout, fcntl.F_GETFL)
        fcntl.fcntl(self.process.stdout, fcntl.F_SETFL, flags | os.O_NONBLOCK)
        print("[+] MC server start!")

    def send(self, data, tail = '\n'):
        msg = bytes(data+tail, encoding='utf-8')
        self.process.stdin.write(msg)
        self.process.stdin.flush()

    def recv(self, t=.1, stderr=0):
        r = ''
        pr = self.process.stdout
        if stderr:
            pr = self.process.stdout
        while True:
            if not select.select([pr], [], [], 0)[0]:
                time.sleep(t)
                continue
            r = pr.read()
            return r.rstrip().replace(b"[Server thread/INFO]", b'')
        return r.rstrip().replace(b"[Server thread/INFO]", b'')

    def recv_once(self):
        pr = self.process.stdout
        r = pr.read()
        if r == None:
          return b''
        else:
          return r.rstrip().replace(b"[Server thread/INFO]", b'')

loop = asyncio.get_event_loop()
bcc = Broadcast(loop=loop)
app = GraiaMiraiApplication(
                        broadcast=bcc,
                        connect_info=Session(
                            host="http://localhost:8080", # 填入 httpapi 服务运行的地址
                            authKey="xdchaseforever", # 填入 authKey
                            account=dontwannatellyou, # 你的机器人的 qq 号
                            websocket=True # Graia 已经可以根据所配置的消息接收的方式来保证消息接收部分的正常运作.
                        )
                    )
targetGroup = None
targetMember = None
permittedCmd = ['list', 'seed', 'whitelist']
happyEvent = ['achievement']
badEvent = ['swim in lava']
otherEvent = []
ServerArgs = ['bash', '/root/start_mc_server.sh']
mcserver = MCBackServer(ServerArgs)



@bcc.receiver("FriendMessage")
async def friend_message_listener(app: GraiaMiraiApplication, friend: Friend):
    await app.sendFriendMessage(friend, MessageChain.create([
        Plain("施工中...")
    ]))


@bcc.receiver("GroupMessage")
async def test(
    message: MessageChain,
    app: GraiaMiraiApplication,
    group: Group, member: Member,
):
    global targetGroup, targetMember
    targetGroup = group
    if message.asDisplay().startswith("!"):
        ifPermitted = False
        msg = message.asDisplay()[1:]
       # print("msg: " + msg)
        if msg.startswith('ping'):
            await app.sendGroupMessage(group, MessageChain.create([
                At(member.id), Plain(" pong! I'm working well~~")
            ]))
            return

        for i in permittedCmd:
            if msg.startswith(i):
                ifPermitted = True
                break
        if ifPermitted:
            mcserver.send(msg)
            res = mcserver.recv().decode()
            await app.sendGroupMessage(group, MessageChain.create([
                At(member.id), Plain('\n'+res)
            ]))
        else:
            await app.sendGroupMessage(group, MessageChain.create([
                At(member.id), Plain("\nSorry, Command Error! These are all we permitted : " + ','.join(permittedCmd))
            ]))
    else:
        mcserver.send("say " + member.name + "@QQ : " + message.asDisplay())
       # print(b'[+]' + mcserver.recv())


def BotLoop():
    app.launch_blocking()


def MCLoop():
    global loop
    print("[+] We ask every 2 seconds")
    while(1):
        res = mcserver.recv_once().decode()
        if res != '' and targetGroup != None:
            res = res.split('\n')
            ret2qq = ''
            for mcmsg in res:
                if "Can't keep up" not in mcmsg:
                  print("mcmsg ："+mcmsg)
                  for i in happyEvent:
                      if i in mcmsg:
                          ret2qq += " 【喜报】 " + mcmsg + '\n'
                  for i in badEvent:
                      if i in mcmsg:
                          ret2qq += " 【悲报】 " + mcmsg + '\n'
                  for i in otherEvent:
                      if i in mcmsg:
                          ret2qq += mcmsg + '\n'
                  if 'joined the game' in mcmsg:
                      ret2qq += " Welcome ~~~ \n"
                  else:
                      if "<" in mcmsg and '>' in mcmsg:
                          ret2qq += mcmsg + '\n'
            if ret2qq != '':
              print("now ret2qq is : " + ret2qq)
              asyncio.run_coroutine_threadsafe( app.sendGroupMessage(targetGroup, MessageChain.create([
                    Plain(ret2qq)
                ])), loop).result()

        time.sleep(1)
        print("[+] ", end='')
        print(targetGroup, res)



if __name__ == "__main__":


    print(mcserver.recv())
    bot = threading.Thread(target=BotLoop)
    bot.setDaemon(True)
    bot.start()

    # wait for the coroutine to finish

    MCLoop()