Ahenk/opt/ahenk/base/execution/ExecutionManager.py

146 lines
6.8 KiB
Python
Raw Normal View History

2016-03-08 18:05:00 +02:00
#!/usr/bin/env python3
# -*- coding: utf-8 -*-
# Author: Volkan Şahin <volkansah.in> <bm.volkansahin@gmail.com>
import hashlib
import json
import os
import shutil
import stat
import subprocess
2016-03-08 18:05:00 +02:00
from base.Scope import Scope
from base.model.Policy import Policy
from base.model.Task import Task
from base.model.MessageType import MessageType
2016-03-08 18:05:00 +02:00
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()
2016-03-14 17:16:26 +02:00
self.task_manager = scope.getTaskManager()
self.messager = scope.getMessager()
self.logger = scope.getLogger()
self.db_service = scope.getDbService()
self.event_manager.register_event(MessageType.EXECUTE_SCRIPT, self.execute_script)
self.event_manager.register_event(MessageType.REQUEST_FILE, self.request_file)
self.event_manager.register_event(MessageType.MOVE_FILE, self.move_file)
self.event_manager.register_event(MessageType.EXECUTE_TASK, self.execute_task)
self.event_manager.register_event(MessageType.EXECUTE_POLICY, self.execute_policy)
2016-03-29 16:31:49 +03:00
def execute_policy(self, arg):
self.logger.debug('[ExecutionManager] Updating policies...')
policy = Policy(json.loads(arg))
2016-03-29 16:31:49 +03:00
# TODO get username and machine uid
2016-03-29 16:31:49 +03:00
username = '_username'
machine_uid='_machine_uid'
ahenk_policy_ver = self.db_service.select_one_result('policy', 'version', 'type = \'A\'')
user_policy_version = self.db_service.select_one_result('policy', 'version', 'type = \'U\' and name = \'' + username + '\'')
installed_plugins = self.get_installed_plugins()
missing_plugins = []
profile_columns = ['id', 'create_date', 'modify_date', 'label', 'description', 'overridable', 'active', 'deleted', 'profile_data', 'plugin']
if policy.ahenk_policy_version != ahenk_policy_ver:
ahenk_policy_id = self.db_service.select_one_result('policy', 'id', 'type = \'A\'')
if ahenk_policy_id is not None:
self.db_service.delete('profile', 'id=' + str(ahenk_policy_id))
self.db_service.update('policy', ['version'], [str(policy.ahenk_policy_version)], 'type=\'A\'')
else:
self.db_service.update('policy', ['type', 'version', 'name'], ['A', str(policy.ahenk_policy_version), machine_uid])
ahenk_policy_id = self.db_service.select_one_result('policy', 'id', 'type = \'A\'')
for profile in policy.ahenk_profiles:
args = [str(ahenk_policy_id), str(profile.create_date), str(profile.modify_date), str(profile.label),
str(profile.description), str(profile.overridable), str(profile.active), str(profile.deleted), str(profile.profile_data), str(profile.plugin)]
self.db_service.update('profile', profile_columns, args)
if profile.plugin.name not in installed_plugins and profile.plugin.name not in missing_plugins:
missing_plugins.append(profile.plugin.name)
else:
self.logger.debug('[ExecutionManager] Already there is ahenk policy')
if policy.user_policy_version != user_policy_version:
user_policy_id = self.db_service.select_one_result('policy', 'id', 'type = \'U\' and name=\'' + username + '\'')
if user_policy_id is not None:
self.db_service.delete('profile', 'id=' + str(user_policy_id))
self.db_service.update('policy', ['version'], [str(policy.user_policy_version)], 'type=\'U\' and name=\'' + username + '\'')
else:
self.db_service.update('policy', ['type', 'version', 'name'], ['U', str(policy.user_policy_version), username])
user_policy_id = self.db_service.select_one_result('policy', 'id', 'type = \'U\' and name=\'' + username + '\'')
for profile in policy.user_profiles:
args = [int(user_policy_id), str(profile.create_date), str(profile.modify_date), str(profile.label),
str(profile.description), int(profile.overridable), int(profile.active), int(profile.deleted), str(profile.profile_data), str(profile.plugin.to_string())]
self.db_service.update('profile', profile_columns, args)
if profile.plugin.name not in installed_plugins and profile.plugin.name not in missing_plugins:
missing_plugins.append(profile.plugin.name)
else:
self.logger.debug('[ExecutionManager] Already there is user policy')
# TODO check plugins
print("but first need these plugins:" + str(missing_plugins))
print("Executing policy")
self.task_manager.addPolicy(policy)
def get_installed_plugins(self):
plugins = self.db_service.select('plugin', ['name', 'version'])
p_list = []
for p in plugins:
p_list.append(str(p[0]) + '-' + str(p[1]))
return p_list
def execute_task(self, arg):
2016-03-14 17:42:17 +02:00
self.logger.debug('[ExecutionManager] Adding new task...')
2016-03-21 12:02:15 +02:00
task = Task(json.loads(arg))
2016-03-14 17:16:26 +02:00
self.task_manager.addTask(task)
2016-03-21 12:02:15 +02:00
self.logger.debug('[ExecutionManager] Task added')
def move_file(self, arg):
default_file_path = self.config_manager.get('CONNECTION', 'receiveFileParam')
j = json.loads(arg)
# msg_id =str(j['id']).lower()
2016-03-25 17:56:15 +02:00
target_file_path = str(j['filePath']).lower()
file_name = str(j['filename']).lower()
self.logger.debug('[ExecutionManager] ' + file_name + ' will be moved to ' + target_file_path)
shutil.move(default_file_path + file_name, target_file_path + file_name)
def execute_script(self, arg):
j = json.loads(arg)
# msg_id =str(j['id']).lower()
2016-03-25 17:56:15 +02:00
file_path = str(j['filePath']).lower()
time_stamp = str(j['timestamp']).lower()
self.logger.debug('[ExecutionManager] Making executable file (%s) for execution' % file_path)
st = os.stat(file_path)
os.chmod(file_path, st.st_mode | stat.S_IEXEC)
subprocess.call("/bin/sh " + file_path, shell=True)
# need to move somewhere else
def request_file(self, arg):
j = json.loads(arg)
# msg_id =str(j['id']).lower()
2016-03-25 17:56:15 +02:00
file_path = str(j['filePath']).lower()
time_stamp = str(j['timestamp']).lower()
self.logger.debug('[ExecutionManager] Requested file is ' + file_path)
self.messager.send_file(file_path)
def get_md5_file(self, fname):
self.logger.debug('[ExecutionManager] md5 hashing')
hash_md5 = hashlib.md5()
with open(fname, 'rb') as f:
for chunk in iter(lambda: f.read(4096), b""):
hash_md5.update(chunk)
return str(hash_md5.hexdigest())