Update mission_engine.py

mission_engine.py

@@ -329,6 +329,35 @@ class MissionEvaluator:
     """Deterministic logic engine for matching rules against observations."""
     def __init__(self):
         self.active_rules: List[MissionRule] = []
+        # Pre-process the concept map to ensure bidirectional matching
+        self.concept_mirror = self._mirror_concept_map(self.CONCEPT_MAP)
+
+    def _mirror_concept_map(self, original_map: Dict[str, List[str]]) -> Dict[str, set]:
+        """
+        Hardens the CONCEPT_MAP by making it bidirectional and self-referential.
+        If 'person' maps to 'human', then 'human' will now map to 'person'.
+        """
+        mirrored = {}
+        
+        # 1. First, ensure every key is in its own list and create initial sets
+        for key, synonyms in original_map.items():
+            all_words = set(synonyms)
+            all_words.add(key)
+            
+            if key not in mirrored:
+                mirrored[key] = all_words
+            else:
+                mirrored[key].update(all_words)
+                
+            # 2. For every synonym, create a key if it doesn't exist and add the whole group
+            for syn in synonyms:
+                if syn not in mirrored:
+                    mirrored[syn] = all_words
+                else:
+                    mirrored[syn].update(all_words)
+        
+        logger.info(f"[EVALUATOR] Semantic Mirroring complete. Expanded {len(original_map)} concepts into {len(mirrored)} bidirectional links.")
+        return mirrored
 
     def set_rules(self, rules: List[MissionRule]):
         self.active_rules = rules
@@ -477,9 +506,9 @@ class MissionEvaluator:
         # ═══════════════════════════════════════════
         # THREAT / DANGER / EMERGENCY
         # ═══════════════════════════════════════════
-        "danger": ["knife", "gun", "weapon", "fire", "flame", "blood", "fight", "alarm", "scream", "explosion", "threat", "attack", "violence", "aggressive", "sword", "pistol", "rifle", "crash", "collision", "smoke", "broken", "falling", "injured"],
-        "threat": ["knife", "gun", "weapon", "fire", "blood", "fight", "alarm", "scream", "explosion", "attack", "violence", "aggressive", "intruder", "suspicious", "trespassing", "masked", "hooded"],
-        "emergency": ["fire", "smoke", "alarm", "siren", "scream", "crash", "explosion", "injured", "blood", "ambulance", "fallen", "collapse", "unconscious", "drowning"],
+        "danger": ["knife", "gun", "weapon", "fire", "flame", "blood", "fight", "alarm", "scream", "explosion", "threat", "attack", "violence", "aggressive", "sword", "pistol", "rifle", "crash", "collision", "smoke", "broken", "falling", "injured", "hazard", "threat"],
+        "threat": ["knife", "gun", "weapon", "fire", "blood", "fight", "alarm", "scream", "explosion", "attack", "violence", "aggressive", "intruder", "suspicious", "trespassing", "masked", "hooded", "danger", "hostile"],
+        "emergency": ["fire", "smoke", "alarm", "siren", "scream", "crash", "explosion", "injured", "blood", "ambulance", "fallen", "collapse", "unconscious", "drowning", "critical"],
         "accident": ["crash", "collision", "fall", "fallen", "broken", "blood", "damage", "wreck", "injury", "injured", "ambulance", "fire", "smoke", "shattered", "debris", "impact", "overturned", "dent"],
         "crime": ["knife", "gun", "weapon", "masked", "hooded", "stealing", "robbery", "intruder", "trespassing", "suspicious", "fight", "assault", "vandalism", "break-in", "threat"],
         "weapon": ["knife", "gun", "pistol", "rifle", "sword", "blade", "firearm", "machete", "bat", "club", "axe", "hammer"],
@@ -492,7 +521,7 @@ class MissionEvaluator:
         # ═══════════════════════════════════════════
         # HUMAN ACTIVITIES & ACTIONS
         # ═══════════════════════════════════════════
-        "activity": ["walking", "running", "sitting", "standing", "holding", "moving", "talking", "eating", "drinking", "working", "playing", "reading", "typing", "cooking", "cleaning", "dancing", "exercising", "sleeping", "lying", "writing"],
+        "activity": ["walking", "running", "sitting", "standing", "holding", "moving", "talking", "eating", "drinking", "working", "playing", "reading", "typing", "cooking", "cleaning", "dancing", "exercising", "sleeping", "lying", "writing", "person", "man", "woman", "human", "subject", "individual", "boy", "girl", "child", "people"],
         "movement": ["walking", "running", "moving", "jumping", "climbing", "crawling", "dancing", "jogging", "sprinting", "stepping", "marching", "pacing", "sliding"],
         "interaction": ["talking", "speaking", "shaking hands", "hugging", "fighting", "pointing", "waving", "greeting", "kissing", "arguing", "collaborating"],
         "working": ["typing", "writing", "computer", "laptop", "desk", "phone", "meeting", "office", "paperwork", "keyboard", "tool", "construction"],
@@ -524,6 +553,7 @@ class MissionEvaluator:
         # ═══════════════════════════════════════════
         # PEOPLE / IDENTITY
         # ═══════════════════════════════════════════
+        "human": ["human", "person", "man", "woman", "subject", "individual", "boy", "girl", "child", "people"],
         "person": ["person", "man", "woman", "human", "subject", "individual", "boy", "girl", "child", "people", "face", "standing", "walking", "sitting"],
         "man": ["man", "male", "guy", "boy", "gentleman", "person"],
         "woman": ["woman", "female", "lady", "girl", "person"],
@@ -1028,8 +1058,10 @@ class MissionEvaluator:
                     continue
                 positive_sentences.append(s)
             
-            # Combine positive findings for the report-wide verification
+            # Combine positive findings and sanitize special characters (slashes/parentheses)
+            # This allows "standing/active" to match "standing" and "person(s)" to match "person"
             verified_context = " ".join(positive_sentences)
+            verified_context = verified_context.replace("/", " ").replace("(", " ").replace(")", " ")
             
             if not verified_context:
                 continue
@@ -1047,9 +1079,9 @@ class MissionEvaluator:
                 # Literal check
                 if re.search(fr"\b{re.escape(word)}\b", verified_context):
                     word_found = True
-                # Semantic expansion check
-                elif word in self.CONCEPT_MAP:
-                    for kw in self.CONCEPT_MAP[word]:
+                # Semantic expansion check (using the new Bidirectional Mirror)
+                elif word in self.concept_mirror:
+                    for kw in self.concept_mirror[word]:
                         if re.search(fr"\b{re.escape(kw)}\b", verified_context):
                             word_found = True
                             break