equal
deleted
inserted
replaced
16 # import standard library |
16 # import standard library |
17 import atexit |
17 import atexit |
18 import logging |
18 import logging |
19 logger = logging.getLogger('PyAMS (media)') |
19 logger = logging.getLogger('PyAMS (media)') |
20 |
20 |
|
21 import os.path |
21 import sys |
22 import sys |
22 |
23 |
23 # import interfaces |
24 # import interfaces |
24 from pyams_media.interfaces import CONVERTER_HANDLER_KEY, CONVERTER_STARTER_KEY, CONVERTER_NAME |
25 from pyams_media.interfaces import CONVERTER_HANDLER_KEY, CONVERTER_STARTER_KEY, CONVERTER_NAME |
25 from pyams_utils.interfaces import PYAMS_APPLICATION_SETTINGS_KEY, PYAMS_APPLICATION_DEFAULT_NAME |
26 from pyams_utils.interfaces import PYAMS_APPLICATION_SETTINGS_KEY, PYAMS_APPLICATION_DEFAULT_NAME |
51 |
52 |
52 @subscriber(IApplicationCreated) |
53 @subscriber(IApplicationCreated) |
53 def handle_new_application(event): |
54 def handle_new_application(event): |
54 """Start converter process when application created""" |
55 """Start converter process when application created""" |
55 |
56 |
56 # check for upgrade mode |
57 # check for PyAMS command line script |
57 if sys.argv[0].endswith('pyams_upgrade'): |
58 cmsline = os.path.split(sys.argv[0])[-1] |
|
59 if cmsline.startswith('pyams_'): |
58 return |
60 return |
59 |
61 |
60 registry = get_global_registry() |
62 registry = get_global_registry() |
61 settings = registry.settings |
63 settings = registry.settings |
62 start_handler = asbool(settings.get(CONVERTER_STARTER_KEY, False)) |
64 start_handler = asbool(settings.get(CONVERTER_STARTER_KEY, False)) |
65 connection = get_connection_from_settings(settings) |
67 connection = get_connection_from_settings(settings) |
66 root = connection.root() |
68 root = connection.root() |
67 # get application |
69 # get application |
68 application_name = settings.get(PYAMS_APPLICATION_SETTINGS_KEY, PYAMS_APPLICATION_DEFAULT_NAME) |
70 application_name = settings.get(PYAMS_APPLICATION_SETTINGS_KEY, PYAMS_APPLICATION_DEFAULT_NAME) |
69 application = root.get(application_name) |
71 application = root.get(application_name) |
70 process = None |
|
71 if application is not None: |
72 if application is not None: |
72 sm = application.getSiteManager() |
73 sm = application.getSiteManager() |
73 set_local_registry(sm) |
74 set_local_registry(sm) |
|
75 process = None |
74 try: |
76 try: |
75 conversion_util = sm.get(CONVERTER_NAME) |
77 conversion_util = sm.get(CONVERTER_NAME) |
76 if conversion_util is not None: |
78 if conversion_util is not None: |
77 # create medias converter process |
79 # create medias converter process |
78 process = MediaConversionProcess(settings.get(CONVERTER_HANDLER_KEY, '127.0.0.1:5556'), |
80 process = MediaConversionProcess(settings.get(CONVERTER_HANDLER_KEY, '127.0.0.1:5556'), |