email_agent.rb 2.6KB

    module Agents class EmailAgent < Agent include EmailConcern cannot_be_scheduled! cannot_create_events! no_bulk_receive! description <<-MD The Email Agent sends any events it receives via email immediately. You can specify the email's subject line by providing a `subject` option, which can contain Liquid formatting. E.g., you could provide `"Huginn email"` to set a simple subject, or `{{subject}}` to use the `subject` key from the incoming Event. By default, the email body will contain an optional `headline`, followed by a listing of the Events' keys. You can customize the email body by including the optional `body` param. Like the `subject`, the `body` can be a simple message or a Liquid template. You could send only the Event's `some_text` field with a `body` set to `{{ some_text }}`. The body can contain simple HTML and will be sanitized. You can specify one or more `recipients` for the email, or skip the option in order to send the email to your account's default email address. You can provide a `from` address for the email, or leave it blank to default to the value of `EMAIL_FROM_ADDRESS` (`#{ENV['EMAIL_FROM_ADDRESS']}`). You can provide a `content_type` for the email and specify `text/plain` or `text/html` to be sent. If you do not specify `content_type`, then the recipient email server will determine the correct rendering. Set `expected_receive_period_in_days` to the maximum amount of time that you'd expect to pass between Events being received by this Agent. MD def default_options { 'subject' => "You have a notification!", 'headline' => "Your notification:", 'expected_receive_period_in_days' => "2" } end def working? received_event_without_error? end def receive(incoming_events) incoming_events.each do |event| recipients(event.payload).each do |recipient| begin SystemMailer.send_message( to: recipient, from: interpolated(event)['from'], subject: interpolated(event)['subject'], headline: interpolated(event)['headline'], body: interpolated(event)['body'], content_type: interpolated(event)['content_type'], groups: [present(event.payload)] ).deliver_now log "Sent mail to #{recipient} with event #{event.id}" rescue => e error("Error sending mail to #{recipient} with event #{event.id}: #{e.message}") raise end end end end end end