-
Notifications
You must be signed in to change notification settings - Fork 0
/
ServiceManager.py
47 lines (38 loc) · 1.88 KB
/
ServiceManager.py
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
import threading
import importlib
from core.Service import Service
class ServiceManager:
def __init__(self, core, config):
self.core = core
self.services = {}
self.readConfigFile(config)
def readConfigFile(self, config):
for sectionName in config.sections():
indexOfLastPoint = sectionName.rfind('.')
indexOfEqual = sectionName.rfind('=')
serviceId = sectionName[0:indexOfEqual]
moduleName = sectionName[indexOfEqual + 1:indexOfLastPoint]
className = sectionName[indexOfLastPoint + 1:len(sectionName)]
self.instantiateService(moduleName, className, serviceId)
def instantiateService(self, module_name, class_name, service_id):
self.core.logger.log("Instantiating Module: " + module_name + ", Class: " + class_name + ", ID: " + service_id)
reflectedModule = importlib.import_module(module_name)
reflectedClass = getattr(reflectedModule, class_name)
serviceInstance = reflectedClass()
self.addService(serviceInstance, service_id)
def addService(self, service, service_id):
if not issubclass(type(service), Service):
raise Exception('Class \'' + type(service).__name__ + '\' does not extend from \'' + type(service).__name__ + '\'')
elif service_id in self.services:
raise Exception('Service ID ' + service + ' already exists.')
service.core = self.core
service.id = service_id
self.services[service_id] = service
def initializeServices(self):
for service in self.services.values():
initservicethread = threading.Thread(target=service.initialize)
initservicethread.start()
def startServices(self):
for service in self.services.values():
startservicethread = threading.Thread(target=service.start)
startservicethread.start()