Differential D159 Diff 357 wallace/module_invitationpolicy.py

Changeset View

Standalone View

wallace/module_invitationpolicy.py

Show First 20 Lines • Show All 46 Lines • ▼ Show 20 Lines
from pykolab.xml import event_from_message		from pykolab.xml import event_from_message
from pykolab.xml import participant_status_label		from pykolab.xml import participant_status_label
from pykolab.itip import objects_from_message		from pykolab.itip import objects_from_message
from pykolab.itip import check_event_conflict		from pykolab.itip import check_event_conflict
from pykolab.itip import send_reply		from pykolab.itip import send_reply
from pykolab.translate import _		from pykolab.translate import _

# define some contstants used in the code below		# define some contstants used in the code below
ACT_MANUAL = 1		ACT_MANUAL = 1
		Lint: PEP8 E221 Inline Actions multiple spaces before operator Lint: PEP8 E221: multiple spaces before operator
ACT_ACCEPT = 2		ACT_ACCEPT = 2
		Lint: PEP8 E221 Inline Actions multiple spaces before operator Lint: PEP8 E221: multiple spaces before operator
ACT_DELEGATE = 4		ACT_DELEGATE = 4
		Lint: PEP8 E221 Inline Actions multiple spaces before operator Lint: PEP8 E221: multiple spaces before operator
ACT_REJECT = 8		ACT_REJECT = 8
		Lint: PEP8 E221 Inline Actions multiple spaces before operator Lint: PEP8 E221: multiple spaces before operator
ACT_UPDATE = 16		ACT_UPDATE = 16
		Lint: PEP8 E221 Inline Actions multiple spaces before operator Lint: PEP8 E221: multiple spaces before operator
ACT_CANCEL_DELETE = 32		ACT_CANCEL_DELETE = 32
		Lint: PEP8 E221 Inline Actions multiple spaces before operator Lint: PEP8 E221: multiple spaces before operator
ACT_SAVE_TO_FOLDER = 64		ACT_SAVE_TO_FOLDER = 64

COND_IF_AVAILABLE = 128		COND_IF_AVAILABLE = 128
		Lint: PEP8 E221 Inline Actions multiple spaces before operator Lint: PEP8 E221: multiple spaces before operator
COND_IF_CONFLICT = 256		COND_IF_CONFLICT = 256
		Lint: PEP8 E221 Inline Actions multiple spaces before operator Lint: PEP8 E221: multiple spaces before operator
COND_TENTATIVE = 512		COND_TENTATIVE = 512
		Lint: PEP8 E221 Inline Actions multiple spaces before operator Lint: PEP8 E221: multiple spaces before operator
COND_NOTIFY = 1024		COND_NOTIFY = 1024
		Lint: PEP8 E221 Inline Actions multiple spaces before operator Lint: PEP8 E221: multiple spaces before operator
COND_FORWARD = 2048		COND_FORWARD = 2048
		Lint: PEP8 E221 Inline Actions multiple spaces before operator Lint: PEP8 E221: multiple spaces before operator
COND_TYPE_EVENT = 4096		COND_TYPE_EVENT = 4096
		Lint: PEP8 E221 Inline Actions multiple spaces before operator Lint: PEP8 E221: multiple spaces before operator
COND_TYPE_TASK = 8192		COND_TYPE_TASK = 8192
		Lint: PEP8 E221 Inline Actions multiple spaces before operator Lint: PEP8 E221: multiple spaces before operator
COND_TYPE_ALL = COND_TYPE_EVENT + COND_TYPE_TASK		COND_TYPE_ALL = COND_TYPE_EVENT + COND_TYPE_TASK
		Lint: PEP8 E221 Inline Actions multiple spaces before operator Lint: PEP8 E221: multiple spaces before operator

ACT_TENTATIVE = ACT_ACCEPT + COND_TENTATIVE		ACT_TENTATIVE = ACT_ACCEPT + COND_TENTATIVE
		Lint: PEP8 E221 Inline Actions multiple spaces before operator Lint: PEP8 E221: multiple spaces before operator
ACT_UPDATE_AND_NOTIFY = ACT_UPDATE + COND_NOTIFY		ACT_UPDATE_AND_NOTIFY = ACT_UPDATE + COND_NOTIFY
ACT_SAVE_AND_FORWARD = ACT_SAVE_TO_FOLDER + COND_FORWARD		ACT_SAVE_AND_FORWARD = ACT_SAVE_TO_FOLDER + COND_FORWARD
		Lint: PEP8 E221 Inline Actions multiple spaces before operator Lint: PEP8 E221: multiple spaces before operator
ACT_CANCEL_DELETE_AND_NOTIFY = ACT_CANCEL_DELETE + COND_NOTIFY		ACT_CANCEL_DELETE_AND_NOTIFY = ACT_CANCEL_DELETE + COND_NOTIFY

FOLDER_TYPE_ANNOTATION = '/vendor/kolab/folder-type'		FOLDER_TYPE_ANNOTATION = '/vendor/kolab/folder-type'

MESSAGE_PROCESSED = 1		MESSAGE_PROCESSED = 1
MESSAGE_FORWARD = 2		MESSAGE_FORWARD = 2
		Lint: PEP8 E221 Inline Actions multiple spaces before operator Lint: PEP8 E221: multiple spaces before operator

policy_name_map = {		policy_name_map = {
# policy values applying to all object types		# policy values applying to all object types
'ALL_MANUAL': ACT_MANUAL + COND_TYPE_ALL,		'ALL_MANUAL': ACT_MANUAL + COND_TYPE_ALL,
'ALL_ACCEPT': ACT_ACCEPT + COND_TYPE_ALL,		'ALL_ACCEPT': ACT_ACCEPT + COND_TYPE_ALL,
'ALL_REJECT': ACT_REJECT + COND_TYPE_ALL,		'ALL_REJECT': ACT_REJECT + COND_TYPE_ALL,
'ALL_DELEGATE': ACT_DELEGATE + COND_TYPE_ALL, # not implemented		'ALL_DELEGATE': ACT_DELEGATE + COND_TYPE_ALL, # not implemented
'ALL_UPDATE': ACT_UPDATE + COND_TYPE_ALL,		'ALL_UPDATE': ACT_UPDATE + COND_TYPE_ALL,
▲ Show 20 Lines • Show All 42 Lines • ▼ Show 20 Lines	policy_name_map = {
'ACT_UPDATE': ACT_UPDATE + COND_TYPE_ALL,		'ACT_UPDATE': ACT_UPDATE + COND_TYPE_ALL,
'ACT_UPDATE_AND_NOTIFY': ACT_UPDATE_AND_NOTIFY + COND_TYPE_ALL,		'ACT_UPDATE_AND_NOTIFY': ACT_UPDATE_AND_NOTIFY + COND_TYPE_ALL,
'ACT_CANCEL_DELETE': ACT_CANCEL_DELETE + COND_TYPE_ALL,		'ACT_CANCEL_DELETE': ACT_CANCEL_DELETE + COND_TYPE_ALL,
'ACT_CANCEL_DELETE_AND_NOTIFY': ACT_CANCEL_DELETE_AND_NOTIFY + COND_TYPE_ALL,		'ACT_CANCEL_DELETE_AND_NOTIFY': ACT_CANCEL_DELETE_AND_NOTIFY + COND_TYPE_ALL,
'ACT_SAVE_TO_CALENDAR': ACT_SAVE_TO_FOLDER + COND_TYPE_EVENT,		'ACT_SAVE_TO_CALENDAR': ACT_SAVE_TO_FOLDER + COND_TYPE_EVENT,
'ACT_SAVE_AND_FORWARD': ACT_SAVE_AND_FORWARD + COND_TYPE_EVENT,		'ACT_SAVE_AND_FORWARD': ACT_SAVE_AND_FORWARD + COND_TYPE_EVENT,
}		}

policy_value_map = dict([(v &~ COND_TYPE_ALL, k) for (k, v) in policy_name_map.iteritems()])		policy_value_map = dict([(v &~ COND_TYPE_ALL, k) for (k, v) in policy_name_map.iteritems()])
		Lint: PEP8 E225 Inline Actions missing whitespace around operator Lint: PEP8 E225: missing whitespace around operator

object_type_conditons = {		object_type_conditons = {
'event': COND_TYPE_EVENT,		'event': COND_TYPE_EVENT,
'task': COND_TYPE_TASK		'task': COND_TYPE_TASK
}		}

log = pykolab.getLogger('pykolab.wallace')		log = pykolab.getLogger('pykolab.wallace')
conf = pykolab.getConf()		conf = pykolab.getConf()
▲ Show 20 Lines • Show All 308 Lines • ▼ Show 20 Lines	elif policy & ACT_UPDATE and existing:
rsvp = False		rsvp = False

# retain task status and percent-complete properties from my old copy		# retain task status and percent-complete properties from my old copy
if is_task:		if is_task:
itip_event['xml'].set_status(existing.get_status())		itip_event['xml'].set_status(existing.get_status())
itip_event['xml'].set_percentcomplete(existing.get_percentcomplete())		itip_event['xml'].set_percentcomplete(existing.get_percentcomplete())

if policy & COND_NOTIFY:		if policy & COND_NOTIFY:
send_update_notification(itip_event['xml'], receiving_user, existing, False)		sender = itip_event['xml'].get_organizer()
		vanmeeuwenUnsubmitted Not Done Inline Actions How is the sender the organizer, and not the user responding? vanmeeuwen: How is the sender the organizer, and not the user responding?
		machniakAuthorUnsubmitted Not Done Inline Actions Because only organizer sends REQUEST messages. And we use this only to add "<Sender> commented..." in the notification. So, I think it's reasonably safe assumption. Getting sender from mail headers would be more complicated. machniak: Because only organizer sends REQUEST messages. And we use this only to add "<Sender> commented..
		comment = itip_event['xml'].get_comment()
		send_update_notification(itip_event['xml'], receiving_user, existing, False,
		sender, comment)
		vanmeeuwenUnsubmitted Not Done Inline Actions Why would we bounce the sender and comment about like this, noted that send_update_notification is already supplied with the itip_event['xml'] that contains both the organizer and the comment? vanmeeuwen: Why would we bounce the sender and comment about like this, noted that send_update_notification…
		machniakAuthorUnsubmitted Not Done Inline Actions It's because there's a case when we don't use itip_event['xml'] as an argument for send_update_notification(). machniak: It's because there's a case when we don't use itip_event['xml'] as an argument for…

# if RSVP, send an iTip REPLY		# if RSVP, send an iTip REPLY
if rsvp or scheduling_required:		if rsvp or scheduling_required:
# set attendee's CN from LDAP record if yet missing		# set attendee's CN from LDAP record if yet missing
if not receiving_attendee.get_name() and receiving_user.has_key('cn'):		if not receiving_attendee.get_name() and receiving_user.has_key('cn'):
receiving_attendee.set_name(receiving_user['cn'])		receiving_attendee.set_name(receiving_user['cn'])

# send iTip reply		# send iTip reply
if respond_with is not None and not respond_with == 'NEEDS-ACTION':		if respond_with is not None and not respond_with == 'NEEDS-ACTION':
receiving_attendee.set_participant_status(respond_with)		receiving_attendee.set_participant_status(respond_with)
send_reply(recipient_email, itip_event, invitation_response_text(itip_event['type']),		send_reply(recipient_email, itip_event, invitation_response_text(itip_event['type']),
subject=_('"%(summary)s" has been %(status)s'))		subject=_('"%(summary)s" has been %(status)s'))
		Lint: PEP8 E128 Inline Actions continuation line under-indented for visual indent Lint: PEP8 E128: continuation line under-indented for visual indent

elif policy & ACT_SAVE_TO_FOLDER:		elif policy & ACT_SAVE_TO_FOLDER:
# copy the invitation into the user's default folder with PARTSTAT=NEEDS-ACTION		# copy the invitation into the user's default folder with PARTSTAT=NEEDS-ACTION
itip_event['xml'].set_attendee_participant_status(receiving_attendee, respond_with or 'NEEDS-ACTION')		itip_event['xml'].set_attendee_participant_status(receiving_attendee, respond_with or 'NEEDS-ACTION')
save_object = True		save_object = True

else:		else:
# policy doesn't match, pass on to next one		# policy doesn't match, pass on to next one
▲ Show 20 Lines • Show All 94 Lines • ▼ Show 20 Lines	if policy & ACT_UPDATE:
log.debug(_("Update delegator: %r") % (existing_attendee.to_dict()), level=9)		log.debug(_("Update delegator: %r") % (existing_attendee.to_dict()), level=9)

except Exception, errmsg:		except Exception, errmsg:
log.error("Could not find delegated-to attendee: %r" % (errmsg))		log.error("Could not find delegated-to attendee: %r" % (errmsg))

# update the organizer's copy of the object		# update the organizer's copy of the object
if update_object(existing, receiving_user, master):		if update_object(existing, receiving_user, master):
if policy & COND_NOTIFY:		if policy & COND_NOTIFY:
send_update_notification(existing, receiving_user, existing, True)		send_update_notification(existing, receiving_user, existing, True,
		sender_attendee, itip_event['xml'].get_comment())
		vanmeeuwenUnsubmitted Not Done Inline Actions Here, the sender is a sender_attendee? vanmeeuwen: Here, the sender is a sender_attendee?
		machniakAuthorUnsubmitted Not Done Inline Actions Yes, because this is iTip REPLY. machniak: Yes, because this is iTip REPLY.

# update all other attendee's copies		# update all other attendee's copies
if conf.get('wallace','invitationpolicy_autoupdate_other_attendees_on_reply'):		if conf.get('wallace','invitationpolicy_autoupdate_other_attendees_on_reply'):
propagate_changes_to_attendees_accounts(existing, updated_attendees)		propagate_changes_to_attendees_accounts(existing, updated_attendees)

return MESSAGE_PROCESSED		return MESSAGE_PROCESSED

else:		else:
▲ Show 20 Lines • Show All 47 Lines • ▼ Show 20 Lines	if policy & ACT_UPDATE or policy & ACT_CANCEL_DELETE:
log.debug(_("Update cancelled %s %r with STATUS=CANCELLED") % (existing.type, existing.uid), level=8)		log.debug(_("Update cancelled %s %r with STATUS=CANCELLED") % (existing.type, existing.uid), level=8)
existing.set_status('CANCELLED')		existing.set_status('CANCELLED')
existing.set_transparency(True)		existing.set_transparency(True)
success = update_object(existing, receiving_user, master)		success = update_object(existing, receiving_user, master)

if success:		if success:
# send cancellation notification		# send cancellation notification
if policy & COND_NOTIFY:		if policy & COND_NOTIFY:
send_cancel_notification(existing, receiving_user, remove_object)		sender = itip_event['xml'].get_organizer()
		comment = itip_event['xml'].get_comment()
		send_cancel_notification(existing, receiving_user, remove_object, sender, comment)
		vanmeeuwenUnsubmitted Not Done Inline Actions Same comments/questions as before on 464-467. vanmeeuwen: Same comments/questions as before on 464-467.
		machniakAuthorUnsubmitted Not Done Inline Actions Same answers as above. This is iTip CANCEL and we use this only to add "<Sender> commented..." to the notification message. machniak: Same answers as above. This is iTip CANCEL and we use this only to add "<Sender> commented..."…

return MESSAGE_PROCESSED		return MESSAGE_PROCESSED

else:		else:
log.error(_("The object referred by this cancel request was not found in the user's folders. Forwarding to Inbox."))		log.error(_("The object referred by this cancel request was not found in the user's folders. Forwarding to Inbox."))
return MESSAGE_FORWARD		return MESSAGE_FORWARD

return None		return None
▲ Show 20 Lines • Show All 58 Lines • ▼ Show 20 Lines	for p in policies:
domain = ''		domain = ''

if domain == '' or domain == '*' or str(sender_email).endswith(domain):		if domain == '' or domain == '*' or str(sender_email).endswith(domain):
value = value.upper()		value = value.upper()
if policy_name_map.has_key(value):		if policy_name_map.has_key(value):
val = policy_name_map[value]		val = policy_name_map[value]
# append if type condition matches		# append if type condition matches
if val & type_condition:		if val & type_condition:
matches.append(val &~ COND_TYPE_ALL)		matches.append(val &~ COND_TYPE_ALL)
		Lint: PEP8 E225 Inline Actions missing whitespace around operator Lint: PEP8 E225: missing whitespace around operator

# add manual as default action		# add manual as default action
if len(matches) == 0:		if len(matches) == 0:
matches.append(ACT_MANUAL)		matches.append(ACT_MANUAL)

return matches		return matches


Show All 32 Lines
def list_user_folders(user_rec, type):		def list_user_folders(user_rec, type):
"""		"""
Get a list of the given user's private calendar/tasks folders		Get a list of the given user's private calendar/tasks folders
"""		"""
global imap		global imap

# return cached list		# return cached list
if user_rec.has_key('_imap_folders'):		if user_rec.has_key('_imap_folders'):
return user_rec['_imap_folders'];		return user_rec['_imap_folders']

result = []		result = []

if not imap_proxy_auth(user_rec):		if not imap_proxy_auth(user_rec):
return result		return result

folders = imap.list_folders('*')		folders = imap.list_folders('*')
log.debug(_("List %r folders for user %r: %r") % (type, user_rec['mail'], folders), level=8)		log.debug(_("List %r folders for user %r: %r") % (type, user_rec['mail'], folders), level=8)

(ns_personal, ns_other, ns_shared) = imap.namespaces()		(ns_personal, ns_other, ns_shared) = imap.namespaces()

for folder in folders:		for folder in folders:
# exclude shared and other user's namespace		# exclude shared and other user's namespace
if not ns_other is None and folder.startswith(ns_other) and user_rec.has_key('_delegated_mailboxes'):		if ns_other is not None and folder.startswith(ns_other) and '_delegated_mailboxes' in user_rec:
# allow shared folders from delegators		# allow shared folders from delegators
if len([_mailbox for _mailbox in user_rec['_delegated_mailboxes'] if folder.startswith(ns_other + _mailbox + '/')]) == 0:		if len([_mailbox for _mailbox in user_rec['_delegated_mailboxes'] if folder.startswith(ns_other + _mailbox + '/')]) == 0:
continue;		continue
# TODO: list shared folders the user has write privileges ?		# TODO: list shared folders the user has write privileges ?
if not ns_shared is None and len([_ns for _ns in ns_shared if folder.startswith(_ns)]) > 0:		if ns_shared is not None and len([_ns for _ns in ns_shared if folder.startswith(_ns)]) > 0:
continue;		continue

metadata = imap.get_metadata(folder)		metadata = imap.get_metadata(folder)
log.debug(_("IMAP metadata for %r: %r") % (folder, metadata), level=9)		log.debug(_("IMAP metadata for %r: %r") % (folder, metadata), level=9)
if metadata.has_key(folder) and ( \		if metadata.has_key(folder) and ( \
		Lint: PEP8 E502 Inline Actions the backslash is redundant between brackets Lint: PEP8 E502: the backslash is redundant between brackets
metadata[folder].has_key('/shared' + FOLDER_TYPE_ANNOTATION) and metadata[folder]['/shared' + FOLDER_TYPE_ANNOTATION].startswith(type) \		metadata[folder].has_key('/shared' + FOLDER_TYPE_ANNOTATION) and metadata[folder]['/shared' + FOLDER_TYPE_ANNOTATION].startswith(type) \
		Lint: PEP8 E502 Inline Actions the backslash is redundant between brackets Lint: PEP8 E502: the backslash is redundant between brackets
or metadata[folder].has_key('/private' + FOLDER_TYPE_ANNOTATION) and metadata[folder]['/private' + FOLDER_TYPE_ANNOTATION].startswith(type)):		or metadata[folder].has_key('/private' + FOLDER_TYPE_ANNOTATION) and metadata[folder]['/private' + FOLDER_TYPE_ANNOTATION].startswith(type)):
		Lint: PEP8 E125 Inline Actions continuation line with same indent as next logical line Lint: PEP8 E125: continuation line with same indent as next logical line
result.append(folder)		result.append(folder)

if metadata[folder].has_key('/private' + FOLDER_TYPE_ANNOTATION):		if metadata[folder].has_key('/private' + FOLDER_TYPE_ANNOTATION):
# store default folder in user record		# store default folder in user record
if metadata[folder]['/private' + FOLDER_TYPE_ANNOTATION].endswith('.default'):		if metadata[folder]['/private' + FOLDER_TYPE_ANNOTATION].endswith('.default'):
user_rec['_default_folder'] = folder		user_rec['_default_folder'] = folder

# store private and confidential folders in user record		# store private and confidential folders in user record
▲ Show 20 Lines • Show All 285 Lines • ▼ Show 20 Lines	def delete_object(existing):
except Exception, errmsg:		except Exception, errmsg:
log.error(_("Failed to delete %s from folder %r: %r") % (		log.error(_("Failed to delete %s from folder %r: %r") % (
existing.type, targetfolder, errmsg		existing.type, targetfolder, errmsg
))		))

return False		return False


def send_update_notification(object, receiving_user, old=None, reply=True):		def send_update_notification(object, receiving_user, old=None, reply=True, sender=None, comment=None):
"""		"""
Send a (consolidated) notification about the current participant status to organizer		Send a (consolidated) notification about the current participant status to organizer
"""		"""
global auth		global auth

import smtplib		import smtplib
from email.MIMEText import MIMEText		from email.MIMEText import MIMEText
from email.Utils import formatdate		from email.Utils import formatdate
from email.header import Header		from email.header import Header
from email import charset		from email import charset

# encode unicode strings with quoted-printable		# encode unicode strings with quoted-printable
charset.add_charset('utf-8', charset.SHORTEST, charset.QP)		charset.add_charset('utf-8', charset.SHORTEST, charset.QP)

organizer = object.get_organizer()		organizer = object.get_organizer()
orgemail = organizer.email()		orgemail = organizer.email()
orgname = organizer.name()		orgname = organizer.name()

		itip_comment = None
		if sender is not None and not comment == '':
		itip_comment = _("%s commented: %s") % (_attendee_name(sender), comment)
		vanmeeuwenUnsubmitted Not Done Inline Actions What is the 'sender' here is the initiator of a request or reply -- for requests, 'old is None', and for replies, I reckon 'old is not None', for a reply is supposed to be a mutation of an orignal. vanmeeuwen: What is the 'sender' here is the initiator of a request or reply -- for requests, 'old is None'…
		machniakAuthorUnsubmitted Not Done Inline Actions This is just a sanity check. We add comment to the notification if we know the sender and there's a comment. machniak: This is just a sanity check. We add comment to the notification if we know the sender and…

if reply:		if reply:
log.debug(_("Compose participation status summary for %s %r to user %r") % (		log.debug(_("Compose participation status summary for %s %r to user %r") % (
object.type, object.uid, receiving_user['mail']		object.type, object.uid, receiving_user['mail']
), level=8)		), level=8)

auto_replies_expected = 0		auto_replies_expected = 0
auto_replies_received = 0		auto_replies_received = 0
		is_manual_reply = True
		vanmeeuwenUnsubmitted Not Done Inline Actions I thought we had agreed to determine whether the attendee (whom this reply concerns) is an attendee for which the policy would dictate an automated reply be issued using is_auto_reply()? vanmeeuwen: I thought we had agreed to determine whether the attendee (whom this reply concerns) is an…
partstats = { 'ACCEPTED':[], 'TENTATIVE':[], 'DECLINED':[], 'DELEGATED':[], 'IN-PROCESS':[], 'COMPLETED':[], 'PENDING':[] }		partstats = {'ACCEPTED': [], 'TENTATIVE': [], 'DECLINED': [], 'DELEGATED': [], 'IN-PROCESS': [], 'COMPLETED': [], 'PENDING': []}

for attendee in object.get_attendees():		for attendee in object.get_attendees():
parstat = attendee.get_participant_status(True)		parstat = attendee.get_participant_status(True)
if partstats.has_key(parstat):		if partstats.has_key(parstat):
partstats[parstat].append(attendee.get_displayname())		partstats[parstat].append(attendee.get_displayname())
else:		else:
partstats['PENDING'].append(attendee.get_displayname())		partstats['PENDING'].append(attendee.get_displayname())

# look-up kolabinvitationpolicy for this attendee		# look-up kolabinvitationpolicy for this attendee
if attendee.get_cutype() == kolabformat.CutypeResource:		if attendee.get_cutype() == kolabformat.CutypeResource:
resource_dns = auth.find_resource(attendee.get_email())		resource_dns = auth.find_resource(attendee.get_email())
if isinstance(resource_dns, list):		if isinstance(resource_dns, list):
attendee_dn = resource_dns[0] if len(resource_dns) > 0 else None		attendee_dn = resource_dns[0] if len(resource_dns) > 0 else None
else:		else:
attendee_dn = resource_dns		attendee_dn = resource_dns
else:		else:
attendee_dn = user_dn_from_email_address(attendee.get_email())		attendee_dn = user_dn_from_email_address(attendee.get_email())

if attendee_dn:		if attendee_dn:
attendee_rec = auth.get_entry_attributes(None, attendee_dn, ['kolabinvitationpolicy'])		attendee_rec = auth.get_entry_attributes(None, attendee_dn, ['kolabinvitationpolicy'])
if is_auto_reply(attendee_rec, orgemail, object.type):		if is_auto_reply(attendee_rec, orgemail, object.type):
auto_replies_expected += 1		auto_replies_expected += 1
if not parstat == 'NEEDS-ACTION':		if not parstat == 'NEEDS-ACTION':
auto_replies_received += 1		auto_replies_received += 1

		if sender is not None and sender.get_email() == attendee.get_email():
		is_manual_reply = False

		vanmeeuwenUnsubmitted Not Done Inline Actions I do not understand how this clause validates. vanmeeuwen: I do not understand how this clause validates.
		machniakAuthorUnsubmitted Not Done Inline Actions This is a loop over all attendees. So, if sender is defined and sender email equals currently processed attendee's email and this is auto-reply we unset the manual reply. I think this way we'll have less false-positives. machniak: This is a loop over all attendees. So, if sender is defined and sender email equals currently…
# skip notification until we got replies from all automatically responding attendees		# skip notification until we got replies from all automatically responding attendees
if auto_replies_received < auto_replies_expected:		if not is_manual_reply and auto_replies_received < auto_replies_expected:
log.debug(_("Waiting for more automated replies (got %d of %d); skipping notification") % (		log.debug(_("Waiting for more automated replies (got %d of %d); skipping notification") % (
auto_replies_received, auto_replies_expected		auto_replies_received, auto_replies_expected
), level=8)		), level=8)
return		return

		# build notification message body
roundup = ''		roundup = ''

		if itip_comment is not None:
		roundup += "\n" + itip_comment

for status,attendees in partstats.iteritems():		for status,attendees in partstats.iteritems():
if len(attendees) > 0:		if len(attendees) > 0:
roundup += "\n" + participant_status_label(status) + ":\n" + "\n".join(attendees) + "\n"		roundup += "\n" + participant_status_label(status) + ":\n\t" + "\n\t".join(attendees) + "\n"
else:		else:
roundup = "\n" + _("Changes submitted by %s have been automatically applied.") % (orgname if orgname else orgemail)		# build notification message body
		roundup = ''

		if itip_comment is not None:
		roundup += "\n" + itip_comment

		roundup += "\n" + _("Changes submitted by %s have been automatically applied.") % (orgname if orgname else orgemail)

# list properties changed from previous version		# list properties changed from previous version
if old:		if old:
diff = xmlutils.compute_diff(old.to_dict(), object.to_dict())		diff = xmlutils.compute_diff(old.to_dict(), object.to_dict())
if len(diff) > 1:		if len(diff) > 1:
roundup += "\n"		roundup += "\n"
for change in diff:		for change in diff:
if not change['property'] in ['created','lastmodified-date','sequence']:		if not change['property'] in ['created','lastmodified-date','sequence']:
▲ Show 20 Lines • Show All 52 Lines • ▼ Show 20 Lines	while not success and retries > 0:
log.error(_("SMTP sendmail error: %r") % (errmsg))		log.error(_("SMTP sendmail error: %r") % (errmsg))

time.sleep(10)		time.sleep(10)
retries -= 1		retries -= 1

return success		return success


def send_cancel_notification(object, receiving_user, deleted=False):		def send_cancel_notification(object, receiving_user, deleted=False, sender=None, comment=None):
"""		"""
Send a notification about event/task cancellation		Send a notification about event/task cancellation
"""		"""
import smtplib		import smtplib
from email.MIMEText import MIMEText		from email.MIMEText import MIMEText
from email.Utils import formatdate		from email.Utils import formatdate
from email.header import Header		from email.header import Header
from email import charset		from email import charset
Show All 25 Lines	else:
'start': xmlutils.property_to_string('start', object.get_start()),		'start': xmlutils.property_to_string('start', object.get_start()),
'organizer': orgname if orgname else orgemail		'organizer': orgname if orgname else orgemail
}		}
if deleted:		if deleted:
message_text += " " + _("The copy in your calendar has been removed accordingly.")		message_text += " " + _("The copy in your calendar has been removed accordingly.")
else:		else:
message_text += " " + _("The copy in your calendar has been marked as cancelled accordingly.")		message_text += " " + _("The copy in your calendar has been marked as cancelled accordingly.")

		if sender is not None and not comment == '':
		message_text += "\n" + _("%s commented: %s") % (_attendee_name(sender), comment)

if object.get_recurrence_id():		if object.get_recurrence_id():
message_text += "\n" + _("NOTE: This cancellation only refers to this single occurrence!")		message_text += "\n" + _("NOTE: This cancellation only refers to this single occurrence!")

message_text += "\n\n" + _("* This is an automated message. Please do not reply. *")		message_text += "\n\n" + _("* This is an automated message. Please do not reply. *")

# compose mime message		# compose mime message
msg = MIMEText(utils.stripped_message(message_text), _charset='utf-8')		msg = MIMEText(utils.stripped_message(message_text), _charset='utf-8')

▲ Show 20 Lines • Show All 64 Lines • ▼ Show 20 Lines	for attendee in object.get_attendees():
try:		try:
attendee_entry = attendee_object.get_attendee_by_email(attendee_email)		attendee_entry = attendee_object.get_attendee_by_email(attendee_email)
except:		except:
attendee_entry = None		attendee_entry = None
if attendee_entry:		if attendee_entry:
break		break

# copy all attendees from master object (covers additions and removals)		# copy all attendees from master object (covers additions and removals)
new_attendees = [];		new_attendees = []
for a in object.get_attendees():		for a in object.get_attendees():
# keep my own entry intact		# keep my own entry intact
if attendee_entry is not None and attendee_entry.get_email() == a.get_email():		if attendee_entry is not None and attendee_entry.get_email() == a.get_email():
new_attendees.append(attendee_entry)		new_attendees.append(attendee_entry)
else:		else:
new_attendees.append(a)		new_attendees.append(a)

attendee_object.set_attendees(new_attendees)		attendee_object.set_attendees(new_attendees)
Show All 14 Lines

def invitation_response_text(type):		def invitation_response_text(type):
footer = "\n\n" + _("* This is an automated message. Please do not reply. *")		footer = "\n\n" + _("* This is an automated message. Please do not reply. *")

if type == 'task':		if type == 'task':
return _("%(name)s has %(status)s your assignment for %(summary)s.") + footer		return _("%(name)s has %(status)s your assignment for %(summary)s.") + footer
else:		else:
return _("%(name)s has %(status)s your invitation for %(summary)s.") + footer		return _("%(name)s has %(status)s your invitation for %(summary)s.") + footer


		def _attendee_name(attendee):
		# attendee here can be Attendee or ContactReference
		try:
		name = attendee.get_name()
		except Exception:
		name = attendee.name()

		if name == '':
		try:
		name = attendee.get_email()
		except Exception:
		name = attendee.email()

		return name