Mercurial > libervia-backend

comparison libervia/backend/plugins/plugin_exp_jingle_stream.py @ 4270:0d7bb4df2343

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
Reformatted code base using black.
author Goffi <goffi@goffi.org>
date Wed, 19 Jun 2024 18:44:57 +0200
parents 4b842c1fb686
children e9971a4b0627
comparison
equal deleted inserted replaced
4269:64a85ce8be70 4270:0d7bb4df2343
215 raise e 215 raise e
216 else: 216 else:
217 factory.port_listening = port_listening 217 factory.port_listening = port_listening
218 break 218 break
219 # we don't want to wait for IQ result of initiate 219 # we don't want to wait for IQ result of initiate
220 defer.ensureDeferred(self._j.initiate( 220 defer.ensureDeferred(
221 client, 221 self._j.initiate(
222 to_jid, 222 client,
223 [ 223 to_jid,
224 { 224 [
225 "app_ns": NS_STREAM, 225 {
226 "senders": self._j.ROLE_INITIATOR, 226 "app_ns": NS_STREAM,
227 "app_kwargs": {"stream_object": factory}, 227 "senders": self._j.ROLE_INITIATOR,
228 } 228 "app_kwargs": {"stream_object": factory},
229 ], 229 }
230 )) 230 ],
231 )
232 )
231 return str(port) 233 return str(port)
232 234
233 def jingle_session_init(self, client, session, content_name, stream_object): 235 def jingle_session_init(self, client, session, content_name, stream_object):
234 content_data = session["contents"][content_name] 236 content_data = session["contents"][content_name]
235 application_data = content_data["application_data"] 237 application_data = content_data["application_data"]
237 application_data["stream_object"] = stream_object 239 application_data["stream_object"] = stream_object
238 desc_elt = domish.Element((NS_STREAM, "description")) 240 desc_elt = domish.Element((NS_STREAM, "description"))
239 return desc_elt 241 return desc_elt
240 242
241 @defer.inlineCallbacks 243 @defer.inlineCallbacks
242 def jingle_request_confirmation(self, client, action, session, content_name, desc_elt): 244 def jingle_request_confirmation(
245 self, client, action, session, content_name, desc_elt
246 ):
243 """This method request confirmation for a jingle session""" 247 """This method request confirmation for a jingle session"""
244 content_data = session["contents"][content_name] 248 content_data = session["contents"][content_name]
245 if content_data["senders"] not in ( 249 if content_data["senders"] not in (
246 self._j.ROLE_INITIATOR, 250 self._j.ROLE_INITIATOR,
247 self._j.ROLE_RESPONDER, 251 self._j.ROLE_RESPONDER,
285 elif action == self._j.A_SESSION_ACCEPT: 289 elif action == self._j.A_SESSION_ACCEPT:
286 assert not "stream_object" in content_data 290 assert not "stream_object" in content_data
287 content_data["stream_object"] = application_data["stream_object"] 291 content_data["stream_object"] = application_data["stream_object"]
288 finished_d = content_data["finished_d"] = defer.Deferred() 292 finished_d = content_data["finished_d"] = defer.Deferred()
289 args = [client, session, content_name, content_data] 293 args = [client, session, content_name, content_data]
290 finished_d.addCallbacks(self._finished_cb, self._finished_eb, args, None, args) 294 finished_d.addCallbacks(
295 self._finished_cb, self._finished_eb, args, None, args
296 )
291 else: 297 else:
292 log.warning("FIXME: unmanaged action {}".format(action)) 298 log.warning("FIXME: unmanaged action {}".format(action))
293 return desc_elt 299 return desc_elt
294 300
295 def _finished_cb(self, __, client, session, content_name, content_data): 301 def _finished_cb(self, __, client, session, content_name, content_data):