bug: lib/bots: fix names of private attributes

Make private members `__is_multithreadable` and `__collector_empty_process` protected members `_is_multithreadable` and `_collector_empty_process` to make them easily modifiable by Bot classes

fixes #2108

Author: Sebastian Wagner

CHANGELOG.md

@@ -11,6 +11,17 @@ CHANGELOG
 
 ### Core
 - `intelmq.lib.bot.CollectorBot`: Fixed an issue with within the `new_report` function, which re-loads the harmonization file after a new incoming dataset, which leads to CPU drain and decreased performance (PR#2106 by Sebastian Waldbauer, fixes #2098).
+- `intelmq.lib.bot.Bot`: Make private members `__is_multithreadable` and `__collector_empty_process` protected members `_is_multithreadable` and `_collector_empty_process` to make them easily modifiable by Bot classes (PR#2109 by Sebastian Wagner, fixes #2108).
+  Also affected and adapted bots by this change are:
+  - `intelmq.bots.collectors.api.collector_api`
+  - `intelmq.bots.collectors.stomp.collector`
+  - `intelmq.bots.experts.splunk_saved_search.expert`
+  - `intelmq.bots.experts.threshold.expert`
+  - `intelmq.bots.outputs.file.output`
+  - `intelmq.bots.outputs.misp.output_api`
+  - `intelmq.bots.outputs.misp.output_feed`
+  - `intelmq.bots.outputs.tcp.output`
+  - `intelmq.bots.outputs.udp.output`
 
 ### Bots
 #### Experts

intelmq/bots/collectors/api/collector_api.py

@@ -37,9 +37,9 @@ class APICollectorBot(CollectorBot):
     """Collect data by exposing a HTTP API interface"""
     name: str = "API"
     port: int = 5000
-    __collector_empty_process: bool = True
+    _collector_empty_process: bool = True
     provider: str = "APICollector"
-    __is_multithreadable: bool = False
+    _is_multithreadable: bool = False
     use_socket = False
     socket_path = '/tmp/imq_api_default_socket'
     _server: Optional['HTTPServer'] = None

intelmq/bots/collectors/stomp/collector.py

@@ -69,7 +69,7 @@ class StompCollectorBot(CollectorBot):
     ssl_client_certificate_key: str = 'client.key'  # TODO pathlib.Path
     heartbeat: int = 6000
 
-    __collector_empty_process: bool = True
+    _collector_empty_process: bool = True
     __conn = False  # define here so shutdown method can check for it
 
     def init(self):

intelmq/bots/experts/splunk_saved_search/expert.py

@@ -82,7 +82,7 @@ class SplunkSavedSearchBot(Bot):
     search_parameters = {"event field": "search parameter"}
     url: str = None
 
-    __is_multithreadable = False
+    _is_multithreadable = False
 
     def init(self):
         if requests is None:

intelmq/bots/experts/threshold/expert.py

@@ -68,7 +68,7 @@ class ThresholdExpertBot(Bot, CacheMixin):
 
     _message_processed_verb = 'Forwarded'
 
-    __is_multithreadable = False
+    _is_multithreadable = False
     bypass = False
 
     def init(self):

intelmq/bots/outputs/file/output.py

@@ -22,7 +22,7 @@ class FileOutputBot(OutputBot):
     message_jsondict_as_string: bool = False
     message_with_type: bool = False
     single_key: bool = False
-    __is_multithreadable = False
+    _is_multithreadable = False
 
     def init(self):
         # needs to be done here, because in process() FileNotFoundError handling we call init(),

intelmq/bots/outputs/misp/output_api.py

@@ -95,7 +95,7 @@ class MISPAPIOutputBot(OutputBot):
     misp_url: str = None
     significant_fields: list = []
 
-    _Bot__is_multithreadable = False
+    _is_multithreadable = False
 
     def init(self):
         if pymisp is None and import_fail_reason == 'syntax':

intelmq/bots/outputs/misp/output_feed.py

@@ -35,7 +35,7 @@ class MISPFeedOutputBot(OutputBot):
     misp_org_name = None
     misp_org_uuid = None
     output_dir: str = "/opt/intelmq/var/lib/bots/mispfeed-output"  # TODO: should be path
-    __is_multithreadable: bool = False
+    _is_multithreadable: bool = False
 
     @staticmethod
     def check_output_dir(dirname):

intelmq/bots/outputs/tcp/output.py

@@ -25,7 +25,7 @@ class TCPOutputBot(Bot):
     port: int = None
     separator: str = None
 
-    __is_multithreadable = False
+    _is_multithreadable = False
 
     def init(self):
         self.to_intelmq = self.counterpart_is_intelmq

intelmq/bots/outputs/udp/output.py

@@ -19,7 +19,7 @@ class UDPOutputBot(Bot):
     udp_host: str = "localhost"
     udp_port: int = None
 
-    __is_multithreadable = False
+    _is_multithreadable = False
 
     def init(self):
         self.delimiter = self.field_delimiter