Added docstrings from origin functions to proxy side functions

Author: Codemation

easyrpc/proxy.py

@@ -155,7 +155,7 @@ async def create(cls,
 
     def run_cron(self, action, interval):
         async def cron():
-            self.log.warning(f"creating cron or {action.__name__} - interval {interval}")
+            self.log.debug(f"creating cron or {action.__name__} - interval {interval}")
             tasks = []
             while True:
                 try:
@@ -466,7 +466,7 @@ async def ws_client():
                     ws_sender = self.get_ws_sender(ws)
                     ws_receiver = self.get_ws_receiver(ws)
 
-                    self.log.warning(
+                    self.log.debug(
                         f"started connection to server {self.origin_host}:{self.origin_port}"
                     )
                     async def keep_alive():

easyrpc/register.py

@@ -46,8 +46,8 @@ async def __proxy__(*args, **kwargs):
             return await result
         return result
 
-    #__proxy__.__name__ = f"{config['name']}_proxy"
     __proxy__.__name__ = f"{config['name']}"
+    __proxy__.__doc__ = config.get('doc', '')
     nf = create_function(
         create_signature_from_dict(
             config['sig']
@@ -126,6 +126,7 @@ def register(f, namespace):
             obj.namespaces[namespace][f.__name__]['config'] = {
                 'sig': get_signature_as_dict(f),
                 'name': f.__name__,
+                'doc': f.__doc__,
                 'is_async': iscoroutinefunction(f)
             }
             obj.namespaces[namespace][f.__name__]['method'] = f

easyrpc/server.py

@@ -23,11 +23,11 @@ async def connect(self, websocket: WebSocket):
         return await websocket.accept()
 
     def store_connect(self, endpoint_id, websocket: WebSocket):
-        self.log.warning(f"created websocket connection with endpoint {endpoint_id}")
+        self.log.debug(f"created websocket connection with endpoint {endpoint_id}")
         self.active_connections[endpoint_id] = websocket
 
     def disconnect(self, endpoint_id: str):
-        self.log.warning(f"deleted websocket connection with endpoint {endpoint_id}")
+        self.log.debug(f"deleted websocket connection with endpoint {endpoint_id}")
         del self.active_connections[endpoint_id]
     async def broadcast(self, message: str):
         for connection in self.active_connections:
@@ -422,7 +422,7 @@ async def ws_receiver():
                 await finished.get()
 
                 # child connection closed
-                self.log.warning(f"client websocket connection with id {decoded_id} finished")
+                self.log.debug(f"client websocket connection with id {decoded_id} finished")
 
                 # check if child is server or proxy
                 if setup['type'] == 'SERVER':