454 lines
14 KiB
Python
Executable File
454 lines
14 KiB
Python
Executable File
# Caolan McNamara caolanm@redhat.com
|
|
# a simple email mailmerge component
|
|
|
|
# manual installation for hackers, not necessary for users
|
|
# cp mailmerge.py /usr/lib/libreoffice/program
|
|
# cd /usr/lib/libreoffice/program
|
|
# ./unopkg add --shared mailmerge.py
|
|
# edit ~/.openoffice.org2/user/registry/data/org/openoffice/Office/Writer.xcu
|
|
# and change EMailSupported to as follows...
|
|
# <prop oor:name="EMailSupported" oor:type="xs:boolean">
|
|
# <value>true</value>
|
|
# </prop>
|
|
|
|
import unohelper
|
|
import uno
|
|
import re
|
|
import os
|
|
|
|
#to implement com::sun::star::mail::XMailServiceProvider
|
|
#and
|
|
#to implement com.sun.star.mail.XMailMessage
|
|
|
|
from com.sun.star.mail import XMailServiceProvider
|
|
from com.sun.star.mail import XMailService
|
|
from com.sun.star.mail import XSmtpService
|
|
from com.sun.star.mail import XConnectionListener
|
|
from com.sun.star.mail import XAuthenticator
|
|
from com.sun.star.mail import XMailMessage
|
|
from com.sun.star.mail.MailServiceType import SMTP
|
|
from com.sun.star.mail.MailServiceType import POP3
|
|
from com.sun.star.mail.MailServiceType import IMAP
|
|
from com.sun.star.uno import XCurrentContext
|
|
from com.sun.star.lang import IllegalArgumentException
|
|
from com.sun.star.lang import EventObject
|
|
from com.sun.star.mail import SendMailMessageFailedException
|
|
|
|
from email.MIMEBase import MIMEBase
|
|
from email.Message import Message
|
|
from email import Encoders
|
|
from email.Header import Header
|
|
from email.MIMEMultipart import MIMEMultipart
|
|
from email.Utils import formatdate
|
|
from email.Utils import parseaddr
|
|
|
|
import sys, smtplib, imaplib, poplib
|
|
dbg = False
|
|
|
|
#no stderr under windows, output to pymailmerge.log
|
|
#with no buffering
|
|
if dbg and os.name == 'nt':
|
|
dbgout = open('pymailmerge.log', 'w', 0)
|
|
else
|
|
dbgout = sys.stderr
|
|
|
|
class PyMailSMTPService(unohelper.Base, XSmtpService):
|
|
def __init__( self, ctx ):
|
|
self.ctx = ctx
|
|
self.listeners = []
|
|
self.supportedtypes = ('Insecure', 'Ssl')
|
|
self.server = None
|
|
self.connectioncontext = None
|
|
self.notify = EventObject()
|
|
if dbg:
|
|
print >> dbgout, "PyMailSMPTService init"
|
|
def addConnectionListener(self, xListener):
|
|
if dbg:
|
|
print >> dbgout, "PyMailSMPTService addConnectionListener"
|
|
self.listeners.append(xListener)
|
|
def removeConnectionListener(self, xListener):
|
|
if dbg:
|
|
print >> dbgout, "PyMailSMPTService removeConnectionListener"
|
|
self.listeners.remove(xListener)
|
|
def getSupportedConnectionTypes(self):
|
|
if dbg:
|
|
print >> dbgout, "PyMailSMPTService getSupportedConnectionTypes"
|
|
return self.supportedtypes
|
|
def connect(self, xConnectionContext, xAuthenticator):
|
|
self.connectioncontext = xConnectionContext
|
|
if dbg:
|
|
print >> dbgout, "PyMailSMPTService connect"
|
|
server = xConnectionContext.getValueByName("ServerName")
|
|
if dbg:
|
|
print >> dbgout, server
|
|
port = int(xConnectionContext.getValueByName("Port"))
|
|
if dbg:
|
|
print >> dbgout, port
|
|
self.server = smtplib.SMTP(server, port)
|
|
#stderr not available for us under windows, but
|
|
#set_debuglevel outputs there, and so throw
|
|
#an exception under windows on debugging mode
|
|
#with this enabled
|
|
if dbg and os.name != 'nt':
|
|
self.server.set_debuglevel(1)
|
|
connectiontype = xConnectionContext.getValueByName("ConnectionType")
|
|
if dbg:
|
|
print >> dbgout, connectiontype
|
|
if connectiontype == 'Ssl':
|
|
self.server.ehlo()
|
|
self.server.starttls()
|
|
self.server.ehlo()
|
|
|
|
user = xAuthenticator.getUserName().encode('ascii')
|
|
password = xAuthenticator.getPassword().encode('ascii')
|
|
if user != '':
|
|
if dbg:
|
|
print >> dbgout, 'Logging in, username of', user
|
|
self.server.login(user, password)
|
|
|
|
for listener in self.listeners:
|
|
listener.connected(self.notify)
|
|
def disconnect(self):
|
|
if dbg:
|
|
print >> dbgout, "PyMailSMPTService disconnect"
|
|
if self.server:
|
|
self.server.quit()
|
|
self.server = None
|
|
for listener in self.listeners:
|
|
listener.disconnected(self.notify)
|
|
def isConnected(self):
|
|
if dbg:
|
|
print >> dbgout, "PyMailSMPTService isConnected"
|
|
return self.server != None
|
|
def getCurrentConnectionContext(self):
|
|
if dbg:
|
|
print >> dbgout, "PyMailSMPTService getCurrentConnectionContext"
|
|
return self.connectioncontext
|
|
def sendMailMessage(self, xMailMessage):
|
|
COMMASPACE = ', '
|
|
|
|
if dbg:
|
|
print >> dbgout, "PyMailSMPTService sendMailMessage"
|
|
recipients = xMailMessage.getRecipients()
|
|
sendermail = xMailMessage.SenderAddress
|
|
sendername = xMailMessage.SenderName
|
|
subject = xMailMessage.Subject
|
|
ccrecipients = xMailMessage.getCcRecipients()
|
|
bccrecipients = xMailMessage.getBccRecipients()
|
|
if dbg:
|
|
print >> dbgout, "PyMailSMPTService subject", subject
|
|
print >> dbgout, "PyMailSMPTService from", sendername.encode('utf-8')
|
|
print >> dbgout, "PyMailSMTPService from", sendermail
|
|
print >> dbgout, "PyMailSMPTService send to", recipients
|
|
|
|
attachments = xMailMessage.getAttachments()
|
|
|
|
textmsg = Message()
|
|
|
|
content = xMailMessage.Body
|
|
flavors = content.getTransferDataFlavors()
|
|
if dbg:
|
|
print >> dbgout, "PyMailSMPTService flavors len", len(flavors)
|
|
|
|
#Use first flavor that's sane for an email body
|
|
for flavor in flavors:
|
|
if flavor.MimeType.find('text/html') != -1 or flavor.MimeType.find('text/plain') != -1:
|
|
if dbg:
|
|
print >> dbgout, "PyMailSMPTService mimetype is", flavor.MimeType
|
|
textbody = content.getTransferData(flavor)
|
|
try:
|
|
textbody = textbody.value
|
|
except:
|
|
pass
|
|
textbody = textbody.encode('utf-8')
|
|
|
|
if len(textbody):
|
|
mimeEncoding = re.sub("charset=.*", "charset=UTF-8", flavor.MimeType)
|
|
if mimeEncoding.find('charset=UTF-8') == -1:
|
|
mimeEncoding = mimeEncoding + "; charset=UTF-8"
|
|
textmsg['Content-Type'] = mimeEncoding
|
|
textmsg['MIME-Version'] = '1.0'
|
|
textmsg.set_payload(textbody)
|
|
|
|
break
|
|
|
|
if (len(attachments)):
|
|
msg = MIMEMultipart()
|
|
msg.epilogue = ''
|
|
msg.attach(textmsg)
|
|
else:
|
|
msg = textmsg
|
|
|
|
hdr = Header(sendername, 'utf-8')
|
|
hdr.append('<'+sendermail+'>','us-ascii')
|
|
msg['Subject'] = subject
|
|
msg['From'] = hdr
|
|
msg['To'] = COMMASPACE.join(recipients)
|
|
if len(ccrecipients):
|
|
msg['Cc'] = COMMASPACE.join(ccrecipients)
|
|
if xMailMessage.ReplyToAddress != '':
|
|
msg['Reply-To'] = xMailMessage.ReplyToAddress
|
|
|
|
mailerstring = "LibreOffice via Caolan's mailmerge component"
|
|
try:
|
|
ctx = uno.getComponentContext()
|
|
aConfigProvider = ctx.ServiceManager.createInstance("com.sun.star.configuration.ConfigurationProvider")
|
|
prop = uno.createUnoStruct('com.sun.star.beans.PropertyValue')
|
|
prop.Name = "nodepath"
|
|
prop.Value = "/org.openoffice.Setup/Product"
|
|
aSettings = aConfigProvider.createInstanceWithArguments("com.sun.star.configuration.ConfigurationAccess",
|
|
(prop,))
|
|
mailerstring = aSettings.getByName("ooName") + " " + \
|
|
aSettings.getByName("ooSetupVersion") + " via Caolan's mailmerge component"
|
|
except:
|
|
pass
|
|
|
|
msg['X-Mailer'] = mailerstring
|
|
msg['Date'] = formatdate(localtime=True)
|
|
|
|
for attachment in attachments:
|
|
content = attachment.Data
|
|
flavors = content.getTransferDataFlavors()
|
|
flavor = flavors[0]
|
|
ctype = flavor.MimeType
|
|
maintype, subtype = ctype.split('/', 1)
|
|
msgattachment = MIMEBase(maintype, subtype)
|
|
data = content.getTransferData(flavor)
|
|
msgattachment.set_payload(data)
|
|
Encoders.encode_base64(msgattachment)
|
|
msgattachment.add_header('Content-Disposition', 'attachment', \
|
|
filename=attachment.ReadableName)
|
|
msg.attach(msgattachment)
|
|
|
|
uniquer = {}
|
|
for key in recipients:
|
|
uniquer[key] = True
|
|
if len(ccrecipients):
|
|
for key in ccrecipients:
|
|
uniquer[key] = True
|
|
if len(bccrecipients):
|
|
for key in bccrecipients:
|
|
uniquer[key] = True
|
|
truerecipients = uniquer.keys()
|
|
|
|
if dbg:
|
|
print >> dbgout, "PyMailSMPTService recipients are", truerecipients
|
|
|
|
self.server.sendmail(sendermail, truerecipients, msg.as_string())
|
|
|
|
class PyMailIMAPService(unohelper.Base, XMailService):
|
|
def __init__( self, ctx ):
|
|
self.ctx = ctx
|
|
self.listeners = []
|
|
self.supportedtypes = ('Insecure', 'Ssl')
|
|
self.server = None
|
|
self.connectioncontext = None
|
|
self.notify = EventObject()
|
|
if dbg:
|
|
print >> dbgout, "PyMailIMAPService init"
|
|
def addConnectionListener(self, xListener):
|
|
if dbg:
|
|
print >> dbgout, "PyMailIMAPService addConnectionListener"
|
|
self.listeners.append(xListener)
|
|
def removeConnectionListener(self, xListener):
|
|
if dbg:
|
|
print >> dbgout, "PyMailIMAPService removeConnectionListener"
|
|
self.listeners.remove(xListener)
|
|
def getSupportedConnectionTypes(self):
|
|
if dbg:
|
|
print >> dbgout, "PyMailIMAPService getSupportedConnectionTypes"
|
|
return self.supportedtypes
|
|
def connect(self, xConnectionContext, xAuthenticator):
|
|
if dbg:
|
|
print >> dbgout, "PyMailIMAPService connect"
|
|
|
|
self.connectioncontext = xConnectionContext
|
|
server = xConnectionContext.getValueByName("ServerName")
|
|
if dbg:
|
|
print >> dbgout, server
|
|
port = int(xConnectionContext.getValueByName("Port"))
|
|
if dbg:
|
|
print >> dbgout, port
|
|
connectiontype = xConnectionContext.getValueByName("ConnectionType")
|
|
if dbg:
|
|
print >> dbgout, connectiontype
|
|
print >> dbgout, "BEFORE"
|
|
if connectiontype == 'Ssl':
|
|
self.server = imaplib.IMAP4_SSL(server, port)
|
|
else:
|
|
self.server = imaplib.IMAP4(server, port)
|
|
print >> dbgout, "AFTER"
|
|
|
|
user = xAuthenticator.getUserName().encode('ascii')
|
|
password = xAuthenticator.getPassword().encode('ascii')
|
|
if user != '':
|
|
if dbg:
|
|
print >> dbgout, 'Logging in, username of', user
|
|
self.server.login(user, password)
|
|
|
|
for listener in self.listeners:
|
|
listener.connected(self.notify)
|
|
def disconnect(self):
|
|
if dbg:
|
|
print >> dbgout, "PyMailIMAPService disconnect"
|
|
if self.server:
|
|
self.server.logout()
|
|
self.server = None
|
|
for listener in self.listeners:
|
|
listener.disconnected(self.notify)
|
|
def isConnected(self):
|
|
if dbg:
|
|
print >> dbgout, "PyMailIMAPService isConnected"
|
|
return self.server != None
|
|
def getCurrentConnectionContext(self):
|
|
if dbg:
|
|
print >> dbgout, "PyMailIMAPService getCurrentConnectionContext"
|
|
return self.connectioncontext
|
|
|
|
class PyMailPOP3Service(unohelper.Base, XMailService):
|
|
def __init__( self, ctx ):
|
|
self.ctx = ctx
|
|
self.listeners = []
|
|
self.supportedtypes = ('Insecure', 'Ssl')
|
|
self.server = None
|
|
self.connectioncontext = None
|
|
self.notify = EventObject()
|
|
if dbg:
|
|
print >> dbgout, "PyMailPOP3Service init"
|
|
def addConnectionListener(self, xListener):
|
|
if dbg:
|
|
print >> dbgout, "PyMailPOP3Service addConnectionListener"
|
|
self.listeners.append(xListener)
|
|
def removeConnectionListener(self, xListener):
|
|
if dbg:
|
|
print >> dbgout, "PyMailPOP3Service removeConnectionListener"
|
|
self.listeners.remove(xListener)
|
|
def getSupportedConnectionTypes(self):
|
|
if dbg:
|
|
print >> dbgout, "PyMailPOP3Service getSupportedConnectionTypes"
|
|
return self.supportedtypes
|
|
def connect(self, xConnectionContext, xAuthenticator):
|
|
if dbg:
|
|
print >> dbgout, "PyMailPOP3Service connect"
|
|
|
|
self.connectioncontext = xConnectionContext
|
|
server = xConnectionContext.getValueByName("ServerName")
|
|
if dbg:
|
|
print >> dbgout, server
|
|
port = int(xConnectionContext.getValueByName("Port"))
|
|
if dbg:
|
|
print >> dbgout, port
|
|
connectiontype = xConnectionContext.getValueByName("ConnectionType")
|
|
if dbg:
|
|
print >> dbgout, connectiontype
|
|
print >> dbgout, "BEFORE"
|
|
if connectiontype == 'Ssl':
|
|
self.server = poplib.POP3_SSL(server, port)
|
|
else:
|
|
self.server = poplib.POP3(server, port)
|
|
print >> dbgout, "AFTER"
|
|
|
|
user = xAuthenticator.getUserName().encode('ascii')
|
|
password = xAuthenticator.getPassword().encode('ascii')
|
|
if dbg:
|
|
print >> dbgout, 'Logging in, username of', user
|
|
self.server.user(user)
|
|
self.server.pass_(user, password)
|
|
|
|
for listener in self.listeners:
|
|
listener.connected(self.notify)
|
|
def disconnect(self):
|
|
if dbg:
|
|
print >> dbgout, "PyMailPOP3Service disconnect"
|
|
if self.server:
|
|
self.server.quit()
|
|
self.server = None
|
|
for listener in self.listeners:
|
|
listener.disconnected(self.notify)
|
|
def isConnected(self):
|
|
if dbg:
|
|
print >> dbgout, "PyMailPOP3Service isConnected"
|
|
return self.server != None
|
|
def getCurrentConnectionContext(self):
|
|
if dbg:
|
|
print >> dbgout, "PyMailPOP3Service getCurrentConnectionContext"
|
|
return self.connectioncontext
|
|
|
|
class PyMailServiceProvider(unohelper.Base, XMailServiceProvider):
|
|
def __init__( self, ctx ):
|
|
if dbg:
|
|
print >> dbgout, "PyMailServiceProvider init"
|
|
self.ctx = ctx
|
|
def create(self, aType):
|
|
if dbg:
|
|
print >> dbgout, "PyMailServiceProvider create with", aType
|
|
if aType == SMTP:
|
|
return PyMailSMTPService(self.ctx);
|
|
elif aType == POP3:
|
|
return PyMailPOP3Service(self.ctx);
|
|
elif aType == IMAP:
|
|
return PyMailIMAPService(self.ctx);
|
|
else:
|
|
print >> dbgout, "PyMailServiceProvider, unknown TYPE", aType
|
|
|
|
class PyMailMessage(unohelper.Base, XMailMessage):
|
|
def __init__( self, ctx, sTo='', sFrom='', Subject='', Body=None, aMailAttachment=None ):
|
|
if dbg:
|
|
print >> dbgout, "PyMailMessage init"
|
|
self.ctx = ctx
|
|
|
|
self.recipients = sTo,
|
|
self.ccrecipients = ()
|
|
self.bccrecipients = ()
|
|
self.aMailAttachments = ()
|
|
if aMailAttachment != None:
|
|
self.aMailAttachments = aMailAttachment,
|
|
|
|
self.SenderName, self.SenderAddress = parseaddr(sFrom)
|
|
self.ReplyToAddress = sFrom
|
|
self.Subject = Subject
|
|
self.Body = Body
|
|
if dbg:
|
|
print >> dbgout, "post PyMailMessage init"
|
|
def addRecipient( self, recipient ):
|
|
if dbg:
|
|
print >> dbgout, "PyMailMessage.addRecipient", recipient
|
|
self.recipients = self.recipients, recipient
|
|
def addCcRecipient( self, ccrecipient ):
|
|
if dbg:
|
|
print >> dbgout, "PyMailMessage.addCcRecipient", ccrecipient
|
|
self.ccrecipients = self.ccrecipients, ccrecipient
|
|
def addBccRecipient( self, bccrecipient ):
|
|
if dbg:
|
|
print >> dbgout, "PyMailMessage.addBccRecipient", bccrecipient
|
|
self.bccrecipients = self.bccrecipients, bccrecipient
|
|
def getRecipients( self ):
|
|
if dbg:
|
|
print >> dbgout, "PyMailMessage.getRecipients", self.recipients
|
|
return self.recipients
|
|
def getCcRecipients( self ):
|
|
if dbg:
|
|
print >> dbgout, "PyMailMessage.getCcRecipients", self.ccrecipients
|
|
return self.ccrecipients
|
|
def getBccRecipients( self ):
|
|
if dbg:
|
|
print >> dbgout, "PyMailMessage.getBccRecipients", self.bccrecipients
|
|
return self.bccrecipients
|
|
def addAttachment( self, aMailAttachment ):
|
|
if dbg:
|
|
print >> dbgout, "PyMailMessage.addAttachment"
|
|
self.aMailAttachments = self.aMailAttachments, aMailAttachment
|
|
def getAttachments( self ):
|
|
if dbg:
|
|
print >> dbgout, "PyMailMessage.getAttachments"
|
|
return self.aMailAttachments
|
|
|
|
# pythonloader looks for a static g_ImplementationHelper variable
|
|
g_ImplementationHelper = unohelper.ImplementationHelper()
|
|
g_ImplementationHelper.addImplementation( \
|
|
PyMailServiceProvider, "org.openoffice.pyuno.MailServiceProvider",
|
|
("com.sun.star.mail.MailServiceProvider",),)
|
|
g_ImplementationHelper.addImplementation( \
|
|
PyMailMessage, "org.openoffice.pyuno.MailMessage",
|
|
("com.sun.star.mail.MailMessage",),)
|