Refactor wiring to reduce complexity

This commit is contained in:
Roman Mogylatov 2020-10-30 16:47:26 -04:00
parent c5f799a1ec
commit 63977a73b2

View File

@ -273,6 +273,39 @@ def _is_method(member):
def _patch_with_injections(fn, injections, closing):
if inspect.iscoroutinefunction(fn):
_patched = _get_async_patched(fn, injections, closing)
else:
_patched = _get_patched(fn, injections, closing)
_patched.__wired__ = True
_patched.__original__ = fn
_patched.__injections__ = injections
_patched.__closing__ = closing
return _patched
def _get_patched(fn, injections, closing):
def _patched(*args, **kwargs):
to_inject = kwargs.copy()
for injection, provider in injections.items():
if injection not in kwargs:
to_inject[injection] = provider()
result = fn(*args, **to_inject)
for injection, provider in closing.items():
if injection in kwargs:
continue
if not isinstance(provider, providers.Resource):
continue
provider.shutdown()
return result
return _patched
def _get_async_patched(fn, injections, closing):
@functools.wraps(fn)
async def _patched(*args, **kwargs):
to_inject = kwargs.copy()
@ -290,30 +323,6 @@ def _patch_with_injections(fn, injections, closing):
provider.shutdown()
return result
else:
@functools.wraps(fn)
def _patched(*args, **kwargs):
to_inject = kwargs.copy()
for injection, provider in injections.items():
if injection not in kwargs:
to_inject[injection] = provider()
result = fn(*args, **to_inject)
for injection, provider in closing.items():
if injection in kwargs:
continue
if not isinstance(provider, providers.Resource):
continue
provider.shutdown()
return result
_patched.__wired__ = True
_patched.__original__ = fn
_patched.__injections__ = injections
_patched.__closing__ = closing
return _patched