--- a/src/pyams_media/utility.py Sun Feb 18 12:47:42 2018 +0100
+++ b/src/pyams_media/utility.py Mon Mar 05 12:51:54 2018 +0100
@@ -17,7 +17,7 @@
# import interfaces
from pyams_media.interfaces import IMediaConversionUtility, CONVERTER_HANDLER_KEY, CUSTOM_AUDIO_TYPES, \
- CUSTOM_VIDEO_TYPES
+ CUSTOM_VIDEO_TYPES, CONVERTER_AUTH_KEY
from zope.intid.interfaces import IIntIds
# import packages
@@ -63,15 +63,15 @@
for format in requested_formats:
self.convert(media, format)
- def _get_socket(self):
+ def get_socket(self):
registry = get_current_registry()
handler = registry.settings.get(CONVERTER_HANDLER_KEY, False)
if handler:
- return zmq_socket(handler)
+ return zmq_socket(handler, auth=registry.settings.get(CONVERTER_AUTH_KEY))
def convert(self, media, format):
"""Send conversion request for given media"""
- socket = self._get_socket()
+ socket = self.get_socket()
if socket is None:
return [501, "No socket handler defined in configuration file"]
intids = get_utility(IIntIds)
@@ -83,7 +83,7 @@
def test_process(self):
"""Send test request to conversion process"""
- socket = self._get_socket()
+ socket = self.get_socket()
if socket is None:
return [501, "No socket handler defined in configuration file"]
socket.send_json(['test', {}])