115 lines
4.5 KiB
Python
115 lines
4.5 KiB
Python
#!/usr/bin/python3
|
|
|
|
from flask import Flask, render_template, current_app, request
|
|
|
|
from Docker import Docker
|
|
from Config import Config
|
|
import utils
|
|
import os, json, re, copy, traceback
|
|
|
|
app = Flask(__name__, static_url_path="/", static_folder="static", template_folder="templates")
|
|
ABSOLUTE_URI = ""
|
|
if "ABSOLUTE_URI" in os.environ :
|
|
ABSOLUTE_URI = os.environ["ABSOLUTE_URI"]
|
|
DOCKER_HOST = "unix:///var/run/docker.sock"
|
|
if "DOCKER_HOST" in os.environ :
|
|
DOCKER_HOST = os.environ["DOCKER_HOST"]
|
|
app.config["ABSOLUTE_URI"] = ABSOLUTE_URI
|
|
app.config["DOCKER"] = Docker(DOCKER_HOST)
|
|
app.config["CONFIG"] = Config()
|
|
app.jinja_env.globals.update(env_to_summary_class=utils.env_to_summary_class)
|
|
app.jinja_env.globals.update(form_service_gen=utils.form_service_gen)
|
|
app.jinja_env.globals.update(form_service_gen_multiple=utils.form_service_gen_multiple)
|
|
app.jinja_env.globals.update(form_service_gen_multiple_values=utils.form_service_gen_multiple_values)
|
|
|
|
@app.route('/')
|
|
@app.route('/home')
|
|
def home() :
|
|
try :
|
|
instances_number = len(app.config["DOCKER"].get_instances())
|
|
services_number = len(app.config["CONFIG"].get_services())
|
|
return render_template("home.html", title="Home", instances_number=instances_number, services_number=services_number)
|
|
except Exception as e :
|
|
return render_template("error.html", title="Error", error=e)
|
|
|
|
@app.route('/instances', methods=["GET", "POST"])
|
|
def instances() :
|
|
try :
|
|
# Manage instances
|
|
operation = ""
|
|
if request.method == "POST" :
|
|
|
|
# Check operation
|
|
if not "operation" in request.form or not request.form["operation"] in ["reload", "start", "stop", "restart", "delete"] :
|
|
raise Exception("Missing operation parameter on /instances.")
|
|
|
|
# Check that all fields are present
|
|
if not "INSTANCE_ID" in request.form :
|
|
raise Exception("Missing INSTANCE_ID parameter.")
|
|
|
|
# Do the operation
|
|
if request.form["operation"] == "reload" :
|
|
operation = app.config["DOCKER"].reload_instance(request.form["INSTANCE_ID"])
|
|
elif request.form["operation"] == "start" :
|
|
operation = app.config["DOCKER"].start_instance(request.form["INSTANCE_ID"])
|
|
elif request.form["operation"] == "stop" :
|
|
operation = app.config["DOCKER"].stop_instance(request.form["INSTANCE_ID"])
|
|
elif request.form["operation"] == "restart" :
|
|
operation = app.config["DOCKER"].restart_instance(request.form["INSTANCE_ID"])
|
|
elif request.form["operation"] == "delete" :
|
|
operation = app.config["DOCKER"].delete_instance(request.form["INSTANCE_ID"])
|
|
|
|
# Display instances
|
|
instances = app.config["DOCKER"].get_instances()
|
|
return render_template("instances.html", title="Instances", instances=instances, operation=operation)
|
|
|
|
except Exception as e :
|
|
return render_template("error.html", title="Error", error=str(e))
|
|
|
|
|
|
@app.route('/services', methods=["GET", "POST"])
|
|
def services():
|
|
try :
|
|
# Manage services
|
|
operation = ""
|
|
if request.method == "POST" :
|
|
|
|
# Check operation
|
|
if not "operation" in request.form or not request.form["operation"] in ["new", "edit", "delete"] :
|
|
raise Exception("Missing operation parameter on /services.")
|
|
|
|
# Check variables
|
|
variables = copy.deepcopy(request.form.to_dict())
|
|
if not "OLD_SERVER_NAME" in request.form and request.form["operation"] == "edit" :
|
|
raise Exception("Missing OLD_SERVER_NAME parameter.")
|
|
if request.form["operation"] in ["new", "edit"] :
|
|
del variables["operation"]
|
|
if request.form["operation"] == "edit" :
|
|
del variables["OLD_SERVER_NAME"]
|
|
app.config["CONFIG"].check_variables(variables)
|
|
|
|
# Delete
|
|
elif request.form["operation"] == "delete" :
|
|
if not "SERVER_NAME" in request.form :
|
|
raise Exception("Missing SERVER_NAME parameter.")
|
|
app.config["CONFIG"].check_variables({"SERVER_NAME" : request.form["SERVER_NAME"]})
|
|
|
|
# Do the operation
|
|
if request.form["operation"] == "new" :
|
|
operation = app.config["CONFIG"].new_service(variables)
|
|
elif request.form["operation"] == "edit" :
|
|
operation = app.config["CONFIG"].edit_service(request.form["OLD_SERVER_NAME"], variables)
|
|
elif request.form["operation"] == "delete" :
|
|
operation = app.config["CONFIG"].delete_service(request.form["SERVER_NAME"])
|
|
|
|
# Reload containers
|
|
for instance in app.config["DOCKER"].get_instances() :
|
|
app.config["DOCKER"].reload_instance(instance.id)
|
|
|
|
# Display services
|
|
services = app.config["CONFIG"].get_services()
|
|
return render_template("services.html", title="Services", services=services, operation=operation)
|
|
|
|
except Exception as e :
|
|
return render_template("error.html", title="Error", error=str(e) + traceback.format_exc())
|