#!/usr/bin/env python3.9
# vim: set filetype=python:

import sys
import time
import urllib.parse

import requests

from drive_utils import (build_fqdn, get_ips_for_hostname, run_remote_command,
                         smoketest_db_node)


def add_downtime(fqdn: str,
                 apikey: str,
                 monitor_host: str = 'monitor.drive.test.sunet.se') -> None:
    if not apikey:
        return
    print("\tAdding downtime for: {}".format(fqdn))
    action = 'schedule_host_svc_downtime'

    start_time = int(time.time())
    end_time = start_time + (10 * 60)  # 10 minutes
    data = {
        'comment_data': 'Reboot from script',
        'start_time': start_time,
        'end_time': end_time
    }

    post_url = 'https://{}/thruk/r/hosts/{}/cmd/{}'.format(
        monitor_host, fqdn, action)
    headers = {'X-Thruk-Auth-Key': apikey}
    requests.post(post_url, data=data, headers=headers)


def remove_downtime(fqdn: str,
                    apikey: str,
                    monitor_host: str = 'monitor.drive.test.sunet.se') -> None:
    if not apikey:
        return
    print("\tRemoving downtime for: {}".format(fqdn))
    get_url = 'https://{}/thruk/r/hosts?name={}&columns=services'.format(
        monitor_host, fqdn)
    headers = {'X-Thruk-Auth-Key': apikey}
    req = requests.get(get_url, headers=headers)
    action = 'del_active_service_downtimes'
    for service in req.json()[0]['services']:
        post_url = 'https://{}/thruk/r/services/{}/{}/cmd/{}'.format(
            monitor_host, fqdn, urllib.parse.quote(service), action)
        requests.post(post_url, headers=headers)


def main() -> int:
    customers = ["<%= @customer %>"]
    environment = "<%= @environment %>"
    apikey_test = "<%= @apikey_test %>"
    apikey_prod = "<%= @apikey_prod %>"
    user = "script"

    reboot_command = ['sudo /usr/local/bin/safer_reboot']

    if customers[0] == "common":
        customers = ["gss", "lookup", "multinode"]
    for customer in customers:
        for number in reversed(range(1, 4)):
            fqdn = build_fqdn(customer, environment, number)
            ipv4, _ = get_ips_for_hostname(fqdn)
            ip = ipv4[0]
            print("Upgrading: {} with ip: {}".format(fqdn, ip))
            add_downtime(fqdn, apikey_test)
            add_downtime(fqdn, apikey_prod, monitor_host="monitor.drive.sunet.se")

            run_remote_command(fqdn, reboot_command, user = user)
            success = False

            for testnumber in reversed(range(1, 32, 2)):
                print("\tSleeping for {} seconds before smoketest on {}".format(
                    testnumber, fqdn))
                time.sleep(testnumber)

                if smoketest_db_node(fqdn, user = user):
                    success = True

                    break

            remove_downtime(fqdn, apikey_test)
            remove_downtime(fqdn, apikey_prod, monitor_host="monitor.drive.sunet.se")
            if success:
                print("Upgrade cycle succeeded on {} ".format(fqdn))
            else:
                print("Smoketest failed on {} after server reboot command".format(
                    fqdn))

                return 5
        print("All {}-servers successfully upgraded for {}".format(
            environment, customer))

    return 0


if __name__ == "__main__":
    sys.exit(main())