1

import asyncio

     2

import qmsk.web.application

     3

import werkzeug

     4

import werkzeug.exceptions

     5

     6

class Handler (qmsk.web.application.Handler) :

     7

    @asyncio.coroutine

     8

    def process_async (self, **params) :

     9

        """

    10

            Process request asynchronously.

    11

    12

            May optionally return a Response, to e.g. redirect after POST.

    13

        """

    14

    15

        pass

    16

    17

    @asyncio.coroutine

    18

    def respond_async (self, **params):

    19

        response = yield from self.process_async(**params)

    20

    21

        if response :

    22

            return response

    23

    24

        return self.respond(**params)

    25

    26

class Application (qmsk.web.application.Application) :

    27

    @asyncio.coroutine

    28

    def __call__ (self, environ, start_response):

    29

        request = werkzeug.Request(environ)

    30

    31

        handler = None

    32

    33

        try:

    34

            handler, params = self.lookup(request)

    35

    36

            handler.init()

    37

    38

            response = yield from handler.respond_async(**params)

    39

    40

        except werkzeug.exceptions.HTTPException as error :

    41

            response = error

    42

    43

        finally:

    44

            if handler:

    45

                handler.cleanup()

    46

    47

        return response(environ, start_response)