Access framework HTTP Request from method about jsonrpcserver HOT 8 CLOSED

class MyView(web.View):
    @methods.add
    async def ping(self):
        aio_http_request = self.request
        statsd = self.request.app.config['statsd_client']
        # ...

    async def post(self):
        request = await self.request.text()
        response = await methods.dispatch(request)
        return web.json_response(response)

app.router.add_route('*', '/', MyView)

context = {'request': aio_http_request, 'statsd': statsd}
response = await methods.dispatch(jsonrpc_request, context=context)

@methods.add
async def ping(context):
    statsd = context['statsd']
    # ...

from aiohttp import web
from jsonrpcserver.aio import dispatch
from jsonrpcserver.response import NotificationResponse

class MyView(web.View):
    def __init__(self, *args, **kwargs):
        super().__init__(*args, **kwargs)
        self.methods = (self.ping,)

    async def ping(self):
        request = self.request
        # ...
        return 'pong'

    async def post(self):
        request = await self.request.text()
        response = await dispatch(self.methods, request)
        if isinstance(response, NotificationResponse):
            return web.Response()
        else:
            return web.json_response(response)

app = web.Application()
app.router.add_route('*', '/', MyView)

if __name__ == '__main__':
    web.run_app(app, port=5000)

async def rpc_handler(request):
    raw_request = await request.text()
    json_request = json.loads(raw_request)
    json_request.setdefault('params', {}).update({'request': request})

    response = await methods.dispatch(json_request)

    return web.json_response(response)

@methods.add
async def my_method(request):
    pass

@methods.add
async def my_method(context=None):
    # Use request here...
    pass

async def rpc_handler(request):
    raw_request = await request.text()
    response = await methods.dispatch(raw_request, context=request)
    if response.is_notification:
        return web.Response()
    else:
        return web.json_response(response)