Contents

require 'net/http'

module RestFtpDaemon
  class Notification
    attr_accessor :job_id
    attr_accessor :signal
    attr_accessor :error
    attr_accessor :message
    attr_accessor :status
    attr_accessor :url
    attr_accessor :job

    def initialize url, params
      # Generate a random key
      @id = Helpers.identifier(IDENT_NOTIF_LEN)

      # Logger
      # @logger = RestFtpDaemon::Logger.new(:workers, "NOTIF #{key}")
      @logger = RestFtpDaemon::LoggerPool.instance.get :notify

      # Check context
      if url.nil?
        info "skipping (missing url): #{params}"
        return
      elsif params[:signal].nil?
        info "skipping (missing signal): #{params}"
        return
      else
        # info "queuing: s[#{params[:signal]}] e[#{params[:error]}] u[#{url}]"
        info "queuing: #{params.inspect}"
      end

      # Params
      body = {
        id:       params[:id].to_s,
        signal:   params[:signal],
        error:    params[:error],
        host:     Settings['host'].to_s,
        }
      body[:status] = params[:status] if (params[:status].is_a? Enumerable) unless params[:status].nil?

      # Send message in a thread
      Thread.new do |thread|
        # Prepare query
        uri = URI(url)
        headers = {"Content-Type" => "application/json",
                  "Accept" => "application/json"}

        # Post notification
        info "sending: #{body.inspect}"
        http = Net::HTTP.new(uri.host, uri.port)
        response = http.post(uri.path, body.to_json, headers)

        # info "notify reply: #{response.body.strip}"
        info "reply: #{response.body.strip}"
      end

    end

  protected

    def info message, level = 0
      return if @logger.nil?
      #puts "JOB: #{message}"
      @logger.info_with_id message, level: level, id: @id
    end

  end
end

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
rest-ftp-daemon-0.100.2	lib/rest-ftp-daemon/notification.rb
rest-ftp-daemon-0.100	lib/rest-ftp-daemon/notification.rb