2015-09-25 17:59:38 +00:00
|
|
|
import flask
|
|
|
|
import rethinkstuff
|
2015-09-25 19:15:20 +00:00
|
|
|
import json
|
|
|
|
import logging
|
|
|
|
import sys
|
2015-09-25 17:59:38 +00:00
|
|
|
|
2015-09-25 19:15:20 +00:00
|
|
|
logging.basicConfig(stream=sys.stdout, level=logging.INFO,
|
|
|
|
format="%(asctime)s %(process)d %(levelname)s %(threadName)s %(name)s.%(funcName)s(%(filename)s:%(lineno)d) %(message)s")
|
|
|
|
|
|
|
|
app = flask.Flask(__name__, static_url_path="")
|
2015-09-25 17:59:38 +00:00
|
|
|
|
|
|
|
r = rethinkstuff.Rethinker(["wbgrp-svc020", "wbgrp-svc035", "wbgrp-svc036"],
|
|
|
|
db="archiveit_brozzler")
|
|
|
|
|
2015-09-25 22:19:29 +00:00
|
|
|
@app.route("/api/jobs/<int:job_id>/sites")
|
|
|
|
def sites(job_id):
|
|
|
|
sites_ = r.table("sites").get_all(job_id, index="job_id").run()
|
|
|
|
return flask.jsonify(sites=sites_)
|
|
|
|
|
|
|
|
@app.route("/api/jobs/<int:job_id>")
|
|
|
|
def job(job_id):
|
|
|
|
job_ = r.table("jobs").get(job_id).run()
|
|
|
|
return flask.jsonify(job_)
|
|
|
|
|
2015-09-25 19:15:20 +00:00
|
|
|
@app.route("/api/jobs")
|
2015-09-25 17:59:38 +00:00
|
|
|
def jobs():
|
2015-09-25 22:19:29 +00:00
|
|
|
jobs_ = list(r.table("jobs").run())
|
|
|
|
return flask.jsonify(jobs=jobs_)
|
2015-09-25 19:15:20 +00:00
|
|
|
|
|
|
|
@app.route("/")
|
|
|
|
def root():
|
|
|
|
return app.send_static_file("index.html")
|
|
|
|
|
2015-09-25 17:59:38 +00:00
|
|
|
if __name__ == "__main__":
|
|
|
|
app.run(host="0.0.0.0", port=8081, debug=True)
|
|
|
|
|