email loop fix initial commit

app/mailboxes/reply_mailbox.rb

@@ -1,5 +1,7 @@
 class ReplyMailbox < ApplicationMailbox
-  attr_accessor :conversation, :processed_mail
+  include IncomingEmailValidityHelper
+
+  attr_accessor :conversation, :processed_mail, :account
 
   before_processing :find_conversation
 
@@ -7,12 +9,17 @@ class ReplyMailbox < ApplicationMailbox
     # Return early if no conversation was found (e.g., notification emails, suspended accounts)
     return unless @conversation
 
+    decorate_mail
+    unless incoming_email_from_valid_email?
+      Rails.logger.info "Email #{mail.message_id} rejected - failed incoming email validity checks"
+      return
+    end
+
     # Wrap everything in a transaction to ensure atomicity
     # This prevents orphan conversations if message/attachment creation fails
     # and ensures idempotency on job retry (conversation won't be duplicated)
     ActiveRecord::Base.transaction do
       persist_conversation_if_needed
-      decorate_mail
       create_message
       add_attachments_to_message
     end
@@ -22,6 +29,7 @@ class ReplyMailbox < ApplicationMailbox
 
   def find_conversation
     @conversation = Mailbox::ConversationFinder.new(mail).find
+    @account = @conversation&.account
     # Log when email is rejected
     Rails.logger.info "Email #{mail.message_id} rejected - no conversation found" unless @conversation
   end
@@ -36,6 +44,6 @@ class ReplyMailbox < ApplicationMailbox
   end
 
   def decorate_mail
-    @processed_mail = MailPresenter.new(mail, @conversation.account)
+    @processed_mail = MailPresenter.new(mail, @account)
   end
 end

app/presenters/mail_presenter.rb

@@ -174,13 +174,31 @@ class MailPresenter < SimpleDelegator
   end
 
   def notification_email_from_chatwoot?
-    # notification emails are send via mailer sender email address. so it should match
-    configured_sender = Mail::Address.new(ENV.fetch('MAILER_SENDER_EMAIL', 'Chatwoot <accounts@chatwoot.com>')).address
-    original_sender.to_s.casecmp?(configured_sender)
+    sender_address = original_sender.to_s.downcase
+    return false if sender_address.blank?
+
+    # Notification emails are sent via mailer sender email address.
+    configured_sender = parse_mail_address(ENV.fetch('MAILER_SENDER_EMAIL', 'Chatwoot <accounts@chatwoot.com>'))&.address&.downcase
+    return true if configured_sender.present? && sender_address.casecmp?(configured_sender)
+
+    reply_thread_email_from_chatwoot?(sender_address)
   end
 
   private
 
+  REPLY_THREAD_SENDER_PATTERN = /^reply\+[0-9a-f]{8}-[0-9a-f]{4}-[0-9a-f]{4}-[0-9a-f]{4}-[0-9a-f]{12}$/i
+
+  def reply_thread_email_from_chatwoot?(sender_address)
+    inbound_domain = @account&.inbound_email_domain.to_s.downcase
+    return false if inbound_domain.blank?
+
+    local_part, domain = sender_address.split('@', 2)
+    return false if local_part.blank? || domain.blank?
+    return false unless domain.casecmp?(inbound_domain)
+
+    local_part.match?(REPLY_THREAD_SENDER_PATTERN)
+  end
+
   def parse_mail_address(email)
     return if email.blank?
 

app/services/messages/send_email_notification_service.rb

@@ -20,12 +20,17 @@ class Messages::SendEmailNotificationService
 
   def should_send_email_notification?
     return false unless message.email_notifiable_message?
+    return false if bot_sender_message?
     return false if message.conversation.contact.email.blank?
     return false unless message.account.within_email_rate_limit?
 
     email_reply_enabled?
   end
 
+  def bot_sender_message?
+    message.sender_type.in?(%w[AgentBot Captain::Assistant])
+  end
+
   def email_reply_enabled?
     inbox = message.inbox
     case inbox.channel.class.to_s