# Copyright 2016 Peter Dahlberg
#
# Licensed under the Apache License, Version 2.0 (the "License");
# you may not use this file except in compliance with the License.
# You may obtain a copy of the License at
#
# http://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing, software
# distributed under the License is distributed on an "AS IS" BASIS,
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
# See the License for the specific language governing permissions and
# limitations under the License.
from bottle import route, template, request, post, Bottle, HTTPError, auth_basic
from pprint import pformat
from itertools import islice
from functools import wraps
import logging
import sys
log = logging.getLogger(__name__)
app = Bottle()
def _auth_basic(fn):
@wraps(fn)
def wrapper(*args, **kwargs):
authfn = app.config.get("auth_basic_fn")
if authfn:
return auth_basic(authfn)(fn)(*args, **kwargs)
else:
return fn(*args, **kwargs)
return wrapper
def set_schedulers(**name_scheduler_mapping):
app.config["deploy.schedulers"] = name_scheduler_mapping
def set_runners(**name_runner_mapping):
app.config["deploy.runners"] = name_runner_mapping
def set_auth_basic_fn(fn):
app.config["auth_basic_fn"] = fn
def _get_runner(name):
try:
runners = app.config["deploy.runners"]
except KeyError as e:
sys.exit("you have to call set_runners first")
return runners[name]
@app.route('/')
def status():
tpl = """
Runners
% for r in runners:
<%
bs = r.build_status[-1] if r.build_status else None
%>
% if bs:
<%
date = bs.date.strftime("%Y-%m-%d %H:%M:%S %Z%z")
%>
{{r.name}}:
{{date}} - {{bs.msg}} - running: {{bs.running}} - ok: {{bs.ok}}
% else:
No job was ever running.
% end
Scheduled Jobs:
% for j in scheds[r.name].get_jobs():
{{j}}
% end
% end
"""
return template(tpl, runners=app.config["deploy.runners"].values(),
scheds=app.config["deploy.schedulers"])
@app.route('/')
@_auth_basic
def runnerstatus(name):
runner = _get_runner(name)
rerun = "rerun" in request.query
start = int(request.query.get("start", 0))
end = int(request.query.get("end", 50))
start = start if start >= 0 else 0
end = end if end >= 0 else 0
tpl = """
{{runner.name}} status events ({{start}} - {{end}}) --
(re)start build
% for bs in islice(reversed(bss),start,end):
<%
date = bs.date.strftime("%Y-%m-%d %H:%M:%S %Z%z")
%>