mantisbt-smtp-gateway

@@ -9,6 +9,7 @@ import MantisSMTPServer

 import logging

 from optparse import OptionParser

 import simplejson as json

+import os

 parser = OptionParser()

@@ -63,6 +64,15 @@ parser.add_option('-p',

                   help="The bind port",

                   default=1025)

+parser.add_option('-s',

+                  '--save',

+                  action="store",

+                  type="string",

+                  dest="save_dir",

+                  help="Save all message receive in this directory",

+                  default=None)

+

+

 (options, args) = parser.parse_args()

@@ -100,7 +110,7 @@ if options.configfile:

 		sys.exit(2)

 	try:

-		for param in ['mail_from','ws_url','ws_user','ws_pwd','ws_default_category']:

+		for param in ['mail_from','ws_url','ws_user','ws_pwd','ws_default_category','save_dir']:

 			if param in config:

 				server.set_option(param,config[param])

@@ -119,6 +129,13 @@ if options.configfile:

 else:

 	logging.warning('No config file supply. Running with default configuration...')

+if options.save_dir:

+	if os.path.isdir(options.save_dir):

+		server.set_option('save_dir',options.save_dir)

+	else:

+		logging.error("Incorrect directory path : %s" % options.save_dir)

+		sys.exit(4)

+

 try:

 	if options.daemon:

 		server.startDaemon(options.pidfile)

@@ -9,6 +9,7 @@ import MantisWS

 import asyncore

 import os

 import signal

+import time

 class MantisSMTPServer(smtpd.SMTPServer):

@@ -22,6 +23,7 @@ class MantisSMTPServer(smtpd.SMTPServer):

 	_options['ws_user']='mantis'

 	_options['ws_pwd']='password'

 	_options['ws_default_category']='other'

+	_options['save_dir']=None

 	ws=None

@@ -62,6 +64,7 @@ class MantisSMTPServer(smtpd.SMTPServer):

 	def process_message(self, peer, mailfrom, rcpttos, data):

 		logging.info('Message receive from %s, send by %s to %s' % (peer,mailfrom,rcpttos))

+		self.save_msg(peer, mailfrom, rcpttos, data)

 		try:

 			msg = MantisMail.MantisMail(mailfrom,rcpttos,data)

@@ -163,3 +166,14 @@ class MantisSMTPServer(smtpd.SMTPServer):

 			return issue_id

 		else:

 			logging.error('Error during add issue')

+

+	def save_msg(self,peer, mailfrom, rcpttos, data):

+		if self._options['save_dir']:

+			f="%s/%s" % (self._options['save_dir'],"%s-%s--%s--%s.msg" % (time.time(), peer[0],mailfrom,rcpttos[0]))

+			try:

+				logging.info('Save mail data into %s' % f)

+				fd=open(f,'w')

+				fd.write(data)

+				fd.close()

+			except Exception, e:

+				logging.error("Can't save message from %s to % receive from %s into %s : %s" % (mailfrom,rcpttos,peer,f,e))