Commit 7858626b authored by Dan Pascu's avatar Dan Pascu

Adapted to the latest changes in python-sipsimple

parent 020dc188
...@@ -39,7 +39,8 @@ from sipsimple.core import SIPCoreError, SIPURI, ToHeader ...@@ -39,7 +39,8 @@ from sipsimple.core import SIPCoreError, SIPURI, ToHeader
from sipsimple.lookup import DNSLookup from sipsimple.lookup import DNSLookup
from sipsimple.session import Session from sipsimple.session import Session
from sipsimple.streams import MediaStreamRegistry from sipsimple.streams import MediaStreamRegistry
from sipsimple.streams.msrp import FileSelector, ExternalVNCServerHandler, ExternalVNCViewerHandler, ScreenSharingStream from sipsimple.streams.msrp.filetransfer import FileSelector
from sipsimple.streams.msrp.screensharing import ExternalVNCServerHandler, ExternalVNCViewerHandler, ScreenSharingStream
from sipsimple.threading import run_in_thread, run_in_twisted_thread from sipsimple.threading import run_in_thread, run_in_twisted_thread
from blink.configuration.settings import BlinkSettings from blink.configuration.settings import BlinkSettings
...@@ -241,8 +242,7 @@ class StreamDescription(object): ...@@ -241,8 +242,7 @@ class StreamDescription(object):
self.attributes = kw self.attributes = kw
def create_stream(self): def create_stream(self):
registry = MediaStreamRegistry() cls = MediaStreamRegistry.get(self.type)
cls = registry.get(self.type)
return cls(**self.attributes) return cls(**self.attributes)
def __repr__(self): def __repr__(self):
...@@ -3759,9 +3759,7 @@ class BlinkFileTransfer(object): ...@@ -3759,9 +3759,7 @@ class BlinkFileTransfer(object):
self._terminate(failure_reason='Destination not found') self._terminate(failure_reason='Destination not found')
return return
self.sip_session = Session(self.account) self.sip_session = Session(self.account)
registry = MediaStreamRegistry() self.stream = MediaStreamRegistry.FileTransferStream(self.file_selector, 'sendonly', transfer_id=self.id)
cls = registry.get('file-transfer')
self.stream = cls(self.file_selector, 'sendonly', transfer_id=self.id)
self.handler = self.stream.handler self.handler = self.stream.handler
self.sip_session.connect(ToHeader(self._uri), routes, [self.stream]) self.sip_session.connect(ToHeader(self._uri), routes, [self.stream])
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment