Mercurial > libervia-backend
diff libervia/backend/plugins/plugin_exp_pubsub_hook.py @ 4270:0d7bb4df2343
Reformatted code base using black.
author | Goffi <goffi@goffi.org> |
---|---|
date | Wed, 19 Jun 2024 18:44:57 +0200 |
parents | 4b842c1fb686 |
children |
line wrap: on
line diff
--- a/libervia/backend/plugins/plugin_exp_pubsub_hook.py Tue Jun 18 12:06:45 2024 +0200 +++ b/libervia/backend/plugins/plugin_exp_pubsub_hook.py Wed Jun 19 18:44:57 2024 +0200 @@ -55,7 +55,9 @@ def __init__(self, host): log.info(_("PubSub Hook initialization")) self.host = host - self.node_hooks = {} # keep track of the number of hooks per node (for all profiles) + self.node_hooks = ( + {} + ) # keep track of the number of hooks per node (for all profiles) host.bridge.add_method( "ps_hook_add", ".plugin", in_sign="ssssbs", out_sign="", method=self._addHook ) @@ -108,7 +110,9 @@ else: if self.node_hooks[node] == 0: del self.node_hooks[node] - self.host.plugins["XEP-0060"].remove_managed_node(node, self._items_received) + self.host.plugins["XEP-0060"].remove_managed_node( + node, self._items_received + ) log.debug(_("hook removed")) else: log.debug(_("node still needed for an other hook")) @@ -120,9 +124,7 @@ ) if hook_type != HOOK_TYPE_PYTHON_FILE: raise NotImplementedError( - _("{hook_type} hook type not implemented yet").format( - hook_type=hook_type - ) + _("{hook_type} hook type not implemented yet").format(hook_type=hook_type) ) self._install_node_manager(client, node) hook_data = {"service": service, "type": hook_type, "arg": hook_arg} @@ -160,7 +162,14 @@ try: if hook_type == HOOK_TYPE_PYTHON_FILE: hook_globals = {} - exec(compile(open(hook_data["arg"], "rb").read(), hook_data["arg"], 'exec'), hook_globals) + exec( + compile( + open(hook_data["arg"], "rb").read(), + hook_data["arg"], + "exec", + ), + hook_globals, + ) callback = hook_globals["hook"] else: raise NotImplementedError( @@ -224,7 +233,9 @@ def _removeHook(self, service, node, hook_type, hook_arg, profile): client = self.host.get_client(profile) service = jid.JID(service) if service else client.jid.userhostJID() - return self.remove_hook(client, service, node, hook_type or None, hook_arg or None) + return self.remove_hook( + client, service, node, hook_type or None, hook_arg or None + ) def remove_hook(self, client, service, node, hook_type=None, hook_arg=None): """Remove a persistent or temporaty root