Update stt/stt_google.py

stt/stt_google.py

@@ -91,7 +91,10 @@ class GoogleCloudSTT(STTInterface):
             "OGG_OPUS": speech.RecognitionConfig.AudioEncoding.OGG_OPUS,
         }
         return encoding_map.get(encoding_str, speech.RecognitionConfig.AudioEncoding.WEBM_OPUS)
-        
+    
+    # Alias for compatibility
+    _get_google_encoding = _get_encoding
+    
     async def stream_audio(self, audio_chunk: bytes) -> AsyncGenerator[TranscriptionResult, None]:
         """Stream audio chunk and get results"""
         if not self.is_streaming:
@@ -428,4 +431,57 @@ class GoogleCloudSTT(STTInterface):
                 
                 # Log response
                 has_results = len(response.results) > 0 if hasattr(response, 'results') else False
-                log_info(f"📨 Google STT Response #{response_count}: has_results={has_results}")
+                log_info(f"📨 Google STT Response #{response_count}: has_results={has_results}")
+                
+                if not response.results:
+                    continue
+                
+                # Process results
+                for result_idx, result in enumerate(response.results):
+                    # Check result type
+                    result_type = "🔄 INTERIM" if not result.is_final else "✅ FINAL"
+                    stability = getattr(result, 'stability', 0.0)
+                    
+                    log_info(f"{result_type} Result #{result_idx}: "
+                            f"alternatives={len(result.alternatives)}, "
+                            f"stability={stability:.3f}")
+                    
+                    if result.alternatives:
+                        best_alternative = result.alternatives[0]
+                        transcript = best_alternative.transcript
+                        confidence = best_alternative.confidence if result.is_final else stability
+                        
+                        # Log transcript
+                        if result.is_final:
+                            log_info(f"✅ FINAL TRANSCRIPT: '{transcript}' "
+                                    f"(confidence: {confidence:.3f})")
+                        else:
+                            log_info(f"🔄 INTERIM TRANSCRIPT: '{transcript[:100]}...' "
+                                    f"(stability: {stability:.3f})")
+                        
+                        # Queue result
+                        result_obj = TranscriptionResult(
+                            text=transcript,
+                            is_final=result.is_final,
+                            confidence=confidence,
+                            timestamp=datetime.utcnow()
+                        )
+                        
+                        self.responses_queue.put(result_obj)
+                        log_info(f"📥 {'FINAL' if result.is_final else 'INTERIM'} result queued")
+            
+            # Log completion
+            if response_count == 0:
+                log_error("❌ Google STT stream ended without ANY responses!")
+            else:
+                log_info(f"✅ Google STT stream ended normally after {response_count} responses")
+                
+        except Exception as e:
+            log_error(f"❌ Google STT error: {e}")
+            if hasattr(e, 'details'):
+                log_error(f"Error details: {e.details}")
+            self.error_message = str(e)
+        finally:
+            log_info("🎤 Google STT stream thread ended")
+            with self.lock:
+                self.is_streaming = False