zammad/spec/models/channel/driver/smtp_spec.rb

# Copyright (C) 2012-2024 Zammad Foundation, https://zammad-foundation.org/

require 'rails_helper'

RSpec.describe Channel::Driver::Smtp, integration: true, required_envs: %w[MAIL_SERVER MAIL_ADDRESS MAIL_PASS] do
  let(:server_host)     { ENV['MAIL_SERVER'] }
  let(:server_login)    { ENV['MAIL_ADDRESS'] }
  let(:server_password) { ENV['MAIL_PASS'] }
  let(:email_address)   { create(:email_address, name: 'me Helpdesk', email: "some-zammad-#{server_login}") }
  let(:group)           { create(:group, name: 'DeliverTest', email_address: email_address) }
  let(:channel) do
    create(:email_channel,
           group:    group,
           outbound: outbound,
           inbound:  {
             adapter: 'imap',
             options: {
               host:     'mx1.example.com',
               user:     'example',
               password: 'some_pw',
               ssl:      true,
             }
           })
  end
  let(:state_name) { 'new' }
  let(:ticket)     { create(:ticket, title: 'some delivery test', group: group, state_name: state_name) }
  let(:article)    { create(:ticket_article, :outbound_email, ticket: ticket, to: 'some_recipient@example_not_existing_what_ever.com', subject: 'some subject', message_id: 'some@id', body: 'some message delivery test') }

  before do
    freeze_time
    email_address.update!(channel_id: channel.id)
    ticket && article
  end

  context 'when modifying channel options', :aggregate_failures do
    let(:outbound) { { adapter: 'sendmail' } }

    it 'updates article delivery preferences' do
      expect(article.preferences).not_to include(:delivery_retry,
                                                 :delivery_status,
                                                 :delivery_status_date,
                                                 :delivery_status_message)

      TicketArticleCommunicateEmailJob.new.perform(article.id)

      expect(article.reload.preferences).to include(delivery_retry:          1,
                                                    delivery_status:         'success',
                                                    delivery_status_date:    be_present,
                                                    delivery_status_message: be_nil)

      # Send with invalid smtp settings.
      channel.options.tap do |options|
        options['outbound'] = {
          adapter: 'smtp',
          options: {
            host:      'mx1.example.com',
            port:      25,
            start_tls: true,
            user:      'not_existing',
            password:  'not_existing',
          },
        }
      end
      channel.save!

      expect { TicketArticleCommunicateEmailJob.new.perform(article.id) }.to raise_error(RuntimeError)

      expect(article.reload.preferences).to include(delivery_retry:          2,
                                                    delivery_status:         'fail',
                                                    delivery_status_date:    be_present,
                                                    delivery_status_message: be_present)

      # Send with valid smtp settings.
      channel.options.tap do |options|
        options['outbound'] = {
          adapter: 'smtp',
          options: {
            host:       server_host,
            port:       25,
            start_tls:  true,
            user:       server_login,
            password:   server_password,
            ssl_verify: false,
          },
        }
      end
      channel.save!

      TicketArticleCommunicateEmailJob.new.perform(article.id)

      expect(article.reload.preferences).to include(delivery_retry:          3,
                                                    delivery_status:         'success',
                                                    delivery_status_date:    be_present,
                                                    delivery_status_message: be_nil)
    end
  end

  context 'when encounters sending errors', :aggregate_failures, performs_jobs: true do
    let(:state_name) { 'closed' }
    let(:outbound) do
      {
        adapter: 'smtp',
        options: {
          host:      'mx1.example.com',
          port:      25,
          start_tls: true,
          user:      'not_existing',
          password:  'not_existing',
        },
      }
    end

    it 'retries delivery in expected intervals' do
      expect do
        perform_enqueued_jobs
      end.to have_performed_job(TicketArticleCommunicateEmailJob)

      expect(ticket.reload.articles.count).to eq(1)
      expect(ticket.state.name).to eq('closed')
      expect(article.reload.preferences).to include(delivery_retry:          1,
                                                    delivery_status:         'fail',
                                                    delivery_status_date:    be_present,
                                                    delivery_status_message: be_present)

      expect do
        perform_enqueued_jobs
      end.to have_performed_job(TicketArticleCommunicateEmailJob).at(25.seconds.from_now)

      expect(article.reload.preferences).to include(delivery_retry:          2,
                                                    delivery_status:         'fail',
                                                    delivery_status_date:    be_present,
                                                    delivery_status_message: be_present)
      expect(ticket.reload.articles.count).to eq(1)
      expect(ticket.state.name).to eq('closed')

      expect do
        perform_enqueued_jobs
      end.to have_performed_job(TicketArticleCommunicateEmailJob).at(50.seconds.from_now)

      expect(article.reload.preferences).to include(delivery_retry:          3,
                                                    delivery_status:         'fail',
                                                    delivery_status_date:    be_present,
                                                    delivery_status_message: be_present)
      expect(ticket.reload.articles.count).to eq(1)
      expect(ticket.state.name).to eq('closed')

      expect do
        perform_enqueued_jobs
      end.to raise_error(RuntimeError).and have_performed_job(TicketArticleCommunicateEmailJob).at(75.seconds.from_now)

      expect(article.reload.preferences).to include(delivery_retry:          4,
                                                    delivery_status:         'fail',
                                                    delivery_status_date:    be_present,
                                                    delivery_status_message: be_present)
      expect(ticket.reload.articles.count).to eq(2)
      expect(ticket.state).to eq(Ticket::State.find_by(default_follow_up: true))
      expect(ticket.articles.last).to have_attributes(sender:      Ticket::Article::Sender.lookup(name: 'System'),
                                                      preferences: include(delivery_message:            true,
                                                                           delivery_article_id_related: article.id,
                                                                           notification:                true))
    end
  end
end