Update app.py

app.py

@@ -101,28 +101,24 @@ class OpenFloorResearchAgent:
     def handle_utterance_event(self, envelope: Envelope) -> Envelope:
         """Handle research requests from AI experts"""
         print(f"🔍 DEBUG: {self.tool.name} - Starting handle_utterance_event")
-        print(f"🔍 DEBUG: Envelope has {len(envelope.events)} events")
         
         # Extract the query from the utterance
-        for i, event in enumerate(envelope.events):
-            print(f"🔍 DEBUG: Event {i}: {type(event)} - hasattr eventType: {hasattr(event, 'eventType')}")
-            
-            if hasattr(event, 'eventType'):
-                print(f"🔍 DEBUG: Event {i} eventType: {event.eventType}")
+        for event in envelope.events:
+            if hasattr(event, 'eventType') and event.eventType == 'utterance':
+                dialog_event = event.parameters.get('dialogEvent')
                 
-                if event.eventType == 'utterance':
-                    print(f"🔍 DEBUG: Found utterance event, getting parameters...")
-                    dialog_event = event.parameters.get('dialogEvent')
-                    print(f"🔍 DEBUG: dialog_event: {type(dialog_event)}")
+                if dialog_event and isinstance(dialog_event, dict):
+                    # dialog_event is a dict, not an object - use dict access
+                    features = dialog_event.get('features')
+                    print(f"🔍 DEBUG: features: {features}")
                     
-                    if dialog_event and hasattr(dialog_event, 'features'):
-                        print(f"🔍 DEBUG: dialog_event has features")
-                        text_feature = dialog_event.features.get('text')
-                        print(f"🔍 DEBUG: text_feature: {type(text_feature)}")
+                    if features and 'text' in features:
+                        text_feature = features['text']
+                        print(f"🔍 DEBUG: text_feature: {text_feature}")
                         
-                        if text_feature and hasattr(text_feature, 'tokens'):
-                            print(f"🔍 DEBUG: text_feature has {len(text_feature.tokens)} tokens")
-                            query_text = ' '.join([token.get('value', '') for token in text_feature.tokens])
+                        if 'tokens' in text_feature:
+                            tokens = text_feature['tokens']
+                            query_text = ' '.join([token.get('value', '') for token in tokens])
                             
                             print(f"🔍 DEBUG: {self.tool.name} received query: '{query_text}'")
                             
@@ -138,16 +134,7 @@ class OpenFloorResearchAgent:
                             
                             # Create response envelope
                             return self._create_response_envelope(envelope, research_result, query_text)
-                        else:
-                            print(f"🔍 DEBUG: text_feature doesn't have tokens or is None")
-                    else:
-                        print(f"🔍 DEBUG: dialog_event doesn't have features or is None")
-                else:
-                    print(f"🔍 DEBUG: Event {i} is not utterance, skipping")
-            else:
-                print(f"🔍 DEBUG: Event {i} doesn't have eventType attribute")
         
-        print(f"🔍 DEBUG: No valid utterance event found, returning error")
         return self._create_error_response(envelope, "Could not extract query from request")
     
     def _create_response_envelope(self, original_envelope: Envelope, research_result: str, query: str) -> Envelope: