summaryrefslogtreecommitdiff
path: root/lib/oxidized/output/http.rb
blob: 13ba300d7a85c9fba3bb8050485c620bfdf45ad9 (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
module Oxidized
  class Http < Output
    attr_reader :commitref
    def initialize
      @cfg = Oxidized.config.output.http
    end

    def setup
      if @cfg.empty?
        CFGS.user.output.http.user  = 'Oxidized'
        CFGS.user.output.http.pasword = 'secret'
        CFGS.user.output.http.url  =  'http://localhost/web-api/oxidized'
        CFGS.save :user
        raise NoConfig, 'no output http config, edit ~/.config/oxidized/config'
      end
    end
    require "net/http"
    require "uri"
    require "json"
    def store node, outputs, opt={}
      @commitref = nil
      json = JSON.pretty_generate(
          {
              'msg' => opt[:msg],
              'user' => opt[:user],
              'email' => opt[:email],
              'group' => opt[:group],
              'node' => node,
              'config' => outputs.to_cfg,
              # actually we need to also iterate outputs, for other types like in gitlab. But most people don't use 'type' functionality.
          }
      )
      uri = URI.parse @cfg.url
      http = Net::HTTP.new uri.host, uri.port
      #http.use_ssl = true if uri.scheme = 'https'
      req = Net::HTTP::Post.new(uri.request_uri, initheader = { 'Content-Type' => 'application/json'})
      req.basic_auth @cfg.user, @cfg.password
      req.body = json
      response = http.request req

      case response.code.to_i
        when 200 || 201
          Oxidized.logger.info "Configuration http backup complete for #{node}"
          p [:success]
        when (400..499)
          Oxidized.logger.info "Configuration http backup for #{node} failed status: #{response.body}"
          p [:bad_request]
        when (500..599)
          p [:server_problems]
          Oxidized.logger.info "Configuration http backup for #{node} failed status: #{response.body}"
      end

    end

  end
end