app.py

from database import db_session, init_db
from schema import schema

from graphql_server import (HttpQueryError, default_format_error,
                            encode_execution_results, json_encode,
                            load_json_body, run_http_query)


class App():
  def __init__(self):
    init_db()

  def query(self, request):
      data  = self.parse_body(request)
      execution_results, params = run_http_query(
              schema,
              'post',
              data)
      result, status_code = encode_execution_results(
              execution_results,
              format_error=default_format_error,is_batch=False, encode=json_encode)
      return result

  def parse_body(self,request):
      # We use mimetype here since we don't need the other
      # information provided by content_type
      content_type = request.mimetype
      if content_type == 'application/graphql':
          return {'query': request.data.decode('utf8')}

      elif content_type == 'application/json':
          return load_json_body(request.data.decode('utf8'))

      elif content_type in ('application/x-www-form-urlencoded', 'multipart/form-data'):
          return request.form

      return {}