mirror of
https://github.com/avatao-content/baseimage-tutorial-framework
synced 2024-09-19 02:34:10 +00:00
44 lines
1.5 KiB
Python
44 lines
1.5 KiB
Python
# Copyright (C) 2018 Avatao.com Innovative Learning Kft.
|
|
# All Rights Reserved. See LICENSE file for details.
|
|
|
|
from os.path import dirname
|
|
|
|
from watchdog.events import PatternMatchingEventHandler as PatternMatchingWatchdogEventHandler
|
|
|
|
from tfw.networking.event_handlers import ServerUplinkConnector
|
|
from tfw.decorators import RateLimiter
|
|
from tfw.mixins import ObserverMixin, SupervisorLogMixin
|
|
|
|
|
|
class LogMonitor(ObserverMixin):
|
|
def __init__(self, process_name):
|
|
ObserverMixin.__init__(self)
|
|
event_handler = SendLogWatchdogEventHandler(process_name)
|
|
self.observer.schedule(
|
|
event_handler,
|
|
event_handler.path
|
|
)
|
|
|
|
|
|
class SendLogWatchdogEventHandler(PatternMatchingWatchdogEventHandler, SupervisorLogMixin):
|
|
def __init__(self, process_name):
|
|
self.process_name = process_name
|
|
self.procinfo = self.supervisor.getProcessInfo(self.process_name)
|
|
super().__init__([self.procinfo['stdout_logfile'], self.procinfo['stderr_logfile']])
|
|
self.uplink = ServerUplinkConnector()
|
|
|
|
@property
|
|
def path(self):
|
|
return dirname(self.procinfo['stdout_logfile'])
|
|
|
|
@RateLimiter(rate_per_second=5)
|
|
def on_modified(self, event):
|
|
self.uplink.send({
|
|
'key': 'console',
|
|
'data': {
|
|
'command': 'writelog',
|
|
'stdout': self.read_stdout(self.process_name),
|
|
'stderr': self.read_stderr(self.process_name)
|
|
}
|
|
})
|