Source code for polyglot.core

''' The primary functionality for the Polyglot application '''
# [cython] from cpython.exc cimport PyErr_CheckSignals
import logging
import signal
import sys
import time

from polyglot.config_manager import ConfigManager
from polyglot.element_manager import ElementManager
from polyglot.nodeserver_manager import NodeServerManager
from polyglot.version import PGVERSION

_LOGGER = logging.getLogger(__name__)

[docs]class Polyglot(object): """ Core class :param config_dir: Directory where configuration is stored :ivar config: Dictionary of current config """ def __init__(self, config_dir): self.version = PGVERSION'Creating Polyglot, version %s', self.version) sys.modules['pglot'] = self # initialize components self.config = ConfigManager(config_dir) self.elements = ElementManager(self) self.nodeservers = NodeServerManager(self) self.running = False self.isy_version = self.config.get_isy_version() # handle SIGTERMs signal.signal(signal.SIGTERM, self.stop)
[docs] def setup(self): """ Setup Polyglot to resume the last known state """'Starting Polyglot') self.elements.load() self.nodeservers.load()
[docs] def run(self): """ Run the Polyglot server """ self.running = True try: while self.running: time.sleep(1) # [cython] PyErr_CheckSignals() except KeyboardInterrupt: self.stop()
[docs] def stop(self, *args): """ Stops the Polyglot server """ # pylint: disable=unused-argument self.update_config() self.running = False'Stopping Polyglot') self.nodeservers.unload() self.elements.unload()
[docs] def update_config(self): """ Signal Polyglot to fetch updated configuration. """ if not self.running:'Not saving configuration (shutting down or not yet running)') return _LOGGER.debug('Saving Configuration') config = {'nodeservers': self.nodeservers.config, 'elements': self.elements.config} self.config.update(config)
[docs] def get_log(self): """ Read and return the log file contents. """ fname = self.config.make_path('polyglot.log') return open(fname).read()