Skip to content

Commit 3227e42

Browse files
committed
Slight refactoring of infer_message() and send_scheduled_message_from_send_queue(), and added setting of Message.sent when sent.
- Legacy-Id: 17347
1 parent 2d72442 commit 3227e42

1 file changed

Lines changed: 17 additions & 13 deletions

File tree

ietf/message/utils.py

Lines changed: 17 additions & 13 deletions
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
1-
# Copyright The IETF Trust 2012-2019, All Rights Reserved
1+
# Copyright The IETF Trust 2012-2020, All Rights Reserved
22
# -*- coding: utf-8 -*-
33

44

@@ -16,19 +16,21 @@
1616
def infer_message(s):
1717
parsed = email.message_from_string(force_str(s))
1818

19-
m = Message()
20-
m.subject = parsed.get("Subject", "")
21-
m.frm = parsed.get("From", "")
22-
m.to = parsed.get("To", "")
23-
m.cc = parsed.get("Cc", "")
24-
m.bcc = parsed.get("Bcc", "")
25-
m.reply_to = parsed.get("Reply-To", "")
26-
m.body = get_payload(parsed)
19+
m = Message(
20+
subject = parsed.get("Subject", ""),
21+
frm = parsed.get("From", ""),
22+
to = parsed.get("To", ""),
23+
cc = parsed.get("Cc", ""),
24+
bcc = parsed.get("Bcc", ""),
25+
reply_to = parsed.get("Reply-To", ""),
26+
body = get_payload(parsed),
27+
content_type = parsed.get_content_type(),
28+
)
2729

2830
return m
2931

30-
def send_scheduled_message_from_send_queue(send_queue):
31-
message = send_queue.message
32+
def send_scheduled_message_from_send_queue(queue_item):
33+
message = queue_item.message
3234

3335
# for some reason, the old Perl code base substituted away . on line starts
3436
body = first_dot_on_line_re.sub("", message.body)
@@ -52,6 +54,8 @@ def send_scheduled_message_from_send_queue(send_queue):
5254
send_mail_mime(None, message.to, message.frm, message.subject,
5355
msg, cc=message.cc, bcc=message.bcc)
5456

55-
send_queue.sent_at = datetime.datetime.now()
56-
send_queue.save()
57+
queue_item.sent_at = datetime.datetime.now()
58+
queue_item.save()
5759

60+
queue_item.message.sent = queue_item.sent_at
61+
queue_item.message.save()

0 commit comments

Comments
 (0)