Class: ZabbixApi::Client

Inherits:
Object
  • Object
show all
Defined in:
lib/zabbixapi/client.rb

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(options = {}) ⇒ ZabbixApi::Client

Initializes a new Client object

Parameters:

  • options (Hash) (defaults to: {})
  • opts (Hash) —

    a customizable set of options



56
57
58
59
60
61
62
63
64
65
66
67
68
 
# File 'lib/zabbixapi/client.rb', line 56

def initialize(options = {})
  @options = options
  if !ENV['http_proxy'].nil? && options[:no_proxy] != true
    @proxy_uri = URI.parse(ENV['http_proxy'])
    @proxy_host = @proxy_uri.host
    @proxy_port = @proxy_uri.port
    @proxy_user, @proxy_pass = @proxy_uri.userinfo.split(/:/) if @proxy_uri.userinfo
  end
  unless api_version =~ /(2\.4|3\.[024]|4\.0)\.\d+/
    raise ApiError.new("Zabbix API version: #{api_version} is not support by this version of zabbixapi")
  end
  @auth_hash = auth
end

Instance Attribute Details

#options ⇒ Hash (readonly)

Parameters:

  • options (Hash)
  • opts (Hash) —

    a customizable set of options

Returns:

  • (Hash) 


8
9
10
 
# File 'lib/zabbixapi/client.rb', line 8

def options
  @options
end

Instance Method Details

#_request(body) ⇒ Hash, String

Parameters:

  • body (String)

Returns:

  • (Hash, String)

Raises:



124
125
126
127
128
129
 
# File 'lib/zabbixapi/client.rb', line 124

def _request(body)
  puts "[DEBUG] Send request: #{body}" if @options[:debug]
  result = JSON.parse(http_request(body))
  raise ApiError.new("Server answer API error\n #{JSON.pretty_unparse(result['error'])}\n on request:\n #{pretty_body(body)}", result) if result['error']
  result['result']
end

#api_request(body) ⇒ Hash, String

Execute Zabbix API requests and return response

Parameters:

  • body (Hash)

Returns:

  • (Hash, String) 


144
145
146
 
# File 'lib/zabbixapi/client.rb', line 144

def api_request(body)
  _request message_json(body)
end

#api_version ⇒ String

Returns the API version from the Zabbix Server

Returns:

  • (String) 


18
19
20
 
# File 'lib/zabbixapi/client.rb', line 18

def api_version
  @version ||= api_request(:method => 'apiinfo.version', :params => {})
end

#auth ⇒ Hash

Log in to the Zabbix Server and generate an auth token using the API

Returns:

  • (Hash) 


25
26
27
28
29
30
31
32
33
 
# File 'lib/zabbixapi/client.rb', line 25

def auth
  api_request(
    :method => 'user.login',
    :params => {
      :user     => @options[:user],
      :password => @options[:password],
    }
  )
end

#http_request(body) ⇒ String

Parameters:

  • body (String)

Returns:

  • (String)

Raises:



89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
 
# File 'lib/zabbixapi/client.rb', line 89

def http_request(body)
  uri = URI.parse(@options[:url])

  # set the time out the default (60) or to what the user passed
  timeout = @options[:timeout].nil? ? 60 : @options[:timeout]
  puts "[DEBUG] Timeout for request set to #{timeout} seconds" if @options[:debug]

  if @proxy_uri
    http = Net::HTTP.Proxy(@proxy_host, @proxy_port, @proxy_user, @proxy_pass).new(uri.host, uri.port)
  else
    http = Net::HTTP.new(uri.host, uri.port)
  end

  if uri.scheme == 'https'
    http.use_ssl = true
    http.verify_mode = OpenSSL::SSL::VERIFY_NONE
  end

  http.open_timeout = timeout
  http.read_timeout = timeout

  request = Net::HTTP::Post.new(uri.request_uri)
  request.basic_auth @options[:http_user], @options[:http_password] if @options[:http_user]
  request.add_field('Content-Type', 'application/json-rpc')
  request.body = body
  response = http.request(request)

  raise HttpError.new("HTTP Error: #{response.code} on #{@options[:url]}", response) unless response.code == '200'

  puts "[DEBUG] Get answer: #{response.body}" if @options[:debug]
  response.body
end

#id ⇒ Integer

Returns:

  • (Integer) 


11
12
13
 
# File 'lib/zabbixapi/client.rb', line 11

def id
  rand(100_000)
end

#logout ⇒ Boolean

Log out from the Zabbix Server

Returns:

  • (Boolean) 


38
39
40
41
42
43
 
# File 'lib/zabbixapi/client.rb', line 38

def logout
  api_request(
    :method => 'user.logout',
    :params => []
  )
end

#message_json(body) ⇒ String

Convert message body to JSON string for the Zabbix API

Parameters:

  • body (Hash)

Returns:

  • (String) 


74
75
76
77
78
79
80
81
82
83
84
85
 
# File 'lib/zabbixapi/client.rb', line 74

def message_json(body)
  message = {
    :method  => body[:method],
    :params  => body[:params],
    :id      => id,
    :jsonrpc => '2.0',
  }

  message[:auth] = @auth_hash unless body[:method] == 'apiinfo.version' || body[:method] == 'user.login'

  JSON.generate(message)
end

#pretty_body(body) ⇒ Object 



131
132
133
134
135
136
137
138
 
# File 'lib/zabbixapi/client.rb', line 131

def pretty_body(body)
  parsed_body = JSON.parse(body)

  # If password is in body hide it
  parsed_body['params']['password'] = '***' if parsed_body['params'].is_a?(Hash) && parsed_body['params'].key?('password')

  JSON.pretty_unparse(parsed_body)
end