watch.py

import sys
import logging
from logging import Formatter
import json
import http.client
import time

from apscheduler.schedulers.background import BackgroundScheduler
from flask import Flask
from flask import Response, request, send_from_directory, jsonify


logger = logging.getLogger(__name__)
logger.info("Stackdriver webhook-sample starting up on %s" % (str.replace(sys.version, '\n', ' ')))

app = Flask("arvo-healthcheck", static_url_path='')
global galaxy_statuses
galaxy_statuses = {}

global latestPing
latestPing = 0

global galaxies
# galaxies = [
#     'zod',
#     'bus',
#     'dev',
#     'fed',
#     'def',
#     'feb',
#     'fet',
#     'marzod',
#     'binzod',
#     'dopzod',
#     'samzod',
#     'wanzod'
# ]

galaxies = [
    'bus',
    'def',
    'dev',
    'feb',
    'fet',
    'lur',
    'nes',
    'nus',
    'pem',
    'pub',
    'rel',
    'rud',
    'sud',
    'ten',
    'zod',
    'marzod',
    'binzod',
    'samzod',
    'wanzod',
    'dopzod',
    'bitpyx-dildus',
    'bolbex-fogdys'
]


@app.route('/')
def root():
    return send_from_directory('dist', 'index.html')


@app.route('/js/<path:path>')
def send_js(path):
    return send_from_directory('dist/js', path)

@app.route('/css/<path:path>')
def send_css(path):
    return send_from_directory('dist/css', path)

@app.route('/galaxy-status')
def galaxy_status():
    statusAsArray=[]
    for ship, respCode in galaxy_statuses.items():
        statusAsArray.append({
            'ship': ship,
            'status': respCode,
        })
    return jsonify({
        'status': statusAsArray,
        'latestPing': latestPing,
    })


def healthcheck():
    global latestPing
    latestPing = int(time.time())

    for gal in galaxies:
        try:
            conn = http.client.HTTPConnection(gal + ".arvo.network")
            conn.request("GET", "/")
            galaxy_statuses[gal] = conn.getresponse().status
        except:
            galaxy_statuses[gal] = 500


if __name__ == '__main__':
    scheduler = BackgroundScheduler()
    scheduler.add_job(healthcheck, 'interval', seconds=60)
    scheduler.start()
    app.run()