diff --git a/bot.py b/bot.py new file mode 100644 index 0000000..bebc0a8 --- /dev/null +++ b/bot.py @@ -0,0 +1,210 @@ +#!/usr/bin/env python3 + +import logging +from getpass import getpass +from argparse import ArgumentParser +import sys +import rcon +import socket +import select +import subprocess +import re +chatPattern = re.compile(r'Chat\: \<(.*)\> (.*)\n') + +import slixmpp + +class BridgeBot(slixmpp.ClientXMPP): + + """ + A simple Slixmpp bot that will greets those + who enter the room, and acknowledge any messages + that mentions the bot's nickname. + """ + + def __init__(self, jid, password, room, nick, addr, port, secret, logfile): + slixmpp.ClientXMPP.__init__(self, jid, password) + + self.room = room + self.nick = nick + self.addr = addr + self.port = port + self.secret = secret + self.logfile = logfile + self.logFO = subprocess.Popen(['tail','-n','1','-F',logfile],stdout=subprocess.PIPE,stderr=subprocess.PIPE) + self.p =select.poll() + self.p.register(self.logFO.stdout) + + + # The session_start event will be triggered when + # the bot establishes its connection with the server + # and the XML streams are ready for use. We want to + # listen for this event so that we we can initialize + # our roster. + self.add_event_handler("session_start", self.start) + + # The groupchat_message event is triggered whenever a message + # stanza is received from any chat room. If you also also + # register a handler for the 'message' event, MUC messages + # will be processed by both handlers. + self.add_event_handler("groupchat_message", self.muc_message) + + # The groupchat_presence event is triggered whenever a + # presence stanza is received from any chat room, including + # any presences you send yourself. To limit event handling + # to a single room, use the events muc::room@server::presence, + # muc::room@server::got_online, or muc::room@server::got_offline. + self.add_event_handler("muc::%s::got_online" % self.room, + self.muc_online) + + + async def start(self, event): + """ + Process the session_start event. + + Typical actions for the session_start event are + requesting the roster and broadcasting an initial + presence stanza. + + Arguments: + event -- An empty dictionary. The session_start + event does not provide any additional + data. + """ + await self.get_roster() + self.send_presence() + self.plugin['xep_0045'].join_muc(self.room, + self.nick, + ) + + def sendrcon(self, nick, msg): + print(f'<{nick}> {msg}') + with rcon.source.Client(self.addr, int(self.port), passwd=self.secret, timeout=0.1) as client: + response = client.run(f'broadcast <{nick}> {msg}') + print(response) + def sendxmpp(self,nick,msg): + self.send_message(mto=self.room, mtype='groupchat', mbody=f'<{nick}> {msg}') + def checklog(self): + while self.p.poll(1): + line = self.logFO.stdout.readline().decode("utf-8") + try: + mo = chatPattern.search(line) + print(mo.groups()) + self.sendxmpp(mo.group(1),mo.group(2)) + except AttributeError as e: + continue + def muc_message(self, msg): + """ + Process incoming message stanzas from any chat room. Be aware + that if you also have any handlers for the 'message' event, + message stanzas may be processed by both handlers, so check + the 'type' attribute when using a 'message' event handler. + + Whenever the bot's nickname is mentioned, respond to + the message. + + IMPORTANT: Always check that a message is not from yourself, + otherwise you will create an infinite loop responding + to your own messages. + + This handler will reply to messages that mention + the bot's nickname. + + Arguments: + msg -- The received message stanza. See the documentation + for stanza objects and the Message stanza to see + how it may be used. + """ + """ + if msg['mucnick'] != self.nick and self.nick in msg['body']: + self.send_message(mto=msg['from'].bare, + mbody="I heard that, %s." % msg['mucnick'], + mtype='groupchat') + """ + if msg['mucnick'] != self.nick: + while True: + try: + self.sendrcon(msg['mucnick'], msg['body']) + except socket.timeout as timeout: + #print(timeout) + continue + break + + def muc_online(self, presence): + """ + Process a presence stanza from a chat room. In this case, + presences from users that have just come online are + handled by sending a welcome message that includes + the user's nickname and role in the room. + + Arguments: + presence -- The received presence stanza. See the + documentation for the Presence stanza + to see how else it may be used. + """ + """ + if presence['muc']['nick'] != self.nick: + self.send_message(mto=presence['from'].bare, + mbody="Hello, %s %s" % (presence['muc']['role'], + presence['muc']['nick']), + mtype='groupchat') + """ + print("Online.") + + +if __name__ == '__main__': + # Setup the command line arguments. + parser = ArgumentParser() + + # Output verbosity options. + parser.add_argument("-q", "--quiet", help="set logging to ERROR", + action="store_const", dest="loglevel", + const=logging.ERROR, default=logging.INFO) + parser.add_argument("-d", "--debug", help="set logging to DEBUG", + action="store_const", dest="loglevel", + const=logging.DEBUG, default=logging.INFO) + + # JID and password options. + parser.add_argument("-j", "--jid", dest="jid", + help="JID to use") + parser.add_argument("-p", "--password", dest="password", + help="password to use") + parser.add_argument("-r", "--room", dest="room", + help="MUC room to join") + parser.add_argument("-n", "--nick", dest="nick", + help="MUC nickname") + parser.add_argument("-a", "--address", dest="addr", + help="RCON address") + parser.add_argument("-P", "--port", dest="port", + help="RCON port") + parser.add_argument("-s", "--secret", dest="secret", + help="RCON password/secret") + parser.add_argument("-f", "--logfile", dest="logfile", + help="Log file to read chat from") + + args = parser.parse_args() + print(type(args)) + # Setup logging. + logging.basicConfig(level=args.loglevel, + format='%(levelname)-8s %(message)s') + if args.jid is None: + args.jid = input("Username: ") + if args.password is None: + args.password = getpass("Password: ") + if args.room is None: + args.room = input("MUC room: ") + if args.nick is None: + args.nick = input("MUC nickname: ") + + # Setup the MUCBot and register plugins. Note that while plugins may + # have interdependencies, the order in which you register them does + # not matter. + xmpp = BridgeBot(args.jid, args.password, args.room, args.nick, args.addr, args.port, args.secret, args.logfile) + xmpp.register_plugin('xep_0030') # Service Discovery + xmpp.register_plugin('xep_0045') # Multi-User Chat + xmpp.register_plugin('xep_0199') # XMPP Ping + + # Connect to the XMPP server and start processing XMPP stanzas. + xmpp.connect() + while True: + xmpp.process(timeout=1) + xmpp.checklog()