97 lines
4.5 KiB
Python
97 lines
4.5 KiB
Python
#!/usr/bin/env python
|
|
# -*- coding: utf-8 -*-
|
|
##############################################################################
|
|
#
|
|
# OpenERP, Open Source Management Solution
|
|
# Copyright (C) 2004-2009 Tiny SPRL (<http://tiny.be>).
|
|
# Copyright (C) 2010-TODAY OpenERP S.A. (http://www.openerp.com)
|
|
#
|
|
# This program is free software: you can redistribute it and/or modify
|
|
# it under the terms of the GNU Affero General Public License as
|
|
# published by the Free Software Foundation, either version 3 of the
|
|
# License, or (at your option) any later version.
|
|
#
|
|
# This program is distributed in the hope that it will be useful,
|
|
# but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
|
# GNU Affero General Public License for more details.
|
|
#
|
|
# You should have received a copy of the GNU Affero General Public License
|
|
# along with this program. If not, see <http://www.gnu.org/licenses/>
|
|
#
|
|
###########################################################################################
|
|
|
|
import logging
|
|
import optparse
|
|
import sys
|
|
import xmlrpclib
|
|
import email
|
|
|
|
class rpc_proxy(object):
|
|
def __init__(self, uid, passwd, host='localhost', port=8069, path='object', dbname='openerp'):
|
|
self.rpc = xmlrpclib.ServerProxy('http://%s:%s/xmlrpc/%s' % (host, port, path), allow_none=True)
|
|
self.user_id = uid
|
|
self.passwd = passwd
|
|
self.dbname = dbname
|
|
|
|
def __call__(self, *request, **kwargs):
|
|
return self.rpc.execute(self.dbname, self.user_id, self.passwd, *request, **kwargs)
|
|
|
|
class email_parser(object):
|
|
def __init__(self, uid, password, model, email_default, dbname, host, port):
|
|
self.rpc = rpc_proxy(uid, password, host=host, port=port, dbname=dbname)
|
|
try:
|
|
self.model_id = int(model)
|
|
self.model = str(model)
|
|
except:
|
|
self.model_id = self.rpc('ir.model', 'search', [('model', '=', model)])[0]
|
|
self.model = str(model)
|
|
self.email_default = email_default
|
|
|
|
|
|
def parse(self, message, custom_values=None):
|
|
if custom_values is None:
|
|
custom_values = {}
|
|
try:
|
|
# pass message as bytes because we don't know its encoding until we parse its headers
|
|
# and hence can't convert it to utf-8 for transport
|
|
res_id = self.rpc('email.server.tools', 'process_email', self.model, xmlrpclib.Binary(message), custom_values)
|
|
except Exception, e:
|
|
logger = logging.getLogger('mail-gateway')
|
|
logger.warning('Failed to process incoming email. Source of the failed mail is available at debug level.', exc_info=True)
|
|
logger.debug('Source of the mail that failed to parse:', message)
|
|
res_id = False
|
|
|
|
if __name__ == '__main__':
|
|
parser = optparse.OptionParser(usage='usage: %prog [options]', version='%prog v1.0')
|
|
group = optparse.OptionGroup(parser, "Note",
|
|
"This program parse a mail from standard input and communicate "
|
|
"with the OpenERP server for case management in the CRM module.")
|
|
parser.add_option_group(group)
|
|
parser.add_option("-u", "--user", dest="userid", help="ID of the user in OpenERP", default=1, type='int')
|
|
parser.add_option("-p", "--password", dest="password", help="Password of the user in OpenERP", default='admin')
|
|
parser.add_option("-o", "--model", dest="model", help="Name or ID of crm model", default="crm.lead")
|
|
parser.add_option("-m", "--default", dest="default", help="Default eMail in case of any trouble.", default=None)
|
|
parser.add_option("-d", "--dbname", dest="dbname", help="Database name (default: openerp)", default='openerp')
|
|
parser.add_option("--host", dest="host", help="Hostname of the OpenERP Server", default="localhost")
|
|
parser.add_option("--port", dest="port", help="Port of the OpenERP Server", default="8069")
|
|
parser.add_option("--custom-values", dest="custom_values", help="Add Custom Values to the object", default=None)
|
|
|
|
(options, args) = parser.parse_args()
|
|
|
|
logging.basicConfig(level=logging.DEBUG, format="%(asctime)s %(levelname)s %(message)s")
|
|
|
|
parser = email_parser(options.userid, options.password, options.model, options.default, dbname=options.dbname, host=options.host, port=options.port)
|
|
|
|
msg_txt = sys.stdin.read()
|
|
|
|
custom_values = {}
|
|
try:
|
|
custom_values = dict(eval(options.custom_values))
|
|
except:
|
|
pass
|
|
|
|
parser.parse(msg_txt, custom_values)
|
|
|
|
# vim:expandtab:smartindent:tabstop=4:softtabstop=4:shiftwidth=4:
|