Compare commits
3 commits
be80b1ed8c
...
e8de509346
Author | SHA1 | Date | |
---|---|---|---|
|
e8de509346 | ||
|
5a7a46355c | ||
|
a36ce4070b |
2 changed files with 28 additions and 11 deletions
|
@ -705,6 +705,7 @@ class LdapClient:
|
|||
attrs = dict(
|
||||
(attr, self.encode(values))
|
||||
for attr, values in attrs.items()
|
||||
if attr != 'dn'
|
||||
)
|
||||
try:
|
||||
if self._just_try:
|
||||
|
@ -729,11 +730,14 @@ class LdapClient:
|
|||
:param rdn_attr: The LDAP object RDN attribute (to detect renaming, default: auto-detected)
|
||||
"""
|
||||
assert isinstance(changes, (list, tuple)) and len(changes) == 2 and isinstance(changes[0], dict) and isinstance(changes[1], dict), "changes parameter must be a result of get_changes() method (%s given)" % type(changes)
|
||||
# In case of RDN change, we need to modify passed changes, copy it to make it unchanged in
|
||||
# this case
|
||||
_changes = copy.deepcopy(changes)
|
||||
if not rdn_attr:
|
||||
rdn_attr = ldap_obj['dn'].split('=')[0]
|
||||
log.debug('Auto-detected RDN attribute from DN: %s => %s', ldap_obj['dn'], rdn_attr)
|
||||
old_rdn_values = self.get_attr(changes[0], rdn_attr, all_values=True)
|
||||
new_rdn_values = self.get_attr(changes[1], rdn_attr, all_values=True)
|
||||
old_rdn_values = self.get_attr(_changes[0], rdn_attr, all_values=True)
|
||||
new_rdn_values = self.get_attr(_changes[1], rdn_attr, all_values=True)
|
||||
if old_rdn_values or new_rdn_values:
|
||||
if not new_rdn_values:
|
||||
log.error(
|
||||
|
@ -758,15 +762,15 @@ class LdapClient:
|
|||
return False
|
||||
|
||||
# Remove RDN in changes list
|
||||
for attr in list(changes[0].keys()):
|
||||
for attr in list(_changes[0].keys()):
|
||||
if attr.lower() == rdn_attr.lower():
|
||||
del changes[0][attr]
|
||||
for attr in list(changes[1].keys()):
|
||||
del _changes[0][attr]
|
||||
for attr in list(_changes[1].keys()):
|
||||
if attr.lower() == rdn_attr.lower():
|
||||
del changes[1][attr]
|
||||
del _changes[1][attr]
|
||||
|
||||
# Check that there are other changes
|
||||
if not changes[0] and not changes[1]:
|
||||
if not _changes[0] and not _changes[1]:
|
||||
log.debug('%s: No other change after renaming', new_dn)
|
||||
return True
|
||||
|
||||
|
@ -782,14 +786,14 @@ class LdapClient:
|
|||
assert self._conn or self.initialize()
|
||||
return self._conn.update_object(
|
||||
ldap_obj['dn'],
|
||||
changes[0],
|
||||
changes[1],
|
||||
_changes[0],
|
||||
_changes[1],
|
||||
ignore_attrs=protected_attrs
|
||||
)
|
||||
except LdapServerException:
|
||||
log.error(
|
||||
"An error occurred updating object %s in LDAP:\n%s\n -> \n%s\n\n",
|
||||
ldap_obj['dn'], pretty_format_dict(changes[0]), pretty_format_dict(changes[1]),
|
||||
ldap_obj['dn'], pretty_format_dict(_changes[0]), pretty_format_dict(_changes[1]),
|
||||
exc_info=True
|
||||
)
|
||||
return False
|
||||
|
|
|
@ -33,6 +33,8 @@ class Report(ConfigurableObject): # pylint: disable=useless-object-inheritance
|
|||
def __init__(self, email_client=None, initialize=True, **kwargs):
|
||||
super().__init__(**kwargs)
|
||||
self.email_client = email_client
|
||||
self._attachment_files = []
|
||||
self._attachment_payloads = []
|
||||
|
||||
if initialize:
|
||||
self.initialize()
|
||||
|
@ -84,6 +86,14 @@ class Report(ConfigurableObject): # pylint: disable=useless-object-inheritance
|
|||
""" Read the report content """
|
||||
return "".join(self.content)
|
||||
|
||||
def add_attachment_file(self, filepath):
|
||||
""" Add attachment file """
|
||||
self._attachment_files.append(filepath)
|
||||
|
||||
def add_attachment_payload(self, payload):
|
||||
""" Add attachment payload """
|
||||
self._attachment_payloads.append(payload)
|
||||
|
||||
def send(self, subject=None, rcpt_to=None, email_client=None, just_try=False):
|
||||
""" Send report using an EmailClient """
|
||||
if rcpt_to is None:
|
||||
|
@ -102,7 +112,10 @@ class Report(ConfigurableObject): # pylint: disable=useless-object-inheritance
|
|||
if not content:
|
||||
log.debug('Report is empty, do not send it')
|
||||
return True
|
||||
msg = email_client.forge_message(rcpt_to, subject=subject, text_body=content)
|
||||
msg = email_client.forge_message(
|
||||
rcpt_to, subject=subject, text_body=content,
|
||||
attachment_files=self._attachment_files,
|
||||
attachment_payloads=self._attachment_payloads)
|
||||
if email_client.send(rcpt_to, msg=msg, just_try=just_try):
|
||||
log.debug('Report sent to %s', rcpt_to)
|
||||
return True
|
||||
|
|
Loading…
Reference in a new issue