Skip to content

Commit 4874aca

Browse files
authored
[client] Remove type property on collectors config (#125)
1 parent 43bab79 commit 4874aca

File tree

3 files changed

+20
-3
lines changed

3 files changed

+20
-3
lines changed

pyobas/daemons/collector_daemon.py

Lines changed: 16 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,8 @@
11
import sched
22
import time
3+
from argparse import ArgumentError
34

5+
from pyobas import Configuration
46
from pyobas.daemons import BaseDaemon
57
from pyobas.utils import PingAlive
68

@@ -17,6 +19,19 @@ class CollectorDaemon(BaseDaemon):
1719
time between each loop start is time_of_loop+period.
1820
"""
1921

22+
def __init__(
23+
self,
24+
configuration: Configuration,
25+
callback: callable = None,
26+
logger=None,
27+
api_client=None,
28+
collector_type=None,
29+
):
30+
super().__init__(configuration, callback, logger, api_client)
31+
if collector_type is None:
32+
raise ArgumentError("Must defined a value for collector type")
33+
self.collector_type = collector_type
34+
2035
def _setup(self):
2136
if self._configuration.get("collector_period") is None:
2237
self._configuration.set("collector_period", DEFAULT_PERIOD_SECONDS)
@@ -45,7 +60,7 @@ def _setup(self):
4560
config = {
4661
"collector_id": self._configuration.get("collector_id"),
4762
"collector_name": self._configuration.get("collector_name"),
48-
"collector_type": self._configuration.get("collector_type"),
63+
"collector_type": self.collector_type,
4964
"collector_period": self._configuration.get("collector_period"),
5065
"collector_security_platform": security_platform_id,
5166
}

pyobas/helpers.py

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -263,6 +263,7 @@ def __init__(
263263
self,
264264
config: OpenBASConfigHelper,
265265
icon,
266+
collector_type=None,
266267
security_platform_type=None,
267268
connect_run_and_terminate: bool = False,
268269
) -> None:
@@ -276,6 +277,7 @@ def __init__(
276277
self.__daemon = CollectorDaemon(
277278
configuration=config_obj,
278279
callback=None,
280+
collector_type=collector_type,
279281
)
280282

281283
self.__daemon.logger.warning(
@@ -292,7 +294,7 @@ def __init__(
292294
self.config = {
293295
"collector_id": config_obj.get("collector_id"),
294296
"collector_name": config_obj.get("collector_name"),
295-
"collector_type": config_obj.get("collector_type"),
297+
"collector_type": collector_type,
296298
"collector_period": config_obj.get("collector_period"),
297299
}
298300

test/daemons/test_collector_daemon.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -28,7 +28,7 @@ def test_when_no_period_config_provided_set_default_period(
2828
"collector_id": {"data": "fake id"},
2929
}
3030
)
31-
collector = CollectorDaemon(config)
31+
collector = CollectorDaemon(configuration=config, collector_type="test")
3232

3333
collector._setup()
3434

0 commit comments

Comments
 (0)