Infra
/
risotto
9
0
Fork 1
Code Issues 1 Releases Wiki Activity

log on_join function

This commit is contained in:
Emmanuel Garette 2020-01-31 11:34:27 +01:00
parent ab71686633
commit 251b521274
2 changed files with 6 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/risotto/dispatcher.py
View File

@ -351,7 +351,7 @@ class Dispatcher(register.RegisterDispatcher, CallDispatcher, PublishDispatcher)
await log.info_msg(risotto_context, await log.info_msg(risotto_context,
{'arguments': kwargs, {'arguments': kwargs,
'returns': returns}, 'returns': returns},
info_msg) info_msg)
# notification # notification
if function_obj.get('notification'): if function_obj.get('notification'):
notif_version, notif_message = function_obj['notification'].split('.', 1) notif_version, notif_message = function_obj['notification'].split('.', 1)

5
src/risotto/register.py
View File

@ -9,6 +9,7 @@ from .error import RegistrationError
from .message import get_messages from .message import get_messages
from .context import Context from .context import Context
from .config import INTERNAL_USER, get_config from .config import INTERNAL_USER, get_config
from .logger import log
def register(uris: str, def register(uris: str,
@ -234,6 +235,10 @@ class RegisterDispatcher:
risotto_context.paths.append(f'{module_name}.on_join') risotto_context.paths.append(f'{module_name}.on_join')
risotto_context.type = None risotto_context.type = None
risotto_context.connection = connection risotto_context.connection = connection
info_msg = _(f'in module {module_name}.on_join')
await log.info_msg(risotto_context,
None,
info_msg)
await module.on_join(risotto_context) await module.on_join(risotto_context)
async def insert_message(self, async def insert_message(self,