From 8f8151256056de54a1d6424fa7e5671b0bf44158 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Volkan=20=C5=9Eahin?= Date: Fri, 11 Mar 2016 17:39:32 +0200 Subject: [PATCH] new json messages created --- opt/ahenk/base/messaging/Messaging.py | 57 +++++++++++++++++++++------ 1 file changed, 45 insertions(+), 12 deletions(-) diff --git a/opt/ahenk/base/messaging/Messaging.py b/opt/ahenk/base/messaging/Messaging.py index b779d48..6016539 100644 --- a/opt/ahenk/base/messaging/Messaging.py +++ b/opt/ahenk/base/messaging/Messaging.py @@ -1,51 +1,84 @@ #!/usr/bin/env python3 # -*- coding: utf-8 -*- # Author: Volkan Şahin +import sys, pwd, os, datetime, json -import sys,pwd,os -import datetime,json sys.path.append('../..') from base.Scope import Scope -class Messaging(object): +class Messaging(object): def __init__(self): - scope = Scope().getInstance() self.logger = scope.getLogger() - self.configurationManager = scope.getConfigurationManager() - self.event_manger=scope.getEventManager() + self.conf_manager = scope.getConfigurationManager() + self.event_manger = scope.getEventManager() - #TODO can use sh commands for getting username and timestamp + # TODO can use sh commands or api for getting username and timestamp def login_msg(self): data = {} data['type'] = 'LOGIN' - data['username'] = str(pwd.getpwuid( os.getuid() )[ 0 ]) + data['username'] = str(pwd.getpwuid(os.getuid())[0]) data['timestamp'] = str(datetime.datetime.now().strftime("%d-%m-%Y %I:%M")) json_data = json.dumps(data) + self.logger.debug('[Messaging] Login message was created') return json_data def logout_msg(self): data = {} data['type'] = 'LOGOUT' - data['username'] = str(pwd.getpwuid( os.getuid() )[ 0 ]) + data['username'] = str(pwd.getpwuid(os.getuid())[0]) data['timestamp'] = str(datetime.datetime.now().strftime("%d-%m-%Y %I:%M")) json_data = json.dumps(data) + self.logger.debug('[Messaging] Logout message was created') return json_data - def get_policies_msg(self): + def policies_msg(self): data = {} data['type'] = 'GET_POLICIES' - data['username'] = str(pwd.getpwuid( os.getuid() )[ 0 ]) + data['username'] = str(pwd.getpwuid(os.getuid())[0]) data['timestamp'] = str(datetime.datetime.now().strftime("%d-%m-%Y %I:%M")) json_data = json.dumps(data) + self.logger.debug('[Messaging] Get Policies message was created') + return json_data + + def registration_msg(self): + data = {} + data['type'] = 'REGISTER' + data['from'] = str(self.conf_manager.get('REGISTRATION', 'from')) + data['password'] = str(self.conf_manager.get('REGISTRATION', 'password')) + data['macAddresses'] = str(self.conf_manager.get('REGISTRATION', 'macAddresses')) + data['ipAddresses'] = str(self.conf_manager.get('REGISTRATION', 'ipAddresses')) + data['hostname'] = str(self.conf_manager.get('REGISTRATION', 'hostname')) + data['timestamp'] = str(datetime.datetime.now().strftime("%d-%m-%Y %I:%M")) + json_data = json.dumps(data) + self.logger.debug('[Messaging] Registration message was created') + return json_data + + def ldap_registration_msg(self): + data = {} + data['type'] = 'REGISTER_LDAP' + data['from'] = str(self.conf_manager.get('REGISTRATION', 'from')) + data['password'] = str(self.conf_manager.get('REGISTRATION', 'password')) + data['macAddresses'] = str(self.conf_manager.get('REGISTRATION', 'macAddresses')) + data['ipAddresses'] = str(self.conf_manager.get('REGISTRATION', 'ipAddresses')) + data['hostname'] = str(self.conf_manager.get('REGISTRATION', 'hostname')) + data['timestamp'] = str(datetime.datetime.now().strftime("%d-%m-%Y %I:%M")) + json_data = json.dumps(data) + self.logger.debug('[Messaging] LDAP Registration message was created') return json_data def unregister_msg(self): data = {} data['type'] = 'UNREGISTER' - data['username'] = str(pwd.getpwuid( os.getuid() )[ 0 ]) + data['from'] = str(self.conf_manager.get('REGISTRATION', 'from')) + data['password'] = str(self.conf_manager.get('REGISTRATION', 'password')) + data['macAddresses'] = str(self.conf_manager.get('REGISTRATION', 'macAddresses')) + data['ipAddresses'] = str(self.conf_manager.get('REGISTRATION', 'ipAddresses')) + data['hostname'] = str(self.conf_manager.get('REGISTRATION', 'hostname')) + # data['username'] = str(pwd.getpwuid( os.getuid() )[ 0 ]) data['timestamp'] = str(datetime.datetime.now().strftime("%d-%m-%Y %I:%M")) json_data = json.dumps(data) + self.logger.debug('[Messaging] Unregister message was created') return json_data