mirror of https://github.com/Aidaho12/haproxy-wi
parent
9aaab60202
commit
c98011249c
21
app/funct.py
21
app/funct.py
|
@ -8,6 +8,10 @@ def is_ip_or_dns(server_from_request: str) -> str:
|
||||||
import re
|
import re
|
||||||
ip_regex = "^(([0-9]|[1-9][0-9]|1[0-9]{2}|2[0-4][0-9]|25[0-5])\.){3}([0-9]|[1-9][0-9]|1[0-9]{2}|2[0-4][0-9]|25[0-5])$"
|
ip_regex = "^(([0-9]|[1-9][0-9]|1[0-9]{2}|2[0-4][0-9]|25[0-5])\.){3}([0-9]|[1-9][0-9]|1[0-9]{2}|2[0-4][0-9]|25[0-5])$"
|
||||||
dns_regex = "^(?!-)[A-Za-z0-9-]+([\\-\\.]{1}[a-z0-9]+)*\\.[A-Za-z]{2,6}$"
|
dns_regex = "^(?!-)[A-Za-z0-9-]+([\\-\\.]{1}[a-z0-9]+)*\\.[A-Za-z]{2,6}$"
|
||||||
|
try:
|
||||||
|
server_from_request = server_from_request.strip()
|
||||||
|
except Exception:
|
||||||
|
pass
|
||||||
try:
|
try:
|
||||||
if server_from_request in (
|
if server_from_request in (
|
||||||
'roxy-wi-checker', 'roxy-wi-keep_alive', 'roxy-wi-keep-alive', 'roxy-wi-metrics',
|
'roxy-wi-checker', 'roxy-wi-keep_alive', 'roxy-wi-keep-alive', 'roxy-wi-metrics',
|
||||||
|
@ -209,11 +213,13 @@ def telegram_send_mess(mess, **kwargs):
|
||||||
token_bot = ''
|
token_bot = ''
|
||||||
channel_name = ''
|
channel_name = ''
|
||||||
|
|
||||||
|
if kwargs.get('telegram_channel_id') == 0:
|
||||||
|
return
|
||||||
|
|
||||||
if kwargs.get('telegram_channel_id'):
|
if kwargs.get('telegram_channel_id'):
|
||||||
telegrams = sql.get_telegram_by_id(kwargs.get('telegram_channel_id'))
|
telegrams = sql.get_telegram_by_id(kwargs.get('telegram_channel_id'))
|
||||||
else:
|
else:
|
||||||
telegrams = sql.get_telegram_by_ip(kwargs.get('ip'))
|
telegrams = sql.get_telegram_by_ip(kwargs.get('ip'))
|
||||||
slack_send_mess(mess, ip=kwargs.get('ip'))
|
|
||||||
|
|
||||||
proxy = sql.get_setting('proxy')
|
proxy = sql.get_setting('proxy')
|
||||||
|
|
||||||
|
@ -243,6 +249,9 @@ def slack_send_mess(mess, **kwargs):
|
||||||
slack_token = ''
|
slack_token = ''
|
||||||
channel_name = ''
|
channel_name = ''
|
||||||
|
|
||||||
|
if kwargs.get('slack_channel_id') == 0:
|
||||||
|
return
|
||||||
|
|
||||||
if kwargs.get('slack_channel_id'):
|
if kwargs.get('slack_channel_id'):
|
||||||
slacks = sql.get_slack_by_id(kwargs.get('slack_channel_id'))
|
slacks = sql.get_slack_by_id(kwargs.get('slack_channel_id'))
|
||||||
else:
|
else:
|
||||||
|
@ -827,7 +836,7 @@ def install_nginx(server_ip, **kwargs):
|
||||||
os.system("rm -f %s" % script)
|
os.system("rm -f %s" % script)
|
||||||
|
|
||||||
|
|
||||||
def update_haproxy_wi(service):
|
def update_roxy_wi(service):
|
||||||
import distro
|
import distro
|
||||||
restart_service = ''
|
restart_service = ''
|
||||||
|
|
||||||
|
@ -845,7 +854,7 @@ def update_haproxy_wi(service):
|
||||||
else:
|
else:
|
||||||
if service != 'roxy-wi':
|
if service != 'roxy-wi':
|
||||||
restart_service = ' && sudo systemctl restart ' + service
|
restart_service = ' && sudo systemctl restart ' + service
|
||||||
cmd = 'sudo -S yum -y update ' + service + restart_service
|
cmd = 'sudo -S yum -y install ' + service + restart_service
|
||||||
|
|
||||||
output, stderr = subprocess_execute(cmd)
|
output, stderr = subprocess_execute(cmd)
|
||||||
print(output)
|
print(output)
|
||||||
|
@ -1067,12 +1076,14 @@ def upload_and_restart(server_ip, cfg, **kwargs):
|
||||||
def master_slave_upload_and_restart(server_ip, cfg, just_save, **kwargs):
|
def master_slave_upload_and_restart(server_ip, cfg, just_save, **kwargs):
|
||||||
import sql
|
import sql
|
||||||
masters = sql.is_master(server_ip)
|
masters = sql.is_master(server_ip)
|
||||||
|
slave_error = ''
|
||||||
for master in masters:
|
for master in masters:
|
||||||
if master[0] is not None:
|
if master[0] is not None:
|
||||||
error = upload_and_restart(
|
slave_error = upload_and_restart(
|
||||||
master[0], cfg, just_save=just_save, nginx=kwargs.get('nginx'),
|
master[0], cfg, just_save=just_save, nginx=kwargs.get('nginx'),
|
||||||
apache=kwargs.get('apache'), config_file_name=kwargs.get('config_file_name'), slave=1
|
apache=kwargs.get('apache'), config_file_name=kwargs.get('config_file_name'), slave=1
|
||||||
)
|
)
|
||||||
|
slave_error = master[0] + ': ' + slave_error
|
||||||
|
|
||||||
if kwargs.get('login'):
|
if kwargs.get('login'):
|
||||||
login = kwargs.get('login')
|
login = kwargs.get('login')
|
||||||
|
@ -1082,7 +1093,9 @@ def master_slave_upload_and_restart(server_ip, cfg, just_save, **kwargs):
|
||||||
server_ip, cfg, just_save=just_save, nginx=kwargs.get('nginx'), apache=kwargs.get('apache'),
|
server_ip, cfg, just_save=just_save, nginx=kwargs.get('nginx'), apache=kwargs.get('apache'),
|
||||||
config_file_name=kwargs.get('config_file_name'), oldcfg=kwargs.get('oldcfg'), login=login
|
config_file_name=kwargs.get('config_file_name'), oldcfg=kwargs.get('oldcfg'), login=login
|
||||||
)
|
)
|
||||||
|
error = server_ip + ': ' + error
|
||||||
|
|
||||||
|
error = error + slave_error
|
||||||
return error
|
return error
|
||||||
|
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue