import os
from time import sleep
from pyzabbix import ZabbixAPI, ZabbixAPIException

zabbix_url = os.environ['ZBX_API_URL']
zabbix_user = os.environ['ZBX_API_USER']
zabbix_password = os.environ['ZBX_API_PASSWORD']
print(zabbix_url, zabbix_user, zabbix_password)

zapi = ZabbixAPI(zabbix_url, timeout=5)

for i in range(10):
  print("Trying to connected to Zabbix API %s" % zabbix_url)
  try:
    zapi.login(zabbix_user, zabbix_password)
    print("Connected to Zabbix API Version %s" % zapi.api_version())
    break
  except ZabbixAPIException as e:
    print e
    sleep(5)
  except:
    print("Waiting")
    sleep(5)


config_path = os.environ['ZBX_CONFIG']
import_rules = {
  'discoveryRules': {
      'createMissing': True,
      'updateExisting': True
  },
  'graphs': {
      'createMissing': True,
      'updateExisting': True
  },
  'host_groups': {
      'createMissing': True
  },
  'hosts': {
      'createMissing': True,
      'updateExisting': True
  },
  'images': {
      'createMissing': True,
      'updateExisting': True
  },
  'items': {
      'createMissing': True,
      'updateExisting': True
  },
  'maps': {
      'createMissing': True,
      'updateExisting': True
  },
  'templateLinkage': {
      'createMissing': True,
  },
  'templates': {
      'createMissing': True,
      'updateExisting': True
  },
  'triggers': {
      'createMissing': True,
      'updateExisting': True
  },
}

print("Importing Zabbix config from %s" % config_path)
with open(config_path, 'r') as f:
  config = f.read()

  try:
    # https://github.com/lukecyca/pyzabbix/issues/62
    import_result = zapi.confimport("xml", config, import_rules)
    print(import_result)
  except ZabbixAPIException as e:
    print e

for h in zapi.host.get(output="extend"):
    print(h['name'])