From 6c681008e95cda7928d94ee07ce03e0717d0e01f Mon Sep 17 00:00:00 2001 From: Matthieu Lamalle Date: Thu, 6 May 2021 15:15:00 +0200 Subject: [PATCH] add del_servers_group --- scripts/del_servers_group.py | 112 +++++++++++++++++++++++++++++++++++ 1 file changed, 112 insertions(+) create mode 100644 scripts/del_servers_group.py diff --git a/scripts/del_servers_group.py b/scripts/del_servers_group.py new file mode 100644 index 0000000..d36c585 --- /dev/null +++ b/scripts/del_servers_group.py @@ -0,0 +1,112 @@ +#!/usr/bin/env python +# -*- coding: utf-8 -*- + +import sys, getpass, socket +from pyeole.ihm import print_line +from pyeole.ansiprint import print_orange, print_red +from creole.client import CreoleClient +from collections import OrderedDict + + +try: + from zephir.zephir_conf.zephir_conf import adresse_zephir +except: + client = CreoleClient() + adresse_zephir = client.get_creole('nom_domaine_machine') +from zephir.lib_zephir import convert +from zephir.lib_zephir import xmlrpclib +from zephir.lib_zephir import EoleProxy +from zephir.lib_zephir import TransportEole +from zephir.lib_zephir import flushed_input + + +def display_help(): + print("Script de suppression des serveurs appartenant d'un groupe") + print("{} [numero du groupe]".format(sys.argv[0])) + + +def argparser(): + # récupère l'ID du groupe + la liste des variables éventuelles + arglen = len(sys.argv) + if arglen == 1: + return None + if sys.argv[1] in ['-h', '--help']: + display_help() + sys.exit(0) + group_id = sys.argv[1] + + return group_id + + +def main(): + # import des fonctions communes de Zéphir client + group_id = argparser() + + authentified, proxy = get_pwd(adresse_zephir, 7080) + if authentified == False: + sys.exit(1) + id_variante = "" + try: + groups = {grp_id: (group_name, liste_serveurs) for grp_id, group_name, liste_serveurs in convert(proxy.serveurs.get_groups())[1]} + except xmlrpclib.ProtocolError: + print_red("""Erreur de permissions ou Zéphir non disponible""") + sys.exit(1) + except socket.error, e: + print_red("""Erreur de connexion au serveur Zéphir (%s)""" % str(e)) + sys.exit(1) + # on récupère l'ID du groupe concerné + if group_id is None: + print('Liste des groupes :') + for grp_id, group_infos in groups.items(): + print(' - ' + str(grp_id) + ' : ' + group_infos[0]) + while group_id is None: + tmp_group_id = flushed_input("Numéro du groupe : ") + try: + group_id = int(tmp_group_id) + except Exception as err: + print(err) + continue + if not group_id in groups: + print_red('Groupe inconnu') + group_id = None + elif not group_id in groups: + print_red('Le groupe "{}" est inconnu'.format(group_id)) + sys.exit(1) + liste_serveurs = groups[group_id][1] + for id_serv in liste_serveurs : + proxy.serveurs.del_serveur(id_serv) + + print('Les serveurs {} ont été supprimés'.format(liste_serveurs)) + + + +def get_pwd(addr, port): + """lecture d'un login/passwd pour l'application zephir + """ + login_ok = 0 + user = "toto" + while login_ok == 0 and user != "": + try: + # flush de l'entrée standard au cas où l'utilisateur aurait + # tapé pendant l'Upgrade + termios.tcflush(sys.stdin, termios.TCIOFLUSH) + except: + pass + user = flushed_input("Entrez votre login zephir (rien pour sortir) : ") + if user != "": + passwd = getpass.getpass("Mot de passe zephir pour %s : " % user) + # création du proxy avec zephir + proxy = EoleProxy("https://%s:%s@%s:%s" % (user, passwd, addr, port), transport=TransportEole()) + login_ok = 1 + try: + res = convert(proxy.get_permissions(user)) + except xmlrpclib.ProtocolError: + login_ok = 0 + print_line("\n Erreur d'authentification \n") + else: + return False, "! Abandon de la procédure !" + return True, proxy + + +if __name__ == '__main__': + main()