diff --git a/opt/ahenk/base/execution/ExecutionManager.py b/opt/ahenk/base/execution/ExecutionManager.py new file mode 100644 index 0000000..f8e2b0e --- /dev/null +++ b/opt/ahenk/base/execution/ExecutionManager.py @@ -0,0 +1,45 @@ +#!/usr/bin/env python3 +# -*- coding: utf-8 -*- +# Author: Volkan Şahin +import sys +import logging +import logging.config +from base.Scope import Scope + +class ExecutionManager(object): + """docstring for FileTransferManager""" + + def __init__(self): + super(ExecutionManager, self).__init__() + + scope = Scope.getInstance() + self.config_manager = scope.getConfigurationManager() + self.event_manager = scope.getEventManager() + + self.event_manager.register_event('EXECUTE_TASK',self.execute_task) + self.event_manager.register_event('EXECUTE_SCRIPT',self.execute_script) + self.event_manager.register_event('SEND_FILE',self.send_file) + + def execute_task(self,arg): + print("execute_task") + + def execute_script(self,arg): + print("execute_script") + j = json.loads(arg) + msg_id =str(j['id']).lower() + file_path =str(j['filePath']).lower() + time_stamp=str(j['timestamp']).lower() + + os.system('./command.sh') #TODO + + + #need to move somewhere else + def send_file(self,arg): + print("send_file") + j = json.loads(arg) + msg_id =str(j['id']).lower() + file_path =str(j['filePath']).lower() + time_stamp=str(j['timestamp']).lower() + + message_sender=MessageSender(None,file_path) + message_sender.connect_to_server() diff --git a/opt/ahenk/base/execution/__init__.py b/opt/ahenk/base/execution/__init__.py new file mode 100644 index 0000000..e69de29