added

Author: Luismpso

.gitignore

@@ -33,5 +33,11 @@ prosody-data/
 *.log
 logs/
 
+# Coverage / test artifacts
+.coverage
+.coverage.*
+htmlcov/
+.pytest_cache/
+
 # Jupyter (se usado)
 .ipynb_checkpoints/

README.md

@@ -4,7 +4,7 @@
 ![SPADE](https://img.shields.io/badge/SPADE-3.3+-green)
 ![FIPA-ACL](https://img.shields.io/badge/Protocol-FIPA--ACL-orange)
 ![XMPP](https://img.shields.io/badge/Transport-XMPP-blueviolet)
-![Tests](https://img.shields.io/badge/tests-193%20passed-brightgreen)
+![Tests](https://img.shields.io/badge/tests-203%20passed-brightgreen)
 ![Coverage](https://img.shields.io/badge/coverage-64%25-green)
 ![Lint](https://img.shields.io/badge/ruff-clean-brightgreen)
 ![License](https://img.shields.io/badge/License-Academic-lightgrey)
@@ -169,7 +169,7 @@ SmartStudyRoom/
 │   ├── massive_negotiation.py         #   Contract Net massivo (throughput)
 │   └── multi_campus_cfp.py            #   Escalação multicampus via GlobalCoord.
 │
-├── tests/                             # 193 testes pytest (unit + integração)
+├── tests/                             # 203 testes pytest (unit + integração)
 │   ├── test_ontology.py, test_fipa.py, test_config.py, …
 │   └── test_contract_net.py implícito em test_coordinator_async.py
 │
@@ -278,7 +278,7 @@ Editar `config.py` ou definir variáveis de ambiente:
 
 ## 🧪 Testes
 
-Suite de 193 testes (unit + assíncronos) com configuração em `pyproject.toml`:
+Suite de 203 testes (unit + assíncronos) com configuração em `pyproject.toml`:
 
 ```bash
 # Correr todos os testes

agents/energy_agent.py

@@ -23,9 +23,8 @@
 ADJUSTMENTS_HISTORY_LIMIT = 100
 
 
-def compute_energy_utility(env, occupancy_ratio: float,
-                           weights: dict = ENERGY_UTILITY_WEIGHTS) -> float:
-    """Função de utilidade pura: U = we·E + wc·(1−C) + wq·(1−Q).
+def energy_indices(env, occupancy_ratio: float) -> tuple[float, float, float]:
+    """Componentes (E, C, Q) da função de utilidade energética — fonte única.
 
     E = custo energético estimado (aumenta com ocupação)
     C = índice de conforto (temperatura+ruído normalizados) ∈ [0,1]
@@ -36,6 +35,13 @@ def compute_energy_utility(env, occupancy_ratio: float,
     noise_ok = 1.0 if env.noise <= TH["noise"]["max"] else 0.3
     C = (temp_ok + noise_ok) / 2.0
     Q = max(0.0, min(1.0, 1.0 - (env.co2 - 400) / 1000))
+    return E, C, Q
+
+
+def compute_energy_utility(env, occupancy_ratio: float,
+                           weights: dict = ENERGY_UTILITY_WEIGHTS) -> float:
+    """Função de utilidade pura: U = we·E + wc·(1−C) + wq·(1−Q)."""
+    E, C, Q = energy_indices(env, occupancy_ratio)
     return weights["energy"] * E + weights["comfort"] * (1 - C) + weights["air_quality"] * (1 - Q)
 
 
@@ -190,11 +196,9 @@ async def run(self):
                 env = room.environment
                 occupancy_ratio = room.occupied_seats / max(room.total_seats, 1)
 
-                E = occupancy_ratio * 0.5 + 0.3
-                temp_ok = 1.0 if TH["temperature"]["min"] <= env.temperature <= TH["temperature"]["max"] else 0.5
-                noise_ok = 1.0 if env.noise <= TH["noise"]["max"] else 0.3
-                C = (temp_ok + noise_ok) / 2.0
-                Q = max(0.0, min(1.0, 1.0 - (env.co2 - 400) / 1000))
+                # Componentes partilhados com compute_energy_utility (fonte única):
+                # afinar a fórmula em energy_indices propaga-se aos dois sítios.
+                E, C, Q = energy_indices(env, occupancy_ratio)
                 U = agent.we * E + agent.wc * (1 - C) + agent.wq * (1 - Q)
 
                 action = "maintain"

agents/room_agent.py

@@ -62,13 +62,23 @@ def map_action_to_parameter(action: str) -> str:
 
 
 def compute_comfort_score(env) -> float:
-    """Score de conforto ∈ [0,1] usado nas PROPOSE do Contract Net."""
+    """Score de conforto contínuo ∈ [0,1] para ordenar PROPOSEs no Contract Net.
+
+    NOTA DE DESIGN: os limiares aqui são *deliberadamente mais apertados* do que
+    os limiares "duros" de COMFORT_THRESHOLDS usados por Room._check_comfort /
+    comfort_ok (CO2 ≤ 1000 ppm, ruído ≤ 60 dB). A intenção é que este score seja
+    um discriminador mais fino entre salas que estão todas dentro do limite duro
+    (comfort_ok=True): uma sala a 900 ppm continua "ok" mas é menos desejável do
+    que outra a 450 ppm, e o score capta essa diferença ao penalizar mais cedo.
+    Não é uma inconsistência mas uma escolha: comfort_ok responde "aceitável?";
+    comfort_score responde "quão bom?".
+    """
     comfort_score = 1.0
-    if env.temperature < 18 or env.temperature > 26:
+    if env.temperature < 18 or env.temperature > 26:   # banda de conforto (= config)
         comfort_score -= 0.3
-    if env.co2 > 800:
+    if env.co2 > 800:                                   # soft: abaixo do limiar duro (1000)
         comfort_score -= 0.2
-    if env.noise > 50:
+    if env.noise > 50:                                  # soft: abaixo do limiar duro (60)
         comfort_score -= 0.2
     return max(0.0, comfort_score)
 

config.py

@@ -18,8 +18,8 @@ def jid(agent_name: str) -> str:
 
 # --- Configuração do Campus ---
 # Totais garantidos: 2 bibliotecas, 6 salas, 22 mesas, 104 lugares
-# Biblioteca Geral (BG): 4 salas, 15 mesas, 68 lugares
-# Biblioteca Azurém (BA): 2 salas, 7 mesas, 36 lugares
+# Biblioteca Geral (BG): 4 salas, 14 mesas, 68 lugares
+# Biblioteca Azurém (BA): 2 salas, 8 mesas, 36 lugares
 CAMPUS_CONFIG = {
     "campus_id": "C1",
     "campus_name": "Campus Gualtar",

main.py

@@ -10,18 +10,8 @@
 import random
 import signal
 import sys
-# --- Patch slixmpp para permitir SASL PLAIN/SCRAM sem TLS (dev local) ---
-# Por default o slixmpp recusa autenticar sem encriptação; em dev local com
-# Prosody em internal_plain isso impede o login. Habilitamos os mecanismos
-# inseguros porque toda a comunicação fica em loopback (127.0.0.1).
+
 import slixmpp
-_orig_xmpp_init = slixmpp.ClientXMPP.__init__
-def _patched_xmpp_init(self, *args, **kwargs):
-    _orig_xmpp_init(self, *args, **kwargs)
-    self["feature_mechanisms"].unencrypted_plain = True
-    self["feature_mechanisms"].unencrypted_scram = True
-    self["feature_starttls"].do_starttls = False     
-slixmpp.ClientXMPP.__init__ = _patched_xmpp_init
 
 from agents.comfort_agent import ComfortAgent
 from agents.coordinator_agent import CoordinatorAgent
@@ -51,6 +41,25 @@ def _patched_xmpp_init(self, *args, **kwargs):
 from simulation.mqtt_bus import MQTTSensorPublisher
 from simulation.mqtt_bus import is_available as mqtt_available
 
+# --- Patch slixmpp para permitir SASL PLAIN/SCRAM sem TLS (dev local) ---
+# Por default o slixmpp recusa autenticar sem encriptação; em dev local com
+# Prosody em internal_plain isso impede o login. Habilitamos os mecanismos
+# inseguros porque toda a comunicação fica em loopback (127.0.0.1).
+# O patch é aplicado a nível de módulo (antes de qualquer agent.start()); a
+# importação de SPADE acima não instancia nenhum ClientXMPP, apenas regista as
+# classes, pelo que o monkey-patch entra em vigor antes do primeiro cliente.
+_orig_xmpp_init = slixmpp.ClientXMPP.__init__
+
+
+def _patched_xmpp_init(self, *args, **kwargs):
+    _orig_xmpp_init(self, *args, **kwargs)
+    self["feature_mechanisms"].unencrypted_plain = True
+    self["feature_mechanisms"].unencrypted_scram = True
+    self["feature_starttls"].do_starttls = False
+
+
+slixmpp.ClientXMPP.__init__ = _patched_xmpp_init
+
 # ─── Logging ─────────────────────────────────────────────────────────────────
 
 configure_logging(level="INFO", to_file=True)
@@ -153,10 +162,20 @@ async def main():
     # em valor 0 desde o arranque.
     from core.metrics import (
         active_negotiations as _an,
+    )
+    from core.metrics import (
         cfp_sent_total as _cs,
+    )
+    from core.metrics import (
         escalations_total as _es,
+    )
+    from core.metrics import (
         proposals_received_total as _pr,
+    )
+    from core.metrics import (
         redistributions_total as _rt,
+    )
+    from core.metrics import (
         refusals_received_total as _rf,
     )
     for lib in campus.libraries:

scenarios/reproducibility.py

@@ -141,7 +141,7 @@ def run() -> int:
          for i, r in enumerate(runs)],
         ["corrida", "seed", "hash_output"],
     )
-    print(f"\nCorrida controlo (seed diferente):")
+    print("\nCorrida controlo (seed diferente):")
     print(f"  seed={other['seed']}  hash={other_hash}")
 
     # Diff detalhado das corridas com seed fixa (so para inspecao visual)