daemon

mrim-bot/config.json

@@ -0,0 +1,5 @@
+{
+    "email": "johann-the-builder@mail.ru",
+    "password": "buildpleasemail",
+    "allowed_emails": ["alexandr.smirnov@corp.mail.ru"]
+}

mrim-bot/daemon.py

@@ -0,0 +1,129 @@
+#!/usr/bin/env python
+
+import sys, os, time, atexit
+from signal import SIGTERM 
+
+class Daemon(object):
+	"""
+	A generic daemon class.
+	
+	Usage: subclass the Daemon class and override the run() method
+	"""
+	def __init__(self, pidfile, stdin='/dev/null', stdout='/dev/null', stderr='/dev/null'):
+		self.stdin = stdin
+		self.stdout = stdout
+		self.stderr = stderr
+		self.pidfile = pidfile
+
+	def daemonize(self):
+		"""
+		do the UNIX double-fork magic, see Stevens' "Advanced 
+		Programming in the UNIX Environment" for details (ISBN 0201563177)
+		http://www.erlenstar.demon.co.uk/unix/faq_2.html#SEC16
+		"""
+		try: 
+			pid = os.fork() 
+			if pid > 0:
+				# exit first parent
+				sys.exit(0) 
+		except OSError, e: 
+			sys.stderr.write("fork #1 failed: %d (%s)\n" % (e.errno, e.strerror))
+			sys.exit(1)
+
+		# decouple from parent environment
+		os.chdir("/") 
+		os.setsid() 
+		os.umask(0) 
+
+		# do second fork
+		try: 
+			pid = os.fork() 
+			if pid > 0:
+				# exit from second parent
+				sys.exit(0) 
+		except OSError, e: 
+			sys.stderr.write("fork #2 failed: %d (%s)\n" % (e.errno, e.strerror))
+			sys.exit(1) 
+
+		# redirect standard file descriptors
+		sys.stdout.flush()
+		sys.stderr.flush()
+		si = file(self.stdin, 'r')
+		so = file(self.stdout, 'a+')
+		se = file(self.stderr, 'a+', 0)
+		os.dup2(si.fileno(), sys.stdin.fileno())
+		os.dup2(so.fileno(), sys.stdout.fileno())
+		os.dup2(se.fileno(), sys.stderr.fileno())
+
+		# write pidfile
+		atexit.register(self.delpid)
+		pid = str(os.getpid())
+		file(self.pidfile,'w+').write("%s\n" % pid)
+
+	def delpid(self):
+		os.remove(self.pidfile)
+
+	def start(self):
+		"""
+		Start the daemon
+		"""
+		# Check for a pidfile to see if the daemon already runs
+		try:
+			pf = file(self.pidfile,'r')
+			pid = int(pf.read().strip())
+			pf.close()
+		except IOError:
+			pid = None
+
+		if pid:
+			message = "pidfile %s already exist. Daemon already running?\n"
+			sys.stderr.write(message % self.pidfile)
+			sys.exit(1)
+
+		# Start the daemon
+		self.daemonize()
+		self.run()
+
+	def stop(self):
+		"""
+		Stop the daemon
+		"""
+		# Get the pid from the pidfile
+		try:
+			pf = file(self.pidfile,'r')
+			pid = int(pf.read().strip())
+			pf.close()
+		except IOError:
+			pid = None
+
+		if not pid:
+			message = "pidfile %s does not exist. Daemon not running?\n"
+			sys.stderr.write(message % self.pidfile)
+			return # not an error in a restart
+
+		# Try killing the daemon process	
+		try:
+			while 1:
+				os.kill(pid, SIGTERM)
+				time.sleep(0.1)
+		except OSError, err:
+			err = str(err)
+			if err.find("No such process") > 0:
+				if os.path.exists(self.pidfile):
+					os.remove(self.pidfile)
+			else:
+				print str(err)
+				sys.exit(1)
+
+	def restart(self):
+		"""
+		Restart the daemon
+		"""
+		self.stop()
+		self.start()
+
+	def run(self):
+		"""
+		You should override this method when you subclass Daemon. It will be called after the process has been
+		daemonized by start() or restart().
+		"""

mrim-bot/mmpbase.py

@@ -1,3 +1,7 @@
+#
+# Alexander Smirnov (alexander@smirn0v.ru)
+#
+
 from mmptypes import *
 import struct
 

mrim-bot/mmpbot.py

@@ -0,0 +1,51 @@
+#!/usr/bin/python
+
+import mmpprotocol
+import json
+import sys
+import os
+from twisted.internet import reactor
+from daemon import Daemon
+
+class MMPBot(mmpprotocol.MMPCallbackBase):
+    def __init__(self,configPath):
+        super(MMPBot,self).__init__()
+        json_data=open(configPath)
+        self.config = json.load(json_data)
+        json_data.close()
+
+    def loginPassword(self):
+        return (self.config["email"],self.config["password"])
+
+    def authrizationRequest(self,from_email):
+        if from_email in self.config["allowed_emails"]:
+            self.protocol.authorize(from_email) 
+
+    def message(self,from_email,message):
+        print "%s: %s"%(from_email,message)
+
+class BotDaemon(Daemon):
+    def __init__(self,pidfile):
+        super(BotDaemon,self).__init__(pidfile,stderr='/tmp/mrim-bot.log')
+        self.configPath = None
+    def run(self):
+        host, port = mmpprotocol.connection_endpoint()
+        reactor.connectTCP(host, port, mmpprotocol.MMPClientFactory(MMPBot(self.configPath)))
+        reactor.run()
+
+if __name__ == "__main__":
+    daemon = BotDaemon('/tmp/mrim-bot.pid')
+    if len(sys.argv) == 2:
+        if 'start' == sys.argv[1]:
+            daemon.configPath = os.path.abspath("config.json")
+            daemon.start()
+        elif 'stop' == sys.argv[1]:
+            daemon.stop()
+        elif 'restart' == sys.argv[1]:
+            daemon.restart()
+        else:
+            print "Unknown command"
+            sys.exit(2)
+    else:
+        print "usage: %s start|stop|restart" % sys.argv[0]
+        sys.exit(2)

mrim-bot/mmp_protocol.py → mrim-bot/mmpprotocol.py

@@ -2,6 +2,26 @@
 from twisted.internet import reactor, protocol, task
 from twisted.persisted import styles
 from twisted.protocols import basic
+import telnetlib
+
+class MMPInvalidEndpoint(Exception):
+    pass
+
+def connection_endpoint():
+    telnet = telnetlib.Telnet("mrim.mail.ru",2042)
+    address = telnet.read_all()
+    telnet.close()
+
+    host,port = address.split(":")
+
+    if host == None or port == None or \
+       len(port) < 2 or port[-1] != '\n': 
+        raise MMPInvalidEndpoint,"Invalid mrim server response"
+
+    port = port[:-1] #trim '\n'
+    if not port.isdigit(): raise MMPInvalidEndpoint,"Invalid mrim server response"
+
+    return host,int(port) 
 
 class MMPCallbackBase(object):
     def __init__(self):
@@ -67,7 +87,7 @@ def handlePacket(self,packet):
         self.protocol.startHeartbeat(packet.interval)
         header = self.protocol.createHeader()
         loginPassword = self.protocol.callback.loginPassword()
-        packet = MMPClientLogin2Packet(header,loginPassword[0],loginPassword[1])
+        packet = MMPClientLogin2Packet(header,loginPassword[0].encode('ascii'),loginPassword[1].encode('ascii'))
         self.protocol.addHandler(MMPLogin2RejHandler(self.protocol,header.seq))
         self.protocol.addHandler(MMPLogin2AckHandler(self.protocol,header.seq))
         self.protocol.sendPacket(packet)