|
31 | 31 | GMAIL_BATCH_SIZE = 25 |
32 | 32 | GMAIL_REQUEST_DELAY = 0.1 |
33 | 33 | HTML_BODY_TRUNCATE_LIMIT = 20000 |
34 | | -GMAIL_METADATA_HEADERS = ["Subject", "From", "To", "Cc", "Message-ID"] |
| 34 | +GMAIL_METADATA_HEADERS = ["Subject", "From", "To", "Cc", "Message-ID", "Date"] |
35 | 35 |
|
36 | 36 |
|
37 | 37 | class _HTMLTextExtractor(HTMLParser): |
@@ -461,7 +461,7 @@ async def get_gmail_message_content( |
461 | 461 | user_google_email (str): The user's Google email address. Required. |
462 | 462 |
|
463 | 463 | Returns: |
464 | | - str: The message details including subject, sender, recipients (To, Cc), and body content. |
| 464 | + str: The message details including subject, sender, date, Message-ID, recipients (To, Cc), and body content. |
465 | 465 | """ |
466 | 466 | logger.info( |
467 | 467 | f"[get_gmail_message_content] Invoked. Message ID: '{message_id}', Email: '{user_google_email}'" |
@@ -518,6 +518,7 @@ async def get_gmail_message_content( |
518 | 518 | content_lines = [ |
519 | 519 | f"Subject: {subject}", |
520 | 520 | f"From: {sender}", |
| 521 | + f"Date: {headers.get('Date', '(unknown date)')}", |
521 | 522 | ] |
522 | 523 |
|
523 | 524 | if rfc822_msg_id: |
@@ -565,7 +566,7 @@ async def get_gmail_messages_content_batch( |
565 | 566 | format (Literal["full", "metadata"]): Message format. "full" includes body, "metadata" only headers. |
566 | 567 |
|
567 | 568 | Returns: |
568 | | - str: A formatted list of message contents including subject, sender, recipients (To, Cc), and body (if full format). |
| 569 | + str: A formatted list of message contents including subject, sender, date, Message-ID, recipients (To, Cc), and body (if full format). |
569 | 570 | """ |
570 | 571 | logger.info( |
571 | 572 | f"[get_gmail_messages_content_batch] Invoked. Message count: {len(message_ids)}, Email: '{user_google_email}'" |
@@ -690,6 +691,7 @@ async def fetch_message_with_retry(mid: str, max_retries: int = 3): |
690 | 691 |
|
691 | 692 | msg_output = ( |
692 | 693 | f"Message ID: {mid}\nSubject: {subject}\nFrom: {sender}\n" |
| 694 | + f"Date: {headers.get('Date', '(unknown date)')}\n" |
693 | 695 | ) |
694 | 696 | if rfc822_msg_id: |
695 | 697 | msg_output += f"Message-ID: {rfc822_msg_id}\n" |
@@ -720,6 +722,7 @@ async def fetch_message_with_retry(mid: str, max_retries: int = 3): |
720 | 722 |
|
721 | 723 | msg_output = ( |
722 | 724 | f"Message ID: {mid}\nSubject: {subject}\nFrom: {sender}\n" |
| 725 | + f"Date: {headers.get('Date', '(unknown date)')}\n" |
723 | 726 | ) |
724 | 727 | if rfc822_msg_id: |
725 | 728 | msg_output += f"Message-ID: {rfc822_msg_id}\n" |
|
0 commit comments