huginn/app/models/agents/pushover_agent.rb

module Agents
  class PushoverAgent < Agent
    cannot_be_scheduled!
    cannot_create_events!

    API_URL = 'https://api.pushover.net/1/messages.json'

    description <<-MD
      The PushoverAgent receives and collects events and sends them via push notification to a user/group.

      **You need a Pushover API Token:** [https://pushover.net/apps/build](https://pushover.net/apps/build)

      **You must provide** a `message` or `text` key that will contain the body of the notification. This can come from an event or be set as a default. Pushover API has a `512` Character Limit including `title`. `message` will be truncated.

      * `token`: your application's API token
      * `user`: the user or group key (not e-mail address).
      * `expected_receive_period_in_days`:  is maximum number of days that you would expect to pass between events being received by this agent.

      Your event can provide any of the following optional parameters or you can provide defaults:

      * `device` - your user's device name to send the message directly to that device, rather than all of the user's devices
      * `title` or `subject` - your notifications's title
      * `url` - a supplementary URL to show with your message - `512` Character Limit
      * `url_title` - a title for your supplementary URL, otherwise just the URL is shown - `100` Character Limit
      * `priority` - send as `-1` to always send as a quiet notification, `0` is default, `1` to display as high-priority and bypass the user's quiet hours, or `2` for emergency priority: [Please read Pushover Docs on Emergency Priority](https://pushover.net/api#priority)
      * `sound` - the name of one of the sounds supported by device clients to override the user's default sound choice. [See PushOver docs for sound options.](https://pushover.net/api#sounds)
      * `retry` - Requred for emergency priority - Specifies how often (in seconds) the Pushover servers will send the same notification to the user. Minimum value: `30`
      * `expire` - Requred for emergency priority - Specifies how many seconds your notification will continue to be retried for (every retry seconds). Maximum value: `86400`

      Your event can also pass along a timestamp parameter:

      * `timestamp` - a [Unix timestamp](https://en.wikipedia.org/wiki/Unix_time) of your message's date and time to display to the user, rather than the time your message is received by the Pushover API.

    MD

    def default_options
      {
        'token' => '',
        'user' => '',
        'message' => 'a default message',
        'device' => '',
        'title' => '',
        'url' => '',
        'url_title' => '',
        'priority' => 0,
        'sound' => 'pushover',
        'retry' => 0,
        'expire' => 0,
        'expected_receive_period_in_days' => '1'
      }
    end

    def validate_options
      unless options['token'].present? && options['user'].present? && options['expected_receive_period_in_days'].present?
        errors.add(:base, 'token, user, and expected_receive_period_in_days are all required.')
      end
    end

    def receive(incoming_events)
      incoming_events.each do |event|
        message = (event.payload['message'].presence  || event.payload['text'].presence  || options['message']).to_s
        if message.present?
            post_params = {
              'token' => options['token'],
              'user' => options['user'],
              'message' => message
            }

            post_params['device'] = event.payload['device'].presence  || options['device']
            post_params['title'] = event.payload['title'].presence  || event.payload['subject'].presence  || options['title']

            url = (event.payload['url'].presence  || options['url'] || '').to_s
            url = url.slice 0..512
            post_params['url'] = url

            url_title = (event.payload['url_title'].presence  || options['url_title']).to_s
            url_title = url_title.slice 0..100
            post_params['url_title'] = url_title

            post_params['priority'] = (event.payload['priority'].presence  || options['priority']).to_i

            if event.payload.has_key? 'timestamp'
              post_params['timestamp'] = (event.payload['timestamp']).to_s
            end

            post_params['sound'] = (event.payload['sound'].presence  || options['sound']).to_s

            post_params['retry'] = (event.payload['retry'].presence  || options['retry']).to_i

            post_params['expire'] = (event.payload['expire'].presence  || options['expire']).to_i

            send_notification(post_params)
        end
      end
    end

    def working?
      last_receive_at && last_receive_at > options['expected_receive_period_in_days'].to_i.days.ago && !recent_error_logs?
    end

    def send_notification(post_params)
      response = HTTParty.post(API_URL, :query => post_params)
      puts response
    end

  end
end