650fee58a6
This PR adds the following changes 1. Add `Imap::GoogleFetchEmailService` and `Google::RefreshOauthTokenService`. The `Google::RefreshOauthTokenService` uses `OmniAuth::Strategies::GoogleOauth2` which is already added as a packge 2. Update `Inboxes::FetchImapEmailsJob` to handle Google inboxes 3. Add SMTP settings for Google in `ConversationReplyMailerHelper` to allow sending emails ## Preview #### Incoming emails  #### Outgoing email  --------- Co-authored-by: Muhsin Keloth <muhsinkeramam@gmail.com>
54 lines
2.1 KiB
Ruby
54 lines
2.1 KiB
Ruby
require 'net/imap'
|
|
|
|
class Inboxes::FetchImapEmailsJob < MutexApplicationJob
|
|
queue_as :scheduled_jobs
|
|
|
|
def perform(channel, interval = 1)
|
|
return unless should_fetch_email?(channel)
|
|
|
|
key = format(::Redis::Alfred::EMAIL_MESSAGE_MUTEX, inbox_id: channel.inbox.id)
|
|
|
|
with_lock(key, 5.minutes) do
|
|
process_email_for_channel(channel, interval)
|
|
end
|
|
rescue *ExceptionList::IMAP_EXCEPTIONS => e
|
|
Rails.logger.error "Authorization error for email channel - #{channel.inbox.id} : #{e.message}"
|
|
rescue EOFError, OpenSSL::SSL::SSLError, Net::IMAP::NoResponseError, Net::IMAP::BadResponseError, Net::IMAP::InvalidResponseError => e
|
|
Rails.logger.error "Error for email channel - #{channel.inbox.id} : #{e.message}"
|
|
rescue LockAcquisitionError
|
|
Rails.logger.error "Lock failed for #{channel.inbox.id}"
|
|
rescue StandardError => e
|
|
ChatwootExceptionTracker.new(e, account: channel.account).capture_exception
|
|
end
|
|
|
|
private
|
|
|
|
def should_fetch_email?(channel)
|
|
channel.imap_enabled? && !channel.reauthorization_required?
|
|
end
|
|
|
|
def process_email_for_channel(channel, interval)
|
|
inbound_emails = if channel.microsoft?
|
|
Imap::MicrosoftFetchEmailService.new(channel: channel, interval: interval).perform
|
|
elsif channel.google?
|
|
Imap::GoogleFetchEmailService.new(channel: channel, interval: interval).perform
|
|
else
|
|
Imap::FetchEmailService.new(channel: channel, interval: interval).perform
|
|
end
|
|
inbound_emails.map do |inbound_mail|
|
|
process_mail(inbound_mail, channel)
|
|
end
|
|
rescue OAuth2::Error => e
|
|
Rails.logger.error "Error for email channel - #{channel.inbox.id} : #{e.message}"
|
|
channel.authorization_error!
|
|
end
|
|
|
|
def process_mail(inbound_mail, channel)
|
|
Imap::ImapMailbox.new.process(inbound_mail, channel)
|
|
rescue StandardError => e
|
|
ChatwootExceptionTracker.new(e, account: channel.account).capture_exception
|
|
Rails.logger.error("
|
|
#{channel.provider} Email dropped: #{inbound_mail.from} and message_source_id: #{inbound_mail.message_id}")
|
|
end
|
|
end
|