Skip to content
Snippets Groups Projects
Commit f6e2fc21 authored by sveseli's avatar sveseli
Browse files

fixed logging for new utilities

parent b9c45a69
No related branches found
No related tags found
No related merge requests found
...@@ -7,6 +7,7 @@ from dm.common.exceptions.invalidArgument import InvalidArgument ...@@ -7,6 +7,7 @@ from dm.common.exceptions.invalidArgument import InvalidArgument
from dm.common.cli.dmCli import DmCli from dm.common.cli.dmCli import DmCli
from dm.common.utility.ldapUserManager import LdapUserManager from dm.common.utility.ldapUserManager import LdapUserManager
from dm.common.utility.configurationManager import ConfigurationManager from dm.common.utility.configurationManager import ConfigurationManager
from dm.common.utility.loggingManager import LoggingManager
from dm.aps_user_db.api.apsUserDbApi import ApsUserDbApi from dm.aps_user_db.api.apsUserDbApi import ApsUserDbApi
class UpdateUserFromApsDbCli(DmCli): class UpdateUserFromApsDbCli(DmCli):
...@@ -35,28 +36,33 @@ Description: ...@@ -35,28 +36,33 @@ Description:
Updates user in DM LDAP and database using information from APS DB. Updates user in DM LDAP and database using information from APS DB.
""") """)
ConfigurationManager.getInstance().setConfigFile(self.options.configFile) ConfigurationManager.getInstance().setConfigFile(self.options.configFile)
LoggingManager.getInstance().configure()
self.checkArgs() self.checkArgs()
apsUserDbApi = ApsUserDbApi() apsUserDbApi = ApsUserDbApi()
badge = self.getBadge() badge = self.getBadge()
username = 'd%s' % badge username = 'd%s' % badge
self.logger.debug('Retrieving APS user with badge %s' % badge)
apsUser = apsUserDbApi.getApsUserByBadgeNumber(badge) apsUser = apsUserDbApi.getApsUserByBadgeNumber(badge)
#print 'APS User Info: ', apsUser.getDisplayString(self.getDisplayKeys(), self.getDisplayFormat()) self.logger.info('APS User Info: %s' % apsUser)
print 'APS User Info: ', apsUser print('APS User Info: %s\n' % apsUser)
print
ldapUserManager = LdapUserManager.createInstance() ldapUserManager = LdapUserManager.createInstance()
try: try:
self.logger.debug('Modifying LDAP user with badge %s: %s' % (badge, apsUser['name'])) self.logger.debug('Modifying LDAP user with badge %s: %s' % (badge, apsUser['name']))
ldapUser = ldapUserManager.getUserInfo(username) ldapUser = ldapUserManager.getUserInfo(username)
print 'LDAP User Info (before update): ', ldapUser self.logger.info('LDAP User Info (before update): %s' % ldapUser)
print 'LDAP User Password Hash (before update): ', ldapUserManager.decodePasswordHash(ldapUser.getUserPassword()) self.logger.info('LDAP User Password Hash (before update): %s\n' % ldapUserManager.decodePasswordHash(ldapUser.getUserPassword()))
print print('LDAP User Info (before update): %s' % ldapUser)
print('LDAP User Password Hash (before update): %s\n' % ldapUserManager.decodePasswordHash(ldapUser.getUserPassword()))
ldapUserManager.modifyUserInfo(username, apsUser) ldapUserManager.modifyUserInfo(username, apsUser)
ldapUser = ldapUserManager.getUserInfo(username) ldapUser = ldapUserManager.getUserInfo(username)
except ObjectNotFound, ex: except ObjectNotFound, ex:
self.logger.debug('User with badge %s does not exist, creating it' % (badge)) self.logger.debug('User with badge %s does not exist, creating it' % (badge))
ldapUser = ldapUserManager.createUserInfo(username, apsUser) ldapUser = ldapUserManager.createUserInfo(username, apsUser)
print 'LDAP User Info (after update): ', ldapUser self.logger.info('LDAP User Info (after update): %s' % ldapUser)
print 'LDAP User Password Hash (after update): ', ldapUserManager.decodePasswordHash(ldapUser.getUserPassword()) self.logger.info('LDAP User Password Hash (after update): %s\n' % ldapUserManager.decodePasswordHash(ldapUser.getUserPassword()))
print('LDAP User Info (after update): %s' % ldapUser)
print('LDAP User Password Hash (after update): %s\n' % ldapUserManager.decodePasswordHash(ldapUser.getUserPassword()))
####################################################################### #######################################################################
# Run command. # Run command.
......
...@@ -8,6 +8,7 @@ from dm.common.exceptions.objectAlreadyExists import ObjectAlreadyExists ...@@ -8,6 +8,7 @@ from dm.common.exceptions.objectAlreadyExists import ObjectAlreadyExists
from dm.common.cli.dmCli import DmCli from dm.common.cli.dmCli import DmCli
from dm.common.db.api.userDbApi import UserDbApi from dm.common.db.api.userDbApi import UserDbApi
from dm.common.utility.configurationManager import ConfigurationManager from dm.common.utility.configurationManager import ConfigurationManager
from dm.common.utility.loggingManager import LoggingManager
from dm.common.utility.ldapUserManager import LdapUserManager from dm.common.utility.ldapUserManager import LdapUserManager
from dm.aps_user_db.api.apsUserDbApi import ApsUserDbApi from dm.aps_user_db.api.apsUserDbApi import ApsUserDbApi
from dm.ds_web_service.api.dsRestApiFactory import DsRestApiFactory from dm.ds_web_service.api.dsRestApiFactory import DsRestApiFactory
...@@ -35,8 +36,10 @@ class UpdateUsersFromApsDbCli(DmCli): ...@@ -35,8 +36,10 @@ class UpdateUsersFromApsDbCli(DmCli):
Description: Description:
Updates all users in DM LDAP and database using information from APS DB. This command by default uses DM DB to determine whether or not user needs to be created or updated. If the --without-dm-db flag is set, DM DB will not be used nor it will be updated. Updates all users in DM LDAP and database using information from APS DB. This command by default uses DM DB to determine whether or not user needs to be created or updated. If the --without-dm-db flag is set, DM DB will not be used nor it will be updated.
""") """)
self.checkArgs()
ConfigurationManager.getInstance().setConfigFile(self.options.configFile) ConfigurationManager.getInstance().setConfigFile(self.options.configFile)
LoggingManager.getInstance().configure()
self.checkArgs()
self.logger.debug('Starting sync process') self.logger.debug('Starting sync process')
apsUserDbApi = ApsUserDbApi() apsUserDbApi = ApsUserDbApi()
ldapUserManager = LdapUserManager.createInstance() ldapUserManager = LdapUserManager.createInstance()
......
...@@ -30,7 +30,7 @@ DEFAULT_DM_FILE_LOG_LEVEL = 'INFO' ...@@ -30,7 +30,7 @@ DEFAULT_DM_FILE_LOG_LEVEL = 'INFO'
#DEFAULT_DM_LOG_RECORD_FORMAT = '%(asctime)s,%(msecs)03d [%(levelname)s] %(module)s:%(lineno)d %(user)s@%(host)s %(name)s (%(process)d): %(message)s' #DEFAULT_DM_LOG_RECORD_FORMAT = '%(asctime)s,%(msecs)03d [%(levelname)s] %(module)s:%(lineno)d %(user)s@%(host)s %(name)s (%(process)d): %(message)s'
#DEFAULT_DM_LOG_RECORD_FORMAT = '%(asctime)s,%(msecs)03d %(levelname)s %(module)s:%(lineno)d %(process)d: %(message)s' #DEFAULT_DM_LOG_RECORD_FORMAT = '%(asctime)s,%(msecs)03d %(levelname)s %(module)s:%(lineno)d %(process)d: %(message)s'
DEFAULT_DM_LOG_RECORD_FORMAT = '%(asctime)s,%(msecs)03d %(levelname)s %(process)d: %(message)s' DEFAULT_DM_LOG_RECORD_FORMAT = '%(asctime)s,%(msecs)03d %(levelname)s %(process)d: %(message)s'
DEFAULT_DM_LOG_DATE_FORMAT = '%Y-%m-%d %H:%M:%S' DEFAULT_DM_LOG_DATE_FORMAT = '%Y/%m/%d %H:%M:%S'
DEFAULT_DM_CHERRYPY_LOG_LEVEL = 'ERROR' DEFAULT_DM_CHERRYPY_LOG_LEVEL = 'ERROR'
DEFAULT_DM_CHERRYPY_LOG_FILE = '%s/var/log/%s.%s.cherrypy.error' # requires install dir/db name/service name DEFAULT_DM_CHERRYPY_LOG_FILE = '%s/var/log/%s.%s.cherrypy.error' # requires install dir/db name/service name
......
...@@ -91,7 +91,7 @@ class LoggingManager: ...@@ -91,7 +91,7 @@ class LoggingManager:
raise ConfigurationError('"%s" is not valid log level' % levelStr) raise ConfigurationError('"%s" is not valid log level' % levelStr)
# Configure log handlers. # Configure log handlers.
def configureHandlers(self): def configure(self):
""" Configure log handlers from the config file. """ """ Configure log handlers from the config file. """
cm = ConfigurationManager.getInstance() cm = ConfigurationManager.getInstance()
configFile = cm.getConfigFile() configFile = cm.getConfigFile()
...@@ -100,15 +100,16 @@ class LoggingManager: ...@@ -100,15 +100,16 @@ class LoggingManager:
# Console handler. # Console handler.
defaults = { defaults = {
'level' : cm.getConsoleLogLevel(), 'level' : cm.getConsoleLogLevel(),
'format' : cm.getLogRecordFormat(), 'format' : cm.getLogRecordFormat(),
'dateFormat' : cm.getLogDateFormat(), 'dateFormat' : cm.getLogDateFormat(),
'handler' : 'ConsoleLoggingHandler(sys.stdout,)' 'handler' : 'ConsoleLoggingHandler(sys.stdout,)'
} }
consoleHandler = self.__configureHandler(configParser, 'ConsoleLogging', defaults) if not self.consoleHandler:
consoleHandler = self.__configureHandler(configParser, 'ConsoleLogging', defaults)
if consoleHandler != None: if consoleHandler != None:
self.consoleHandler = consoleHandler self.consoleHandler = consoleHandler
# File logging. # File logging.
# Do not configure if log directory does not exist. # Do not configure if log directory does not exist.
...@@ -234,7 +235,7 @@ class LoggingManager: ...@@ -234,7 +235,7 @@ class LoggingManager:
def getLogger(self, name='defaultLogger'): def getLogger(self, name='defaultLogger'):
if not self.initFlag: if not self.initFlag:
self.initFlag = True self.initFlag = True
self.configureHandlers() self.configure()
logger = logging.getLogger(name) logger = logging.getLogger(name)
logger.setLevel(self.getLevel(name)) logger.setLevel(self.getLevel(name))
return logger return logger
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment