diff options
author | mdecimus <mauro@stalw.art> | 2024-08-22 14:29:11 +0200 |
---|---|---|
committer | mdecimus <mauro@stalw.art> | 2024-08-22 14:29:11 +0200 |
commit | 0aaf493f94b501d290ba960c4a9a74a8c6af1299 (patch) | |
tree | aed419c491825023684dc6ff412c4efbf3d5ea97 | |
parent | fe0ccb11bd3192c224615fe09efe47d04c29cfe9 (diff) |
Log messageId on ingestion
-rw-r--r-- | crates/jmap/src/email/ingest.rs | 9 |
1 files changed, 5 insertions, 4 deletions
diff --git a/crates/jmap/src/email/ingest.rs b/crates/jmap/src/email/ingest.rs index 618e5bc4..b6c59d46 100644 --- a/crates/jmap/src/email/ingest.rs +++ b/crates/jmap/src/email/ingest.rs @@ -112,16 +112,16 @@ impl JMAP { } // Obtain message references and thread name + let mut message_id = String::new(); let thread_id = { let mut references = Vec::with_capacity(5); let mut subject = ""; - let mut message_id = ""; for header in message.root_part().headers().iter().rev() { match &header.name { HeaderName::MessageId => header.value.visit_text(|id| { if !id.is_empty() && id.len() < MAX_ID_LENGTH { if message_id.is_empty() { - message_id = id; + message_id = id.to_string(); } references.push(id); } @@ -160,7 +160,7 @@ impl JMAP { params.account_id, Collection::Email, vec![ - Filter::eq(Property::MessageId, message_id), + Filter::eq(Property::MessageId, &message_id), Filter::is_in_bitmap( Property::MailboxIds, params.mailbox_ids.first().copied().unwrap_or(INBOX_ID), @@ -176,7 +176,7 @@ impl JMAP { MessageIngest(MessageIngestEvent::Duplicate), SpanId = params.session_id, AccountId = params.account_id, - MessageId = message_id.to_string(), + MessageId = message_id, ); return Ok(IngestedEmail { @@ -353,6 +353,7 @@ impl JMAP { MailboxId = mailbox_ids_event, BlobId = blob_id.hash.to_hex(), ChangeId = change_id, + MessageId = message_id, Size = raw_message_len as u64, Elapsed = start_time.elapsed(), ); |