mirror of
https://github.com/OpenFusionProject/scripts.git
synced 2024-11-22 14:10:04 +00:00
Compare commits
2 Commits
f62f3af483
...
9deba1956f
Author | SHA1 | Date | |
---|---|---|---|
9deba1956f | |||
1a3a530c7f |
@ -1,20 +1,35 @@
|
|||||||
|
# This script serves an HTTP endpoint that provides the racing scores.
|
||||||
|
#
|
||||||
|
# Example invocation for testing:
|
||||||
|
# $ RANKENDPOINT_DBPATH=/path/to/database.db RANKENDPOINT_ROUTE=/getranks flask --app rankendpoint.py run
|
||||||
|
#
|
||||||
|
# Example invocation in production (behind a properly configured gateway like nginx):
|
||||||
|
# $ RANKENDPOINT_DBPATH=/path/to/database.db RANKENDPOINT_ROUTE=/getranks uwsgi \
|
||||||
|
# -s localhost:3031 --manage-script-name --mount /=rankendpoint:app --plugin python3
|
||||||
|
|
||||||
from flask import Flask, request
|
from flask import Flask, request
|
||||||
app = Flask(__name__)
|
app = Flask(__name__)
|
||||||
|
|
||||||
import sqlite3
|
import sqlite3
|
||||||
import sys
|
import sys
|
||||||
|
import os
|
||||||
|
|
||||||
header = "SUCCESS"
|
header = "SUCCESS"
|
||||||
|
|
||||||
def main(db_path):
|
db_path = os.environ.get('RANKENDPOINT_DBPATH')
|
||||||
# Opens database in read-only mode
|
route = os.environ.get('RANKENDPOINT_ROUTE')
|
||||||
# Checking same thread disabled for now, which is fine since we never modify anything
|
|
||||||
try:
|
if None in (db_path, route):
|
||||||
db = sqlite3.connect('file:{}?mode=ro'.format(db_path), uri=True, check_same_thread=False)
|
sys.exit('must set RANKENDPOINT_DBPATH and RANKENDPOINT_ROUTE environment variables')
|
||||||
cur = db.cursor()
|
|
||||||
except Exception as ex:
|
# Opens database in read-only mode
|
||||||
print(ex)
|
# Checking same thread disabled for now, which is fine since we never modify anything
|
||||||
sys.exit()
|
try:
|
||||||
|
db = sqlite3.connect('file:{}?mode=ro'.format(db_path), uri=True, check_same_thread=False)
|
||||||
|
cur = db.cursor()
|
||||||
|
except Exception as ex:
|
||||||
|
print(ex)
|
||||||
|
sys.exit()
|
||||||
|
|
||||||
#db.set_trace_callback(print)
|
#db.set_trace_callback(print)
|
||||||
|
|
||||||
@ -85,7 +100,8 @@ def get_score_entries(data, name):
|
|||||||
|
|
||||||
return scores
|
return scores
|
||||||
|
|
||||||
@app.route('/getranks', methods=['POST'])
|
# route should be something like /getranks
|
||||||
|
@app.route(f'{route}', methods=['POST'])
|
||||||
def rankings():
|
def rankings():
|
||||||
#print("PCUID:", request.form['PCUID'])
|
#print("PCUID:", request.form['PCUID'])
|
||||||
#print("EP_ID:", request.form['EP_ID'])
|
#print("EP_ID:", request.form['EP_ID'])
|
||||||
@ -128,9 +144,3 @@ def rankings():
|
|||||||
# and send it off!
|
# and send it off!
|
||||||
return header + xmlbody
|
return header + xmlbody
|
||||||
|
|
||||||
if __name__ == "__main__":
|
|
||||||
if len(sys.argv) < 2:
|
|
||||||
print("Usage: {} <db file>".format(sys.argv[0]))
|
|
||||||
else:
|
|
||||||
main(sys.argv[1])
|
|
||||||
|
|
||||||
|
Loading…
Reference in New Issue
Block a user