Mercurial > libervia-backend
comparison libervia/backend/plugins/plugin_xep_0047.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 |
comparison
equal
deleted
inserted
replaced
| 4269:64a85ce8be70 | 4270:0d7bb4df2343 |
|---|---|
| 153 } | 153 } |
| 154 | 154 |
| 155 return session_data | 155 return session_data |
| 156 | 156 |
| 157 def _on_ibb_open(self, iq_elt, client): | 157 def _on_ibb_open(self, iq_elt, client): |
| 158 """"Called when an IBB <open> element is received | 158 """ "Called when an IBB <open> element is received |
| 159 | 159 |
| 160 @param iq_elt(domish.Element): the whole <iq> stanza | 160 @param iq_elt(domish.Element): the whole <iq> stanza |
| 161 """ | 161 """ |
| 162 log.debug(_("IBB stream opening")) | 162 log.debug(_("IBB stream opening")) |
| 163 iq_elt.handled = True | 163 iq_elt.handled = True |
| 190 event_close = IBB_CLOSE.format(sid) | 190 event_close = IBB_CLOSE.format(sid) |
| 191 # we now set the stream observer to look after data packet | 191 # we now set the stream observer to look after data packet |
| 192 # FIXME: if we never get the events, the observers stay. | 192 # FIXME: if we never get the events, the observers stay. |
| 193 # would be better to have generic observer and check id once triggered | 193 # would be better to have generic observer and check id once triggered |
| 194 client.xmlstream.addObserver(event_data, observer_cb, client=client) | 194 client.xmlstream.addObserver(event_data, observer_cb, client=client) |
| 195 client.xmlstream.addOnetimeObserver(event_close, self._on_ibb_close, client=client) | 195 client.xmlstream.addOnetimeObserver( |
| 196 event_close, self._on_ibb_close, client=client | |
| 197 ) | |
| 196 # finally, we send the accept stanza | 198 # finally, we send the accept stanza |
| 197 iq_result_elt = xmlstream.toResponse(iq_elt, "result") | 199 iq_result_elt = xmlstream.toResponse(iq_elt, "result") |
| 198 client.send(iq_result_elt) | 200 client.send(iq_result_elt) |
| 199 | 201 |
| 200 def _on_ibb_close(self, iq_elt, client): | 202 def _on_ibb_close(self, iq_elt, client): |
| 201 """"Called when an IBB <close> element is received | 203 """ "Called when an IBB <close> element is received |
| 202 | 204 |
| 203 @param iq_elt(domish.Element): the whole <iq> stanza | 205 @param iq_elt(domish.Element): the whole <iq> stanza |
| 204 """ | 206 """ |
| 205 iq_elt.handled = True | 207 iq_elt.handled = True |
| 206 log.debug(_("IBB stream closing")) | 208 log.debug(_("IBB stream closing")) |
| 285 ) | 287 ) |
| 286 if sid is not None: | 288 if sid is not None: |
| 287 self._kill_session(sid, client, error_condition) | 289 self._kill_session(sid, client, error_condition) |
| 288 client.send(iq_elt) | 290 client.send(iq_elt) |
| 289 | 291 |
| 290 def start_stream(self, client, stream_object, local_jid, to_jid, sid, block_size=None): | 292 def start_stream( |
| 293 self, client, stream_object, local_jid, to_jid, sid, block_size=None | |
| 294 ): | |
| 291 """Launch the stream workflow | 295 """Launch the stream workflow |
| 292 | 296 |
| 293 @param stream_object(ifaces.IStreamProducer): stream object to send | 297 @param stream_object(ifaces.IStreamProducer): stream object to send |
| 294 @param local_jid(jid.JID): jid to use as local jid | 298 @param local_jid(jid.JID): jid to use as local jid |
| 295 This is needed for client which can be addressed with a different jid than | 299 This is needed for client which can be addressed with a different jid than |
| 338 data_elt["seq"] = str(seq) | 342 data_elt["seq"] = str(seq) |
| 339 data_elt["sid"] = session_data["id"] | 343 data_elt["sid"] = session_data["id"] |
| 340 data_elt.addContent(base64.b64encode(buffer_).decode()) | 344 data_elt.addContent(base64.b64encode(buffer_).decode()) |
| 341 args = [session_data, client] | 345 args = [session_data, client] |
| 342 d = next_iq_elt.send() | 346 d = next_iq_elt.send() |
| 343 d.addCallbacks(self._iq_data_stream_cb, self._iq_data_stream_eb, args, None, args) | 347 d.addCallbacks( |
| 348 self._iq_data_stream_cb, self._iq_data_stream_eb, args, None, args | |
| 349 ) | |
| 344 else: | 350 else: |
| 345 self.terminate_stream(session_data, client) | 351 self.terminate_stream(session_data, client) |
| 346 | 352 |
| 347 def _iq_data_stream_eb(self, failure, session_data, client): | 353 def _iq_data_stream_eb(self, failure, session_data, client): |
| 348 if failure.check(error.StanzaError): | 354 if failure.check(error.StanzaError): |