p34709852
/
monkey
forked from p15670423/monkey
1
0
Fork 1
Code Issues Pull Requests Projects Releases Wiki Activity

Agent: Implement PBA thread in AutomatedMaster

This commit is contained in:
Mike Salvatore 2021-12-03 11:05:31 -05:00
parent fecb7342ad
commit 261826fc78
1 changed files with 10 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
monkey/infection_monkey/master/automated_master.py
View File

@ -7,6 +7,7 @@ from infection_monkey.i_control_channel import IControlChannel
from infection_monkey.i_master import IMaster from infection_monkey.i_master import IMaster
from infection_monkey.i_puppet import IPuppet from infection_monkey.i_puppet import IPuppet
from infection_monkey.telemetry.messengers.i_telemetry_messenger import ITelemetryMessenger from infection_monkey.telemetry.messengers.i_telemetry_messenger import ITelemetryMessenger
from infection_monkey.telemetry.post_breach_telem import PostBreachTelem
from infection_monkey.telemetry.system_info_telem import SystemInfoTelem from infection_monkey.telemetry.system_info_telem import SystemInfoTelem
from infection_monkey.utils.timer import Timer from infection_monkey.utils.timer import Timer
@ -96,7 +97,9 @@ class AutomatedMaster(IMaster):
daemon=True, daemon=True,
) )
pba_thread = threading.Thread( pba_thread = threading.Thread(
target=self._run_pbas, args=(config["post_breach_actions"],), daemon=True target=self._run_plugins,
args=(config["post_breach_actions"].items(), "post-breach action", self._run_pba),
daemon=True,
) )
system_info_collector_thread.start() system_info_collector_thread.start()
@ -140,8 +143,12 @@ class AutomatedMaster(IMaster):
SystemInfoTelem({"collectors": system_info_telemetry}) SystemInfoTelem({"collectors": system_info_telemetry})
) )
def _run_pbas(self, enabled_pbas: List[str]): def _run_pba(self, pba: Tuple[str, Dict]):
pass name = pba[0]
options = pba[1]
command, result = self._puppet.run_pba(name, options)
self._telemetry_messenger.send_telemetry(PostBreachTelem(name, command, result))
def _can_propagate(self): def _can_propagate(self):
return True return True