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
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
|
# -*- coding: utf-8 -*-
# (c) 2021, Markus Fischbacher (fischbacher.markus@gmail.com)
# GNU General Public License v3.0+ (see COPYING or https://www.gnu.org/licenses/gpl-3.0.txt)
# Quick Link to Zabbix API docs: https://www.zabbix.com/documentation/current/manual/api
from __future__ import absolute_import, division, print_function
__metaclass__ = type
from uuid import uuid4
from ssl import CertificateError
from ansible.module_utils.connection import ConnectionError
from ansible.module_utils.connection import Connection
from ansible.module_utils._text import to_text
class ZabbixApiRequest(object):
def __init__(self, module):
self.module = module
self.connection = Connection(self.module._socket_path)
def _httpapi_error_handle(self, payload=None):
try:
code, response = self.connection.send_request(data=payload)
except ConnectionError as e:
self.module.fail_json(msg="connection error occurred: {0}".format(e))
except CertificateError as e:
self.module.fail_json(msg="certificate error occurred: {0}".format(e))
except ValueError as e:
self.module.fail_json(msg="certificate not found: {0}".format(e))
if code == 404:
if to_text(u"Object not found") in to_text(response) or to_text(
u"Could not find object"
) in to_text(response):
return {}
if not (code >= 200 and code < 300):
self.module.fail_json(
msg="Zabbix httpapi returned error {0} with message {1}".format(
code, response
)
)
return response
def api_version(self):
return self.connection.api_version()
@staticmethod
def payload_builder(method_, params, jsonrpc_version='2.0', reqid=str(uuid4()), **kwargs):
req = {'jsonrpc': jsonrpc_version, 'method': method_, 'id': reqid}
req['params'] = params
return req
def __getattr__(self, name):
return ZabbixApiSection(self, name)
class ZabbixApiSection(object):
parent = None
name = None
def __init__(self, parent, name):
self.name = name
self.parent = parent
def __getattr__(self, name):
def method(opts=None):
if self.name == "configuration" and name == "import_":
_method = "configuration.import"
else:
_method = "%s.%s" % (self.name, name)
if not opts:
opts = {}
payload = ZabbixApiRequest.payload_builder(_method, opts)
return self.parent._httpapi_error_handle(payload=payload)
return method
|
