Skip to content

Commit

Permalink
Changed some normalizers to include network in every object where it …
Browse files Browse the repository at this point in the history
…is needed
  • Loading branch information
Souf149 committed Dec 20, 2024
1 parent 1fcd593 commit c4e1470
Show file tree
Hide file tree
Showing 3 changed files with 24 additions and 8 deletions.
10 changes: 7 additions & 3 deletions boefjes/boefjes/plugins/kat_binaryedge/containers/normalize.py
Original file line number Diff line number Diff line change
Expand Up @@ -36,12 +36,16 @@ def run(input_ooi: dict, raw: bytes) -> Iterable[NormalizerOutput]:
yield ip_ooi
ip_ref = ip_ooi.reference

ip_port_ooi = IPPort(address=ip_ref, protocol=Protocol(protocol), port=port_nr, state=PortState("open"))
ip_port_ooi = IPPort(
address=ip_ref, protocol=Protocol(protocol), port=port_nr, state=PortState("open"), network=network
)
yield ip_port_ooi

software_ooi = Software(name=module.capitalize())
software_ooi = Software(name=module.capitalize(), network=network)
yield software_ooi
software_instance_ooi = SoftwareInstance(ooi=ip_port_ooi.reference, software=software_ooi.reference)
software_instance_ooi = SoftwareInstance(
ooi=ip_port_ooi.reference, software=software_ooi.reference, network=network
)
yield software_instance_ooi

kat_ooi = KATFindingType(id="KAT-VERIFIED-VULNERABILITY")
Expand Down
14 changes: 11 additions & 3 deletions boefjes/boefjes/plugins/kat_binaryedge/databases/normalize.py
Original file line number Diff line number Diff line change
Expand Up @@ -36,7 +36,9 @@ def run(input_ooi: dict, raw: bytes) -> Iterable[NormalizerOutput]:
yield ip_ooi
ip_ref = ip_ooi.reference

ip_port_ooi = IPPort(address=ip_ref, protocol=Protocol(protocol), port=port_nr, state=PortState("open"))
ip_port_ooi = IPPort(
address=ip_ref, protocol=Protocol(protocol), port=port_nr, state=PortState("open"), network=network
)
yield ip_port_ooi

software_version = None
Expand All @@ -57,9 +59,15 @@ def run(input_ooi: dict, raw: bytes) -> Iterable[NormalizerOutput]:
software_version = data["redis_version"]
# TODO: data.gccversion

software_ooi = Software(name=module, version=software_version) if software_version else Software(name=module)
software_ooi = (
Software(name=module, version=software_version, network=network)
if software_version
else Software(name=module, network=network)
)
yield software_ooi
software_instance_ooi = SoftwareInstance(ooi=ip_port_ooi.reference, software=software_ooi.reference)
software_instance_ooi = SoftwareInstance(
ooi=ip_port_ooi.reference, software=software_ooi.reference, network=network
)
yield software_instance_ooi

kat_ooi = KATFindingType(id="KAT-EXPOSED-SOFTWARE")
Expand Down
8 changes: 6 additions & 2 deletions boefjes/boefjes/plugins/kat_nmap_tcp/normalize.py
Original file line number Diff line number Diff line change
Expand Up @@ -28,7 +28,11 @@ def get_ip_ports_and_service(host: NmapHost, network: Network, netblock: Referen
continue

ip_port = IPPort(
address=ip.reference, protocol=Protocol(protocol), port=port, state=PortState(service.state)
address=ip.reference,
protocol=Protocol(protocol),
port=port,
state=PortState(service.state),
network=network.reference,
)
yield ip_port

Expand All @@ -39,7 +43,7 @@ def get_ip_ports_and_service(host: NmapHost, network: Network, netblock: Referen
port_service = Service(name=service_name)
yield port_service

ip_service = IPService(ip_port=ip_port.reference, service=port_service.reference)
ip_service = IPService(ip_port=ip_port.reference, service=port_service.reference, network=network.reference)
yield ip_service


Expand Down

0 comments on commit c4e1470

Please sign in to comment.