diff --git a/sat/plugins/plugin_xep_0060.py b/sat/plugins/plugin_xep_0060.py index 5766efe3..5da0fbe2 100644 --- a/sat/plugins/plugin_xep_0060.py +++ b/sat/plugins/plugin_xep_0060.py @@ -1130,7 +1130,8 @@ class XEP_0060(object): ) -> pubsub.Subscription: # TODO: reimplement a subscribtion cache, checking that we have not subscription before trying to subscribe subscription = await client.pubsub_client.subscribe( - service, nodeIdentifier, sub_jid or client.jid.userhostJID(), options=options + service, nodeIdentifier, sub_jid or client.jid.userhostJID(), options=options, + sender=client.jid.userhostJID() ) await self.host.trigger.asyncPoint( "XEP-0060_subscribe", client, service, nodeIdentifier, sub_jid, options,