summaryrefslogtreecommitdiff
path: root/wsgi_server.py
diff options
context:
space:
mode:
Diffstat (limited to 'wsgi_server.py')
-rw-r--r--wsgi_server.py252
1 files changed, 0 insertions, 252 deletions
diff --git a/wsgi_server.py b/wsgi_server.py
deleted file mode 100644
index f754b14..0000000
--- a/wsgi_server.py
+++ /dev/null
@@ -1,252 +0,0 @@
-#!/usr/bin/python3
-# coding=utf-8
-
-# TODO: this module is deprecated, remove it
-# TODO: all new development should occur in server/handlers.py instead
-
-import falcon
-import json
-import client
-from errors.session import NoSuchSession, AuthenticationFailed
-
-MAX_REQUEST_LENGTH = 1024 * 1024 # 1 MB
-
-api = application = falcon.API()
-
-
-def get_json_payload(req, session_is_optional=False):
- content_type_parts = req.content_type.split(';')
- content_type = content_type_parts[0].strip()
- encoding = 'utf-8'
- if len(content_type_parts) > 1:
- for part in content_type_parts[1:]:
- subparts = part.strip().split('=')
- if (len(subparts) == 2) and subparts[0] == 'charset':
- encoding = subparts[1]
- if not ((content_type == 'application/json') or (content_type == 'text/json')):
- raise falcon.HTTPUnsupportedMediaType('Unsupported content-type: {0}'.format(req.content_type))
- length = req.get_header('Content-Length')
- if length is None:
- raise falcon.HTTPLengthRequired('Requests without content-length are not accepted')
- try:
- l = int(length)
- except:
- raise falcon.HTTPBadRequest('Invalid Content-Length', 'The given Content-Length is not a number: {0}'.format(length))
- if l > MAX_REQUEST_LENGTH:
- raise falcon.HTTPError(falcon.HTTP_413, 'Request Entity Too Large', 'Cannot accept the request of length {0}: maximum allowed content-length is {1}'.format(length, MAX_REQUEST_LENGTH))
- try:
- txt = req.stream.read()
- except Exception as e:
- raise falcon.HTTPBadRequest('Error reading request', 'Error while reading the request body: {0}'.format(e.message))
- try:
- js = json.loads(txt.decode(encoding=encoding, errors='replace'))
- except ValueError as e:
- raise falcon.HTTPBadRequest('Error parsing JSON payload', 'Error while parsing the request as JSON: {0}'.format(e.message))
- sid = js.get('sid')
- if sid is None:
- if session_is_optional:
- return js, None
- raise falcon.HTTPBadRequest('No Session', 'Request is missing a session-ID')
- del js['sid']
- try:
- session = client.get_session_by_id(sid)
- except NoSuchSession:
- if session_is_optional:
- return js, None
- raise falcon.HTTPBadRequest('Session Expired', 'This user session has expired. Please log-in again.')
- return js, session
-
-
-class CodeqService(object):
- """Base class for all CodeQ services.
- It only support the POST method and JSON data.
- Handles JSON decoding and encoding, and session retrieval which can be optional.
- """
- session_is_optional = False
-
- def on_post(self, req, resp):
- js, session = get_json_payload(req, self.session_is_optional)
- resp.body = json.dumps(self.process(js, session))
- resp.cache_control = 'private, no-cache, no-store'
- resp.content_type = 'application/json'
- resp.status = falcon.HTTP_200
-
- def process(self, js, session):
- raise falcon.HTTPNotFound()
-
-class ProblemList(CodeqService):
- session_is_optional = True
-
- def process(self, js, session):
- return {'code': 0, 'message': 'ok', 'problems': client.list_problems()}
-
-class Login(CodeqService):
- session_is_optional = True
-
- def process(self, js, old_session):
- username = js.get('username')
- password = js.get('password')
- if username is None:
- return {'code': 1, 'message': 'Username was not provided'}
- elif password is None:
- return {'code': 2, 'message': 'Password was not provided'}
- else:
- try:
- session = client.authenticate_and_create_session(username, password)
- except AuthenticationFailed:
- return {'code': 3, 'message': 'Username or password do not match'}
- else:
- if old_session:
- old_session.destroy()
- return {'code': 0, 'message': 'OK', 'sid':session.get_sid()}
-
-class Activity(CodeqService):
- def process(self, js, session):
- trace = js.get('trace')
- solution = js.get('solution')
- problem_id = js.get('problem_id')
- if (trace is not None) or (solution is not None):
- # we have something to do
- if problem_id is None:
- return {'code': 1, 'message': 'Problem ID is missing'}
- else:
- session.update_solution(problem_id, trace, solution)
-
-class Query(CodeqService):
- def process(self, js, session):
- step = js.get('step')
- if step is None:
- return {'code': 1, 'message': '"step" is not set'}
- else:
- problem_id = js.get('problem_id')
- if problem_id is None:
- return {'code': 4, 'message': 'Problem ID not given'}
- trace = js.get('trace')
- prolog = session.get_prolog()
- program = None
- if step == 'run':
- program = js.get('program')
- query = js.get('query')
- if program is None:
- result = {'code': 2, 'message': 'No program specified'}
- elif query is None:
- result = {'code': 3, 'message': 'No query specified'}
- else:
- messages, status, have_more = prolog.run_for_user(session.get_uid(), problem_id, program, query)
- result = {'code': 0, 'message': 'ok', 'terminal': {'messages': messages, 'status': status, 'have_more': have_more}}
- elif step == 'next':
- messages, status, have_more = prolog.step()
- result = {'code': 0, 'message': 'ok', 'terminal': {'messages': messages, 'status': status, 'have_more': have_more}}
- elif step == 'end':
- messages, status, have_more = prolog.end()
- result = {'code': 0, 'message': 'ok', 'terminal': {'messages': messages, 'status': status, 'have_more': have_more}}
- else:
- result = {'code': 5, 'message': 'Unknown prolog step: {0}'.format(step)}
- if program or trace:
- session.update_solution(problem_id, trace, program)
- return result
-
-# Pull stdout/stderr from the session's Python interpreter.
-class PythonPull(CodeqService):
- def process(self, js, session):
- python = session.get_python()
- output = python.pull()
- return {'code': 0, 'message': 'ok', 'terminal': {'text': output if output else ''}}
-
-# Push stdin to the session's Python interpreter.
-class PythonPush(CodeqService):
- def process(self, js, session):
- text = js.get('text')
- if text is None:
- return {'code': 1, 'message': 'No input specified'}
-
- python = session.get_python()
- python.push(text)
- return {'code': 0, 'message': 'ok'}
-
-class Hint(CodeqService):
- def process(self, js, session):
- language = js.get('language')
- problem_id = js.get('problem_id')
- program = js.get('program')
-
- if problem_id is None:
- return {'code': 1, 'message': 'No problem ID specified'}
- if program is None:
- return {'code': 2, 'message': 'No program specified'}
-
- if language == 'prolog':
- lang_session = session.get_prolog()
- elif language == 'python':
- lang_session = session.get_python()
- else:
- return {'code': 3, 'message': 'Unknown language specified'}
-
- hints = lang_session.hint(session.get_sid(), problem_id, program)
- return {'code': 0, 'message': 'ok', 'hints': hints}
-
-class Test(CodeqService):
- def process(self, js, session):
- language = js.get('language')
- problem_id = js.get('problem_id')
- program = js.get('program')
-
- if problem_id is None:
- return {'code': 1, 'message': 'No problem ID specified'}
- if program is None:
- return {'code': 2, 'message': 'No program specified'}
-
- if language == 'prolog':
- lang_session = session.get_prolog()
- elif language == 'python':
- lang_session = session.get_python()
- else:
- return {'code': 3, 'message': 'Unknown language specified'}
-
- hints = lang_session.test(session.get_sid(), problem_id, program)
- return {'code': 0, 'message': 'ok', 'hints': hints}
-
-class GetProblem(CodeqService):
- def process(self, js, session):
- language = js.get('language')
- problem_group = js.get('problem_group')
- problem = js.get('problem')
- if language is None:
- return {'code': 1, 'message': 'Language identifier not given'}
- elif problem_group is None:
- return {'code': 2, 'message': 'Problem group identifier not given'}
- elif problem is None:
- return {'code': 3, 'message': 'Problem identifier not given'}
- else:
- return {'code': 0, 'message': 'ok', 'data': session.get_problem_data(language, problem_group, problem)}
-
-problem_list = ProblemList()
-api.add_route('/list_problems', problem_list)
-
-login = Login()
-api.add_route('/login', login)
-
-activity = Activity()
-api.add_route('/activity', activity)
-
-query = Query()
-api.add_route('/query', query)
-
-api.add_route('/python_pull', PythonPull())
-api.add_route('/python_push', PythonPush())
-
-hint = Hint()
-api.add_route('/hint', hint)
-
-test = Test()
-api.add_route('/test', test)
-
-get_problem = GetProblem()
-api.add_route('/get_problem', get_problem)
-
-if __name__ == '__main__':
- import logging
- from waitress import serve
- logger = logging.getLogger('waitress')
- logger.setLevel(logging.DEBUG)
- serve(application, host='0.0.0.0', port=8082)
generated by cgit v1.2.1 (git 2.18.0) at 2024-06-02 01:12:06 +0000