mirror of https://github.com/OCA/social.git
137 lines
4.0 KiB
Python
137 lines
4.0 KiB
Python
# Copyright 2018 Therp BV <https://therp.nl>
|
|
# License AGPL-3.0 or later (https://www.gnu.org/licenses/agpl.html).
|
|
from base64 import b64decode
|
|
|
|
from odoo import _, api, exceptions, models
|
|
|
|
try:
|
|
from extract_msg import Message
|
|
except ImportError:
|
|
Message = None
|
|
|
|
|
|
class MailThread(models.AbstractModel):
|
|
_inherit = "mail.thread"
|
|
|
|
@api.model
|
|
def message_drop(
|
|
self,
|
|
model,
|
|
message,
|
|
custom_values=None,
|
|
save_original=False,
|
|
strip_attachments=False,
|
|
thread_id=None,
|
|
):
|
|
disable_notify_mail_drop_target = (
|
|
self.env["ir.config_parameter"]
|
|
.sudo()
|
|
.get_param("mail_drop_target.disable_notify", default=False)
|
|
)
|
|
self_message_process = self
|
|
if disable_notify_mail_drop_target:
|
|
self_message_process = self_message_process.with_context(
|
|
message_create_from_mail_mail=True
|
|
)
|
|
result = self_message_process.message_process(
|
|
model,
|
|
message,
|
|
custom_values=custom_values,
|
|
save_original=save_original,
|
|
strip_attachments=strip_attachments,
|
|
thread_id=thread_id,
|
|
)
|
|
if not result:
|
|
return self.message_drop_existing(
|
|
model,
|
|
message,
|
|
custom_values=custom_values,
|
|
save_original=save_original,
|
|
strip_attachments=strip_attachments,
|
|
thread_id=thread_id,
|
|
)
|
|
return result
|
|
|
|
@api.model
|
|
def message_drop_existing(
|
|
self,
|
|
model,
|
|
message,
|
|
custom_values=None,
|
|
save_original=False,
|
|
strip_attachments=False,
|
|
thread_id=None,
|
|
):
|
|
message = _("This message is already imported.")
|
|
raise exceptions.Warning(message)
|
|
|
|
@api.model
|
|
def message_process_msg(
|
|
self,
|
|
model,
|
|
message,
|
|
custom_values=None,
|
|
save_original=False,
|
|
strip_attachments=False,
|
|
thread_id=None,
|
|
):
|
|
"""Convert message to RFC2822 and pass to message_process"""
|
|
if not Message:
|
|
raise exceptions.UserError(
|
|
_("Install the msg-extractor library to handle .msg files")
|
|
)
|
|
message_msg = Message(b64decode(message))
|
|
try:
|
|
message_id = message_msg.messageId
|
|
except AttributeError:
|
|
# Using extract_msg < 0.24.4
|
|
message_id = message_msg.message_id
|
|
message_email = self.env["ir.mail_server"].build_email(
|
|
message_msg.sender,
|
|
message_msg.to.split(","),
|
|
message_msg.subject,
|
|
# prefer html bodies to text
|
|
message_msg._getStream("__substg1.0_10130102") or message_msg.body,
|
|
email_cc=message_msg.cc,
|
|
headers={"date": message_msg.date},
|
|
message_id=message_id,
|
|
attachments=[
|
|
(attachment.longFilename, attachment.data)
|
|
for attachment in message_msg.attachments
|
|
],
|
|
)
|
|
return self.message_drop(
|
|
model,
|
|
message_email.as_string(),
|
|
custom_values=custom_values,
|
|
save_original=save_original,
|
|
strip_attachments=strip_attachments,
|
|
thread_id=thread_id,
|
|
)
|
|
|
|
def _notify_record_by_email(
|
|
self,
|
|
message,
|
|
recipients_data,
|
|
msg_vals=None,
|
|
model_description=False,
|
|
mail_auto_delete=True,
|
|
check_existing=False,
|
|
force_send=True,
|
|
send_after_commit=True,
|
|
**kwargs,
|
|
):
|
|
if self.env.context.get("message_create_from_mail_mail", False):
|
|
return
|
|
return super()._notify_record_by_email(
|
|
message,
|
|
recipients_data,
|
|
msg_vals=msg_vals,
|
|
model_description=model_description,
|
|
mail_auto_delete=mail_auto_delete,
|
|
check_existing=check_existing,
|
|
force_send=force_send,
|
|
send_after_commit=send_after_commit,
|
|
**kwargs,
|
|
)
|