Add func_utils and add new function/coroutine launcher in async_utils

Author: linuxdaemon

cloudbot/util/async_util.py

@@ -3,10 +3,11 @@
 """
 
 import asyncio
-
 import sys
 from functools import partial
 
+from cloudbot.util.func_utils import call_with_args
+
 
 def wrap_future(fut, *, loop=None):
     """
@@ -33,6 +34,19 @@ def run_func(loop, func, *args, **kwargs):
         return (yield from loop.run_in_executor(None, part))
 
 
+@asyncio.coroutine
+def run_func_with_args(loop, func, arg_data, executor=None):
+    if asyncio.iscoroutine(func):
+        raise TypeError('A coroutine function or a normal, non-async callable are required')
+
+    if asyncio.iscoroutinefunction(func):
+        coro = call_with_args(func, arg_data)
+    else:
+        coro = loop.run_in_executor(executor, call_with_args, func, arg_data)
+
+    return (yield from coro)
+
+
 def run_coroutine_threadsafe(coro, loop):
     """
     Runs a coroutine in a threadsafe manner

cloudbot/util/func_utils.py

@@ -0,0 +1,7 @@
+import inspect
+
+
+def call_with_args(func, arg_data):
+    sig = inspect.signature(func)
+    args = [arg_data[key] for key in sig.parameters.keys() if not key.startswith('_')]
+    return func(*args)