class LogStash::Outputs::Stride

An example output that does nothing.

Public Instance Methods

post_message(access_token,cloud_id,conversation_id,host,type,message) click to toggle source
# File lib/logstash/outputs/stride.rb, line 37
def post_message(access_token,cloud_id,conversation_id,host,type,message)
  message = %Q|#{type} : #{message}| if type
  message = %Q|#{host} : #{message}| if host
  puts "Type : #{type}, Host : #{host}"
  uri = URI.parse("https://api.atlassian.com/site/#{cloud_id}/conversation/#{conversation_id}/message")
  request = Net::HTTP::Post.new(uri)
  request.content_type = "application/json"
  request["Authorization"] = "Bearer #{access_token}"
  request.body = '{"version":1,"type":"doc","content":[{"type":"paragraph","content":[{"type":"text","text":"'+message+'"}]}]}'

  req_options = {
    use_ssl: uri.scheme == "https",
  }

  response = Net::HTTP.start(uri.hostname, uri.port, req_options) do |http|
    http.request(request)
  end

end
receive(event) click to toggle source
# File lib/logstash/outputs/stride.rb, line 23
def receive(event)
  access_token = event.sprintf(@access_token)
  cloud_id = event.sprintf(@cloud_id)
  conversation_id = event.sprintf(@conversation_id)
  host = event.sprintf(@host)
  type = event.sprintf(@type)
  message = event.sprintf(@message)

  post_message(access_token,cloud_id,conversation_id,host,type,message)
rescue Exception => e
  puts e.message
end
register() click to toggle source
# File lib/logstash/outputs/stride.rb, line 19
def register
end