Update app.py

app.py

@@ -423,65 +423,4 @@ async def web_search_endpoint(query: str, num_results: int = 5, api_key: str = D
     result = await web_search(query, num_results)
     if not result['success']:
         raise HTTPException(status_code=500, detail=result['error'])
-    return result, remplace get youtube audio by this def get_youtube_audio(video_id):
-    try:
-        logger.info(f"Starting YouTube audio extraction for video ID: {video_id}")
-        
-        # Create an InnerTube client for iOS
-        client = InnerTube("IOS")
-        logger.info("InnerTube client created")
-
-        # Fetch video info
-        logger.info("Fetching video info")
-        video_info = client.player(video_id)
-        logger.info("Video info fetched successfully")
-
-        # Extract the audio streams
-        streams = video_info["streamingData"]["adaptiveFormats"]
-        audio_streams = [s for s in streams if s['mimeType'].startswith('audio/')]
-
-        if not audio_streams:
-            logger.warning(f"No audio streams found for video ID {video_id}")
-            return {'success': False, 'error': "No audio streams found"}
-
-        # Choose the highest quality audio stream
-        audio_stream = max(audio_streams, key=lambda x: x.get('bitrate', 0))
-        audio_url = audio_stream['url']
-        logger.info(f"Selected audio stream URL: {audio_url[:100]}...")  # Log first 100 chars of URL
-
-        # Prepare headers
-        headers = {
-            'User-Agent': random.choice(USER_AGENTS),
-            'Accept': '*/*',
-            'Accept-Encoding': 'gzip, deflate, br',
-            'Range': 'bytes=0-',
-            'Connection': 'keep-alive',
-        }
-
-        # Download the audio
-        logger.info("Starting audio download")
-        response = requests.get(audio_url, headers=headers, stream=True)
-        logger.info(f"Download response status code: {response.status_code}")
-
-        if response.status_code in [200, 206]:  # 200 OK or 206 Partial Content
-            # Create a temporary file
-            with tempfile.NamedTemporaryFile(delete=False, suffix='.mp4') as temp_file:
-                temp_file_path = temp_file.name
-                logger.info(f"Created temporary file: {temp_file_path}")
-                # Write the audio data to the file
-                total_size = 0
-                for chunk in response.iter_content(chunk_size=8192):
-                    temp_file.write(chunk)
-                    total_size += len(chunk)
-                    if total_size % (1024 * 1024) == 0:  # Log every 1MB
-                        logger.info(f"Downloaded {total_size / (1024 * 1024):.2f} MB")
-
-            logger.info(f"Audio download completed. Total size: {total_size / (1024 * 1024):.2f} MB")
-            return {'success': True, 'temp_file_path': temp_file_path}
-        else:
-            logger.error(f"Failed to download audio: HTTP {response.status_code}")
-            return {'success': False, 'error': f"Download failed: HTTP {response.status_code}"}
-
-    except Exception as e:
-        logger.exception(f"Error fetching YouTube audio for video ID {video_id}: {str(e)}")
-        return {'success': False, 'error': f"Error: {str(e)}"} , add ulpoad to s3 funtion and send the s3 file
+    return result