Liderahenk/Ahenk
1
0
Fork 0
mirror of https://github.com/Pardus-LiderAhenk/ahenk synced 2024-11-22 05:02:15 +03:00
Code Issues Projects Releases Packages Wiki Activity

code block about command was moved to command module and some log-variable name fixing

Browse source
This commit is contained in:
Volkan Şahin 2016-09-21 12:01:07 +03:00
parent 0298cc1897
commit dc4b2135c9
1 changed files with 46 additions and 229 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

275
opt/ahenk/ahenkd.py
View file

@ -3,18 +3,16 @@
# Author: İsmail BAŞARAN <ismail.basaran@tubitak.gov.tr> <basaran.ismaill@gmail.com>
# Author: Volkan Şahin <volkansah.in> <bm.volkansahin@gmail.com>
import json
import os
import queue
import signal
import sys
import threading
import time
from multiprocessing import Process
from base.scope import Scope
from base.agreement.agreement import Agreement
from base.command.commander import Commander
from base.command.command_manager import Commander
from base.command.command_runner import CommandRunner
from base.config.config_manager import ConfigManager
from base.database.ahenk_db_service import AhenkDbService
from base.deamon.base_daemon import BaseDaemon
@ -27,12 +25,13 @@ from base.messaging.messenger import Messenger
from base.plugin.plugin_manager_factory import PluginManagerFactory
from base.registration.registration import Registration
from base.scheduler.scheduler_factory import SchedulerFactory
from base.scope import Scope
from base.system.system import System
from base.task.task_manager import TaskManager
from base.timer.setup_timer import SetupTimer
from base.timer.timer import Timer
from base.util.util import Util
sys.path.append('../..')
ahenk_daemon = None
@ -49,8 +48,8 @@ class AhenkDaemon(BaseDaemon):
def init_logger():
""" docstring"""
logger = Logger()
logger.info('[AhenkDaemon] Log was set')
Scope.getInstance().setLogger(logger)
logger.info('Log was set')
Scope.get_instance().set_logger(logger)
return logger
@staticmethod
@ -58,7 +57,7 @@ class AhenkDaemon(BaseDaemon):
""" docstring"""
config_manager = ConfigManager(config_file_path, configfile_folder_path)
config = config_manager.read()
Scope.getInstance().setConfigurationManager(config)
Scope.get_instance().set_configuration_manager(config)
return config
@staticmethod
@ -66,7 +65,7 @@ class AhenkDaemon(BaseDaemon):
""" docstring"""
scheduler_ins = SchedulerFactory.get_intstance()
scheduler_ins.initialize()
Scope.getInstance().set_scheduler(scheduler_ins)
Scope.get_instance().set_scheduler(scheduler_ins)
sc_thread = threading.Thread(target=scheduler_ins.run)
sc_thread.setDaemon(True)
sc_thread.start()
@ -76,7 +75,7 @@ class AhenkDaemon(BaseDaemon):
def init_event_manager():
""" docstring"""
event_manager = EventManager()
Scope.getInstance().setEventManager(event_manager)
Scope.get_instance().set_event_manager(event_manager)
return event_manager
@staticmethod
@ -85,21 +84,21 @@ class AhenkDaemon(BaseDaemon):
db_service = AhenkDbService()
db_service.connect()
db_service.initialize_table()
Scope.getInstance().setDbService(db_service)
Scope.get_instance().set_sb_service(db_service)
return db_service
@staticmethod
def init_messaging():
""" docstring"""
message_manager = Messaging()
Scope.getInstance().setMessageManager(message_manager)
Scope.get_instance().set_message_manager(message_manager)
return message_manager
@staticmethod
def init_plugin_manager():
""" docstring"""
plugin_manager = PluginManagerFactory.get_instance()
Scope.getInstance().setPluginManager(plugin_manager)
Scope.get_instance().set_plugin_manager(plugin_manager)
# order changed, problem?
plugin_manager.load_plugins()
return plugin_manager
@ -108,21 +107,21 @@ class AhenkDaemon(BaseDaemon):
def init_task_manager():
""" docstring"""
task_manager = TaskManager()
Scope.getInstance().setTaskManager(task_manager)
Scope.get_instance().set_task_manager(task_manager)
return task_manager
@staticmethod
def init_registration():
""" docstring"""
registration = Registration()
Scope.getInstance().setRegistration(registration)
Scope.get_instance().set_registration(registration)
return registration
@staticmethod
def init_execution_manager():
""" docstring"""
execution_manager = ExecutionManager()
Scope.getInstance().setExecutionManager(execution_manager)
Scope.get_instance().set_execution_manager(execution_manager)
return execution_manager
@staticmethod
@ -130,7 +129,7 @@ class AhenkDaemon(BaseDaemon):
""" docstring"""
messenger_ = Messenger()
messenger_.connect_to_server()
Scope.getInstance().setMessenger(messenger_)
Scope.get_instance().set_messenger(messenger_)
return messenger_
@staticmethod
@ -140,7 +139,7 @@ class AhenkDaemon(BaseDaemon):
message_response_queue = MessageResponseQueue(response_queue)
message_response_queue.setDaemon(True)
message_response_queue.start()
Scope.getInstance().setResponseQueue(response_queue)
Scope.get_instance().set_response_queue(response_queue)
return response_queue
def check_registration(self):
@ -148,38 +147,38 @@ class AhenkDaemon(BaseDaemon):
max_attempt_number = int(System.Hardware.Network.interface_size()) * 3
# self.logger.debug()
# logger = Scope.getInstance().getLogger()
registration = Scope.getInstance().getRegistration()
registration = Scope.get_instance().get_registration()
try:
while registration.is_registered() is False:
max_attempt_number -= 1
self.logger.debug('[AhenkDaemon] Ahenk is not registered. Attempting for registration')
self.logger.debug('Ahenk is not registered. Attempting for registration')
registration.registration_request()
if max_attempt_number < 0:
self.logger.warning('[AhenkDaemon] Number of Attempting for registration is over')
self.logger.warning('Number of Attempting for registration is over')
self.registration_failed()
break
except Exception as e:
self.logger.error('[AhenkDaemon] Registration failed. Error message: {0}'.format(str(e)))
self.logger.error('Registration failed. Error message: {0}'.format(str(e)))
@staticmethod
def shutdown_mode():
""" docstring"""
scope = Scope().getInstance()
plugin_manager = scope.getPluginManager()
scope = Scope().get_instance()
plugin_manager = scope.get_plugin_manager()
plugin_manager.process_mode('shutdown')
def registration_failed(self):
""" docstring"""
self.logger.error(
'[AhenkDaemon] Registration failed. All registration attempts were failed. Ahenk is stopping...')
'Registration failed. All registration attempts were failed. Ahenk is stopping...')
print('Registration failed. Ahenk is stopping..')
ahenk_daemon.stop()
@staticmethod
def reload_plugins():
""" docstring"""
Scope.getInstance().getPluginManager().reloadPlugins()
Scope.get_instance().get_plugin_manager().reloadPlugins()
def reload_configuration(self):
# Not implemented yet
@ -201,10 +200,10 @@ class AhenkDaemon(BaseDaemon):
def init_signal_listener(self):
""" docstring"""
try:
signal.signal(signal.SIGALRM, self.run_command_from_fifo)
self.logger.info('[AhenkDaemon] Signal handler is set up')
signal.signal(signal.SIGALRM, CommandRunner().run_command_from_fifo)
self.logger.info('Signal handler is set up')
except Exception as e:
self.logger.error('[AhenkDaemon] Signal handler could not set up. Error Message: {0} '.format(str(e)))
self.logger.error('Signal handler could not set up. Error Message: {0} '.format(str(e)))
@staticmethod
def init_pid_file():
@ -225,7 +224,7 @@ class AhenkDaemon(BaseDaemon):
print('Ahenk running...')
global_scope = Scope()
global_scope.setInstance(global_scope)
global_scope.set_instance(global_scope)
config_file_folder_path = '/etc/ahenk/config.d/'
@ -236,241 +235,59 @@ class AhenkDaemon(BaseDaemon):
self.logger = self.init_logger()
self.init_pid_file()
self.logger.info('[AhenkDaemon] Pid file was created')
self.logger.info('Pid file was created')
self.init_fifo_file()
self.logger.info('[AhenkDaemon] Pid file was created')
self.logger.info('Fifo file was created')
self.init_event_manager()
self.logger.info('[AhenkDaemon] Event Manager was set')
self.logger.info('Event Manager was set')
self.init_ahenk_db()
self.logger.info('[AhenkDaemon] DataBase Service was set')
self.logger.info('DataBase Service was set')
self.init_messaging()
self.logger.info('[AhenkDaemon] Message Manager was set')
self.logger.info('Message Manager was set')
self.init_plugin_manager()
self.logger.info('[AhenkDaemon] Plugin Manager was set')
self.logger.info('Plugin Manager was set')
self.init_scheduler()
self.logger.info('[AhenkDaemon] Scheduler was set')
self.logger.info('Scheduler was set')
self.init_task_manager()
self.logger.info('[AhenkDaemon] Task Manager was set')
self.logger.info('Task Manager was set')
self.init_registration()
self.logger.info('[AhenkDaemon] Registration was set')
self.logger.info('Registration was set')
self.init_execution_manager()
self.logger.info('[AhenkDaemon] Execution Manager was set')
self.logger.info('Execution Manager was set')
self.check_registration()
self.logger.info('[AhenkDaemon] Ahenk was registered')
self.logger.info('Ahenk was registered')
self.messenger = self.init_messenger()
self.logger.info('[AhenkDaemon] Messenger was set')
self.logger.info('Messenger was set')
self.init_signal_listener()
self.logger.info('[AhenkDaemon] Signals listeners was set')
self.logger.info('Signals listeners was set')
Agreement().agreement_contract_update()
global_scope.put_custom_map('ahenk_daemon', ahenk_daemon)
self.init_message_response_queue()
# if registration.is_ldap_registered() is False:
# logger.debug('[AhenkDaemon] Attempting to registering ldap')
# logger.debug('Attempting to registering ldap')
# registration.ldap_registration_request() #TODO work on message
self.logger.info('[AhenkDaemon] LDAP registration of Ahenk is completed')
self.logger.info('LDAP registration of Ahenk is completed')
self.messenger.send_direct_message('test')
while True:
time.sleep(1)
@staticmethod
def running_plugin():
""" docstring"""
scope = Scope().getInstance()
plugin_manager = scope.getPluginManager()
for plugin in plugin_manager.plugins:
if plugin.keep_run is True:
return False
return True
def run_command_from_fifo(self, num, stack):
""" docstring"""
scope = Scope().getInstance()
plugin_manager = scope.getPluginManager()
message_manager = scope.getMessageManager()
messenger = scope.getMessenger()
conf_manager = scope.getConfigurationManager()
db_service = scope.getDbService()
execute_manager = scope.getExecutionManager()
while True:
try:
event = Commander().get_event()
if event is None:
break
json_data = json.loads(event)
except Exception as e:
self.logger.error(
'[AhenkDaemon] A problem occurred while loading json. Check json format! Error Message: {0}.'
' Event = {1}'.format(str(e), str(event)))
return
if json_data is not None:
self.logger.debug('[AhenkDaemon] Signal handled')
self.logger.debug('[AhenkDaemon] Signal is :{0}'.format(str(json_data['event'])))
if str(json_data['event']) == 'login':
username = json_data['username']
display = json_data['display']
desktop = json_data['desktop']
self.logger.info('[AhenkDaemon] login event is handled for user: {0}'.format(username))
login_message = message_manager.login_msg(username)
messenger.send_direct_message(login_message)
agreement = Agreement()
agreement_choice = None
if agreement.check_agreement(username) is not True:
self.logger.debug('[AhenkDaemon] User {0} has not accepted agreement.'.format(username))
thread_ask = Process(target=agreement.ask, args=(username, display,))
thread_ask.start()
agreement_timeout = conf_manager.get('SESSION', 'agreement_timeout')
timeout = int(agreement_timeout) # sec
timer = time.time()
while 1:
if thread_ask.is_alive() is False:
self.logger.warning('[AhenkDaemon] {0} was answered the question '.format(username))
if Agreement().check_agreement(username) is True:
self.logger.warning('[AhenkDaemon] Choice of {0} is YES'.format(username))
agreement_choice = True
break
elif Agreement().check_agreement(username) is False:
self.logger.warning('[AhenkDaemon] Choice of {0} is NO'.format(username))
agreement_choice = False
Util.close_session(username)
break
if (time.time() - timer) > timeout:
if thread_ask.is_alive():
thread_ask.terminate()
Util.close_session(username)
self.logger.warning(
'[AhenkDaemon] Session of {0} was ended because of timeout of contract agreement'.format(
username))
break
time.sleep(1)
if agreement_choice is not None:
messenger.send_direct_message(
message_manager.agreement_answer_msg(username, agreement_choice))
else:
agreement_choice = True
if agreement_choice is True:
db_service.delete('session', 'username=\'{0}\''.format(username))
self.logger.info(
'[AhenkDaemon] Display is {0}, desktop env is {1} for {2}'.format(display, desktop,
username))
db_service.update('session', scope.getDbService().get_cols('session'),
[username, display, desktop, Util.timestamp()])
get_policy_message = message_manager.policy_request_msg(username)
plugin_manager.process_mode('safe', username)
plugin_manager.process_mode('login', username)
kward = dict()
kward['timeout_args'] = username
kward['checker_args'] = username
SetupTimer.start(Timer(timeout=System.Ahenk.get_policy_timeout(),
timeout_function=execute_manager.execute_default_policy,
checker_func=execute_manager.is_policy_executed, kwargs=kward))
self.logger.info(
'[AhenkDaemon] Requesting updated policies from Lider. If Ahenk could not reach updated '
'policies in {0} sec, booked policies will be executed'.format(
System.Ahenk.get_policy_timeout()))
messenger.send_direct_message(get_policy_message)
elif str(json_data['event']) == 'logout':
username = json_data['username']
db_service.delete('session', 'username=\'{0}\''.format(username))
execute_manager.remove_user_executed_policy_dict(username)
# TODO delete all user records while initializing
self.logger.info('[AhenkDaemon] logout event is handled for user: {0}'.format(username))
logout_message = message_manager.logout_msg(username)
messenger.send_direct_message(logout_message)
plugin_manager.process_mode('logout', username)
plugin_manager.process_mode('safe', username)
elif str(json_data['event']) == 'send':
self.logger.info('[AhenkDaemon] Sending message over ahenkd command. Response Message: {0}'.format(
json.dumps(json_data['message'])))
message = json.dumps(json_data['message'])
messenger.send_direct_message(message)
elif str(json_data['event']) == 'load':
plugin_name = str(json_data['plugins'])
if plugin_name == 'all':
self.logger.debug('[AhenkDaemon] All plugins are loading to ahenk')
plugin_manager.load_plugins()
else:
for p_name in plugin_name.split(','):
self.logger.debug('[AhenkDaemon] {0} plugin is loading to ahenk'.format(p_name))
plugin_manager.load_single_plugin(p_name)
elif str(json_data['event']) == 'reload':
plugin_name = str(json_data['plugins'])
if plugin_name == 'all':
self.logger.debug('[AhenkDaemon] All plugins are reloading to ahenk')
plugin_manager.reload_plugins()
else:
for p_name in plugin_name.split(','):
self.logger.debug('[AhenkDaemon] {0} plugin is reloading to ahenk'.format(p_name))
plugin_manager.reload_single_plugin(p_name)
elif str(json_data['event']) == 'remove':
plugin_name = str(json_data['plugins'])
if plugin_name == 'all':
self.logger.debug('[AhenkDaemon] All plugins are removing from ahenk')
plugin_manager.remove_plugins()
else:
for p_name in plugin_name.split(','):
self.logger.debug('[AhenkDaemon] {0} plugin is removing from ahenk'.format(p_name))
plugin_manager.remove_single_plugin(p_name)
elif str(json_data['event']) == 'stop':
self.shutdown_mode()
self.logger.info('[AhenkDaemon] Shutdown mode activated.')
# TODO timeout
while self.running_plugin() is False:
self.logger.debug('[AhenkDaemon] Waiting for progress of plugins...')
time.sleep(0.5)
if Util.is_exist(System.Ahenk.fifo_file()):
Util.delete_file(System.Ahenk.fifo_file())
ahenk_daemon.stop()
else:
self.logger.error('[AhenkDaemon] Unknown command error. Command:' + json_data['event'])
self.logger.debug('[AhenkDaemon] Processing of handled event is completed')
if __name__ == '__main__':