Update stt_google.py

stt_google.py

@@ -137,7 +137,8 @@ class GoogleCloudSTT(STTInterface):
             def request_generator():
                 """Generate streaming requests"""
                 chunk_count = 0
-                total_bytes = 0  # Toplam byte sayısı
+                total_bytes = 0
+                first_chunk_processed = False
                 
                 while not self.stop_event.is_set():
                     try:
@@ -153,10 +154,18 @@ class GoogleCloudSTT(STTInterface):
                         if chunk_count == 1:
                             log_info(f"📤 First chunk - size: {len(chunk)} bytes")
                             # Audio header kontrolü (WEBM magic bytes)
-                            if chunk[:4] == b'\x1a\x45\xdf\xa3':
-                                log_info("✅ Valid WEBM header detected")
-                            else:
-                                log_warning(f"⚠️ Unknown audio format, first 4 bytes: {chunk[:4].hex()}")
+                            if len(chunk) >= 4:
+                                if chunk[:4] == b'\x1a\x45\xdf\xa3':
+                                    log_info("✅ Valid WEBM header detected")
+                                    first_chunk_processed = True
+                                else:
+                                    log_error(f"❌ Invalid audio format, first 4 bytes: {chunk[:4].hex()}")
+                                    # Hatalı format, stream'i durdur
+                                    break
+                        
+                        # İlk chunk geçerliyse devam et
+                        if chunk_count == 1 and not first_chunk_processed:
+                            break
                         
                         # Her 100 chunk'ta durum raporu
                         if chunk_count % 100 == 0:
@@ -184,7 +193,7 @@ class GoogleCloudSTT(STTInterface):
                 ) 
                 
                 log_info("✅ Google STT streaming client created")
-
+    
                 # Response timeout kontrolü
                 last_response_time = time.time()
                 RESPONSE_TIMEOUT = 30  # 30 saniye içinde response gelmezse
@@ -196,7 +205,7 @@ class GoogleCloudSTT(STTInterface):
                 for response in responses:
                     last_response_time = time.time()
                     response_count += 1
-
+    
                     # Response type'ı logla
                     if response_count == 1:
                         log_info(f"📨 First response received from Google STT")
@@ -211,7 +220,7 @@ class GoogleCloudSTT(STTInterface):
                         if empty_response_count == 1:
                             log_debug("📭 Received empty response (no results)")
                         continue
-
+    
                     for i, result in enumerate(response.results):
                         log_debug(f"📋 Result {i}: is_final={result.is_final}, alternatives={len(result.alternatives)}")
                         
@@ -241,10 +250,10 @@ class GoogleCloudSTT(STTInterface):
                         else:
                             log_debug(f"📋 Result {i} has empty transcript")
                             continue    
-
+    
                 if time.time() - last_response_time > RESPONSE_TIMEOUT:
                     log_error(f"❌ No response from Google STT for {RESPONSE_TIMEOUT} seconds")
-
+    
                 log_info(f"📊 Google STT stream ended. Total responses: {response_count}, Empty: {empty_response_count}")
                         
             except Exception as e: