Update app.py

app.py

@@ -199,29 +199,15 @@ class FileProcessor:
 
         return dataset
 
-    def _process_zip_file(self, zip_path: str, temp_dir: str) -> List[Dict]:
-        """Process ZIP file contents"""
-        results = []
+    def process_zip_file(zip_path):
+        """Extract and process files within a ZIP archive."""
+        extraction_directory = tempfile.mkdtemp()
         with zipfile.ZipFile(zip_path, 'r') as zip_ref:
-            zip_ref.extractall(temp_dir)
-            for root, _, files in os.walk(temp_dir):
-                for filename in files:
-                    filepath = os.path.join(root, filename)
-                    if self.is_text_file(filepath):
-                        try:
-                            with open(filepath, 'r', encoding='utf-8', errors='ignore') as f:
-                                content = f.read()
-                            if content.strip():
-                                results.append({
-                                    "source": "file",
-                                    "filename": filename,
-                                    "content": content,
-                                    "timestamp": datetime.now().isoformat()
-                                })
-                        except Exception as e:
-                            logger.error(f"Error reading file {filename}: {str(e)}")
-        return results
-
+            zip_ref.extractall(extraction_directory)
+            for extracted_file in os.listdir(extraction_directory):
+                extracted_file_path = os.path.join(extraction_directory, extracted_file)
+                process_file(extracted_file_path)
+                
 def _process_single_file(self, file) -> List[Dict]:
     try:
         file_stat = os.stat(file.name)