From: Frank Brehm Date: Fri, 7 Dec 2018 11:26:36 +0000 (+0100) Subject: Using FbBaseObject from fb_tools.obj as the general base object X-Git-Tag: 1.6.4^2~106 X-Git-Url: https://git.uhu-banane.net/?a=commitdiff_plain;h=fff89e7b62c2e39b3c2a0218823eefa6163f3ce7;p=pixelpark%2Fpuppetmaster-webhooks.git Using FbBaseObject from fb_tools.obj as the general base object --- diff --git a/lib/webhooks/__init__.py b/lib/webhooks/__init__.py index 8e714de..136e6ca 100644 --- a/lib/webhooks/__init__.py +++ b/lib/webhooks/__init__.py @@ -1,6 +1,6 @@ #!/bin/env python3 # -*- coding: utf-8 -*- -__version__ = '1.2.1' +__version__ = '1.2.2' # vim: ts=4 et list diff --git a/lib/webhooks/base_app.py b/lib/webhooks/base_app.py index 16de573..ffaf22c 100644 --- a/lib/webhooks/base_app.py +++ b/lib/webhooks/base_app.py @@ -33,11 +33,10 @@ import yaml import pytz # Own modules -import webhooks - from fb_tools.common import pp, to_bytes, to_bool +from fb_tools.obj import FbBaseObjectError, FbBaseObject -from .obj import BaseObjectError, BaseObject +from . import __version__ as __pkg_version__ from .handler import BaseHandler @@ -45,7 +44,7 @@ from .module_info import ModuleInfo from .module_list import ModuleInfoDict -__version__ = webhooks.__version__ +__version__ = __pkg_version__ LOG = logging.getLogger(__name__) DEFAULT_FROM_EMAIL = 'puppetmaster@pixelpark.com' @@ -56,7 +55,7 @@ DEFAULT_TO_SENDER = 'Puppet <{}>'.format(DEFAULT_TO_EMAIL) # ============================================================================= -class BaseHookError(BaseObjectError): +class BaseHookError(FbBaseObjectError): """ Base error class useable by all descendand objects. """ @@ -70,7 +69,7 @@ class UncriticalHookError(BaseHookError): """ # ============================================================================= -class BaseHookApp(BaseObject): +class BaseHookApp(FbBaseObject): """ Base class for the application objects. """ diff --git a/lib/webhooks/handler.py b/lib/webhooks/handler.py index cf5c201..c4fe96f 100644 --- a/lib/webhooks/handler.py +++ b/lib/webhooks/handler.py @@ -28,11 +28,9 @@ import six from fb_tools.common import caller_search_path from fb_tools.errors import ReadTimeoutError, WriteTimeoutError from fb_tools.errors import CommandNotFoundError +from fb_tools.obj import FbBaseObjectError, FbBaseObject -from .obj import BaseObjectError -from .obj import BaseObject - -__version__ = '1.2.1' +__version__ = '1.2.2' LOG = logging.getLogger(__name__) @@ -44,7 +42,7 @@ SUDO_CMD = os.sep + os.path.join('usr', 'bin', 'sudo') # ============================================================================= -class BaseHandlerError(BaseObjectError): +class BaseHandlerError(FbBaseObjectError): """Base error class for all exceptions happened during execution this application""" @@ -52,7 +50,7 @@ class BaseHandlerError(BaseObjectError): # ============================================================================= -class BaseHandler(BaseObject): +class BaseHandler(FbBaseObject): """ Base class for handler objects. """ diff --git a/lib/webhooks/lock_handler.py b/lib/webhooks/lock_handler.py index ec38251..5dcdcd8 100644 --- a/lib/webhooks/lock_handler.py +++ b/lib/webhooks/lock_handler.py @@ -27,12 +27,11 @@ from six import reraise # Own modules from fb_tools.common import to_utf8 from fb_tools.errors import CouldntOccupyLockfileError - -from .obj import BaseObject +from fb_tools.obj import FbBaseObject from .handler import BaseHandlerError, BaseHandler -__version__ = '0.4.1' +__version__ = '0.4.2' LOG = logging.getLogger(__name__) @@ -117,7 +116,7 @@ class LockdirNotWriteableError(LockHandlerError): # ============================================================================= -class LockObject(BaseObject): +class LockObject(FbBaseObject): """ Capsulation class as a result of a successful lock action. It contains all important informations about the lock. diff --git a/lib/webhooks/module_info.py b/lib/webhooks/module_info.py index eb5a8ee..15da5f8 100644 --- a/lib/webhooks/module_info.py +++ b/lib/webhooks/module_info.py @@ -22,17 +22,15 @@ import pytz # Own modules from fb_tools.common import pp, to_str, to_bool, is_sequence +from fb_tools.obj import FbBaseObjectError, FbBaseObject -from .obj import BaseObjectError -from .obj import BaseObject - -__version__ = '1.1.1' +__version__ = '1.1.2' LOG = logging.getLogger(__name__) # ============================================================================= -class ModuleInfoError(BaseObjectError): +class ModuleInfoError(FbBaseObjectError): pass @@ -44,7 +42,7 @@ class ModuleInfoTypeError(ModuleInfoError, TypeError): # ============================================================================= -class ModuleInfo(BaseObject): +class ModuleInfo(FbBaseObject): """Class for encapsulating information about a Puppet module.""" re_split_name = re.compile(r'^\s*([a-z0-9]+)[-/_](\S+)\s*$', re.IGNORECASE) diff --git a/lib/webhooks/module_list.py b/lib/webhooks/module_list.py index 552031c..93c096a 100644 --- a/lib/webhooks/module_list.py +++ b/lib/webhooks/module_list.py @@ -19,17 +19,16 @@ from functools import cmp_to_key # Own modules from fb_tools.common import to_bool - -from .obj import BaseObject +from fb_tools.obj import FbBaseObject from .module_info import ModuleInfo -__version__ = '1.2.0' +__version__ = '1.2.1' LOG = logging.getLogger(__name__) # ============================================================================= -class ModuleInfoDict(MutableMapping, BaseObject): +class ModuleInfoDict(MutableMapping, FbBaseObject): """ A dictionary containing ModuleInfo objects. It works like a dict. diff --git a/lib/webhooks/obj.py b/lib/webhooks/obj.py deleted file mode 100644 index cc150a8..0000000 --- a/lib/webhooks/obj.py +++ /dev/null @@ -1,327 +0,0 @@ -#!/usr/bin/env python -# -*- coding: utf-8 -*- -""" -@author: Frank Brehm -@contact: frank.brehm@pixelpark.com -@copyright: © 2018 by Frank Brehm, Publicies Pixelpark GmbH, Berlin -""" -from __future__ import absolute_import - -# Standard modules -import sys -import os -import logging -import datetime -import traceback - -# Third party modules - -# Own modules -from fb_tools.common import pp, to_bytes -from fb_tools.errors import FbError - -__version__ = '1.1.1' - -LOG = logging.getLogger(__name__) - - -# ============================================================================= -class BaseObjectError(FbError): - """ - Base error class useable by all descendand objects. - """ - - pass - - -# ============================================================================= -class BaseObject(object): - """ - Base class for all objects. - """ - - # ------------------------------------------------------------------------- - def __init__( - self, appname=None, verbose=0, version=__version__, base_dir=None, - initialized=False): - """ - Initialisation of the base object. - - Raises an exception on a uncoverable error. - """ - - self._appname = None - """ - @ivar: name of the current running application - @type: str - """ - if appname: - v = str(appname).strip() - if v: - self._appname = v - if not self._appname: - self._appname = os.path.basename(sys.argv[0]) - - self._version = version - """ - @ivar: version string of the current object or application - @type: str - """ - - self._verbose = int(verbose) - """ - @ivar: verbosity level (0 - 9) - @type: int - """ - if self._verbose < 0: - msg = "Wrong verbose level {!r}, must be >= 0".format(verbose) - raise ValueError(msg) - - self._initialized = False - """ - @ivar: initialisation of this object is complete - after __init__() of this object - @type: bool - """ - - self._base_dir = base_dir - """ - @ivar: base directory used for different purposes, must be an existent - directory. Defaults to directory of current script daemon.py. - @type: str - """ - if base_dir: - if not os.path.exists(base_dir): - msg = "Base directory {!r} does not exists.".format(base_dir) - self.handle_error(msg) - self._base_dir = None - elif not os.path.isdir(base_dir): - msg = "Base directory {!r} is not a directory.".format(base_dir) - self.handle_error(msg) - self._base_dir = None - if not self._base_dir: - self._base_dir = os.path.dirname(os.path.abspath(sys.argv[0])) - - self._initialized = bool(initialized) - - # ----------------------------------------------------------- - @property - def appname(self): - """The name of the current running application.""" - if hasattr(self, '_appname'): - return self._appname - return os.path.basename(sys.argv[0]) - - @appname.setter - def appname(self, value): - if value: - v = str(value).strip() - if v: - self._appname = v - - # ----------------------------------------------------------- - @property - def version(self): - """The version string of the current object or application.""" - return getattr(self, '_version', __version__) - - # ----------------------------------------------------------- - @property - def verbose(self): - """The verbosity level.""" - return getattr(self, '_verbose', 0) - - @verbose.setter - def verbose(self, value): - v = int(value) - if v >= 0: - self._verbose = v - else: - LOG.warn("Wrong verbose level {!r}, must be >= 0".format(value)) - - # ----------------------------------------------------------- - @property - def initialized(self): - """The initialisation of this object is complete.""" - return getattr(self, '_initialized', False) - - @initialized.setter - def initialized(self, value): - self._initialized = bool(value) - - # ----------------------------------------------------------- - @property - def base_dir(self): - """The base directory used for different purposes.""" - return self._base_dir - - @base_dir.setter - def base_dir(self, value): - if value.startswith('~'): - value = os.path.expanduser(value) - if not os.path.exists(value): - msg = "Base directory {!r} does not exists.".format(value) - LOG.error(msg) - elif not os.path.isdir(value): - msg = "Base directory {!r} is not a directory.".format(value) - LOG.error(msg) - else: - self._base_dir = value - - # ------------------------------------------------------------------------- - def __str__(self): - """ - Typecasting function for translating object structure - into a string - - @return: structure as string - @rtype: str - """ - - return pp(self.as_dict(short=True)) - - # ------------------------------------------------------------------------- - def __repr__(self): - """Typecasting into a string for reproduction.""" - - out = "<%s(" % (self.__class__.__name__) - - fields = [] - fields.append("appname={!r}".format(self.appname)) - fields.append("verbose={!r}".format(self.verbose)) - fields.append("version={!r}".format(self.version)) - fields.append("base_dir={!r}".format(self.base_dir)) - fields.append("initialized={!r}".format(self.initialized)) - - out += ", ".join(fields) + ")>" - return out - - # ------------------------------------------------------------------------- - def as_dict(self, short=True): - """ - Transforms the elements of the object into a dict - - @param short: don't include local properties in resulting dict. - @type short: bool - - @return: structure as dict - @rtype: dict - """ - - res = self.__dict__ - res = {} - for key in self.__dict__: - if short and key.startswith('_') and not key.startswith('__'): - continue - val = self.__dict__[key] - if isinstance(val, BaseObject): - res[key] = val.as_dict(short=short) - else: - res[key] = val - res['__class_name__'] = self.__class__.__name__ - res['appname'] = self.appname - res['version'] = self.version - res['verbose'] = self.verbose - res['initialized'] = self.initialized - res['base_dir'] = self.base_dir - - return res - - # ------------------------------------------------------------------------- - def handle_error( - self, error_message=None, exception_name=None, do_traceback=False): - """ - Handle an error gracefully. - - Print a traceback and continue. - - @param error_message: the error message to display - @type error_message: str - @param exception_name: name of the exception class - @type exception_name: str - @param do_traceback: allways show a traceback - @type do_traceback: bool - - """ - - msg = 'Exception happened: ' - if exception_name is not None: - exception_name = exception_name.strip() - if exception_name: - msg = exception_name + ': ' - else: - msg = '' - if error_message: - msg += str(error_message) - else: - msg += 'undefined error.' - - root_log = logging.getLogger() - has_handlers = False - if root_log.handlers: - has_handlers = True - - if has_handlers: - LOG.error(msg) - if do_traceback: - LOG.error(traceback.format_exc()) - else: - curdate = datetime.datetime.now() - curdate_str = "[" + curdate.isoformat(' ') + "]: " - msg = curdate_str + msg + "\n" - if hasattr(sys.stderr, 'buffer'): - sys.stderr.buffer.write(to_bytes(msg)) - else: - sys.stderr.write(msg) - if do_traceback: - traceback.print_exc() - - return - - # ------------------------------------------------------------------------- - def handle_info(self, message, info_name=None): - """ - Shows an information. This happens both to STDERR and to all - initialized log handlers. - - @param message: the info message to display - @type message: str - @param info_name: Title of information - @type info_name: str - - """ - - msg = '' - if info_name is not None: - info_name = info_name.strip() - if info_name: - msg = info_name + ': ' - msg += str(message).strip() - - root_log = logging.getLogger() - has_handlers = False - if root_log.handlers: - has_handlers = True - - if has_handlers: - LOG.info(msg) - else: - curdate = datetime.datetime.now() - curdate_str = "[" + curdate.isoformat(' ') + "]: " - msg = curdate_str + msg + "\n" - if hasattr(sys.stderr, 'buffer'): - sys.stderr.buffer.write(to_bytes(msg)) - else: - sys.stderr.write(msg) - - return - - -# ============================================================================= -if __name__ == "__main__": - - pass - -# ============================================================================= - -# vim: tabstop=4 expandtab shiftwidth=4 softtabstop=4 diff --git a/lib/webhooks/puppetfile.py b/lib/webhooks/puppetfile.py index d23dfca..605365b 100644 --- a/lib/webhooks/puppetfile.py +++ b/lib/webhooks/puppetfile.py @@ -20,26 +20,25 @@ import grp import six # Own modules -from .obj import BaseObjectError -from .obj import BaseObject +from fb_tools.obj import FbBaseObjectError, FbBaseObject from .module_info import ModuleInfo from .module_list import ModuleInfoDict -__version__ = '1.0.0' +__version__ = '1.0.1' LOG = logging.getLogger(__name__) # ============================================================================= -class PuppetfileError(BaseObjectError): +class PuppetfileError(FbBaseObjectError): pass # ============================================================================= -class Puppetfile(BaseObject): +class Puppetfile(FbBaseObject): """Class for encapsulating a Puppetfile of a r10k environment.""" default_environment = 'production' diff --git a/requirements.txt b/requirements.txt index 91d77ed..79b1db7 100644 --- a/requirements.txt +++ b/requirements.txt @@ -9,4 +9,4 @@ dnspython flake8 docker-py pathlib -git+https://git.pixelpark.com/frabrehm/python_fb_tools.git@1.2.5 +git+https://git.pixelpark.com/frabrehm/python_fb_tools.git@test