aiohttp_rpc.middlewares.exception_middleware() - Code Metrics - Inspection of "Update README" - expert-m/aiohttp-rpc - Measure and Improve Code Quality continuously with Scrutinizer

Passed

Push — master ( 55adfd...84b7e9 )

by Michael

created 2020-05-29 13:25 UTC

aiohttp_rpc.middlewares.exception_middleware() A

↳ Parent: aiohttp_rpc.middlewares

Complexity

Conditions

Size

Total Lines	19
Code Lines	16

Duplication

Lines	0
Ratio	0 %

Importance

Changes

Metric	Value
eloc	16
dl	0
loc	19
rs	9.6
c	0
b	0
f	0
cc	3
nop	2

import logging
import typing

from . import errors, protocol


__all__ = (
    'exception_middleware',
    'extra_args_middleware',
    'DEFAULT_MIDDLEWARES',
)

logger = logging.getLogger(__name__)


async def extra_args_middleware(request: protocol.JsonRpcRequest, handler: typing.Callable) -> protocol.JsonRpcResponse:
    request.extra_args['rpc_request'] = request
    return await handler(request)


async def exception_middleware(request: protocol.JsonRpcRequest, handler: typing.Callable) -> protocol.JsonRpcResponse:
    try:
        response = await handler(request)
    except errors.JsonRpcError as e:
        logging.warning('Unprocessed errors.JsonRpcError', exc_info=True)
        response = protocol.JsonRpcResponse(
            msg_id=request.msg_id,
            jsonrpc=request.jsonrpc,
            error=e,
        )
    except Exception as e:
        logger.exception(e)
        response = protocol.JsonRpcResponse(
            msg_id=request.msg_id,
            jsonrpc=request.jsonrpc,
            error=errors.InternalError().with_traceback(),
        )

    return response


DEFAULT_MIDDLEWARES = (
    exception_middleware,
    extra_args_middleware,
)


1			import logging
2			import typing
3
4			from . import errors, protocol
5
6
7			__all__ = (
8			'exception_middleware',
9			'extra_args_middleware',
10			'DEFAULT_MIDDLEWARES',
11			)
12
13			logger = logging.getLogger(__name__)
14
15
16			async def extra_args_middleware(request: protocol.JsonRpcRequest, handler: typing.Callable) -> protocol.JsonRpcResponse:
17			request.extra_args['rpc_request'] = request
18			return await handler(request)
19
20
21			async def exception_middleware(request: protocol.JsonRpcRequest, handler: typing.Callable) -> protocol.JsonRpcResponse:
22			try:
23			response = await handler(request)
24			except errors.JsonRpcError as e:
25			logging.warning('Unprocessed errors.JsonRpcError', exc_info=True)
26			response = protocol.JsonRpcResponse(
27			msg_id=request.msg_id,
28			jsonrpc=request.jsonrpc,
29			error=e,
30			)
31			except Exception as e:
32			logger.exception(e)
33			response = protocol.JsonRpcResponse(
34			msg_id=request.msg_id,
35			jsonrpc=request.jsonrpc,
36			error=errors.InternalError().with_traceback(),
37			)
38
39			return response
40
41
42			DEFAULT_MIDDLEWARES = (
43			exception_middleware,
44			extra_args_middleware,
45			)
46

expert-m / aiohttp-rpc

Push — master ( 55adfd...84b7e9 )

aiohttp_rpc.middlewares.exception_middleware() A

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like