def api_method(request, method):
"""
Utility function to create a synchronous wrapper for the JSON-RPC API.
"""
def method_fn(*args, **kwargs):
fn = getattr(request.sdata.api, method)
res = threads.blockingCallFromThread(reactor, fn, *args, **kwargs)
try:
ret = res['result']
ret = m2mstr_object_hook(ret)
except KeyError:
ret = res['error']
return ret
return method_fn
评论列表
文章目录