Update app.py

app.py

@@ -6,18 +6,29 @@ import zipfile
 import glob
 import json
 import uuid
+import boto3
+from botocore.exceptions import NoCredentialsError
 from fastapi import FastAPI, BackgroundTasks
 from fastapi.middleware.cors import CORSMiddleware
 from pydantic import BaseModel
 from playwright.sync_api import sync_playwright
 
-# --- CONFIG ---
+# --- CONFIG SERVER ---
 os.chdir("/tmp")
 os.environ["HOME"] = "/tmp"
 os.environ["UNITY_PATH"] = "/opt/unity/Editor/Unity"
 BASE_PROJECT_PATH = "/app/UnityProject"
 DEST_LICENSE_PATH = "/tmp/Unity_lic.ulf"
 
+# --- CONFIG CLOUDFLARE R2 (SUDAH DIISI) ---
+R2_CONFIG = {
+    "account_id": "31f2970a3442da4e6f17f79064897226",
+    "access_key": "44613d17ec50941707a7ddd9b17944bc",
+    "secret_key": "50185c21ff5e4f53e412e2013305b6ab24b7eda16cc0d3dc66593eed64aa99a2",
+    "bucket_name": "zepeto-builds",  # <--- PASTIKAN BUCKET INI ADA DI R2 ABANG!
+    "public_domain": ""              # Isi jika punya custom domain (contoh: https://cdn.domain.com)
+}
+
 app = FastAPI()
 app.add_middleware(
     CORSMiddleware,
@@ -33,6 +44,72 @@ class ConversionRequest(BaseModel):
     zepeto_id: str
     zepeto_password: str
 
+# --- FUNGSI UPLOAD R2 ---
+def upload_to_r2(file_path, original_filename):
+    print("☁️ [R2] Memulai upload ke Cloudflare R2...", flush=True)
+    try:
+        s3 = boto3.client(
+            's3',
+            endpoint_url=f"https://{R2_CONFIG['account_id']}.r2.cloudflarestorage.com",
+            aws_access_key_id=R2_CONFIG['access_key'],
+            aws_secret_access_key=R2_CONFIG['secret_key']
+        )
+        
+        # Nama file di R2: builds/timestamp_namafile.zepeto
+        object_name = f"builds/{uuid.uuid4().hex[:8]}_{original_filename}.zepeto"
+        
+        s3.upload_file(file_path, R2_CONFIG['bucket_name'], object_name)
+        
+        # Generate URL
+        if R2_CONFIG['public_domain']:
+            url = f"{R2_CONFIG['public_domain']}/{object_name}"
+        else:
+            # Default R2 URL structure
+            url = f"https://{R2_CONFIG['account_id']}.r2.cloudflarestorage.com/{R2_CONFIG['bucket_name']}/{object_name}"
+            
+        print(f"✅ [R2] Upload Sukses! URL BUKTI: {url}", flush=True)
+        return url
+    except Exception as e:
+        print(f"❌ [R2] Upload Gagal: {str(e)}", flush=True)
+        return None
+
+# --- FUNGSI UPLOAD ZEPETO ---
+def upload_to_zepeto(file_path, z_id, z_pw):
+    print(f"🔐 [Zepeto] Login Playwright...", flush=True)
+    try:
+        with sync_playwright() as p:
+            browser = p.chromium.launch(headless=True, args=['--no-sandbox', '--disable-setuid-sandbox'])
+            context = browser.new_context(user_agent="Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/91.0.4472.124 Safari/537.36")
+            page = context.new_page()
+            
+            page.goto("https://account.zepeto.me/signin?sm=1", timeout=60000)
+            page.fill('input[name="userId"]', z_id)
+            page.fill('input[type="password"]', z_pw)
+            page.click('button[type="submit"]')
+            try: page.wait_for_url(lambda u: "signin" not in u, timeout=60000)
+            except: 
+                browser.close()
+                return False, "Login Timeout"
+            
+            cookies = {c['name']: c['value'] for c in context.cookies()}
+            jwt_token = cookies.get('token') or cookies.get('jwt')
+            browser.close()
+            
+            if not jwt_token: return False, "Token Not Found"
+            
+            print(f"🚀 [Zepeto] Uploading via API...", flush=True)
+            headers = {"Authorization": f"Bearer {jwt_token}"}
+            with open(file_path, "rb") as f:
+                res = requests.post(
+                    "https://cf-api-studio.zepeto.me/api/items", 
+                    headers=headers, 
+                    files={"file": (os.path.basename(file_path), f, "application/octet-stream")},
+                    timeout=120
+                )
+            return (True, "Success") if res.status_code in [200, 201] else (False, f"HTTP {res.status_code}")
+    except Exception as e: return False, f"Error: {str(e)}"
+
+# --- PIPELINE UTAMA ---
 def process_pipeline(req: ConversionRequest):
     session_id = str(uuid.uuid4())[:8]
     SESSION_PATH = f"/tmp/Project_{session_id}"
@@ -50,35 +127,32 @@ def process_pipeline(req: ConversionRequest):
         print("📦 [COPY] Cloning Project...", flush=True)
         shutil.copytree(BASE_PROJECT_PATH, SESSION_PATH, ignore=shutil.ignore_patterns("Library", "Temp", "Logs"))
         
-        # --- CLEANER ---
+        # Cleaner
         trash_folders = glob.glob(os.path.join(SESSION_PATH, "Assets", "**", "UnityMeshSimplifier"), recursive=True)
         trash_folders += glob.glob(os.path.join(SESSION_PATH, "Assets", "**", "Tests"), recursive=True)
         for folder in trash_folders:
             if os.path.exists(folder): shutil.rmtree(folder)
 
-        # --- FLATTENER ---
+        # Flattener
         target_input = os.path.join(SESSION_PATH, "Assets", "InputRaw")
         os.makedirs(target_input, exist_ok=True)
-        
         for root, dirs, files in os.walk(extract_tmp):
             for file in files:
                 if file.endswith((".cs", ".ts", ".js", ".asmdef", ".dll")): os.remove(os.path.join(root, file))
-
-        print("📂 [FLATTENER] Memindahkan file ke InputRaw...", flush=True)
+        
+        print("📂 [FLATTENER] Moving files...", flush=True)
         for root, dirs, files in os.walk(extract_tmp):
             for file in files:
                 if file.startswith(".") or file.endswith(".meta"): continue
                 src = os.path.join(root, file)
                 dst = os.path.join(target_input, file)
-                if os.path.exists(dst): 
-                    dst = os.path.join(target_input, f"{uuid.uuid4().hex[:4]}_{file}")
+                if os.path.exists(dst): dst = os.path.join(target_input, f"{uuid.uuid4().hex[:4]}_{file}")
                 shutil.copy(src, dst)
 
-        # --- MANIFEST CLEAN ---
+        # Manifest
         manifest_path = os.path.join(SESSION_PATH, "Packages", "manifest.json")
         if os.path.exists(os.path.join(SESSION_PATH, "Packages", "packages-lock.json")):
             os.remove(os.path.join(SESSION_PATH, "Packages", "packages-lock.json"))
-        
         clean_manifest = {
             "dependencies": {
                 "com.unity.render-pipelines.universal": "14.0.10",
@@ -95,23 +169,17 @@ def process_pipeline(req: ConversionRequest):
         }
         with open(manifest_path, 'w') as f: json.dump(clean_manifest, f, indent=2)
 
-        # --- INJECT SCRIPT BARU (TARGET LINUX) ---
-        # Kita inject langsung disini biar pasti keubah
+        # Inject Script (Target Linux)
         script_path = os.path.join(SESSION_PATH, "Assets", "Editor", "TestBuilder.cs")
         os.makedirs(os.path.dirname(script_path), exist_ok=True)
-        
         csharp_code = r"""
 using UnityEngine;
 using UnityEditor;
 using System.IO;
-
-public class TestBuilder
-{
+public class TestBuilder {
     static readonly string RAW_PATH = "Assets/InputRaw";
     static readonly string OUTPUT_DIR = "Assets/Output";
-
-    public static void ManualConvert()
-    {
+    public static void ManualConvert() {
         Debug.Log("🚀 [NATIVE] STARTING BUILD (TARGET: LINUX64)...");
         try {
             AssetDatabase.Refresh();
@@ -124,27 +192,14 @@ public class TestBuilder
             string assetPath = AssetDatabase.GUIDToAssetPath(guids[0]);
             AssetImporter importer = AssetImporter.GetAtPath(assetPath);
             importer.assetBundleName = "repacked_item.zepeto";
-            
             if (!Directory.Exists(OUTPUT_DIR)) Directory.CreateDirectory(OUTPUT_DIR);
-
-            // PERUBAHAN PENTING DISINI: GANTI KE StandaloneLinux64
-            var manifest = BuildPipeline.BuildAssetBundles(
-                OUTPUT_DIR, 
-                BuildAssetBundleOptions.ForceRebuildAssetBundle, 
-                BuildTarget.StandaloneLinux64 
-            );
-
-            if (manifest == null) {
-                Debug.LogError("❌ [FATAL] Build Failed (Manifest Null)");
-                EditorApplication.Exit(1);
-            } else {
-                Debug.Log("🎉 [SUCCESS] Build Finished!");
-                EditorApplication.Exit(0);
-            }
-        } catch (System.Exception e) {
-            Debug.LogError($"💀 [EXCEPTION] {e.Message}");
-            EditorApplication.Exit(1);
-        }
+            
+            // TARGET LINUX64
+            var manifest = BuildPipeline.BuildAssetBundles(OUTPUT_DIR, BuildAssetBundleOptions.ForceRebuildAssetBundle, BuildTarget.StandaloneLinux64);
+            
+            if (manifest == null) { Debug.LogError("❌ Build Failed"); EditorApplication.Exit(1); }
+            else { Debug.Log("🎉 Build Finished!"); EditorApplication.Exit(0); }
+        } catch (System.Exception e) { Debug.LogError(e.Message); EditorApplication.Exit(1); }
     }
 }
 """
@@ -154,37 +209,38 @@ public class TestBuilder
         print(f"🚀 [UNITY] Repacking...", flush=True)
         cmd_repack = [
             os.environ["UNITY_PATH"], "-batchmode", "-nographics", "-quit",
-            "-projectPath", SESSION_PATH, 
-            "-executeMethod", "TestBuilder.ManualConvert",
-            "-logFile", unity_log_file,
-            "-no-sprite-atlas-cache", 
-            "-job-worker-count", "1"
+            "-projectPath", SESSION_PATH, "-executeMethod", "TestBuilder.ManualConvert",
+            "-logFile", unity_log_file, "-no-sprite-atlas-cache", "-job-worker-count", "1"
         ]
         subprocess.run(cmd_repack, check=False)
 
-        # --- SMART LOG READER ---
+        # Print Log (Filtered)
         print("\n" + "="*50, flush=True)
-        print("🔍 HASIL DIAGNOSA:", flush=True)
-        print("="*50, flush=True)
-        
+        print("🔍 LOG DIAGNOSTICS:", flush=True)
         if os.path.exists(unity_log_file):
             with open(unity_log_file, "r", encoding="utf-8", errors="ignore") as f:
                 for line in f:
                     if any(k in line for k in ["[NATIVE]", "Error", "Exception", "Fail", "CRITICAL"]):
                         if "Shader" in line or "Metal" in line: continue
                         print(line.strip(), flush=True)
-        else:
-            print("❌ LOG FILE TIDAK DITEMUKAN!", flush=True)
+        else: print("❌ Log Not Found")
         print("="*50 + "\n", flush=True)
 
-        # UPLOAD
+        # OUTPUT CHECK & UPLOAD
         output_dir = os.path.join(SESSION_PATH, "Assets", "Output")
         target_file = os.path.join(output_dir, "repacked_item.zepeto")
         
         if os.path.exists(target_file):
-            print(f"🎉 [DONE] File output ditemukan: {target_file}", flush=True)
+            print(f"🎉 [DONE] File generated: {target_file}", flush=True)
+            
+            # 1. UPLOAD KE R2 (BACKUP/BUKTI)
+            upload_to_r2(target_file, req.filename)
+
+            # 2. UPLOAD KE ZEPETO
+            success, msg = upload_to_zepeto(target_file, req.zepeto_id, req.zepeto_password)
+            print(f"🚀 [ZEPETO] Result: {msg}", flush=True)
         else:
-            print("❌ [FAIL] File output TIDAK ADA.", flush=True)
+            print("❌ [FAIL] No output file.", flush=True)
 
     except Exception as e: print(f"❌ [CRITICAL] {e}", flush=True)
     finally: