src/pyams_media/utility.py
changeset 76 6fd737a311f0
parent 65 d38220c1116e
--- 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', {}])