CyberDataLab · isaac1227 · Nov 13, 2024 · Nov 22, 2024 · Dec 3, 2024 · Dec 3, 2024
diff --git a/CHANGELOG.md b/CHANGELOG.md
diff --git a/CONTRIBUTING.md b/CONTRIBUTING.md
diff --git a/Makefile b/Makefile
diff --git a/docs/_prebuilt/changelog.md b/docs/_prebuilt/changelog.md
diff --git a/docs/_prebuilt/contributing.md b/docs/_prebuilt/contributing.md
diff --git a/docs/_prebuilt/css/toc.css b/docs/_prebuilt/css/toc.css
diff --git a/docs/_prebuilt/developerguide.md b/docs/_prebuilt/developerguide.md
diff --git a/docs/_prebuilt/index.md b/docs/_prebuilt/index.md
diff --git a/docs/_prebuilt/installation.md b/docs/_prebuilt/installation.md
diff --git a/docs/_prebuilt/js/toc.js b/docs/_prebuilt/js/toc.js
diff --git a/docs/_prebuilt/static/developerguide/structure.png b/docs/_prebuilt/static/developerguide/structure.png
diff --git a/docs/_prebuilt/static/userguide/deployment.png b/docs/_prebuilt/static/userguide/deployment.png
diff --git a/docs/_prebuilt/static/userguide/frontend.png b/docs/_prebuilt/static/userguide/frontend.png
diff --git a/docs/_prebuilt/static/userguide/monitor.png b/docs/_prebuilt/static/userguide/monitor.png
diff --git a/docs/_prebuilt/static/userguide/nebula-dashboard.png b/docs/_prebuilt/static/userguide/nebula-dashboard.png
diff --git a/docs/_prebuilt/static/userguide/realtime-images.png b/docs/_prebuilt/static/userguide/realtime-images.png
diff --git a/docs/_prebuilt/static/userguide/realtime-scalars.png b/docs/_prebuilt/static/userguide/realtime-scalars.png
diff --git a/docs/_prebuilt/static/userguide/realtime-time-series.png b/docs/_prebuilt/static/userguide/realtime-time-series.png
diff --git a/docs/_prebuilt/static/userguide/running_nebula.png b/docs/_prebuilt/static/userguide/running_nebula.png
diff --git a/docs/_prebuilt/userguide.md b/docs/_prebuilt/userguide.md
diff --git a/docs/mkdocs.yml b/docs/mkdocs.yml
diff --git a/docs/scripts/gen_ref_pages.py b/docs/scripts/gen_ref_pages.py
diff --git a/nebula/addons/attacks/communications/__init__.py b/nebula/addons/attacks/communications/__init__.py
diff --git a/nebula/addons/attacks/communications/communicationattack.py b/nebula/addons/attacks/communications/communicationattack.py
diff --git a/nebula/addons/attacks/communications/delayerattack.py b/nebula/addons/attacks/communications/delayerattack.py
diff --git a/nebula/addons/attacks/communications/floodingattack.py b/nebula/addons/attacks/communications/floodingattack.py
@@ -58,7 +58,8 @@ def decorator(self, flooding_factor: int):
         def decorator(func):
             @wraps(func)
             async def wrapper(*args, **kwargs):
-                if len(args) == 4 and args[3] == "model":
+                flooding_factor = 30
-                flooding_factor = 30
+                # Use the passed-in flooding_factor parameter
-                flooding_factor = 30
+                # Use the passed-in flooding_factor parameter
+                if len(args) > 1:
                     dest_addr = args[1]
                     if dest_addr in self.targets:
                         logging.info(f"[FloodingAttack] Flooding message to {dest_addr} by {flooding_factor} times")
@@ -67,11 +68,13 @@ async def wrapper(*args, **kwargs):
                                 logging.info(
                                     f"[FloodingAttack] Sending duplicate {i + 1}/{flooding_factor} to {dest_addr}"
                                 )
-                            _, *new_args = args  # Exclude self argument
+                            _, dest_addr, serialized_model, *rest = args  # Exclude self argument
+                            new_args = [dest_addr, serialized_model]
                             await func(*new_args, **kwargs)
-                _, *new_args = args 
+                _, dest_addr, serialized_model, *rest = args  # Exclude self argument
+                new_args = [dest_addr, serialized_model]
                 return await func(*new_args)
-            
+
             return wrapper
 
         return decorator
diff --git a/nebula/addons/attacks/dataset/datasetattack.py b/nebula/addons/attacks/dataset/datasetattack.py
diff --git a/nebula/addons/attacks/model/gllneuroninversion.py b/nebula/addons/attacks/model/gllneuroninversion.py
diff --git a/nebula/addons/attacks/model/modelattack.py b/nebula/addons/attacks/model/modelattack.py
diff --git a/nebula/addons/attacks/model/swappingweights.py b/nebula/addons/attacks/model/swappingweights.py
diff --git a/nebula/addons/gps/gpsmodule.py b/nebula/addons/gps/gpsmodule.py
diff --git a/nebula/addons/gps/nebulagps.py b/nebula/addons/gps/nebulagps.py
diff --git a/nebula/addons/networksimulation/nebulanetworksimulator.py b/nebula/addons/networksimulation/nebulanetworksimulator.py
diff --git a/nebula/addons/networksimulation/networksimulator.py b/nebula/addons/networksimulation/networksimulator.py
diff --git a/nebula/addons/reputation/reputation.py b/nebula/addons/reputation/reputation.py
diff --git a/nebula/controller/scenarios.py b/nebula/controller/scenarios.py
@@ -333,6 +333,7 @@ def validate_positive_int(value, name):
             "Flooding",
         }
 
+
         # Get attack type from attack_params
         if attack_params and "attacks" in attack_params:
             attack = attack_params["attacks"]
@@ -544,7 +545,7 @@ def from_dict(cls, data):
 
         # Create the scenario object
         scenario = cls(**scenario_data)
-
+    
         return scenario
 
 
@@ -697,8 +698,26 @@ def __init__(self, scenario, user=None):
                 participant_config["adversarial_args"]["attack_params"] = node_config["attack_params"]
             else:
                 participant_config["adversarial_args"]["attack_params"] = {"attacks": "No Attack"}
-            participant_config["defense_args"]["reputation"] = self.scenario.reputation
-
+                # Defense parameters
-                # Defense parameters
+                # Defense parameters
+                participant_config["defense_args"].setdefault("reputation", {})
-                # Defense parameters
+                # Defense parameters
+                participant_config["defense_args"].setdefault("reputation", {})
+                participant_config["defense_args"]["reputation"]["with_reputation"] = self.scenario.reputation.get("with_reputation", False)
+                participant_config["defense_args"]["reputation"]["initial_reputation"] = self.scenario.reputation.get("initial_reputation", 0.2)
+                metrics_list = self.scenario.reputation.get("reputation_metrics", [])
+                if isinstance(metrics_list, list):
+                    metrics_dict = {
+                        "model_similarity": "model_similarity" in metrics_list,
+                        "num_messages": "num_messages" in metrics_list,
+                        "model_arrival_latency": "model_arrival_latency" in metrics_list,
+                        "fraction_parameters_changed": "fraction_parameters_changed" in metrics_list,
+                    }
+                    participant_config["defense_args"]["reputation"]["reputation_metrics"] = metrics_dict
+                else:
+                    participant_config["defense_args"]["reputation"]["reputation_metrics"] = metrics_list
+                participant_config["defense_args"]["reputation"]["weighting_factor"] = self.scenario.reputation.get("weighting_factor", "dynamic")
+                participant_config["defense_args"]["reputation"]["weight_model_arrival_latency"] = self.scenario.reputation.get("weight_model_arrival_latency", 1.0)
+                participant_config["defense_args"]["reputation"]["weight_model_similarity"] = self.scenario.reputation.get("weight_model_similarity", 1.0)
+                participant_config["defense_args"]["reputation"]["weight_num_messages"] = self.scenario.reputation.get("weight_num_messages", 1.0)
+                participant_config["defense_args"]["reputation"]["weight_fraction_params_changed"] = self.scenario.reputation.get("weight_fraction_params_changed", 1.0)
+            # Mobility and network simulation parameters
             participant_config["mobility_args"]["random_geo"] = self.scenario.random_geo
             participant_config["mobility_args"]["latitude"] = self.scenario.latitude
             participant_config["mobility_args"]["longitude"] = self.scenario.longitude

diff --git a/nebula/core/addonmanager.py b/nebula/core/addonmanager.py
diff --git a/nebula/core/aggregation/updatehandlers/cflupdatehandler.py b/nebula/core/aggregation/updatehandlers/cflupdatehandler.py
diff --git a/nebula/core/aggregation/updatehandlers/dflupdatehandler.py b/nebula/core/aggregation/updatehandlers/dflupdatehandler.py
@@ -137,6 +137,9 @@ async def _check_updates_already_received(self):
                         logging.info(
                             f"Update already received from source: {se} | ({len(self._sources_received)}/{len(self._sources_expected)}) Updates received"
                         )
+                        logging.info(
+                            f"Update already received from source: {se} | ({len(self._sources_received)}/{len(self._sources_expected)}) Updates received"
+                        )
-                        logging.info(
-                            f"Update already received from source: {se} | ({len(self._sources_received)}/{len(self._sources_expected)}) Updates received"
-                        )
-                        logging.info(
-                            f"Update already received from source: {se} | ({len(self._sources_received)}/{len(self._sources_expected)}) Updates received"
-                        )
                 except:
                     logging.exception(
                         f"ERROR: source expected: {se} | last_update None: {(True if not last_updt else False)}, last update storaged None: {(True if not node_storage[-1] else False)}"
@@ -163,8 +166,8 @@ async def storage_update(self, updt_received_event: UpdateReceivedEvent):
                 logging.info(
                     f"Storage Update | source={source} | round={round} | weight={weight} | federation nodes: {self._sources_expected}"
                 )
-
                 self._sources_received.add(source)
+
                 updates_left = self._sources_expected.difference(self._sources_received)
                 logging.info(
                     f"Updates received ({len(self._sources_received)}/{len(self._sources_expected)}) | Missing nodes: {updates_left}"
@@ -192,7 +195,6 @@ async def get_round_updates(self):
             logging.info(f"Missing updates from sources: {updates_missing}")
         else:
             self._missing_ones.clear()
-
         self._nodes_using_historic.clear()
         updates = {}
         for sr in self._sources_received:

diff --git a/nebula/core/aggregation/updatehandlers/sdflupdatehandler.py b/nebula/core/aggregation/updatehandlers/sdflupdatehandler.py
diff --git a/nebula/core/aggregation/updatehandlers/updatehandler.py b/nebula/core/aggregation/updatehandlers/updatehandler.py
diff --git a/nebula/core/engine.py b/nebula/core/engine.py
@@ -158,7 +158,7 @@ def __init__(
         else:
             self._situational_awareness = None
 
-        if self.config.participant["defense_args"]["reputation"]["enabled"]:
+        if self.config.participant["defense_args"]["reputation"]["with_reputation"]:
             self._reputation = Reputation(engine=self, config=self.config)
 
     @property
@@ -354,6 +354,27 @@ async def _federation_federation_start_callback(self, source, message):
         logging.info(f"📝  handle_federation_message | Trigger | Received start federation message from {source}")
         await self.create_trainer_module()
 
+    async def _reputation_share_callback(self, source, message):
+        try:
+            logging.info(f"handle_reputation_message | Trigger | Received reputation message from {source} | Node: {message.node_id} | Score: {message.score} | Round: {message.round}")
+
+            current_node = self.addr
+            nei = message.node_id
+
+            if hasattr(self, '_reputation') and self._reputation is not None:
+                if current_node != nei:
+                    key = (current_node, nei, message.round)
+
+                    if key not in self._reputation.reputation_with_all_feedback:
+                        self._reputation.reputation_with_all_feedback[key] = []
+
+                    self._reputation.reputation_with_all_feedback[key].append(message.score)
+            else:
+                logging.error("Reputation object (_reputation) is not available.")
+
+        except Exception as e:
+            logging.exception(f"Error handling reputation message: {e}")
+
     async def _federation_federation_models_included_callback(self, source, message):
         logging.info(f"📝  handle_federation_message | Trigger | Received aggregation finished message from {source}")
 
@@ -591,7 +612,7 @@ async def deploy_components(self):
         await self.aggregator.init()
         if "situational_awareness" in self.config.participant:
             await self.sa.init()
-        if self.config.participant["defense_args"]["reputation"]["enabled"]:
+        if self.config.participant["defense_args"]["reputation"]["with_reputation"]:
             await self._reputation.setup()
         await self._reporter.start()
         await self._addon_manager.deploy_additional_services()

diff --git a/nebula/core/nebulaevents.py b/nebula/core/nebulaevents.py
@@ -333,6 +333,26 @@ async def get_event_data(self) -> tuple[str, tuple[float, float]]:
 
     async def is_concurrent(self) -> bool:
         return True
+
+class DuplicatedMessageEvent(NodeEvent):
+    """
+    Event triggered when a message is received that has already been processed.
+
+    Attributes:
+        source (str): The address of the node that sent the duplicated message.
+    """
+
+    def __init__(self, source: str, message_type: str):
+        self.source = source
+
+    def __str__(self):
+        return f"DuplicatedMessageEvent from {self.source}"
+
+    async def get_event_data(self) -> tuple[str]:
+        return (self.source)
+
-        self.source = source
-
-    def __str__(self):
-        return f"DuplicatedMessageEvent from {self.source}"
-
-    async def get_event_data(self) -> tuple[str]:
-        return (self.source)
+        super().__init__()  # Ensure proper initialization of the base class
+        self.source = source
+        self.message_type = message_type
+
+    def __str__(self):
+        return f"DuplicatedMessageEvent from {self.source}, type: {self.message_type}"
+
+    async def get_event_data(self) -> tuple[str, str]:
+        """
+        Retrieves the event data.
+
+        Returns:
+            tuple[str, str]: A tuple containing:
+                - The source of the duplicated message.
+                - The type of the duplicated message.
+        """
+        return (self.source, self.message_type)
-        self.source = source
-
-    def __str__(self):
-        return f"DuplicatedMessageEvent from {self.source}"
-
-    async def get_event_data(self) -> tuple[str]:
-        return (self.source)
+        super().__init__()  # Ensure proper initialization of the base class
+        self.source = source
+        self.message_type = message_type
+
+    def __str__(self):
+        return f"DuplicatedMessageEvent from {self.source}, type: {self.message_type}"
+
+    async def get_event_data(self) -> tuple[str, str]:
+        """
+        Retrieves the event data.
+
+        Returns:
+            tuple[str, str]: A tuple containing:
+                - The source of the duplicated message.
+                - The type of the duplicated message.
+        """
+        return (self.source, self.message_type)
+    async def is_concurrent(self) -> bool:
+        return True
 
 
 """                                                     ##############################

diff --git a/nebula/core/network/actions.py b/nebula/core/network/actions.py
diff --git a/nebula/core/network/blacklist.py b/nebula/core/network/blacklist.py
diff --git a/nebula/core/network/communications.py b/nebula/core/network/communications.py
@@ -6,7 +6,7 @@
 import requests
 
 from nebula.core.eventmanager import EventManager
-from nebula.core.nebulaevents import MessageEvent
+from nebula.core.nebulaevents import MessageEvent, DuplicatedMessageEvent
 from nebula.core.network.blacklist import BlackList
 from nebula.core.network.connection import Connection
 from nebula.core.network.discoverer import Discoverer
@@ -803,7 +803,7 @@ async def deploy_additional_services(self):
         await self._forwarder.start()
         self._propagator.start()
 
-    async def include_received_message_hash(self, hash_message):
+    async def include_received_message_hash(self, hash_message, source=None):
         """
         Adds a received message hash to the tracking list if it hasn't been seen before.
 
@@ -819,6 +819,8 @@ async def include_received_message_hash(self, hash_message):
             await self.receive_messages_lock.acquire_async()
             if hash_message in self.received_messages_hashes:
                 logging.info("❗️  handle_incoming_message | Ignoring message already received.")
+                duplicated_event = DuplicatedMessageEvent(source, "Duplicated message received")
+                asyncio.create_task(EventManager.get_instance().publish_node_event(duplicated_event))
                 return False
             self.received_messages_hashes.append(hash_message)
             if len(self.received_messages_hashes) % 10000 == 0:

diff --git a/nebula/core/network/externalconnection/externalconnectionservice.py b/nebula/core/network/externalconnection/externalconnectionservice.py
diff --git a/nebula/core/network/externalconnection/nebuladiscoveryservice.py b/nebula/core/network/externalconnection/nebuladiscoveryservice.py
diff --git a/nebula/core/network/messages.py b/nebula/core/network/messages.py
@@ -151,7 +151,7 @@ async def process_message(self, data, addr_from):
 
             # Message-specific forwarding and processing
             elif message_type in special_processing_messages:
-                if await self.cm.include_received_message_hash(hashlib.md5(data).hexdigest()):
+                if await self.cm.include_received_message_hash(hashlib.md5(data).hexdigest(), addr_from):
                     # Forward the message if required
                     if self._should_forward_message(message_type, message_wrapper):
                         await self.cm.forward_message(data, addr_from)

diff --git a/nebula/core/pb/nebula_pb2.py b/nebula/core/pb/nebula_pb2.py
diff --git a/nebula/core/situationalawareness/__init__.py b/nebula/core/situationalawareness/__init__.py
diff --git a/nebula/core/situationalawareness/awareness/arbitrationpolicies/arbitrationpolicy.py b/nebula/core/situationalawareness/awareness/arbitrationpolicies/arbitrationpolicy.py
diff --git a/nebula/core/situationalawareness/awareness/arbitrationpolicies/staticarbitrationpolicy.py b/nebula/core/situationalawareness/awareness/arbitrationpolicies/staticarbitrationpolicy.py
diff --git a/nebula/core/situationalawareness/awareness/sanetwork/neighborpolicies/__init__.py b/nebula/core/situationalawareness/awareness/sanetwork/neighborpolicies/__init__.py
diff --git a/.../core/situationalawareness/awareness/sanetwork/neighborpolicies/distanceneighborpolicy.py b/.../core/situationalawareness/awareness/sanetwork/neighborpolicies/distanceneighborpolicy.py
diff --git a/nebula/core/situationalawareness/awareness/sanetwork/neighborpolicies/fcneighborpolicy.py b/nebula/core/situationalawareness/awareness/sanetwork/neighborpolicies/fcneighborpolicy.py
diff --git a/nebula/core/situationalawareness/awareness/sanetwork/neighborpolicies/idleneighborpolicy.py b/nebula/core/situationalawareness/awareness/sanetwork/neighborpolicies/idleneighborpolicy.py
diff --git a/nebula/core/situationalawareness/awareness/sanetwork/neighborpolicies/neighborpolicy.py b/nebula/core/situationalawareness/awareness/sanetwork/neighborpolicies/neighborpolicy.py
diff --git a/nebula/core/situationalawareness/awareness/sanetwork/neighborpolicies/ringneighborpolicy.py b/nebula/core/situationalawareness/awareness/sanetwork/neighborpolicies/ringneighborpolicy.py
diff --git a/nebula/core/situationalawareness/awareness/sanetwork/neighborpolicies/starneighborpolicy.py b/nebula/core/situationalawareness/awareness/sanetwork/neighborpolicies/starneighborpolicy.py
diff --git a/nebula/core/situationalawareness/awareness/sanetwork/sanetwork.py b/nebula/core/situationalawareness/awareness/sanetwork/sanetwork.py
diff --git a/nebula/core/situationalawareness/awareness/sareasoner.py b/nebula/core/situationalawareness/awareness/sareasoner.py
diff --git a/nebula/core/situationalawareness/awareness/sautils/sacommand.py b/nebula/core/situationalawareness/awareness/sautils/sacommand.py
diff --git a/nebula/core/situationalawareness/awareness/sautils/samoduleagent.py b/nebula/core/situationalawareness/awareness/sautils/samoduleagent.py
diff --git a/nebula/core/situationalawareness/awareness/sautils/sasystemmonitor.py b/nebula/core/situationalawareness/awareness/sautils/sasystemmonitor.py
diff --git a/nebula/core/situationalawareness/awareness/suggestionbuffer.py b/nebula/core/situationalawareness/awareness/suggestionbuffer.py
diff --git a/nebula/core/situationalawareness/discovery/candidateselection/__init__.py b/nebula/core/situationalawareness/discovery/candidateselection/__init__.py
diff --git a/nebula/core/situationalawareness/discovery/candidateselection/candidateselector.py b/nebula/core/situationalawareness/discovery/candidateselection/candidateselector.py
diff --git a/nebula/core/situationalawareness/discovery/candidateselection/distcandidateselector.py b/nebula/core/situationalawareness/discovery/candidateselection/distcandidateselector.py
diff --git a/nebula/core/situationalawareness/discovery/candidateselection/fccandidateselector.py b/nebula/core/situationalawareness/discovery/candidateselection/fccandidateselector.py
diff --git a/nebula/core/situationalawareness/discovery/candidateselection/ringcandidateselector.py b/nebula/core/situationalawareness/discovery/candidateselection/ringcandidateselector.py
diff --git a/nebula/core/situationalawareness/discovery/candidateselection/stdcandidateselector.py b/nebula/core/situationalawareness/discovery/candidateselection/stdcandidateselector.py
diff --git a/nebula/core/situationalawareness/discovery/federationconnector.py b/nebula/core/situationalawareness/discovery/federationconnector.py
diff --git a/nebula/core/situationalawareness/discovery/modelhandlers/__init__.py b/nebula/core/situationalawareness/discovery/modelhandlers/__init__.py
diff --git a/nebula/core/situationalawareness/discovery/modelhandlers/aggmodelhandler.py b/nebula/core/situationalawareness/discovery/modelhandlers/aggmodelhandler.py
diff --git a/nebula/core/situationalawareness/discovery/modelhandlers/defaultmodelhandler.py b/nebula/core/situationalawareness/discovery/modelhandlers/defaultmodelhandler.py
diff --git a/nebula/core/situationalawareness/discovery/modelhandlers/modelhandler.py b/nebula/core/situationalawareness/discovery/modelhandlers/modelhandler.py
diff --git a/nebula/core/situationalawareness/discovery/modelhandlers/stdmodelhandler.py b/nebula/core/situationalawareness/discovery/modelhandlers/stdmodelhandler.py
diff --git a/nebula/core/situationalawareness/situationalawareness.py b/nebula/core/situationalawareness/situationalawareness.py
diff --git a/nebula/core/utils/tasks.py b/nebula/core/utils/tasks.py
diff --git a/nebula/frontend/config/participant.json.example b/nebula/frontend/config/participant.json.example
@@ -93,9 +93,9 @@
   },
   "defense_args": {
     "reputation": {
-      "enabled": false,
-      "metrics": {},
-      "initial_reputation": 0.6,
+      "with_reputation": false,
+      "reputation_metrics": [],
+      "initial_reputation": 0.2,
       "weighting_factor": "dynamic"
     }
   },

diff --git a/nebula/frontend/static/css/dashboard.css b/nebula/frontend/static/css/dashboard.css
diff --git a/nebula/frontend/static/css/deployment.css b/nebula/frontend/static/css/deployment.css
diff --git a/nebula/frontend/static/css/particles.css b/nebula/frontend/static/css/particles.css
diff --git a/nebula/frontend/static/images/physical-device.png b/nebula/frontend/static/images/physical-device.png
diff --git a/nebula/frontend/static/js/dashboard/config-manager.js b/nebula/frontend/static/js/dashboard/config-manager.js
diff --git a/nebula/frontend/static/js/dashboard/dashboard.js b/nebula/frontend/static/js/dashboard/dashboard.js
diff --git a/nebula/frontend/static/js/dashboard/notes-manager.js b/nebula/frontend/static/js/dashboard/notes-manager.js
diff --git a/nebula/frontend/static/js/dashboard/scenario-actions.js b/nebula/frontend/static/js/dashboard/scenario-actions.js
diff --git a/nebula/frontend/static/js/deployment/attack.js b/nebula/frontend/static/js/deployment/attack.js
diff --git a/nebula/frontend/static/js/deployment/graph-settings.js b/nebula/frontend/static/js/deployment/graph-settings.js
diff --git a/nebula/frontend/static/js/deployment/help-content.js b/nebula/frontend/static/js/deployment/help-content.js
diff --git a/nebula/frontend/static/js/deployment/main.js b/nebula/frontend/static/js/deployment/main.js
diff --git a/nebula/frontend/static/js/deployment/mobility.js b/nebula/frontend/static/js/deployment/mobility.js
diff --git a/nebula/frontend/static/js/deployment/reputation.js b/nebula/frontend/static/js/deployment/reputation.js
@@ -60,70 +60,62 @@ const ReputationManager = (function() {
     }
 
     function getReputationConfig() {
+        const rep_metrics = [];
+
+        if (document.getElementById("model-similarity").checked)
+            rep_metrics.push("model_similarity");
+        if (document.getElementById("num-messages").checked)
+            rep_metrics.push("num_messages");
+        if (document.getElementById("model-arrival-latency").checked)
+            rep_metrics.push("model_arrival_latency");
+        if (document.getElementById("fraction-parameters-changed").checked)
+            rep_metrics.push("fraction_parameters_changed");
+
         return {
-            enabled: document.getElementById("reputationSwitch").checked,
-            initialReputation: parseFloat(document.getElementById("initial-reputation").value),
-            weightingFactor: document.getElementById("weighting-factor").value,
-            metrics: {
-                model_similarity: {
-                    enabled: document.getElementById("model-similarity").checked,
-                    weight: parseFloat(document.getElementById("weight-model-similarity").value)
-                },
-                num_messages: {
-                    enabled: document.getElementById("num-messages").checked,
-                    weight: parseFloat(document.getElementById("weight-num-messages").value)
-                },
-                model_arrival_latency: {
-                    enabled: document.getElementById("model-arrival-latency").checked,
-                    weight: parseFloat(document.getElementById("weight-model-arrival-latency").value)
-                },
-                fraction_parameters_changed: {
-                    enabled: document.getElementById("fraction-parameters-changed").checked,
-                    weight: parseFloat(document.getElementById("weight-fraction-parameters-changed").value)
-                }
-            }
+            with_reputation: document.getElementById("reputationSwitch").checked,
+            reputation_metrics: rep_metrics,
+            initial_reputation: parseFloat(document.getElementById("initial-reputation").value),
+            weighting_factor: document.getElementById("weighting-factor").value,
+            weight_model_arrival_latency: parseFloat(document.getElementById("weight-model-arrival-latency").value),
+            weight_model_similarity: parseFloat(document.getElementById("weight-model-similarity").value),
+            weight_num_messages: parseFloat(document.getElementById("weight-num-messages").value),
+            weight_fraction_params_changed: parseFloat(document.getElementById("weight-fraction-parameters-changed").value),
         };
     }
 
     function setReputationConfig(config) {
         if (!config) return;
 
-        // Set reputation enabled/disabled
-        document.getElementById("reputationSwitch").checked = config.enabled;
-        document.getElementById("reputation-metrics").style.display = config.enabled ? "block" : "none";
-        document.getElementById("reputation-settings").style.display = config.enabled ? "block" : "none";
-        document.getElementById("weighting-settings").style.display = config.enabled ? "block" : "none";
+        const enabled = config.with_reputation ?? config.enabled ?? false;
+
+        // Set reputation switch and visibility
+        document.getElementById("reputationSwitch").checked = enabled;
+        document.getElementById("reputation-metrics").style.display = enabled ? "block" : "none";
+        document.getElementById("reputation-settings").style.display = enabled ? "block" : "none";
+        document.getElementById("weighting-settings").style.display = enabled ? "block" : "none";
 
-        // Set initial reputation
-        document.getElementById("initial-reputation").value = config.initialReputation || 0.6;
+        // Initial reputation and weighting factor
+        document.getElementById("initial-reputation").value = config.initial_reputation ?? config.initialReputation ?? 0.2;
+        document.getElementById("weighting-factor").value = config.weighting_factor ?? config.weightingFactor ?? "dynamic";
 
-        // Set weighting factor
-        document.getElementById("weighting-factor").value = config.weightingFactor || "dynamic";
-        const showWeights = config.weightingFactor === "static";
+        const showWeights = (config.weighting_factor ?? config.weightingFactor) === "static";
         document.querySelectorAll(".weight-input").forEach(input => {
             input.style.display = showWeights ? "inline-block" : "none";
         });
 
-        // Set metrics
-        if (config.metrics) {
-            // Model Similarity
-            document.getElementById("model-similarity").checked = config.metrics.modelSimilarity?.enabled || false;
-            document.getElementById("weight-model-similarity").value = config.metrics.modelSimilarity?.weight || 0;
+        // Metrics (both legacy flat and nested)
+        document.getElementById("model-similarity").checked = config.reputation_metrics?.includes("modelSimilarity") ?? config.metrics?.modelSimilarity?.enabled ?? false;
+        document.getElementById("weight-model-similarity").value = config.weight_model_similarity ?? config.metrics?.modelSimilarity?.weight ?? 0;
 
-            // Number of Messages
-            document.getElementById("num-messages").checked = config.metrics.numMessages?.enabled || false;
-            document.getElementById("weight-num-messages").value = config.metrics.numMessages?.weight || 0;
+        document.getElementById("num-messages").checked = config.reputation_metrics?.includes("numMessages") ?? config.metrics?.numMessages?.enabled ?? false;
+        document.getElementById("weight-num-messages").value = config.weight_num_messages ?? config.metrics?.numMessages?.weight ?? 0;
 
-            // Model Arrival Latency
-            document.getElementById("model-arrival-latency").checked = config.metrics.modelArrivalLatency?.enabled || false;
-            document.getElementById("weight-model-arrival-latency").value = config.metrics.modelArrivalLatency?.weight || 0;
+        document.getElementById("model-arrival-latency").checked = config.reputation_metrics?.includes("modelArrivalLatency") ?? config.metrics?.modelArrivalLatency?.enabled ?? false;
+        document.getElementById("weight-model-arrival-latency").value = config.weight_model_arrival_latency ?? config.metrics?.modelArrivalLatency?.weight ?? 0;
 
-            // Fraction Parameters Changed
-            document.getElementById("fraction-parameters-changed").checked = config.metrics.fractionParametersChanged?.enabled || false;
-            document.getElementById("weight-fraction-parameters-changed").value = config.metrics.fractionParametersChanged?.weight || 0;
-        }
+        document.getElementById("fraction-parameters-changed").checked = config.reputation_metrics?.includes("fractionParametersChanged") ?? config.metrics?.fractionParametersChanged?.enabled ?? false;
+        document.getElementById("weight-fraction-parameters-changed").value = config.weight_fraction_params_changed ?? config.metrics?.fractionParametersChanged?.weight ?? 0;
 
-        // Validate weights
         validateWeights();
     }
 
@@ -133,7 +125,7 @@ const ReputationManager = (function() {
         document.getElementById("reputation-metrics").style.display = "none";
         document.getElementById("reputation-settings").style.display = "none";
         document.getElementById("weighting-settings").style.display = "none";
-        document.getElementById("initial-reputation").value = "0.6";
+        document.getElementById("initial-reputation").value = "0.2";
         document.getElementById("weighting-factor").value = "dynamic";
         document.getElementById("weight-warning").style.display = "none";
 

diff --git a/nebula/frontend/static/js/deployment/scenario.js b/nebula/frontend/static/js/deployment/scenario.js
@@ -75,12 +75,7 @@ const ScenarioManager = (function() {
             report_status_data_queue: document.getElementById("reportingSwitch").checked,
             epochs: parseInt(document.getElementById("epochs").value),
             attack_params: attackConfig,
-            reputation: {
-                enabled: window.ReputationManager.getReputationConfig().enabled || false,
-                metrics: window.ReputationManager.getReputationConfig().metrics || {},
-                initial_reputation: window.ReputationManager.getReputationConfig().initialReputation || 0.6,
-                weighting_factor: window.ReputationManager.getReputationConfig().weightingFactor || "dynamic"
-            },
+            reputation: window.ReputationManager.getReputationConfig(),
             mobility: window.MobilityManager.getMobilityConfig().enabled || false,
             network_simulation: window.MobilityManager.getMobilityConfig().network_simulation || false,
             mobility_type: window.MobilityManager.getMobilityConfig().mobilityType || "random",

diff --git a/nebula/frontend/static/js/deployment/situational-awareness.js b/nebula/frontend/static/js/deployment/situational-awareness.js
diff --git a/nebula/frontend/static/js/deployment/topology.js b/nebula/frontend/static/js/deployment/topology.js
diff --git a/nebula/frontend/static/js/deployment/ui-controls.js b/nebula/frontend/static/js/deployment/ui-controls.js
diff --git a/nebula/frontend/static/js/deployment/utils.js b/nebula/frontend/static/js/deployment/utils.js
diff --git a/nebula/frontend/static/js/monitor/monitor.js b/nebula/frontend/static/js/monitor/monitor.js
diff --git a/nebula/frontend/static/js/particles.json b/nebula/frontend/static/js/particles.json
diff --git a/nebula/frontend/static/js/particles.min.js b/nebula/frontend/static/js/particles.min.js
diff --git a/nebula/utils.py b/nebula/utils.py
diff --git a/pyproject.toml b/pyproject.toml