mirror of
https://github.com/krateng/maloja.git
synced 2023-08-10 21:12:55 +03:00
101 lines
2.6 KiB
Python
Executable File
101 lines
2.6 KiB
Python
Executable File
#!/usr/bin/env python
|
|
|
|
from bottle import route, get, post, run, template, static_file, request, response, FormsDict
|
|
from importlib.machinery import SourceFileLoader
|
|
import _thread
|
|
import waitress
|
|
import urllib.request
|
|
import urllib.parse
|
|
from urllib.error import *
|
|
import sys
|
|
import signal
|
|
|
|
|
|
MAIN_PORT = 42010
|
|
DATABASE_PORT = 42011
|
|
|
|
|
|
@route("")
|
|
@route("/")
|
|
def mainpage():
|
|
return static_file("main.html",root="")
|
|
|
|
|
|
|
|
# this is the fallback option. If you run this service behind a reverse proxy, it is recommended to rewrite /db/ requests to the port of the db server
|
|
# e.g. location /db { rewrite ^/db(.*)$ $1 break; proxy_pass http://yoururl:12349; }
|
|
|
|
@get("/db/<pth:path>")
|
|
def database_get(pth):
|
|
keys = FormsDict.decode(request.query) # The Dal★Shabet handler
|
|
keystring = "?"
|
|
for k in keys:
|
|
keystring += urllib.parse.quote(k) + "=" + urllib.parse.quote(keys[k]) + "&"
|
|
response.set_header("Access-Control-Allow-Origin","*")
|
|
try:
|
|
proxyresponse = urllib.request.urlopen("http://localhost:" + str(DATABASE_PORT) + "/" + pth + keystring)
|
|
contents = proxyresponse.read()
|
|
response.status = proxyresponse.getcode()
|
|
response.content_type = "application/json"
|
|
return contents
|
|
except HTTPError as e:
|
|
response.status = e.code
|
|
return
|
|
|
|
@post("/db/<pth:path>")
|
|
def database_post(pth):
|
|
response.set_header("Access-Control-Allow-Origin","*")
|
|
try:
|
|
proxyresponse = urllib.request.urlopen("http://localhost:" + str(DATABASE_PORT) + "/" + pth,request.body)
|
|
contents = proxyresponse.read()
|
|
response.status = proxyresponse.getcode()
|
|
response.content_type = "application/json"
|
|
return contents
|
|
except HTTPError as e:
|
|
response.status = e.code
|
|
return
|
|
|
|
|
|
|
|
return
|
|
|
|
@route("/exit")
|
|
def shutdown():
|
|
graceful_exit()
|
|
|
|
def graceful_exit(sig=None,frame=None):
|
|
urllib.request.urlopen("http://localhost:" + str(DATABASE_PORT) + "/sync")
|
|
print("Server shutting down...")
|
|
sys.exit()
|
|
|
|
|
|
@route("/<name:re:.*\\.html>")
|
|
@route("/<name:re:.*\\.js>")
|
|
@route("/<name:re:.*\\.css>")
|
|
@route("/<name:re:.*\\.png>")
|
|
@route("/<name:re:.*\\.jpeg>")
|
|
def static(name):
|
|
|
|
return static_file("website/" + name,root="")
|
|
|
|
@route("/<name>")
|
|
def static_html(name):
|
|
|
|
return static_file("website/" + name + ".html",root="")
|
|
|
|
#set graceful shutdown
|
|
signal.signal(signal.SIGINT, graceful_exit)
|
|
signal.signal(signal.SIGTERM, graceful_exit)
|
|
|
|
#rename process, not important
|
|
try:
|
|
import setproctitle
|
|
setproctitle.setproctitle("Maloja")
|
|
except:
|
|
pass
|
|
|
|
## start database server
|
|
_thread.start_new_thread(SourceFileLoader("database","database.py").load_module().runserver,(DATABASE_PORT,))
|
|
|
|
run(host='0.0.0.0', port=MAIN_PORT, server='waitress')
|