Map from %s
" % serv) + stats_port = sql.get_setting('stats_port') + haproxy_config_path = sql.get_setting('haproxy_config_path') + hap_configs_dir = funct.get_config_var('configs', 'haproxy_save_configs_dir') + date = funct.get_data('config') + cfg = hap_configs_dir + serv + "-" + date + ".cfg" - G = nx.DiGraph() + print('
Map from %s
" % serv) - error = funct.get_config(serv, cfg) - if error: - print(error) - try: - conf = open(cfg, "r") - except IOError: - print('error: Can\'t read import config file') + G = nx.DiGraph() - node = "" - line_new2 = [1,""] - i,k = 800, 800 - j, m = 0, 0 - for line in conf: - if line.startswith('listen') or line.startswith('frontend'): - if "stats" not in line: - node = line - i = i - 750 - if line.find("backend") == 0: - node = line - i = i - 700 - G.add_node(node,pos=(k,i),label_pos=(k,i+100)) + error = funct.get_config(serv, cfg) + if error: + print(error) + try: + conf = open(cfg, "r") + except IOError: + print('error: Can\'t read import config file') - if "bind" in line or (line.startswith('listen') and ":" in line) or (line.startswith('frontend') and ":" in line): - try: - bind = line.split(":") - if stats_port not in bind[1]: - bind[1] = bind[1].strip(' ') - bind = bind[1].split("crt") - node = node.strip(' \t\n\r') - node = node + ":" + bind[0] - G.add_node(node,pos=(k,i),label_pos=(k,i+100)) - except: - pass + node = "" + line_new2 = [1, ""] + i, k = 800, 800 + j, m = 0, 0 + for line in conf: + if line.startswith('listen') or line.startswith('frontend'): + if "stats" not in line: + node = line + i = i - 750 + if line.find("backend") == 0: + node = line + i = i - 700 + G.add_node(node, pos=(k, i), label_pos=(k, i + 100)) - if "server " in line or "use_backend" in line or "default_backend" in line and "stats" not in line and "#" not in line: - if "timeout" not in line and "default-server" not in line and "#" not in line and "stats" not in line: - i = i - 1050 - j = j + 1 - if "check" in line: - line_new = line.split("check") - else: - line_new = line.split("if ") - if "server" in line: - line_new1 = line_new[0].split("server") - line_new[0] = line_new1[1] - line_new2 = line_new[0].split(":") - line_new[0] = line_new2[0] + if "bind" in line or (line.startswith('listen') and ":" in line) or ( + line.startswith('frontend') and ":" in line): + try: + bind = line.split(":") + if stats_port not in bind[1]: + bind[1] = bind[1].strip(' ') + bind = bind[1].split("crt") + node = node.strip(' \t\n\r') + node = node + ":" + bind[0] + G.add_node(node, pos=(k, i), label_pos=(k, i + 100)) + except: + pass - line_new[0] = line_new[0].strip(' \t\n\r') - line_new2[1] = line_new2[1].strip(' \t\n\r') + if "server " in line or "use_backend" in line or "default_backend" in line and "stats" not in line and "#" not in line: + if "timeout" not in line and "default-server" not in line and "#" not in line and "stats" not in line: + i = i - 1050 + j = j + 1 + if "check" in line: + line_new = line.split("check") + else: + line_new = line.split("if ") + if "server" in line: + line_new1 = line_new[0].split("server") + line_new[0] = line_new1[1] + line_new2 = line_new[0].split(":") + line_new[0] = line_new2[0] - if j % 2 == 0: - G.add_node(line_new[0],pos=(k+230,i-335),label_pos=(k+225,i-180)) - else: - G.add_node(line_new[0],pos=(k-230,i-0),label_pos=(k-225,i+180)) + line_new[0] = line_new[0].strip(' \t\n\r') + line_new2[1] = line_new2[1].strip(' \t\n\r') - if line_new2[1] != "": - G.add_edge(node, line_new[0], port=line_new2[1]) - else: - G.add_edge(node,line_new[0]) + if j % 2 == 0: + G.add_node(line_new[0], pos=(k + 230, i - 335), label_pos=(k + 225, i - 180)) + else: + G.add_node(line_new[0], pos=(k - 230, i - 0), label_pos=(k - 225, i + 180)) - os.system("/bin/rm -f " + cfg) + if line_new2[1] != "": + G.add_edge(node, line_new[0], port=line_new2[1]) + else: + G.add_edge(node, line_new[0]) - pos=nx.get_node_attributes(G,'pos') - pos_label=nx.get_node_attributes(G,'label_pos') - edge_labels = nx.get_edge_attributes(G,'port') + os.system("/bin/rm -f " + cfg) - try: - plt.figure(10,figsize=(10,15)) - nx.draw(G, pos, with_labels=False, font_weight='bold', width=3, alpha=0.1,linewidths=5) - nx.draw_networkx_nodes(G,pos, node_color="skyblue", node_size=100, alpha=0.8, node_shape="p") - nx.draw_networkx_labels(G,pos=pos_label, alpha=1, font_color="green", font_size=10) - nx.draw_networkx_edges(G,pos, width=0.5,alpha=0.5, edge_color="#5D9CEB",arrows=False) - nx.draw_networkx_edge_labels(G, pos,label_pos=0.5,font_color="blue", labels=edge_labels, font_size=8) + pos = nx.get_node_attributes(G, 'pos') + pos_label = nx.get_node_attributes(G, 'label_pos') + edge_labels = nx.get_edge_attributes(G, 'port') - plt.savefig("map.png") - plt.show() - except Exception as e: - print(str(e)) + try: + plt.figure(10, figsize=(10, 15)) + nx.draw(G, pos, with_labels=False, font_weight='bold', width=3, alpha=0.1, linewidths=5) + nx.draw_networkx_nodes(G, pos, node_color="skyblue", node_size=100, alpha=0.8, node_shape="p") + nx.draw_networkx_labels(G, pos=pos_label, alpha=1, font_color="green", font_size=10) + nx.draw_networkx_edges(G, pos, width=0.5, alpha=0.5, edge_color="#5D9CEB", arrows=False) + nx.draw_networkx_edge_labels(G, pos, label_pos=0.5, font_color="blue", labels=edge_labels, font_size=8) - cmd = "rm -f "+os.path.dirname(os.getcwd())+"/map*.png && mv map.png "+os.path.dirname(os.getcwd())+"/map"+date+".png" - output, stderr = funct.subprocess_execute(cmd) - print(stderr) + plt.savefig("map.png") + plt.show() + except Exception as e: + print(str(e)) - print('
' % date)
+ cmd = "rm -f " + os.path.dirname(os.getcwd()) + "/map*.png && mv map.png " + os.path.dirname(
+ os.getcwd()) + "/map" + date + ".png"
+ output, stderr = funct.subprocess_execute(cmd)
+ print(stderr)
+ print('' % date)
if form.getvalue('servaction') is not None:
- server_state_file = sql.get_setting('server_state_file')
- haproxy_sock = sql.get_setting('haproxy_sock')
- enable = form.getvalue('servaction')
- backend = form.getvalue('servbackend')
- cmd='echo "%s %s" |sudo socat stdio %s' % (enable, backend, haproxy_sock)
+ server_state_file = sql.get_setting('server_state_file')
+ haproxy_sock = sql.get_setting('haproxy_sock')
+ enable = form.getvalue('servaction')
+ backend = form.getvalue('servbackend')
+ cmd = 'echo "%s %s" |sudo socat stdio %s' % (enable, backend, haproxy_sock)
- if form.getvalue('save') == "on":
- save_command = 'echo "show servers state" | sudo socat %s stdio > %s' % (haproxy_sock, server_state_file)
- command = [ cmd + ';' + save_command ]
- else:
- command = [ cmd ]
+ if form.getvalue('save') == "on":
+ save_command = 'echo "show servers state" | sudo socat %s stdio > %s' % (haproxy_sock, server_state_file)
+ command = [cmd + ';' + save_command]
+ else:
+ command = [cmd]
- if enable != "show":
- print('You %s %s on HAproxy %s. Look it or Edit something else
' % (enable, backend, serv, serv)) - - print(funct.ssh_command(serv, command, show_log="1")) - action = 'runtimeapi.py ' + enable + ' ' + backend - funct.logging(serv, action) + if enable != "show": + print( + '
You %s %s on HAproxy %s. Look it or Edit something else
' % ( + enable, backend, serv, serv)) + print(funct.ssh_command(serv, command, show_log="1")) + action = 'runtimeapi.py ' + enable + ' ' + backend + funct.logging(serv, action) if act == "showCompareConfigs": - from jinja2 import Environment, FileSystemLoader - env = Environment(loader=FileSystemLoader('templates/'), autoescape=True) - template = env.get_template('ajax/show_compare_configs.html') - left = form.getvalue('left') - right = form.getvalue('right') + from jinja2 import Environment, FileSystemLoader - if form.getvalue('service') == 'nginx': - return_files=funct.get_files(funct.get_config_var('configs', 'nginx_save_configs_dir'), 'conf') - else: - return_files=funct.get_files() + env = Environment(loader=FileSystemLoader('templates/'), autoescape=True) + template = env.get_template('ajax/show_compare_configs.html') + left = form.getvalue('left') + right = form.getvalue('right') - template = template.render(serv=serv, right=right, left=left, return_files=return_files) - print(template) + if form.getvalue('service') == 'nginx': + return_files = funct.get_files(funct.get_config_var('configs', 'nginx_save_configs_dir'), 'conf') + else: + return_files = funct.get_files() + template = template.render(serv=serv, right=right, left=left, return_files=return_files) + print(template) if serv is not None and form.getvalue('right') is not None: - from jinja2 import Environment, FileSystemLoader - left = form.getvalue('left') - right = form.getvalue('right') - if form.getvalue('service') == 'nginx': - configs_dir = funct.get_config_var('configs', 'nginx_save_configs_dir') - else: - configs_dir = funct.get_config_var('configs', 'haproxy_save_configs_dir') - cmd='diff -ub %s%s %s%s' % (configs_dir, left, configs_dir, right) - env = Environment(loader=FileSystemLoader('templates/'), autoescape=True, extensions=["jinja2.ext.loopcontrols", "jinja2.ext.do"]) - template = env.get_template('ajax/compare.html') + from jinja2 import Environment, FileSystemLoader - output, stderr = funct.subprocess_execute(cmd) - template = template.render(stdout=output) + left = form.getvalue('left') + right = form.getvalue('right') + if form.getvalue('service') == 'nginx': + configs_dir = funct.get_config_var('configs', 'nginx_save_configs_dir') + else: + configs_dir = funct.get_config_var('configs', 'haproxy_save_configs_dir') + cmd = 'diff -ub %s%s %s%s' % (configs_dir, left, configs_dir, right) + env = Environment(loader=FileSystemLoader('templates/'), autoescape=True, + extensions=["jinja2.ext.loopcontrols", "jinja2.ext.do"]) + template = env.get_template('ajax/compare.html') - print(template) - print(stderr) + output, stderr = funct.subprocess_execute(cmd) + template = template.render(stdout=output) + print(template) + print(stderr) if serv is not None and act == "configShow": - if form.getvalue('service') == 'keepalived': - configs_dir = funct.get_config_var('configs', 'kp_save_configs_dir') - cfg = '.conf' - elif form.getvalue('service') == 'nginx': - configs_dir = funct.get_config_var('configs', 'nginx_save_configs_dir') - cfg = '.conf' - else: - configs_dir = funct.get_config_var('configs', 'haproxy_save_configs_dir') - cfg = '.cfg' + if form.getvalue('service') == 'keepalived': + configs_dir = funct.get_config_var('configs', 'kp_save_configs_dir') + cfg = '.conf' + elif form.getvalue('service') == 'nginx': + configs_dir = funct.get_config_var('configs', 'nginx_save_configs_dir') + cfg = '.conf' + else: + configs_dir = funct.get_config_var('configs', 'haproxy_save_configs_dir') + cfg = '.cfg' - if form.getvalue('configver') is None: - cfg = configs_dir + serv + "-" + funct.get_data('config') + cfg - if form.getvalue('service') == 'nginx': - funct.get_config(serv, cfg, nginx=1) - else: - funct.get_config(serv, cfg) - else: - cfg = configs_dir + form.getvalue('configver') - try: - conf = open(cfg, "r") - except IOError: - print('
Can\'t read config file
')
+ if form.getvalue('configver') is None:
+ cfg = configs_dir + serv + "-" + funct.get_data('config') + cfg
+ if form.getvalue('service') == 'nginx':
+ funct.get_config(serv, cfg, nginx=1)
+ else:
+ funct.get_config(serv, cfg)
+ else:
+ cfg = configs_dir + form.getvalue('configver')
+ try:
+ conf = open(cfg, "r")
+ except IOError:
+ print('Can\'t read config file
')
- from jinja2 import Environment, FileSystemLoader
- env = Environment(loader=FileSystemLoader('templates/ajax'), autoescape=True, trim_blocks=True, lstrip_blocks=True, extensions=["jinja2.ext.loopcontrols", "jinja2.ext.do"])
- template = env.get_template('config_show.html')
+ from jinja2 import Environment, FileSystemLoader
- template = template.render(conf=conf,
- serv=serv,
- configver=form.getvalue('configver'),
- role=funct.is_admin(level=3),
- service=form.getvalue('service'))
- print(template)
+ env = Environment(loader=FileSystemLoader('templates/ajax'), autoescape=True, trim_blocks=True, lstrip_blocks=True,
+ extensions=["jinja2.ext.loopcontrols", "jinja2.ext.do"])
+ template = env.get_template('config_show.html')
- if form.getvalue('configver') is None:
- os.system("/bin/rm -f " + cfg)
+ template = template.render(conf=conf,
+ serv=serv,
+ configver=form.getvalue('configver'),
+ role=funct.is_admin(level=3),
+ service=form.getvalue('service'))
+ print(template)
+ if form.getvalue('configver') is None:
+ os.system("/bin/rm -f " + cfg)
if form.getvalue('master'):
- master = form.getvalue('master')
- slave = form.getvalue('slave')
- ETH = form.getvalue('interface')
- IP = form.getvalue('vrrpip')
- syn_flood = form.getvalue('syn_flood')
- script = "install_keepalived.sh"
- fullpath = funct.get_config_var('main', 'fullpath')
- proxy = sql.get_setting('proxy')
- ssh_enable, ssh_user_name, ssh_user_password, ssh_key_name = funct.return_ssh_keys_path(master)
+ master = form.getvalue('master')
+ slave = form.getvalue('slave')
+ ETH = form.getvalue('interface')
+ IP = form.getvalue('vrrpip')
+ syn_flood = form.getvalue('syn_flood')
+ script = "install_keepalived.sh"
+ fullpath = funct.get_config_var('main', 'fullpath')
+ proxy = sql.get_setting('proxy')
+ ssh_enable, ssh_user_name, ssh_user_password, ssh_key_name = funct.return_ssh_keys_path(master)
- if ssh_enable == 0:
- ssh_key_name = ''
+ if ssh_enable == 0:
+ ssh_key_name = ''
- servers = sql.select_servers(server=master)
- for server in servers:
- ssh_port = str(server[10])
+ servers = sql.select_servers(server=master)
+ for server in servers:
+ ssh_port = str(server[10])
- if proxy is not None and proxy != '' and proxy != 'None':
- proxy_serv = proxy
- else:
- proxy_serv = ''
+ if proxy is not None and proxy != '' and proxy != 'None':
+ proxy_serv = proxy
+ else:
+ proxy_serv = ''
- os.system("cp scripts/%s ." % script)
+ os.system("cp scripts/%s ." % script)
- if form.getvalue('hap') == "1":
- funct.install_haproxy(master)
- funct.install_haproxy(slave)
+ if form.getvalue('hap') == "1":
+ funct.install_haproxy(master)
+ funct.install_haproxy(slave)
- if form.getvalue('nginx') == "1":
- funct.install_nginx(master)
- funct.install_nginx(slave)
+ if form.getvalue('nginx') == "1":
+ funct.install_nginx(master)
+ funct.install_nginx(slave)
- commands = [ "chmod +x "+script +" && ./"+script +" PROXY=" + proxy_serv+" SSH_PORT="+ssh_port+
- " ETH="+ETH+" IP="+str(IP)+" MASTER=MASTER"+" SYN_FLOOD="+syn_flood+" HOST="+str(master)+
- " USER="+str(ssh_user_name)+" PASS="+str(ssh_user_password)+" KEY="+str(ssh_key_name) ]
+ commands = ["chmod +x " + script + " && ./" + script + " PROXY=" + proxy_serv + " SSH_PORT=" + ssh_port +
+ " ETH=" + ETH + " IP=" + str(IP) + " MASTER=MASTER" + " SYN_FLOOD=" + syn_flood + " HOST=" + str(
+ master) +
+ " USER=" + str(ssh_user_name) + " PASS=" + str(ssh_user_password) + " KEY=" + str(ssh_key_name)]
- output, error = funct.subprocess_execute(commands[0])
+ output, error = funct.subprocess_execute(commands[0])
- if error:
- funct.logging('localhost', error, haproxywi=1)
- print('error: '+error)
- else:
- for l in output:
- if "msg" in l or "FAILED" in l:
- try:
- l = l.split(':')[1]
- l = l.split('"')[1]
- print(l+"") - break - except: - print(output) - break - else: - print('success: Master Keepalived was installed
') + if error: + funct.logging('localhost', error, haproxywi=1) + print('error: ' + error) + else: + for l in output: + if "msg" in l or "FAILED" in l: + try: + l = l.split(':')[1] + l = l.split('"')[1] + print(l + "
") + break + except: + print(output) + break + else: + print('success: Master Keepalived was installed
') - ssh_enable, ssh_user_name, ssh_user_password, ssh_key_name = funct.return_ssh_keys_path(slave) + ssh_enable, ssh_user_name, ssh_user_password, ssh_key_name = funct.return_ssh_keys_path(slave) - if ssh_enable == 0: - ssh_key_name = '' + if ssh_enable == 0: + ssh_key_name = '' - servers = sql.select_servers(server=slave) - for server in servers: - ssh_port = str(server[10]) + servers = sql.select_servers(server=slave) + for server in servers: + ssh_port = str(server[10]) - commands = [ "chmod +x "+script +" && ./"+script +" PROXY=" +proxy_serv+" SSH_PORT="+ssh_port+ - " ETH="+ETH+" IP="+IP+" MASTER=BACKUP"+" HOST="+str(slave)+ - " USER="+str(ssh_user_name)+" PASS="+str(ssh_user_password)+" KEY="+str(ssh_key_name) ] + commands = ["chmod +x " + script + " && ./" + script + " PROXY=" + proxy_serv + " SSH_PORT=" + ssh_port + + " ETH=" + ETH + " IP=" + IP + " MASTER=BACKUP" + " HOST=" + str(slave) + + " USER=" + str(ssh_user_name) + " PASS=" + str(ssh_user_password) + " KEY=" + str(ssh_key_name)] - output, error = funct.subprocess_execute(commands[0]) + output, error = funct.subprocess_execute(commands[0]) - if error: - funct.logging('localhost', error, haproxywi=1) - print('error: '+error) - else: - for l in output: - if "msg" in l or "FAILED" in l: - try: - l = l.split(':')[1] - l = l.split('"')[1] - print(l+"
") - break - except: - print(output) - break - else: - print('success: Slave Keepalived was installed
') - - os.system("rm -f %s" % script) - sql.update_server_master(master, slave) - sql.update_keepalived(master) - sql.update_keepalived(slave) + if error: + funct.logging('localhost', error, haproxywi=1) + print('error: ' + error) + else: + for l in output: + if "msg" in l or "FAILED" in l: + try: + l = l.split(':')[1] + l = l.split('"')[1] + print(l + "
") + break + except: + print(output) + break + else: + print('success: Slave Keepalived was installed
') + os.system("rm -f %s" % script) + sql.update_server_master(master, slave) + sql.update_keepalived(master) + sql.update_keepalived(slave) if form.getvalue('masteradd'): - master = form.getvalue('masteradd') - slave = form.getvalue('slaveadd') - ETH = form.getvalue('interfaceadd') - IP = form.getvalue('vrrpipadd') - kp = form.getvalue('kp') - script = "install_keepalived.sh" - proxy = sql.get_setting('proxy') - ssh_enable, ssh_user_name, ssh_user_password, ssh_key_name = funct.return_ssh_keys_path(master) + master = form.getvalue('masteradd') + slave = form.getvalue('slaveadd') + ETH = form.getvalue('interfaceadd') + IP = form.getvalue('vrrpipadd') + kp = form.getvalue('kp') + script = "install_keepalived.sh" + proxy = sql.get_setting('proxy') + ssh_enable, ssh_user_name, ssh_user_password, ssh_key_name = funct.return_ssh_keys_path(master) - if ssh_enable == 0: - ssh_key_name = '' + if ssh_enable == 0: + ssh_key_name = '' - if proxy is not None and proxy != '' and proxy != 'None': - proxy_serv = proxy - else: - proxy_serv = '' + if proxy is not None and proxy != '' and proxy != 'None': + proxy_serv = proxy + else: + proxy_serv = '' - os.system("cp scripts/%s ." % script) + os.system("cp scripts/%s ." % script) - servers = sql.select_servers(server=master) - for server in servers: - ssh_port = str(server[10]) + servers = sql.select_servers(server=master) + for server in servers: + ssh_port = str(server[10]) - commands = [ "chmod +x "+script +" && ./"+script +" PROXY=" + proxy_serv+ - " SSH_PORT="+ssh_port+ - " ETH="+ETH+" IP="+str(IP)+" MASTER=MASTER"+" RESTART="+kp+" ADD_VRRP=1 HOST="+str(master)+ - " USER="+str(ssh_user_name)+" PASS="+str(ssh_user_password)+" KEY="+str(ssh_key_name) ] + commands = ["chmod +x " + script + " && ./" + script + " PROXY=" + proxy_serv + + " SSH_PORT=" + ssh_port + " ETH=" + ETH + + " IP=" + str(IP) + " MASTER=MASTER" + " RESTART=" + kp + " ADD_VRRP=1 HOST=" + str(master) + + " USER=" + str(ssh_user_name) + " PASS=" + str(ssh_user_password) + " KEY=" + str(ssh_key_name)] - output, error = funct.subprocess_execute(commands[0]) + output, error = funct.subprocess_execute(commands[0]) - if error: - funct.logging('localhost', error, haproxywi=1) - print('error: '+error) - else: - for l in output: - if "msg" in l or "FAILED" in l: - try: - l = l.split(':')[1] - l = l.split('"')[1] - print(l+"
") - break - except: - print(output) - break - else: - print('success: Master VRRP address was added
') + if error: + funct.logging('localhost', error, haproxywi=1) + print('error: ' + error) + else: + for l in output: + if "msg" in l or "FAILED" in l: + try: + l = l.split(':')[1] + l = l.split('"')[1] + print(l + "
") + break + except: + print(output) + break + else: + print('success: Master VRRP address was added
') + ssh_enable, ssh_user_name, ssh_user_password, ssh_key_name = funct.return_ssh_keys_path(slave) - ssh_enable, ssh_user_name, ssh_user_password, ssh_key_name = funct.return_ssh_keys_path(slave) + if ssh_enable == 0: + ssh_key_name = '' - if ssh_enable == 0: - ssh_key_name = '' + servers = sql.select_servers(server=slave) + for server in servers: + ssh_port = str(server[10]) - servers = sql.select_servers(server=slave) - for server in servers: - ssh_port = str(server[10]) + commands = ["chmod +x " + script + " && ./" + script + " PROXY=" + proxy_serv + + " SSH_PORT=" + ssh_port + " ETH=" + ETH + + " IP=" + str(IP) + " MASTER=BACKUP" + " RESTART=" + kp + " ADD_VRRP=1 HOST=" + str(slave) + + " USER=" + str(ssh_user_name) + " PASS=" + str(ssh_user_password) + " KEY=" + str(ssh_key_name)] - commands = ["chmod +x "+script +" && ./"+script +" PROXY=" + proxy_serv+ - " SSH_PORT="+ssh_port+ - " ETH="+ETH+" IP="+str(IP)+" MASTER=BACKUP"+" RESTART="+kp+" ADD_VRRP=1 HOST="+str(slave)+ - " USER="+str(ssh_user_name)+" PASS="+str(ssh_user_password)+" KEY="+str(ssh_key_name)] + output, error = funct.subprocess_execute(commands[0]) - output, error = funct.subprocess_execute(commands[0]) - - if error: - funct.logging('localhost', error, haproxywi=1) - print('error: '+error) - else: - for l in output: - if "msg" in l or "FAILED" in l: - try: - l = l.split(':')[1] - l = l.split('"')[1] - print(l+"
") - break - except: - print(output) - break - else: - print('success: Slave VRRP address was added
') - - os.system("rm -f %s" % script) + if error: + funct.logging('localhost', error, haproxywi=1) + print('error: ' + error) + else: + for l in output: + if "msg" in l or "FAILED" in l: + try: + l = l.split(':')[1] + l = l.split('"')[1] + print(l + "
") + break + except: + print(output) + break + else: + print('success: Slave VRRP address was added
') + os.system("rm -f %s" % script) if form.getvalue('install_grafana'): - script = "install_grafana.sh" - proxy = sql.get_setting('proxy') + script = "install_grafana.sh" + proxy = sql.get_setting('proxy') - os.system("cp scripts/%s ." % script) + os.system("cp scripts/%s ." % script) - if proxy is not None and proxy != '' and proxy != 'None': - proxy_serv = proxy - else: - proxy_serv = '' + if proxy is not None and proxy != '' and proxy != 'None': + proxy_serv = proxy + else: + proxy_serv = '' - commands = [ "chmod +x "+script +" && ./"+script +" PROXY=" + proxy_serv ] + commands = ["chmod +x " + script + " && ./" + script + " PROXY=" + proxy_serv] - output, error = funct.subprocess_execute(commands[0]) + output, error = funct.subprocess_execute(commands[0]) - if error: - funct.logging('localhost', error, haproxywi=1) - import socket - print('success: Grafana and Prometheus servers were installed. You can find Grafana on http://'+socket.gethostname()+':3000
') - else: - for l in output: - if "FAILED" in l: - try: - l = l.split(':')[1] - l = l.split('"')[1] - print(l+"
") - break - except: - print(output) - break - else: - import socket - print('success: Grafana and Prometheus servers were installed. You can find Grafana on http://'+socket.gethostname()+':3000
') + if error: + funct.logging('localhost', error, haproxywi=1) + import socket - os.system("rm -f %s" % script) + print( + 'success: Grafana and Prometheus servers were installed. You can find Grafana on http://' + socket.gethostname() + ':3000
') + else: + for l in output: + if "FAILED" in l: + try: + l = l.split(':')[1] + l = l.split('"')[1] + print(l + "
") + break + except: + print(output) + break + else: + import socket + print( + 'success: Grafana and Prometheus servers were installed. You can find Grafana on http://' + socket.gethostname() + ':3000
') + + os.system("rm -f %s" % script) if form.getvalue('haproxy_exp_install'): - serv = form.getvalue('haproxy_exp_install') - script = "install_haproxy_exporter.sh" - stats_port = sql.get_setting('stats_port') - server_state_file = sql.get_setting('server_state_file') - stats_user = sql.get_setting('stats_user') - stats_password = sql.get_setting('stats_password') - stat_page = sql.get_setting('stats_page') - proxy = sql.get_setting('proxy') - ssh_enable, ssh_user_name, ssh_user_password, ssh_key_name = funct.return_ssh_keys_path(serv) + serv = form.getvalue('haproxy_exp_install') + script = "install_haproxy_exporter.sh" + stats_port = sql.get_setting('stats_port') + server_state_file = sql.get_setting('server_state_file') + stats_user = sql.get_setting('stats_user') + stats_password = sql.get_setting('stats_password') + stat_page = sql.get_setting('stats_page') + proxy = sql.get_setting('proxy') + ssh_enable, ssh_user_name, ssh_user_password, ssh_key_name = funct.return_ssh_keys_path(serv) - if ssh_enable == 0: - ssh_key_name = '' + if ssh_enable == 0: + ssh_key_name = '' - servers = sql.select_servers(server=serv) - for server in servers: - ssh_port = str(server[10]) + servers = sql.select_servers(server=serv) + for server in servers: + ssh_port = str(server[10]) - os.system("cp scripts/%s ." % script) + os.system("cp scripts/%s ." % script) - if proxy is not None and proxy != '' and proxy != 'None': - proxy_serv = proxy - else: - proxy_serv = '' + if proxy is not None and proxy != '' and proxy != 'None': + proxy_serv = proxy + else: + proxy_serv = '' - commands = ["chmod +x "+script +" && ./"+script +" PROXY=" + proxy_serv+ - " STAT_PORT="+stats_port+" STAT_FILE="+server_state_file+ - " SSH_PORT="+ssh_port+" STAT_PAGE="+stat_page+ - " STATS_USER="+stats_user+" STATS_PASS="+stats_password+" HOST="+serv+ - " USER="+ssh_user_name+" PASS="+ssh_user_password+" KEY="+ssh_key_name] + commands = ["chmod +x " + script + " && ./" + script + " PROXY=" + proxy_serv + + " STAT_PORT=" + stats_port + " STAT_FILE=" + server_state_file + + " SSH_PORT=" + ssh_port + " STAT_PAGE=" + stat_page + + " STATS_USER=" + stats_user + " STATS_PASS=" + stats_password + " HOST=" + serv + + " USER=" + ssh_user_name + " PASS=" + ssh_user_password + " KEY=" + ssh_key_name] - output, error = funct.subprocess_execute(commands[0]) + output, error = funct.subprocess_execute(commands[0]) - if error: - funct.logging('localhost', error, haproxywi=1) - print('error: '+error) - else: - for l in output: - if "msg" in l or "FAILED" in l: - try: - l = l.split(':')[1] - l = l.split('"')[1] - print(l+"
") - break - except: - print(output) - break - else: - print('success: HAProxy exporter was installed
') - - os.system("rm -f %s" % script) + if error: + funct.logging('localhost', error, haproxywi=1) + print('error: ' + error) + else: + for l in output: + if "msg" in l or "FAILED" in l: + try: + l = l.split(':')[1] + l = l.split('"')[1] + print(l + "
") + break + except: + print(output) + break + else: + print('success: HAProxy exporter was installed
') + os.system("rm -f %s" % script) if form.getvalue('nginx_exp_install'): - serv = form.getvalue('nginx_exp_install') - script = "install_nginx_exporter.sh" - stats_user = sql.get_setting('nginx_stats_user') - stats_password = sql.get_setting('nginx_stats_password') - stats_port = sql.get_setting('nginx_stats_port') - stats_page = sql.get_setting('nginx_stats_page') - proxy = sql.get_setting('proxy') - ssh_enable, ssh_user_name, ssh_user_password, ssh_key_name = funct.return_ssh_keys_path(serv) + serv = form.getvalue('nginx_exp_install') + script = "install_nginx_exporter.sh" + stats_user = sql.get_setting('nginx_stats_user') + stats_password = sql.get_setting('nginx_stats_password') + stats_port = sql.get_setting('nginx_stats_port') + stats_page = sql.get_setting('nginx_stats_page') + proxy = sql.get_setting('proxy') + ssh_enable, ssh_user_name, ssh_user_password, ssh_key_name = funct.return_ssh_keys_path(serv) - if ssh_enable == 0: - ssh_key_name = '' + if ssh_enable == 0: + ssh_key_name = '' - servers = sql.select_servers(server=serv) - for server in servers: - ssh_port = str(server[10]) + servers = sql.select_servers(server=serv) + for server in servers: + ssh_port = str(server[10]) - os.system("cp scripts/%s ." % script) + os.system("cp scripts/%s ." % script) - if proxy is not None and proxy != '' and proxy != 'None': - proxy_serv = proxy - else: - proxy_serv = '' + if proxy is not None and proxy != '' and proxy != 'None': + proxy_serv = proxy + else: + proxy_serv = '' - commands = [ "chmod +x "+script +" && ./"+script +" PROXY=" + proxy_serv+ - " STAT_PORT="+stats_port+" SSH_PORT="+ssh_port+" STAT_PAGE="+stats_page+ - " STATS_USER="+stats_user+" STATS_PASS="+stats_password+" HOST="+serv+ - " USER="+ssh_user_name+" PASS="+ssh_user_password+" KEY="+ssh_key_name ] + commands = ["chmod +x " + script + " && ./" + script + " PROXY=" + proxy_serv + + " STAT_PORT=" + stats_port + " SSH_PORT=" + ssh_port + " STAT_PAGE=" + stats_page + + " STATS_USER=" + stats_user + " STATS_PASS=" + stats_password + " HOST=" + serv + + " USER=" + ssh_user_name + " PASS=" + ssh_user_password + " KEY=" + ssh_key_name] - output, error = funct.subprocess_execute(commands[0]) + output, error = funct.subprocess_execute(commands[0]) - if error: - funct.logging('localhost', error, haproxywi=1) - print('error: '+error) - else: - for l in output: - if "msg" in l or "FAILED" in l: - try: - l = l.split(':')[1] - l = l.split('"')[1] - print(l+"
") - break - except: - print(output) - break - else: - print('success: Nginx exporter was installed
') - - os.system("rm -f %s" % script) + if error: + funct.logging('localhost', error, haproxywi=1) + print('error: ' + error) + else: + for l in output: + if "msg" in l or "FAILED" in l: + try: + l = l.split(':')[1] + l = l.split('"')[1] + print(l + "
") + break + except: + print(output) + break + else: + print('success: Nginx exporter was installed
') + os.system("rm -f %s" % script) if form.getvalue('backup') or form.getvalue('deljob') or form.getvalue('backupupdate'): - serv = form.getvalue('server') - rpath = form.getvalue('rpath') - time = form.getvalue('time') - type = form.getvalue('type') - rserver = form.getvalue('rserver') - cred = form.getvalue('cred') - deljob = form.getvalue('deljob') - update = form.getvalue('backupupdate') - description = form.getvalue('description') - script = "backup.sh" - ssh_enable, ssh_user_name, ssh_user_password, ssh_key_name = funct.return_ssh_keys_path('localhost', id=int(cred)) + serv = form.getvalue('server') + rpath = form.getvalue('rpath') + time = form.getvalue('time') + type = form.getvalue('type') + rserver = form.getvalue('rserver') + cred = form.getvalue('cred') + deljob = form.getvalue('deljob') + update = form.getvalue('backupupdate') + description = form.getvalue('description') + script = "backup.sh" + ssh_enable, ssh_user_name, ssh_user_password, ssh_key_name = funct.return_ssh_keys_path('localhost', id=int(cred)) - if deljob: - time = '' - rpath = '' - type = '' - elif update: - deljob = '' - else: - deljob = '' - if sql.check_exists_backup(serv): - print('warning: Backup job for %s already exists' % serv) - sys.exit() + if deljob: + time = '' + rpath = '' + type = '' + elif update: + deljob = '' + else: + deljob = '' + if sql.check_exists_backup(serv): + print('warning: Backup job for %s already exists' % serv) + sys.exit() - servers = sql.select_servers(server=serv) - for server in servers: - ssh_port = str(server[10]) + servers = sql.select_servers(server=serv) + for server in servers: + ssh_port = str(server[10]) - os.system("cp scripts/%s ." % script) + os.system("cp scripts/%s ." % script) - commands = ["chmod +x "+script +" && ./"+script +" HOST="+rserver+" SERVER="+serv+" TYPE="+type+ - " SSH_PORT="+ssh_port+ - " TIME="+time+" RPATH="+rpath+" DELJOB="+deljob+" USER="+str(ssh_user_name)+" KEY="+str(ssh_key_name)] + commands = ["chmod +x " + script + " && ./" + script + " HOST=" + rserver + " SERVER=" + serv + " TYPE=" + type + + " SSH_PORT=" + ssh_port + " TIME=" + time + + " RPATH=" + rpath + " DELJOB=" + deljob + " USER=" + str(ssh_user_name) + " KEY=" + str(ssh_key_name)] - output, error = funct.subprocess_execute(commands[0]) + output, error = funct.subprocess_execute(commands[0]) - if error: - funct.logging('backup', error, haproxywi=1) - print('error: '+error) - else: - for l in output: - if "msg" in l or "FAILED" in l: - try: - l = l.split(':')[1] - l = l.split('"')[1] - print('error: '+l+"
") - break - except: - print('error: ' + output) - break - else: - if not deljob and not update: - if sql.insert_backup_job(serv, rserver, rpath, type, time, cred, description): - #import http.cookies - from jinja2 import Environment, FileSystemLoader - env = Environment(loader=FileSystemLoader('templates/ajax'), autoescape=True) - template = env.get_template('new_backup.html') - template = template.render(backups=sql.select_backups(server=serv, rserver=rserver), sshs=sql.select_ssh()) - print(template) - print('success: Backup job has created') - funct.logging('backup ', ' has created a new backup job for server '+serv , haproxywi=1, login=1) - else: - print('error: Cannot add job into DB') - elif deljob: - sql.delete_backups(deljob) - print('Ok') - funct.logging('backup ', ' has deleted a backup job for server '+serv, haproxywi=1, login=1) - elif update: - sql.update_backup(serv, rserver, rpath, type, time, cred, description, update) - print('Ok') - funct.logging('backup ', ' has updated a backup job for server '+serv, haproxywi=1, login=1) + if error: + funct.logging('backup', error, haproxywi=1) + print('error: ' + error) + else: + for l in output: + if "msg" in l or "FAILED" in l: + try: + l = l.split(':')[1] + l = l.split('"')[1] + print('error: ' + l + "
") + break + except: + print('error: ' + output) + break + else: + if not deljob and not update: + if sql.insert_backup_job(serv, rserver, rpath, type, time, cred, description): + from jinja2 import Environment, FileSystemLoader + env = Environment(loader=FileSystemLoader('templates/ajax'), autoescape=True) + template = env.get_template('new_backup.html') + template = template.render(backups=sql.select_backups(server=serv, rserver=rserver), + sshs=sql.select_ssh()) + print(template) + print('success: Backup job has created') + funct.logging('backup ', ' has created a new backup job for server ' + serv, haproxywi=1, login=1) + else: + print('error: Cannot add job into DB') + elif deljob: + sql.delete_backups(deljob) + print('Ok') + funct.logging('backup ', ' has deleted a backup job for server ' + serv, haproxywi=1, login=1) + elif update: + sql.update_backup(serv, rserver, rpath, type, time, cred, description, update) + print('Ok') + funct.logging('backup ', ' has updated a backup job for server ' + serv, haproxywi=1, login=1) if form.getvalue('install_nginx'): - funct.install_nginx(form.getvalue('install_nginx')) - + funct.install_nginx(form.getvalue('install_nginx')) if form.getvalue('haproxyaddserv'): - funct.install_haproxy(form.getvalue('haproxyaddserv'), syn_flood=form.getvalue('syn_flood'), hapver=form.getvalue('hapver')) - + funct.install_haproxy(form.getvalue('haproxyaddserv'), syn_flood=form.getvalue('syn_flood'), + hapver=form.getvalue('hapver')) if form.getvalue('installwaf'): - funct.waf_install(form.getvalue('installwaf')) - + funct.waf_install(form.getvalue('installwaf')) if form.getvalue('update_haproxy_wi'): - service = form.getvalue('service') - services = ['checker_haproxy', 'haproxy-wi', 'keep_alive', 'smon', 'metrics_haproxy'] - if service not in services: - print('error: '+service+' is not part of HAProxy-WI') - sys.exit() - funct.update_haproxy_wi(service) - + service = form.getvalue('service') + services = ['checker_haproxy', 'haproxy-wi', 'keep_alive', 'smon', 'metrics_haproxy'] + if service not in services: + print('error: ' + service + ' is not part of HAProxy-WI') + sys.exit() + funct.update_haproxy_wi(service) if form.getvalue('metrics_waf'): - sql.update_waf_metrics_enable(form.getvalue('metrics_waf'), form.getvalue('enable')) - + sql.update_waf_metrics_enable(form.getvalue('metrics_waf'), form.getvalue('enable')) if form.getvalue('table_metrics'): - import http.cookies - from jinja2 import Environment, FileSystemLoader - env = Environment(loader=FileSystemLoader('templates/ajax'), autoescape=True) - template = env.get_template('table_metrics.html') + import http.cookies + from jinja2 import Environment, FileSystemLoader - cookie = http.cookies.SimpleCookie(os.environ.get("HTTP_COOKIE")) - user_id = cookie.get('uuid') - table_stat = sql.select_table_metrics(user_id.value) + env = Environment(loader=FileSystemLoader('templates/ajax'), autoescape=True) + template = env.get_template('table_metrics.html') - template = template.render(table_stat=sql.select_table_metrics(user_id.value)) - print(template) + cookie = http.cookies.SimpleCookie(os.environ.get("HTTP_COOKIE")) + user_id = cookie.get('uuid') + table_stat = sql.select_table_metrics(user_id.value) + template = template.render(table_stat=sql.select_table_metrics(user_id.value)) + print(template) if form.getvalue('metrics_hapwi_ram'): - ip = form.getvalue('ip') - metrics = {} - metrics['chartData'] = {} - rams = '' + ip = form.getvalue('ip') + metrics = {'chartData': {}} + rams = '' - if ip == '1': - cmd = "free -m |grep Mem |awk '{print $3,$4,$5,$6,$7}'" - metric, error = funct.subprocess_execute(cmd) - else: - commands = ["free -m |grep Mem |awk '{print $3,$4,$5,$6,$7}'"] - metric, error = funct.subprocess_execute(commands[0]) + if ip == '1': + cmd = "free -m |grep Mem |awk '{print $3,$4,$5,$6,$7}'" + metric, error = funct.subprocess_execute(cmd) + else: + commands = ["free -m |grep Mem |awk '{print $3,$4,$5,$6,$7}'"] + metric, error = funct.subprocess_execute(commands[0]) - for i in metric: - rams = i + for i in metric: + rams = i - metrics['chartData']['rams'] = rams + metrics['chartData']['rams'] = rams - import json - print(json.dumps(metrics)) + import json + print(json.dumps(metrics)) if form.getvalue('metrics_hapwi_cpu'): - ip = form.getvalue('ip') - metrics = {} - metrics['chartData'] = {} - cpus = '' + ip = form.getvalue('ip') + metrics = {'chartData': {}} + cpus = '' - if ip == '1': - cmd = "top -b -n 1 |grep Cpu |awk -F':' '{print $2}'|awk -F' ' 'BEGIN{ORS=\" \";} { for (i=1;i<=NF;i+=2) print $i}'" - metric, error = funct.subprocess_execute(cmd) - else: - commands = ["top -b -n 1 |grep Cpu |awk -F':' '{print $2}'|awk -F' ' 'BEGIN{ORS=\" \";} { for (i=1;i<=NF;i+=2) print $i}'"] - metric, error = funct.subprocess_execute(commands[0]) + if ip == '1': + cmd = "top -b -n 1 |grep Cpu |awk -F':' '{print $2}'|awk -F' ' 'BEGIN{ORS=\" \";} { for (i=1;i<=NF;i+=2) print $i}'" + metric, error = funct.subprocess_execute(cmd) + else: + commands = [ + "top -b -n 1 |grep Cpu |awk -F':' '{print $2}'|awk -F' ' 'BEGIN{ORS=\" \";} { for (i=1;i<=NF;i+=2) print $i}'"] + metric, error = funct.subprocess_execute(commands[0]) - for i in metric: - cpus = i + for i in metric: + cpus = i - metrics['chartData']['cpus'] = cpus + metrics['chartData']['cpus'] = cpus - import json - print(json.dumps(metrics)) + import json + print(json.dumps(metrics)) if form.getvalue('new_metrics'): - serv = form.getvalue('server') - metric = sql.select_metrics(serv) - metrics = {} - metrics['chartData'] = {} - metrics['chartData']['labels'] = {} - labels = '' - curr_con = '' - curr_ssl_con = '' - sess_rate = '' + serv = form.getvalue('server') + metric = sql.select_metrics(serv) + metrics = {'chartData': {}} + metrics['chartData']['labels'] = {} + labels = '' + curr_con = '' + curr_ssl_con = '' + sess_rate = '' - for i in metric: - label = str(i[5]) - label = label.split(' ')[1] - labels += label+',' - curr_con += str(i[1])+',' - curr_ssl_con += str(i[2])+',' - sess_rate += str(i[3])+',' - server = str(i[0]) + for i in metric: + label = str(i[5]) + label = label.split(' ')[1] + labels += label + ',' + curr_con += str(i[1]) + ',' + curr_ssl_con += str(i[2]) + ',' + sess_rate += str(i[3]) + ',' + server = str(i[0]) - metrics['chartData']['labels'] = labels - metrics['chartData']['curr_con'] = curr_con - metrics['chartData']['curr_ssl_con'] = curr_ssl_con - metrics['chartData']['sess_rate'] = sess_rate - metrics['chartData']['server'] = server + metrics['chartData']['labels'] = labels + metrics['chartData']['curr_con'] = curr_con + metrics['chartData']['curr_ssl_con'] = curr_ssl_con + metrics['chartData']['sess_rate'] = sess_rate + metrics['chartData']['server'] = server - import json - print(json.dumps(metrics)) + import json + print(json.dumps(metrics)) if form.getvalue('new_waf_metrics'): - serv = form.getvalue('server') - metric = sql.select_waf_metrics(serv) - metrics = {} - metrics['chartData'] = {} - metrics['chartData']['labels'] = {} - labels = '' - curr_con = '' + serv = form.getvalue('server') + metric = sql.select_waf_metrics(serv) + metrics = {'chartData': {}} + metrics['chartData']['labels'] = {} + labels = '' + curr_con = '' - for i in metric: - label = str(i[2]) - label = label.split(' ')[1] - labels += label+',' - curr_con += str(i[1])+',' + for i in metric: + label = str(i[2]) + label = label.split(' ')[1] + labels += label + ',' + curr_con += str(i[1]) + ',' - metrics['chartData']['labels'] = labels - metrics['chartData']['curr_con'] = curr_con - metrics['chartData']['server'] = serv + metrics['chartData']['labels'] = labels + metrics['chartData']['curr_con'] = curr_con + metrics['chartData']['server'] = serv - import json - print(json.dumps(metrics)) + import json + print(json.dumps(metrics)) if form.getvalue('get_hap_v'): - output = funct.check_haproxy_version(serv) - print(output) - + output = funct.check_haproxy_version(serv) + print(output) if form.getvalue('get_nginx_v'): - cmd = ['/usr/sbin/nginx -v'] - print(funct.ssh_command(serv, cmd)) - + cmd = ['/usr/sbin/nginx -v'] + print(funct.ssh_command(serv, cmd)) if form.getvalue('get_exporter_v'): - print(funct.check_service(serv, form.getvalue('get_exporter_v'))) - + print(funct.check_service(serv, form.getvalue('get_exporter_v'))) if form.getvalue('bwlists'): - list = os.path.dirname(os.getcwd())+"/"+sql.get_setting('lists_path')+"/"+form.getvalue('group')+"/"+form.getvalue('color')+"/"+form.getvalue('bwlists') - try: - file = open(list, "r") - file_read = file.read() - file.close - print(file_read) - except IOError: - print('error: Cat\'n read '+form.getvalue('color')+' list , ') - + list = os.path.dirname(os.getcwd()) + "/" + sql.get_setting('lists_path') + "/" + form.getvalue( + 'group') + "/" + form.getvalue('color') + "/" + form.getvalue('bwlists') + try: + file = open(list, "r") + file_read = file.read() + file.close + print(file_read) + except IOError: + print('error: Cat\'n read ' + form.getvalue('color') + ' list , ') if form.getvalue('bwlists_create'): - color = form.getvalue('color') - list_name = form.getvalue('bwlists_create').split('.')[0] - list_name += '.lst' - list = os.path.dirname(os.getcwd())+"/"+sql.get_setting('lists_path')+"/"+form.getvalue('group')+"/"+color+"/"+list_name - try: - open(list, 'a').close() - print(color) - try: - funct.logging(server[1], 'has created '+color+' list '+list_name, haproxywi=1, login=1) - except: - pass - except IOError as e: - print('error: Cat\'n create new '+color+' list. %s , ' % e) - + color = form.getvalue('color') + list_name = form.getvalue('bwlists_create').split('.')[0] + list_name += '.lst' + list = os.path.dirname(os.getcwd()) + "/" + sql.get_setting('lists_path') + "/" + form.getvalue( + 'group') + "/" + color + "/" + list_name + try: + open(list, 'a').close() + print(color) + try: + funct.logging(server[1], 'has created ' + color + ' list ' + list_name, haproxywi=1, login=1) + except: + pass + except IOError as e: + print('error: Cat\'n create new ' + color + ' list. %s , ' % e) if form.getvalue('bwlists_save'): - color = form.getvalue('color') - bwlists_save = form.getvalue('bwlists_save') - list = os.path.dirname(os.getcwd())+"/"+sql.get_setting('lists_path')+"/"+form.getvalue('group')+"/"+color+"/"+bwlists_save - try: - with open(list, "w") as file: - file.write(form.getvalue('bwlists_content')) - except IOError as e: - print('error: Cat\'n save '+color+' list. %s , ' % e) + color = form.getvalue('color') + bwlists_save = form.getvalue('bwlists_save') + list = os.path.dirname(os.getcwd()) + "/" + sql.get_setting('lists_path') + "/" + form.getvalue( + 'group') + "/" + color + "/" + bwlists_save + try: + with open(list, "w") as file: + file.write(form.getvalue('bwlists_content')) + except IOError as e: + print('error: Cat\'n save ' + color + ' list. %s , ' % e) - path = sql.get_setting('haproxy_dir')+"/"+color - servers = [] + path = sql.get_setting('haproxy_dir') + "/" + color + servers = [] - if serv != 'all': - servers.append(serv) + if serv != 'all': + servers.append(serv) - MASTERS = sql.is_master(serv) - for master in MASTERS: - if master[0] != None: - servers.append(master[0]) - else: - server = sql.get_dick_permit() - for s in server: - servers.append(s[2]) + MASTERS = sql.is_master(serv) + for master in MASTERS: + if master[0] != None: + servers.append(master[0]) + else: + server = sql.get_dick_permit() + for s in server: + servers.append(s[2]) - for serv in servers: - funct.ssh_command(serv, ["sudo mkdir "+path]) - funct.ssh_command(serv, ["sudo chown $(whoami) "+path]) - error = funct.upload(serv, path+"/"+bwlists_save, list, dir='fullpath') - if error: - print('error: Upload fail: %s , ' % error) - else: - print('success: Edited '+color+' list was uploaded to '+serv+' , ') - try: - funct.logging(serv, 'has edited '+color+' list '+bwlists_save, haproxywi=1, login=1) - except: - pass + for serv in servers: + funct.ssh_command(serv, ["sudo mkdir " + path]) + funct.ssh_command(serv, ["sudo chown $(whoami) " + path]) + error = funct.upload(serv, path + "/" + bwlists_save, list, dir='fullpath') + if error: + print('error: Upload fail: %s , ' % error) + else: + print('success: Edited ' + color + ' list was uploaded to ' + serv + ' , ') + try: + funct.logging(serv, 'has edited ' + color + ' list ' + bwlists_save, haproxywi=1, login=1) + except: + pass - haproxy_enterprise = sql.get_setting('haproxy_enterprise') - if haproxy_enterprise == '1': - haproxy_service_name = "hapee-2.0-lb" - else: - haproxy_service_name = "haproxy" - - if form.getvalue('bwlists_restart') == 'restart': - funct.ssh_command(serv, ["sudo systemctl restart "+haproxy_service_name]) - elif form.getvalue('bwlists_restart') == 'reload': - funct.ssh_command(serv, ["sudo systemctl reload "+haproxy_service_name]) + haproxy_enterprise = sql.get_setting('haproxy_enterprise') + if haproxy_enterprise == '1': + haproxy_service_name = "hapee-2.0-lb" + else: + haproxy_service_name = "haproxy" + if form.getvalue('bwlists_restart') == 'restart': + funct.ssh_command(serv, ["sudo systemctl restart " + haproxy_service_name]) + elif form.getvalue('bwlists_restart') == 'reload': + funct.ssh_command(serv, ["sudo systemctl reload " + haproxy_service_name]) if form.getvalue('get_lists'): - list = os.path.dirname(os.getcwd())+"/"+sql.get_setting('lists_path')+"/"+form.getvalue('group')+"/"+form.getvalue('color') - lists = funct.get_files(dir=list, format="lst") - for list in lists: - print(list) - + list = os.path.dirname(os.getcwd()) + "/" + sql.get_setting('lists_path') + "/" + form.getvalue( + 'group') + "/" + form.getvalue('color') + lists = funct.get_files(dir=list, format="lst") + for list in lists: + print(list) if form.getvalue('get_ldap_email'): - username = form.getvalue('get_ldap_email') - import ldap + username = form.getvalue('get_ldap_email') + import ldap - server = sql.get_setting('ldap_server') - port = sql.get_setting('ldap_port') - user = sql.get_setting('ldap_user') - password = sql.get_setting('ldap_password') - ldap_base = sql.get_setting('ldap_base') - domain = sql.get_setting('ldap_domain') - ldap_search_field = sql.get_setting('ldap_search_field') - ldap_class_search = sql.get_setting('ldap_class_search') - ldap_user_attribute = sql.get_setting('ldap_user_attribute') + server = sql.get_setting('ldap_server') + port = sql.get_setting('ldap_port') + user = sql.get_setting('ldap_user') + password = sql.get_setting('ldap_password') + ldap_base = sql.get_setting('ldap_base') + domain = sql.get_setting('ldap_domain') + ldap_search_field = sql.get_setting('ldap_search_field') + ldap_class_search = sql.get_setting('ldap_class_search') + ldap_user_attribute = sql.get_setting('ldap_user_attribute') - l = ldap.initialize(server+':'+port) - try: - l.protocol_version = ldap.VERSION3 - l.set_option(ldap.OPT_REFERRALS, 0) + l = ldap.initialize(server + ':' + port) + try: + l.protocol_version = ldap.VERSION3 + l.set_option(ldap.OPT_REFERRALS, 0) - bind = l.simple_bind_s(user, password) + bind = l.simple_bind_s(user, password) - criteria = "(&(objectClass="+ldap_class_search+")("+ldap_user_attribute+"="+username+"))" - attributes = [ldap_search_field] - result = l.search_s(ldap_base, ldap.SCOPE_SUBTREE, criteria, attributes) - - results = [entry for dn, entry in result if isinstance(entry, dict)] - try: - print('["'+results[0][ldap_search_field][0].decode("utf-8")+'","'+domain+'"]') - except: - print('error: user not found') - finally: - l.unbind() + criteria = "(&(objectClass=" + ldap_class_search + ")(" + ldap_user_attribute + "=" + username + "))" + attributes = [ldap_search_field] + result = l.search_s(ldap_base, ldap.SCOPE_SUBTREE, criteria, attributes) + results = [entry for dn, entry in result if isinstance(entry, dict)] + try: + print('["' + results[0][ldap_search_field][0].decode("utf-8") + '","' + domain + '"]') + except: + print('error: user not found') + finally: + l.unbind() if form.getvalue('change_waf_mode'): - waf_mode = form.getvalue('change_waf_mode') - server_hostname = form.getvalue('server_hostname') - haproxy_dir = sql.get_setting('haproxy_dir') - serv = sql.select_server_by_name(server_hostname) - commands = [ "sudo sed -i 's/^SecRuleEngine.*/SecRuleEngine %s/' %s/waf/modsecurity.conf " % (waf_mode, haproxy_dir) ] - funct.ssh_command(serv, commands) - funct.logging(serv, 'Was changed WAF mod to '+waf_mode, haproxywi=1, login=1) - + waf_mode = form.getvalue('change_waf_mode') + server_hostname = form.getvalue('server_hostname') + haproxy_dir = sql.get_setting('haproxy_dir') + serv = sql.select_server_by_name(server_hostname) + commands = ["sudo sed -i 's/^SecRuleEngine.*/SecRuleEngine %s/' %s/waf/modsecurity.conf " % (waf_mode, haproxy_dir)] + funct.ssh_command(serv, commands) + funct.logging(serv, 'Was changed WAF mod to ' + waf_mode, haproxywi=1, login=1) error_mess = 'error: All fields must be completed' - if form.getvalue('newuser') is not None: - email = form.getvalue('newemail') - password = form.getvalue('newpassword') - role = form.getvalue('newrole') - new_user = form.getvalue('newusername') - page = form.getvalue('page') - activeuser = form.getvalue('activeuser') - group = form.getvalue('newgroupuser') - role_id = sql.get_role_id_by_name(role) + email = form.getvalue('newemail') + password = form.getvalue('newpassword') + role = form.getvalue('newrole') + new_user = form.getvalue('newusername') + page = form.getvalue('page') + activeuser = form.getvalue('activeuser') + group = form.getvalue('newgroupuser') + role_id = sql.get_role_id_by_name(role) - if funct.check_user_group(): - if funct.is_admin(level=role_id): - if sql.add_user(new_user, email, password, role, activeuser): - from jinja2 import Environment, FileSystemLoader - env = Environment(loader=FileSystemLoader('templates/'), autoescape=True) - template = env.get_template('ajax/new_user.html') + if funct.check_user_group(): + if funct.is_admin(level=role_id): + if sql.add_user(new_user, email, password, role, activeuser): + from jinja2 import Environment, FileSystemLoader - template = template.render(users=sql.select_users(user=new_user), - groups=sql.select_groups(), - page=page, - roles=sql.select_roles(), - adding=1) - print(template) - funct.logging('a new user '+new_user, ' has created ', haproxywi=1, login=1) - else: - funct.logging(new_user, ' tried to privilege escalation', haproxywi=1, login=1) + env = Environment(loader=FileSystemLoader('templates/'), autoescape=True) + template = env.get_template('ajax/new_user.html') + template = template.render(users=sql.select_users(user=new_user), + groups=sql.select_groups(), + page=page, + roles=sql.select_roles(), + adding=1) + print(template) + funct.logging('a new user ' + new_user, ' has created ', haproxywi=1, login=1) + else: + funct.logging(new_user, ' tried to privilege escalation', haproxywi=1, login=1) if form.getvalue('userdel') is not None: - userdel = form.getvalue('userdel') - user = sql.select_users(id=userdel) - for u in user: - username = u[1] - if sql.delete_user(userdel): - sql.delete_user_groups(userdel) - funct.logging(username, ' has deleted user ', haproxywi=1, login=1) - print("Ok") - + userdel = form.getvalue('userdel') + user = sql.select_users(id=userdel) + for u in user: + username = u[1] + if sql.delete_user(userdel): + sql.delete_user_groups(userdel) + funct.logging(username, ' has deleted user ', haproxywi=1, login=1) + print("Ok") if form.getvalue('updateuser') is not None: - email = form.getvalue('email') - role = form.getvalue('role') - new_user = form.getvalue('updateuser') - id = form.getvalue('id') - activeuser = form.getvalue('activeuser') - group = form.getvalue('usergroup') - role_id = sql.get_role_id_by_name(role) - - if funct.check_user_group(): - if funct.is_admin(level=role_id): - sql.update_user(new_user, email, role, id, activeuser) - funct.logging(new_user, ' has updated user ', haproxywi=1, login=1) - else: - funct.logging(new_user, ' tried to privilege escalation', haproxywi=1, login=1) + email = form.getvalue('email') + role = form.getvalue('role') + new_user = form.getvalue('updateuser') + id = form.getvalue('id') + activeuser = form.getvalue('activeuser') + group = form.getvalue('usergroup') + role_id = sql.get_role_id_by_name(role) + if funct.check_user_group(): + if funct.is_admin(level=role_id): + sql.update_user(new_user, email, role, id, activeuser) + funct.logging(new_user, ' has updated user ', haproxywi=1, login=1) + else: + funct.logging(new_user, ' tried to privilege escalation', haproxywi=1, login=1) if form.getvalue('updatepassowrd') is not None: - password = form.getvalue('updatepassowrd') - id = form.getvalue('id') - user = sql.select_users(id=id) - for u in user: - username = u[1] - sql.update_user_password(password, id) - funct.logging('user '+username, ' has changed password ', haproxywi=1, login=1) - print("Ok") - + password = form.getvalue('updatepassowrd') + id = form.getvalue('id') + user = sql.select_users(id=id) + for u in user: + username = u[1] + sql.update_user_password(password, id) + funct.logging('user ' + username, ' has changed password ', haproxywi=1, login=1) + print("Ok") if form.getvalue('newserver') is not None: - hostname = form.getvalue('servername') - ip = form.getvalue('newip') - group = form.getvalue('newservergroup') - typeip = form.getvalue('typeip') - haproxy = form.getvalue('haproxy') - nginx = form.getvalue('nginx') - enable = form.getvalue('enable') - master = form.getvalue('slave') - cred = form.getvalue('cred') - page = form.getvalue('page') - page = page.split("#")[0] - port = form.getvalue('newport') - desc = form.getvalue('desc') + hostname = form.getvalue('servername') + ip = form.getvalue('newip') + group = form.getvalue('newservergroup') + typeip = form.getvalue('typeip') + haproxy = form.getvalue('haproxy') + nginx = form.getvalue('nginx') + enable = form.getvalue('enable') + master = form.getvalue('slave') + cred = form.getvalue('cred') + page = form.getvalue('page') + page = page.split("#")[0] + port = form.getvalue('newport') + desc = form.getvalue('desc') - if sql.add_server(hostname, ip, group, typeip, enable, master, cred, port, desc, haproxy, nginx): - from jinja2 import Environment, FileSystemLoader - env = Environment(loader=FileSystemLoader('templates/'), autoescape=True) - template = env.get_template('ajax/new_server.html') + if sql.add_server(hostname, ip, group, typeip, enable, master, cred, port, desc, haproxy, nginx): + from jinja2 import Environment, FileSystemLoader - template = template.render(groups = sql.select_groups(), - servers = sql.select_servers(server=ip), - roles = sql.select_roles(), - masters = sql.select_servers(get_master_servers=1), - sshs = sql.select_ssh(group=group), - page = page, - adding = 1) - print(template) - funct.logging('a new server '+hostname, ' has created ', haproxywi=1, login=1) + env = Environment(loader=FileSystemLoader('templates/'), autoescape=True) + template = env.get_template('ajax/new_server.html') + template = template.render(groups=sql.select_groups(), + servers=sql.select_servers(server=ip), + roles=sql.select_roles(), + masters=sql.select_servers(get_master_servers=1), + sshs=sql.select_ssh(group=group), + page=page, + adding=1) + print(template) + funct.logging('a new server ' + hostname, ' has created ', haproxywi=1, login=1) if form.getvalue('updatehapwiserver') is not None: - id = form.getvalue('updatehapwiserver') - active = form.getvalue('active') - name = form.getvalue('name') - alert = form.getvalue('alert_en') - metrics = form.getvalue('metrics') - sql.update_hapwi_server(id, alert, metrics, active) - funct.logging('the server '+name, ' has updated ', haproxywi=1, login=1) - + id = form.getvalue('updatehapwiserver') + active = form.getvalue('active') + name = form.getvalue('name') + alert = form.getvalue('alert_en') + metrics = form.getvalue('metrics') + sql.update_hapwi_server(id, alert, metrics, active) + funct.logging('the server ' + name, ' has updated ', haproxywi=1, login=1) if form.getvalue('updateserver') is not None: - name = form.getvalue('updateserver') - group = form.getvalue('servergroup') - typeip = form.getvalue('typeip') - haproxy = form.getvalue('haproxy') - nginx = form.getvalue('nginx') - enable = form.getvalue('enable') - master = form.getvalue('slave') - id = form.getvalue('id') - cred = form.getvalue('cred') - port = form.getvalue('port') - desc = form.getvalue('desc') - - if name is None or port is None: - print(error_mess) - else: - sql.update_server(name, group, typeip, enable, master, id, cred, port, desc, haproxy, nginx) - funct.logging('the server '+name, ' has updated ', haproxywi=1, login=1) + name = form.getvalue('updateserver') + group = form.getvalue('servergroup') + typeip = form.getvalue('typeip') + haproxy = form.getvalue('haproxy') + nginx = form.getvalue('nginx') + enable = form.getvalue('enable') + master = form.getvalue('slave') + id = form.getvalue('id') + cred = form.getvalue('cred') + port = form.getvalue('port') + desc = form.getvalue('desc') + if name is None or port is None: + print(error_mess) + else: + sql.update_server(name, group, typeip, enable, master, id, cred, port, desc, haproxy, nginx) + funct.logging('the server ' + name, ' has updated ', haproxywi=1, login=1) if form.getvalue('serverdel') is not None: - serverdel = form.getvalue('serverdel') - server = sql.select_servers(id=serverdel) - for s in server: - hostname = s[1] - ip = s[2] - if sql.check_exists_backup(ip): - print('warning: Delete the backup first ') - sys.exit() - if sql.delete_server(serverdel): - sql.delete_waf_server(serverdel) - print("Ok") - funct.logging(hostname, ' has deleted server with ', haproxywi=1, login=1) - + serverdel = form.getvalue('serverdel') + server = sql.select_servers(id=serverdel) + for s in server: + hostname = s[1] + ip = s[2] + if sql.check_exists_backup(ip): + print('warning: Delete the backup first ') + sys.exit() + if sql.delete_server(serverdel): + sql.delete_waf_server(serverdel) + print("Ok") + funct.logging(hostname, ' has deleted server with ', haproxywi=1, login=1) if form.getvalue('newgroup') is not None: - newgroup = form.getvalue('groupname') - desc = form.getvalue('newdesc') - if newgroup is None: - print(error_mess) - else: - if sql.add_group(newgroup, desc): - from jinja2 import Environment, FileSystemLoader - env = Environment(loader=FileSystemLoader('templates/ajax/'), autoescape=True) - template = env.get_template('/new_group.html') + newgroup = form.getvalue('groupname') + desc = form.getvalue('newdesc') + if newgroup is None: + print(error_mess) + else: + if sql.add_group(newgroup, desc): + from jinja2 import Environment, FileSystemLoader - output_from_parsed_template = template.render(groups = sql.select_groups(group=newgroup)) - print(output_from_parsed_template) - funct.logging('a new group '+newgroup, ' created ', haproxywi=1, login=1) + env = Environment(loader=FileSystemLoader('templates/ajax/'), autoescape=True) + template = env.get_template('/new_group.html') + output_from_parsed_template = template.render(groups=sql.select_groups(group=newgroup)) + print(output_from_parsed_template) + funct.logging('a new group ' + newgroup, ' created ', haproxywi=1, login=1) if form.getvalue('groupdel') is not None: - groupdel = form.getvalue('groupdel') - group = sql.select_groups(id=groupdel) - for g in group: - groupname = g[1] - if sql.delete_group(groupdel): - print("Ok") - funct.logging(groupname, ' has deleted group ', haproxywi=1, login=1) - + groupdel = form.getvalue('groupdel') + group = sql.select_groups(id=groupdel) + for g in group: + groupname = g[1] + if sql.delete_group(groupdel): + print("Ok") + funct.logging(groupname, ' has deleted group ', haproxywi=1, login=1) if form.getvalue('updategroup') is not None: - name = form.getvalue('updategroup') - descript = form.getvalue('descript') - id = form.getvalue('id') - if name is None: - print(error_mess) - else: - group = sql.select_groups(id=id) - for g in group: - groupname = g[1] - sql.update_group(name, descript, id) - funct.logging('the group '+groupname, ' has update ', haproxywi=1, login=1) - + name = form.getvalue('updategroup') + descript = form.getvalue('descript') + id = form.getvalue('id') + if name is None: + print(error_mess) + else: + group = sql.select_groups(id=id) + for g in group: + groupname = g[1] + sql.update_group(name, descript, id) + funct.logging('the group ' + groupname, ' has update ', haproxywi=1, login=1) if form.getvalue('new_ssh'): - user_group = funct.get_user_group() - name = form.getvalue('new_ssh') - name = name + '_' + user_group - enable = form.getvalue('ssh_enable') - group = form.getvalue('new_group') - username = form.getvalue('ssh_user') - password = form.getvalue('ssh_pass') - page = form.getvalue('page') - page = page.split("#")[0] + user_group = funct.get_user_group() + name = form.getvalue('new_ssh') + name = name + '_' + user_group + enable = form.getvalue('ssh_enable') + group = form.getvalue('new_group') + username = form.getvalue('ssh_user') + password = form.getvalue('ssh_pass') + page = form.getvalue('page') + page = page.split("#")[0] - if username is None or name is None: - print(error_mess) - else: - if sql.insert_new_ssh(name, enable, group, username, password): - from jinja2 import Environment, FileSystemLoader - env = Environment(loader=FileSystemLoader('templates/ajax'), autoescape=True) - template = env.get_template('/new_ssh.html') - output_from_parsed_template = template.render(groups=sql.select_groups(), sshs=sql.select_ssh(name=name),page=page) - print(output_from_parsed_template) - funct.logging(name, ' has created a new SSH credentials ', haproxywi=1, login=1) + if username is None or name is None: + print(error_mess) + else: + if sql.insert_new_ssh(name, enable, group, username, password): + from jinja2 import Environment, FileSystemLoader + env = Environment(loader=FileSystemLoader('templates/ajax'), autoescape=True) + template = env.get_template('/new_ssh.html') + output_from_parsed_template = template.render(groups=sql.select_groups(), sshs=sql.select_ssh(name=name), + page=page) + print(output_from_parsed_template) + funct.logging(name, ' has created a new SSH credentials ', haproxywi=1, login=1) if form.getvalue('sshdel') is not None: - fullpath = funct.get_config_var('main', 'fullpath') - sshdel = form.getvalue('sshdel') + fullpath = funct.get_config_var('main', 'fullpath') + sshdel = form.getvalue('sshdel') - for sshs in sql.select_ssh(id=sshdel): - ssh_enable = sshs[2] - name = sshs[1] - ssh_key_name = fullpath+'/keys/%s.pem' % sshs[1] - - if ssh_enable == 1: - cmd = 'rm -f %s' % ssh_key_name - try: - funct.subprocess_execute(cmd) - except: - pass - if sql.delete_ssh(sshdel): - print("Ok") - funct.logging(name, ' has deleted the SSH credentials ', haproxywi=1, login=1) + for sshs in sql.select_ssh(id=sshdel): + ssh_enable = sshs[2] + name = sshs[1] + ssh_key_name = fullpath + '/keys/%s.pem' % sshs[1] + if ssh_enable == 1: + cmd = 'rm -f %s' % ssh_key_name + try: + funct.subprocess_execute(cmd) + except: + pass + if sql.delete_ssh(sshdel): + print("Ok") + funct.logging(name, ' has deleted the SSH credentials ', haproxywi=1, login=1) if form.getvalue('updatessh'): - id = form.getvalue('id') - name = form.getvalue('name') - enable = form.getvalue('ssh_enable') - group = form.getvalue('group') - username = form.getvalue('ssh_user') - password = form.getvalue('ssh_pass') + id = form.getvalue('id') + name = form.getvalue('name') + enable = form.getvalue('ssh_enable') + group = form.getvalue('group') + username = form.getvalue('ssh_user') + password = form.getvalue('ssh_pass') - if username is None: - print(error_mess) - else: + if username is None: + print(error_mess) + else: - fullpath = funct.get_config_var('main', 'fullpath') + fullpath = funct.get_config_var('main', 'fullpath') - for sshs in sql.select_ssh(id=id): - ssh_enable = sshs[2] - ssh_key_name = fullpath+'/keys/%s.pem' % sshs[1] - new_ssh_key_name = fullpath+'/keys/%s.pem' % name - - if ssh_enable == 1: - cmd = 'mv %s %s' % (ssh_key_name, new_ssh_key_name) - cmd1 = 'chmod 600 %s' % new_ssh_key_name - try: - funct.subprocess_execute(cmd) - funct.subprocess_execute(cmd1) - except: - pass - sql.update_ssh(id, name, enable, group, username, password) - funct.logging('the SSH '+name, ' has updated credentials ', haproxywi=1, login=1) + for sshs in sql.select_ssh(id=id): + ssh_enable = sshs[2] + ssh_key_name = fullpath + '/keys/%s.pem' % sshs[1] + new_ssh_key_name = fullpath + '/keys/%s.pem' % name + if ssh_enable == 1: + cmd = 'mv %s %s' % (ssh_key_name, new_ssh_key_name) + cmd1 = 'chmod 600 %s' % new_ssh_key_name + try: + funct.subprocess_execute(cmd) + funct.subprocess_execute(cmd1) + except: + pass + sql.update_ssh(id, name, enable, group, username, password) + funct.logging('the SSH ' + name, ' has updated credentials ', haproxywi=1, login=1) if form.getvalue('ssh_cert'): - user_group = funct.get_user_group() - name = form.getvalue('name') - name = name + '_' + user_group + user_group = funct.get_user_group() + name = form.getvalue('name') + name = name + '_' + user_group - if not os.path.exists(os.getcwd()+'/keys/'): - os.makedirs(os.getcwd()+'/keys/') + if not os.path.exists(os.getcwd() + '/keys/'): + os.makedirs(os.getcwd() + '/keys/') - ssh_keys = os.path.dirname(os.getcwd())+'/keys/'+name+'.pem' + ssh_keys = os.path.dirname(os.getcwd()) + '/keys/' + name + '.pem' - try: - with open(ssh_keys, "w") as conf: - conf.write(form.getvalue('ssh_cert')) - except IOError: - print('error: Can\'t save ssh keys file. Check ssh keys path in config') - else: - print('success: Ssh key was save into: %s ' % ssh_keys) + try: + with open(ssh_keys, "w") as conf: + conf.write(form.getvalue('ssh_cert')) + except IOError: + print('error: Can\'t save ssh keys file. Check ssh keys path in config') + else: + print('success: Ssh key was save into: %s ' % ssh_keys) - try: - cmd = 'chmod 600 %s' % ssh_keys - funct.subprocess_execute(cmd) - except IOError as e: - funct.logging('localhost', e.args[0], haproxywi=1) - - funct.logging("localhost", " upload a new SSH cert %s" % ssh_keys, haproxywi=1, login=1) + try: + cmd = 'chmod 600 %s' % ssh_keys + funct.subprocess_execute(cmd) + except IOError as e: + funct.logging('localhost', e.args[0], haproxywi=1) + funct.logging("localhost", " upload a new SSH cert %s" % ssh_keys, haproxywi=1, login=1) if form.getvalue('newtelegram'): - token = form.getvalue('newtelegram') - channel = form.getvalue('chanel') - group = form.getvalue('telegramgroup') - page = form.getvalue('page') - page = page.split("#")[0] + token = form.getvalue('newtelegram') + channel = form.getvalue('chanel') + group = form.getvalue('telegramgroup') + page = form.getvalue('page') + page = page.split("#")[0] - if token is None or channel is None or group is None: - print(error_mess) - else: - if sql.insert_new_telegram(token, channel, group): - from jinja2 import Environment, FileSystemLoader - env = Environment(loader=FileSystemLoader('templates/ajax'), autoescape=True) - template = env.get_template('/new_telegram.html') - output_from_parsed_template = template.render(groups = sql.select_groups(), telegrams = sql.select_telegram(token=token),page=page) - print(output_from_parsed_template) - funct.logging(channel, ' has created a new Telegram channel ', haproxywi=1, login=1) + if token is None or channel is None or group is None: + print(error_mess) + else: + if sql.insert_new_telegram(token, channel, group): + from jinja2 import Environment, FileSystemLoader + env = Environment(loader=FileSystemLoader('templates/ajax'), autoescape=True) + template = env.get_template('/new_telegram.html') + output_from_parsed_template = template.render(groups=sql.select_groups(), + telegrams=sql.select_telegram(token=token), page=page) + print(output_from_parsed_template) + funct.logging(channel, ' has created a new Telegram channel ', haproxywi=1, login=1) if form.getvalue('telegramdel') is not None: - telegramdel = form.getvalue('telegramdel') - telegram = sql.select_telegram(id=telegramdel) - for t in telegram: - telegram_name = t[1] - if sql.delete_telegram(telegramdel): - print("Ok") - funct.logging(telegram_name, ' has deleted the Telegram channel ', haproxywi=1, login=1) - + telegramdel = form.getvalue('telegramdel') + telegram = sql.select_telegram(id=telegramdel) + for t in telegram: + telegram_name = t[1] + if sql.delete_telegram(telegramdel): + print("Ok") + funct.logging(telegram_name, ' has deleted the Telegram channel ', haproxywi=1, login=1) if form.getvalue('updatetoken') is not None: - token = form.getvalue('updatetoken') - channel = form.getvalue('updategchanel') - group = form.getvalue('updatetelegramgroup') - id = form.getvalue('id') - if token is None or channel is None or group is None: - print(error_mess) - else: - sql.update_telegram(token, channel, group, id) - funct.logging('group '+group, ' telegram token has updated channel: '+channel, haproxywi=1, login=1) - + token = form.getvalue('updatetoken') + channel = form.getvalue('updategchanel') + group = form.getvalue('updatetelegramgroup') + id = form.getvalue('id') + if token is None or channel is None or group is None: + print(error_mess) + else: + sql.update_telegram(token, channel, group, id) + funct.logging('group ' + group, ' telegram token has updated channel: ' + channel, haproxywi=1, login=1) if form.getvalue('updatesettings') is not None: - settings = form.getvalue('updatesettings') - val = form.getvalue('val') - if sql.update_setting(settings, val): - funct.logging('value '+val, ' changed settings '+settings, haproxywi=1, login=1) - print("Ok") - + settings = form.getvalue('updatesettings') + val = form.getvalue('val') + if sql.update_setting(settings, val): + funct.logging('value ' + val, ' changed settings ' + settings, haproxywi=1, login=1) + print("Ok") if form.getvalue('getusergroups'): - id = form.getvalue('getusergroups') - groups = [] - u_g = sql.select_user_groups(id=id) - for g in u_g: - groups.append(g[0]) - from jinja2 import Environment, FileSystemLoader - env = Environment(loader=FileSystemLoader('templates/ajax'), autoescape=True) - template = env.get_template('/show_user_groups.html') - template = template.render(groups=sql.select_groups(), user_groups=groups,id=id) - print(template) + id = form.getvalue('getusergroups') + groups = [] + u_g = sql.select_user_groups(id=id) + for g in u_g: + groups.append(g[0]) + from jinja2 import Environment, FileSystemLoader + env = Environment(loader=FileSystemLoader('templates/ajax'), autoescape=True) + template = env.get_template('/show_user_groups.html') + template = template.render(groups=sql.select_groups(), user_groups=groups, id=id) + print(template) if form.getvalue('changeUserGroupId') is not None: - id = form.getvalue('changeUserGroupId') - groups = form.getvalue('changeUserGroups') - user = form.getvalue('changeUserGroupsUser') - if sql.delete_user_groups(id): - for group in groups: - if group[0] == ',': - continue - sql.update_user_groups(groups=group[0], id=id) - - funct.logging('localhost', ' has upgraded groups for user: '+user, haproxywi=1, login=1) + id = form.getvalue('changeUserGroupId') + groups = form.getvalue('changeUserGroups') + user = form.getvalue('changeUserGroupsUser') + if sql.delete_user_groups(id): + for group in groups: + if group[0] == ',': + continue + sql.update_user_groups(groups=group[0], id=id) + funct.logging('localhost', ' has upgraded groups for user: ' + user, haproxywi=1, login=1) if form.getvalue('getcurrentusergroup') is not None: - import http.cookies - cookie = http.cookies.SimpleCookie(os.environ.get("HTTP_COOKIE")) - user_id = cookie.get('uuid') - group = cookie.get('group') - id = sql.get_user_id_by_uuid(user_id.value) - groups = sql.select_user_groups_with_names(id=id) + import http.cookies - from jinja2 import Environment, FileSystemLoader - env = Environment(loader=FileSystemLoader('templates/ajax'), autoescape=True) - template = env.get_template('/show_user_current_group.html') - template = template.render(groups=groups, group=group.value,id=id) - print(template) + cookie = http.cookies.SimpleCookie(os.environ.get("HTTP_COOKIE")) + user_id = cookie.get('uuid') + group = cookie.get('group') + id = sql.get_user_id_by_uuid(user_id.value) + groups = sql.select_user_groups_with_names(id=id) + from jinja2 import Environment, FileSystemLoader + + env = Environment(loader=FileSystemLoader('templates/ajax'), autoescape=True) + template = env.get_template('/show_user_current_group.html') + template = template.render(groups=groups, group=group.value, id=id) + print(template) if form.getvalue('newsmon') is not None: - user_group = funct.get_user_group(id=1) - server = form.getvalue('newsmon') - port = form.getvalue('newsmonport') - enable = form.getvalue('newsmonenable') - http = form.getvalue('newsmonproto') - uri = form.getvalue('newsmonuri') - body = form.getvalue('newsmonbody') - group = form.getvalue('newsmongroup') - desc = form.getvalue('newsmondescription') - telegram = form.getvalue('newsmontelegram') + user_group = funct.get_user_group(id=1) + server = form.getvalue('newsmon') + port = form.getvalue('newsmonport') + enable = form.getvalue('newsmonenable') + http = form.getvalue('newsmonproto') + uri = form.getvalue('newsmonuri') + body = form.getvalue('newsmonbody') + group = form.getvalue('newsmongroup') + desc = form.getvalue('newsmondescription') + telegram = form.getvalue('newsmontelegram') - try: - port = int(port) - except: - print('SMON error: port must number') - sys.exit() - if port > 65535 or port < 0: - print('SMON error: port must be 0-65535') - sys.exit() - if port == 80 and http == 'https': - print('SMON error: Cannot be HTTPS with 80 port') - sys.exit() - if port == 443 and http == 'http': - print('SMON error: Cannot be HTTP with 443 port') - sys.exit() + try: + port = int(port) + except: + print('SMON error: port must number') + sys.exit() + if port > 65535 or port < 0: + print('SMON error: port must be 0-65535') + sys.exit() + if port == 80 and http == 'https': + print('SMON error: Cannot be HTTPS with 80 port') + sys.exit() + if port == 443 and http == 'http': + print('SMON error: Cannot be HTTP with 443 port') + sys.exit() - if sql.insert_smon(server, port, enable, http, uri, body, group, desc, telegram, user_group): - from jinja2 import Environment, FileSystemLoader - env = Environment(loader=FileSystemLoader('templates'), autoescape=True) - template = env.get_template('ajax/show_new_smon.html') - template = template.render(smon=sql.select_smon(user_group,ip=server,port=port,proto=http,uri=uri,body=body), telegrams=sql.get_user_telegram_by_group(user_group)) - print(template) - funct.logging('SMON', ' Has been add a new server '+server+' to SMON ', haproxywi=1, login=1) + if sql.insert_smon(server, port, enable, http, uri, body, group, desc, telegram, user_group): + from jinja2 import Environment, FileSystemLoader + env = Environment(loader=FileSystemLoader('templates'), autoescape=True) + template = env.get_template('ajax/show_new_smon.html') + template = template.render( + smon=sql.select_smon(user_group, ip=server, port=port, proto=http, uri=uri, body=body), + telegrams=sql.get_user_telegram_by_group(user_group)) + print(template) + funct.logging('SMON', ' Has been add a new server ' + server + ' to SMON ', haproxywi=1, login=1) if form.getvalue('smondel') is not None: - user_group = funct.get_user_group(id=1) - id = form.getvalue('smondel') - - if funct.check_user_group(): - if sql.delete_smon(id, user_group): - print('Ok') - funct.logging('SMON', ' Has been delete server from SMON ', haproxywi=1, login=1) + user_group = funct.get_user_group(id=1) + id = form.getvalue('smondel') + if funct.check_user_group(): + if sql.delete_smon(id, user_group): + print('Ok') + funct.logging('SMON', ' Has been delete server from SMON ', haproxywi=1, login=1) if form.getvalue('showsmon') is not None: - user_group = funct.get_user_group(id=1) - sort = form.getvalue('sort') + user_group = funct.get_user_group(id=1) + sort = form.getvalue('sort') - from jinja2 import Environment, FileSystemLoader - env = Environment(loader=FileSystemLoader('templates'), autoescape=True) - template = env.get_template('ajax/smon_dashboard.html') - template = template.render(smon=sql.smon_list(user_group),sort=sort) - print(template) + from jinja2 import Environment, FileSystemLoader + env = Environment(loader=FileSystemLoader('templates'), autoescape=True) + template = env.get_template('ajax/smon_dashboard.html') + template = template.render(smon=sql.smon_list(user_group), sort=sort) + print(template) if form.getvalue('updateSmonIp') is not None: - id = form.getvalue('id') - ip = form.getvalue('updateSmonIp') - port = form.getvalue('updateSmonPort') - en = form.getvalue('updateSmonEn') - http = form.getvalue('updateSmonHttp') - body = form.getvalue('updateSmonBody') - telegram = form.getvalue('updateSmonTelegram') - group = form.getvalue('updateSmonGroup') - desc = form.getvalue('updateSmonDesc') + id = form.getvalue('id') + ip = form.getvalue('updateSmonIp') + port = form.getvalue('updateSmonPort') + en = form.getvalue('updateSmonEn') + http = form.getvalue('updateSmonHttp') + body = form.getvalue('updateSmonBody') + telegram = form.getvalue('updateSmonTelegram') + group = form.getvalue('updateSmonGroup') + desc = form.getvalue('updateSmonDesc') - try: - port = int(port) - except: - print('SMON error: port must number') - sys.exit() - if port > 65535 or port < 0: - print('SMON error: port must be 0-65535') - sys.exit() - if port == 80 and http == 'https': - print('SMON error: Cannot be https with 80 port') - sys.exit() - if port == 443 and http == 'http': - print('SMON error: Cannot be HTTP with 443 port') - sys.exit() - - if sql.update_smon(id, ip, port, body, telegram, group, desc, en): - print("Ok") - funct.logging('SMON', ' Has been update the server '+ip+' to SMON ', haproxywi=1, login=1) + try: + port = int(port) + except: + print('SMON error: port must number') + sys.exit() + if port > 65535 or port < 0: + print('SMON error: port must be 0-65535') + sys.exit() + if port == 80 and http == 'https': + print('SMON error: Cannot be https with 80 port') + sys.exit() + if port == 443 and http == 'http': + print('SMON error: Cannot be HTTP with 443 port') + sys.exit() + if sql.update_smon(id, ip, port, body, telegram, group, desc, en): + print("Ok") + funct.logging('SMON', ' Has been update the server ' + ip + ' to SMON ', haproxywi=1, login=1) if form.getvalue('showBytes') is not None: - serv = form.getvalue('showBytes') - port = sql.get_setting('haproxy_sock_port') - bin_bout = [] - cmd = "echo 'show stat' |nc "+serv+" "+port+" |cut -d ',' -f 1-2,9|grep -E '[0-9]'|awk -F',' '{sum+=$3;}END{print sum;}'" - bin, stderr = funct.subprocess_execute(cmd) - bin_bout.append(bin[0]) - cmd = "echo 'show stat' |nc "+serv+" "+port+" |cut -d ',' -f 1-2,10|grep -E '[0-9]'|awk -F',' '{sum+=$3;}END{print sum;}'" - bin, stderr = funct.subprocess_execute(cmd) - bin_bout.append(bin[0]) - cmd = "echo 'show stat' |nc "+serv+" "+port+" |cut -d ',' -f 1-2,5|grep -E '[0-9]'|awk -F',' '{sum+=$3;}END{print sum;}'" - bin, stderr = funct.subprocess_execute(cmd) - bin_bout.append(bin[0]) - cmd = "echo 'show stat' |nc "+serv+" "+port+" |cut -d ',' -f 1-2,8|grep -E '[0-9]'|awk -F',' '{sum+=$3;}END{print sum;}'" - bin, stderr = funct.subprocess_execute(cmd) - bin_bout.append(bin[0]) + serv = form.getvalue('showBytes') + port = sql.get_setting('haproxy_sock_port') + bin_bout = [] + cmd = "echo 'show stat' |nc " + serv + " " + port + " |cut -d ',' -f 1-2,9|grep -E '[0-9]'|awk -F',' '{sum+=$3;}END{print sum;}'" + bin, stderr = funct.subprocess_execute(cmd) + bin_bout.append(bin[0]) + cmd = "echo 'show stat' |nc " + serv + " " + port + " |cut -d ',' -f 1-2,10|grep -E '[0-9]'|awk -F',' '{sum+=$3;}END{print sum;}'" + bin, stderr = funct.subprocess_execute(cmd) + bin_bout.append(bin[0]) + cmd = "echo 'show stat' |nc " + serv + " " + port + " |cut -d ',' -f 1-2,5|grep -E '[0-9]'|awk -F',' '{sum+=$3;}END{print sum;}'" + bin, stderr = funct.subprocess_execute(cmd) + bin_bout.append(bin[0]) + cmd = "echo 'show stat' |nc " + serv + " " + port + " |cut -d ',' -f 1-2,8|grep -E '[0-9]'|awk -F',' '{sum+=$3;}END{print sum;}'" + bin, stderr = funct.subprocess_execute(cmd) + bin_bout.append(bin[0]) - from jinja2 import Environment, FileSystemLoader - env = Environment(loader=FileSystemLoader('templates'), autoescape=True) - template = env.get_template('ajax/bin_bout.html') - template = template.render(bin_bout=bin_bout,serv=serv) - print(template) + from jinja2 import Environment, FileSystemLoader + env = Environment(loader=FileSystemLoader('templates'), autoescape=True) + template = env.get_template('ajax/bin_bout.html') + template = template.render(bin_bout=bin_bout, serv=serv) + print(template) if form.getvalue('alert_consumer'): - try: - user_group = funct.get_user_group(id=1) - if funct.check_user_group(): - message = sql.select_alerts(user_group) - for m in message: - print(m[0]+ ': '+ m[1] +' date: '+m[2]+';') - except: - pass - + try: + user_group = funct.get_user_group(id=1) + if funct.check_user_group(): + message = sql.select_alerts(user_group) + for m in message: + print(m[0] + ': ' + m[1] + ' date: ' + m[2] + ';') + except: + pass if form.getvalue('waf_rule_id'): - enable = form.getvalue('waf_en') - rule_id = form.getvalue('waf_rule_id') - haproxy_path = sql.get_setting('haproxy_dir') - rule_file = sql.select_waf_rule_by_id(rule_id) - conf_file_path = haproxy_path + 'waf/modsecurity.conf' - rule_file_path = 'Include ' + haproxy_path + '/waf/rules/' + rule_file + enable = form.getvalue('waf_en') + rule_id = form.getvalue('waf_rule_id') + haproxy_path = sql.get_setting('haproxy_dir') + rule_file = sql.select_waf_rule_by_id(rule_id) + conf_file_path = haproxy_path + 'waf/modsecurity.conf' + rule_file_path = 'Include ' + haproxy_path + '/waf/rules/' + rule_file - if enable == '0': - cmd = ["sudo sed -i 's!"+rule_file_path+"!#"+rule_file_path+"!' "+conf_file_path] - en_for_log = 'disable' - else: - cmd = ["sudo sed -i 's!#"+rule_file_path+"!"+rule_file_path+"!' "+conf_file_path] - en_for_log = 'enable' + if enable == '0': + cmd = ["sudo sed -i 's!" + rule_file_path + "!#" + rule_file_path + "!' " + conf_file_path] + en_for_log = 'disable' + else: + cmd = ["sudo sed -i 's!#" + rule_file_path + "!" + rule_file_path + "!' " + conf_file_path] + en_for_log = 'enable' - try: - funct.logging('WAF', ' Has been '+en_for_log+' WAF rule: '+rule_file+' for the server '+serv, haproxywi=1, login=1) - except: - pass - - print(funct.ssh_command(serv, cmd)) - sql.update_enable_waf_rules(rule_id, serv, enable) + try: + funct.logging('WAF', ' Has been ' + en_for_log + ' WAF rule: ' + rule_file + ' for the server ' + serv, + haproxywi=1, login=1) + except: + pass + print(funct.ssh_command(serv, cmd)) + sql.update_enable_waf_rules(rule_id, serv, enable) if form.getvalue('lets_domain'): - serv = form.getvalue('serv') - lets_domain = form.getvalue('lets_domain') - lets_email = form.getvalue('lets_email') - proxy = sql.get_setting('proxy') - ssl_path = sql.get_setting('cert_path') - script = "letsencrypt.sh" - ssh_enable, ssh_user_name, ssh_user_password, ssh_key_name = funct.return_ssh_keys_path(serv) + serv = form.getvalue('serv') + lets_domain = form.getvalue('lets_domain') + lets_email = form.getvalue('lets_email') + proxy = sql.get_setting('proxy') + ssl_path = sql.get_setting('cert_path') + script = "letsencrypt.sh" + ssh_enable, ssh_user_name, ssh_user_password, ssh_key_name = funct.return_ssh_keys_path(serv) - if ssh_enable == 0: - ssh_key_name = '' + if ssh_enable == 0: + ssh_key_name = '' - servers = sql.select_servers(server=serv) - for server in servers: - ssh_port = str(server[10]) + servers = sql.select_servers(server=serv) + for server in servers: + ssh_port = str(server[10]) - os.system("cp scripts/%s ." % script) + os.system("cp scripts/%s ." % script) - if proxy is not None and proxy != '' and proxy != 'None': - proxy_serv = proxy - else: - proxy_serv = '' + if proxy is not None and proxy != '' and proxy != 'None': + proxy_serv = proxy + else: + proxy_serv = '' - commands = ["chmod +x "+script +" && ./"+script +" PROXY=" + proxy_serv+ - " DOMAIN="+lets_domain+" EMAIL="+lets_email+" SSH_PORT="+ssh_port+" SSL_PATH="+ssl_path+ - " HOST="+serv+" USER="+ssh_user_name+" PASS="+ssh_user_password+" KEY="+ssh_key_name] + commands = ["chmod +x " + script + " && ./" + script + " PROXY=" + proxy_serv + + " DOMAIN=" + lets_domain + " EMAIL=" + lets_email + " SSH_PORT=" + ssh_port + " SSL_PATH=" + ssl_path + + " HOST=" + serv + " USER=" + ssh_user_name + " PASS=" + ssh_user_password + " KEY=" + ssh_key_name] - output, error = funct.subprocess_execute(commands[0]) + output, error = funct.subprocess_execute(commands[0]) - if error: - funct.logging('localhost', error, haproxywi=1) - print(error) - else: - for l in output: - if "msg" in l or "FAILED" in l: - try: - l = l.split(':')[1] - l = l.split('"')[1] - print(l+"
") - break - except: - print(output) - break - else: - print('success: Certificate has been created') + if error: + funct.logging('localhost', error, haproxywi=1) + print(error) + else: + for l in output: + if "msg" in l or "FAILED" in l: + try: + l = l.split(':')[1] + l = l.split('"')[1] + print(l + "
") + break + except: + print(output) + break + else: + print('success: Certificate has been created') - os.system("rm -f %s" % script) \ No newline at end of file + os.system("rm -f %s" % script) diff --git a/app/templates/hapservers.html b/app/templates/hapservers.html index 58766408..4448865d 100644 --- a/app/templates/hapservers.html +++ b/app/templates/hapservers.html @@ -47,6 +47,17 @@ } } }); + {% for s in services %} + {% if s.1 == '* is not installed' %} + {% if s.0 == 'checker_haproxy' %} + $(':regex(id, alert)').checkboxradio('disable'); + {% elif s.0 == 'keep_alive' %} + $(':regex(id, active-)').checkboxradio('disable'); + {% elif s.0 == 'metrics_haproxy' %} + $(':regex(id, metrics-)').checkboxradio('disable'); + {% endif %} + {% endif %} + {% endfor %} }); {% if serv %} @@ -77,7 +88,7 @@ {% endif %}
-
+
{% if service == 'nginx' %}
@@ -165,19 +176,19 @@
{% if role <= 2 %}
{% set id = 'alert-' + s.8.0.0|string() %}
{% if s.8.0.8 == 1 %}
- {{ checkbox(id, title='Enable alerting', value='1', desc='Alert', checked='checked') }}
+ {{ checkbox(id, title='Alerting is enabled', value='1', desc='Alert', checked='checked') }}
{% else %}
{{ checkbox(id, title='Enable alerting', value='1', desc='Alert') }}
{% endif %}
{% set id = 'metrics-' + s.8.0.0|string() %}
{% if s.8.0.9 == 1 %}
- {{ checkbox(id, title='Enable collect metrics', value='1', desc='Metrics', checked='checked') }}
+ {{ checkbox(id, title='Collecting metrics is enabled', value='1', desc='Metrics', checked='checked') }}
{% else %}
{{ checkbox(id, title='Enable collect metrics', value='1', desc='Metrics') }}
{% endif %}
{% set id = 'active-' + s.8.0.0|string() %}
{% if s.8.0.12 == 1 %}
- {{ checkbox(id, title='Enable Compression', value='1', desc='Auto Start', checked='checked') }}
+ {{ checkbox(id, title='Auto Start is enabled', value='1', desc='Auto Start', checked='checked') }}
{% else %}
{{ checkbox(id, title='Enable Auto Start', value='1', desc='Auto Start') }}
{% endif %}
diff --git a/app/templates/include/admin_telegram.html b/app/templates/include/admin_telegram.html
index 834d6ac5..5b19eb77 100644
--- a/app/templates/include/admin_telegram.html
+++ b/app/templates/include/admin_telegram.html
@@ -1,3 +1,6 @@
+{% for s in services %}
+{% if s.0 == 'checker_haproxy' %}
+{% if s.3 != '* is not installed' %}
|
@@ -48,4 +51,14 @@
You can read the description of all parameters here
-
\ No newline at end of file
+
+{% else %}
+ Welcome and let's get started!+ You do not have installed Backends checker. + Read hear + how to install it + |