Update app.py

app.py

@@ -372,6 +372,8 @@ def resize_and_save_worker(args):
     except Exception as e:
         return None, f"{name}: {e}"
 
+from multiprocessing import cpu_count
+import zipfile
 
 def process_and_zip(items, fmt, w, h):
     tmp  = tempfile.mkdtemp()
@@ -379,37 +381,37 @@ def process_and_zip(items, fmt, w, h):
     os.makedirs(proc, exist_ok=True)
 
     files, fails = [], []
-    # Download + open all images
-    with ThreadPoolExecutor(max_workers=8) as ex:
+    # 1) Download & open in parallel
+    workers = cpu_count() * 2
+    with ThreadPoolExecutor(max_workers=workers) as ex:
         results = list(ex.map(lambda it: threaded_download_and_open(it, tmp), items))
 
-    # For each downloaded item, process its frames
+    # 2) Process each downloaded image/list of frames
     for name, imgs, err in results:
         if err or not imgs:
             fails.append(f"{name}: {err}")
-            continue  # skip to next item
+            continue
 
-        # imgs is a list of frames (even if just one)
         for i, img in enumerate(imgs):
             try:
-                # 1) Composite RGBA over white
+                # Composite RGBA over white
                 img = img.convert("RGBA")
                 bg  = Image.new("RGBA", img.size, (255,255,255,255))
                 img = Image.alpha_composite(bg, img)
 
-                # 2) Decide format & extension
+                # Determine save format & extension
                 fmt_upper = fmt.upper()
                 save_fmt  = "JPEG" if fmt_upper in ("JPEG","JPG") else fmt_upper
                 ext       = "jpg"  if fmt_upper in ("JPEG","JPG") else fmt.lower()
 
-                # 3) Convert to RGB if JPEG
+                # Convert to RGB if JPEG
                 if save_fmt == "JPEG":
                     img = img.convert("RGB")
 
-                # 4) Resize with padding
+                # Resize with padding
                 img = resize_with_padding(img, w, h)
 
-                # 5) Build filename
+                # Build filename
                 fname = (
                     f"{name}_frame{i+1}.{ext}"
                     if len(imgs) > 1
@@ -417,7 +419,7 @@ def process_and_zip(items, fmt, w, h):
                 )
                 out_path = os.path.join(proc, fname)
 
-                # 6) Save & record
+                # Save & record
                 img.save(out_path, format=save_fmt, quality=90)
                 files.append(out_path)
 
@@ -425,21 +427,21 @@ def process_and_zip(items, fmt, w, h):
                 print(f"⚠️ Save failed for {name}: {e}")
                 fails.append(f"{name}_frame{i+1}: {e}")
 
-    # If nothing made it through, clean up & report
+    # 3) If nothing succeeded, clean up and report
     if not files:
         stop_event.clear()
         shutil.rmtree(tmp)
         return None, None, "No images processed.", None
 
-    # Otherwise, zip up
+    # 4) Create ZIP in “store” mode (no compression)
     date_str = datetime.now().strftime("%Y-%m-%d")
     zip_name = f"{date_str}.zip"
     zip_path = os.path.join(tmp, zip_name)
-    with zipfile.ZipFile(zip_path, 'w') as zf:
+    with zipfile.ZipFile(zip_path, 'w', compression=zipfile.ZIP_STORED) as zf:
         for f in files:
             zf.write(f, os.path.basename(f))
 
-    # Build status message
+    # 5) Build status message
     msg_lines = [f"✅ Processed {len(files)} image(s)."]
     if fails:
         msg_lines.append(f"❌ Failed: {len(fails)} image(s)")