Class: Smailer::Tasks::Send

Inherits:
Object
  • Object
show all
Defined in:
lib/smailer/tasks/send.rb

Class Method Summary collapse

Class Method Details

.execute(options = {}) ⇒ Object 



6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
 
# File 'lib/smailer/tasks/send.rb', line 6

def self.execute(options = {})
  options.reverse_merge! :verp => !options[:return_path_domain].blank?

  # validate options
  if options[:verp] && options[:return_path_domain].blank?
    raise "VERP is enabled, but a :return_path_domain option has not been specified or is blank."
  end

  Mail.defaults do
    method = Rails.configuration.action_mailer.delivery_method
    delivery_method method, Rails.configuration.action_mailer.send("#{method}_settings") || {}
  end

  batch_size   = (Smailer::Models::Property.get('queue.batch_size') || 100).to_i
  max_retries  = (Smailer::Models::Property.get('queue.max_retries') || 0).to_i
  max_lifetime = (Smailer::Models::Property.get('queue.max_lifetime') || 172800).to_i

  results = []

  # clean up any old locked items
  expired_locks_condition = ['locked = ? AND locked_at <= ?', true, 1.hour.ago.utc]
  Smailer::Compatibility.update_all(Smailer::Models::QueuedMail, {:locked => false}, expired_locks_condition)

  # load the queue items to process
  queue_sort_order = 'retries ASC, id ASC'
  items_to_process = if Smailer::Compatibility.rails_3_or_4?
    Smailer::Models::QueuedMail.where(:locked => false).order(queue_sort_order).limit(batch_size)
  else
    Smailer::Models::QueuedMail.all(:conditions => {:locked => false}, :order => queue_sort_order, :limit => batch_size)
  end

  # lock the queue items
  lock_condition = {:id => items_to_process.map(&:id)}
  lock_update = {:locked => true, :locked_at => Time.now.utc}
  Smailer::Compatibility.update_all(Smailer::Models::QueuedMail, lock_update, lock_condition)

  # map of attachment ID to contents - so we don't keep opening files
  # or URLs
  cached_attachments = {}
  finished_mails_counts = Hash.new(0)

  items_to_process.each do |queue_item|
    # try to send the email
    mail = Mail.new do
      from     queue_item.from
      reply_to queue_item.reply_to if queue_item.reply_to.present?
      to       queue_item.to
      subject  queue_item.subject
      queue_item.attachments.each do |attachment|
        cached_attachments[attachment.id] ||= attachment.body
        add_file :filename => attachment.filename,
                 :content => cached_attachments[attachment.id]
      end

      text_part { body queue_item.body_text }
      html_part { body queue_item.body_html; content_type 'text/html; charset=UTF-8' }
    end
    mail.raise_delivery_errors = true

    # compute the VERP'd return_path if requested
    # or fall-back to a global return-path if not
    item_return_path = if options[:verp]
      "#{Smailer::BOUNCES_PREFIX}#{queue_item.key}@#{options[:return_path_domain]}"
    else
      options[:return_path]
    end

    # set the return-path, if any
    if item_return_path
      mail.return_path   = item_return_path
      mail['Errors-To']  = item_return_path
      mail['Bounces-To'] = item_return_path
    end

    queue_item.last_retry_at = Time.now
    queue_item.retries      += 1
    queue_item.locked        = false # unlock this email

    begin
      # commense delivery
      mail.deliver
    rescue Exception => e
      # failed, we have.
      queue_item.last_error = "#{e.class.name}: #{e.message}"
      queue_item.save

      # check if the message hasn't expired;
      retries_exceeded = max_retries  > 0 && queue_item.retries >= max_retries
      too_old = max_lifetime > 0 && (Time.now - queue_item.created_at) >= max_lifetime

      if retries_exceeded || too_old
        # the message has expired; move to finished_mails
        Smailer::Models::FinishedMail.add(queue_item, Smailer::Models::FinishedMail::Statuses::FAILED, false)
        finished_mails_counts[queue_item.mail_campaign.id] += 1
      end
      results.push [queue_item, :failed]
    else
      # great job, message sent
      Smailer::Models::FinishedMail.add(queue_item, Smailer::Models::FinishedMail::Statuses::SENT, false)
      finished_mails_counts[queue_item.mail_campaign.id] += 1
      results.push [queue_item, :sent]
    end
  end

  finished_mails_counts.each do |mail_campaign_id, finished_mails_for_campaign|
    Smailer::Models::MailCampaign.update_counters mail_campaign_id, :sent_mails_count => finished_mails_for_campaign
  end

  results
end