Contents

require 'net/https'
require 'uri'

module Fluent
  class BugsnagOutput < BufferedOutput
    Plugin.register_output('bugsnag', self)

    config_param :bugsnag_proxy_host, :string, :default => nil
    config_param :bugsnag_proxy_port, :integer, :default => nil
    config_param :bugsnag_proxy_user, :string, :default => nil
    config_param :bugsnag_proxy_password, :string, :default => nil
    config_param :bugsnag_timeout, :integer, :default => nil

    def format(tag, time, record)
      [tag, time, record].to_msgpack
    end

    def write(chunk)
      chunk.msgpack_each do |(tag,time,record)|
        options = record['options'] || {}
        request(record['url'], record['body'], options)
      end
    end

    private

    def request(url, body, options = {})
      uri = URI.parse(url)
      http = Net::HTTP.new(uri.host, uri.port, @bugsnag_proxy_host, @bugsnag_proxy_port, @bugsnag_proxy_user, @bugsnag_proxy_password)
      http.read_timeout = @bugsnag_timeout
      http.open_timeout = @bugsnag_timeout

      if uri.scheme == "https"
        http.use_ssl = true
        # the default in 1.9+, but required for 1.8
        # http.verify_mode = OpenSSL::SSL::VERIFY_PEER
        http.verify_mode = OpenSSL::SSL::VERIFY_NONE
      end

      headers = options.key?('headers') ? options['headers'] : {}
      headers.merge!(default_headers)

      request = Net::HTTP::Post.new(path(uri), headers)
      request.body = body
      http.request(request)
    end

    def path(uri)
      uri.path == "" ? "/" : uri.path
    end

    def default_headers
      {
        "Content-Type" => "application/json",
      }
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
fluent-plugin-bugsnag-0.2.0	lib/fluent/plugin/out_bugsnag.rb