main.py

from flask import Flask, jsonify, send_from_directory, request
from multiping import multi_ping
from netmiko import ConnectHandler
import threading
from pprint import pprint
import re
import time

username = "admin"
password = "T$2z-artek"


clusters = {
    'audag': {
        'ip' : '10.55.15.140',
        'nodes': {},
    },
    'guest': {
        'ip' : '10.55.13.111',
        'nodes': {},
    },
    'skala': {
        'ip' : '10.55.12.123',
        'nodes': {},
    },
}

def auto_update(time):
    for key in clusters:
            nodes = parse_clusternodes(clusters[key]['ip'])
            if nodes :
                clusters[key]['nodes'].update(nodes)
    threading.Timer(time,auto_update,[time]).start()
    print('auto_update')

def parse_clusternodes(ip):
    cluster = {
        'device_type' : 'eltex',
        'ip':   ip,
        'username': username,
        'password': password, }
    try:
        raw_cn = ConnectHandler(**cluster).send_command(
        'get cluster-member detail').split('Property            Value\n''-------------------------------------\n')[1:]
    except Exception as e:
        print(e)
        return False
    cluster_nodes = {}
    node = {}
    for n in raw_cn:
        for params in n.split('\n'):
            p = params.split()
            if(len(p) > 1):
                node[p[0]] = p[1]
        cluster_nodes[node['mac']] = node
        node = {}
    return cluster_nodes



for key in clusters:
    nodes = parse_clusternodes(clusters[key]['ip'])
    if nodes :
        clusters[key]['nodes']



    #auto_update(1800)


app = Flask(__name__)
app.config['TEMPLATES_AUTO_RELOAD'] = True

auto_update(1800)

@app.route('/')
def index():
   return send_from_directory('templates', 'index.html')

@app.route('/reboot', methods=['POST'])
def reboot():
   r = request.get_json()
   print("reboot this node: ",r)
   node_to_reboot = {
      'device_type' : 'eltex',
      'ip': r['ip'],
      'username' : username,
      'password' : password,
   }
   connect_handler = ConnectHandler(**node_to_reboot).send_command('reboot')
   return str(r)

@app.route('/<name>')
def get_cluster_nodes(name):
    nodes = list(clusters[name]['nodes'].values())
    ips = [ n['ip'] for n in nodes]
    resp, no_resp = multi_ping(ips, timeout=2, retry=3)
    for n in nodes:
       if n['ip'] in resp:
          n['ping'] = resp[n['ip']] * 1000
          n['status'] = True
       else:
          n['ping'] = 9999
          n['status'] = False
    return jsonify(nodes)

@app.route('/detail',methods=['POST'])
def get_detail():
    r = request.get_json()
    some_node = {
        'device_type' : 'eltex',
        'ip':   r["ip"],
        'username': username,
        'password': password, }
    raw_nodes = ConnectHandler(**some_node).send_command(
        'get association detail')
    raw_nodes = raw_nodes.split('-----------------------------------------------\n')
    client_nodes = []

    node = {}
    for n in raw_nodes:
        for params in n.split('\n'):
            p = params.split()
            if(len(p) == 2 and p[0] != 'Property'):
                print(p[0], " : ", p[1])
                node[p[0]] = p[1]
        client_nodes.append(node)
        node = {}
    if {} in client_nodes: client_nodes.remove({})
    return jsonify(client_nodes)


if __name__ == "__main__":
    #app = Flask(__name__)
    #app.config['TEMPLATES_AUTO_RELOAD'] = True
    app.run(host="0.0.0.0",port=8005)