add some def to main
parent
293267e70c
commit
1ad2fc8c9a
43
main.py
43
main.py
|
|
@ -1,6 +1,39 @@
|
|||
## Services Abfrage am API Server mit IP-Adresse
|
||||
import update_check
|
||||
import os
|
||||
import platform
|
||||
import subprocess
|
||||
import requests
|
||||
|
||||
## Ping 10sec
|
||||
## Service Abfrage aller 60sec
|
||||
## time = 10
|
||||
## for i in time
|
||||
api_server = "http://api.stines.de:8001/"
|
||||
api_key = ""
|
||||
headers = {"Content-Type":"application/json",
|
||||
"access_token":f"{api_key}"}
|
||||
|
||||
def restart_service():
|
||||
check_os = platform.system()
|
||||
if check_os == ("Linux"):
|
||||
os.popen("systemctl restart agents.services")
|
||||
print("Yes Man!")
|
||||
else:
|
||||
subprocess.run('sc', 'start', 'Agents')
|
||||
|
||||
def get_response(endpoint):
|
||||
respone = requests.get(f"{api_server}{endpoint}",headers=headers)
|
||||
return respone.text
|
||||
|
||||
def post_response(endpoint, data):
|
||||
respone = requests.post(f"{api_server}{endpoint}",headers=headers, json=data)
|
||||
return respone.text
|
||||
|
||||
|
||||
if update_check.check_version() == True:
|
||||
restart_service()
|
||||
post_response("update_checked",update_check.current_version)
|
||||
|
||||
|
||||
## run ping (10sec)
|
||||
## run controller(1m)
|
||||
## Check RAM
|
||||
## Check CPU
|
||||
## Check HDD
|
||||
## run service (60m)
|
||||
|
|
@ -25,7 +25,7 @@ if current_version != new_version:
|
|||
next
|
||||
if os.path.isdir(f"../{new_version}"):
|
||||
try:
|
||||
shutil.move("latest", f"../{current_version}")
|
||||
shutil.move("../latest", f"../{current_version}")
|
||||
except:
|
||||
print("folder not Found")
|
||||
shutil.move(f"../{new_version}", "../latest")
|
||||
|
|
|
|||
Loading…
Reference in New Issue