Update backend with high-quality catalog and fixes

app/api/orders.py

@@ -366,23 +366,26 @@ def upload_payment_receipt(
     if not payment:
         raise HTTPException(status_code=404, detail="Payment record not found")
         
-    # Ensure directory exists in DATA_DIR
-    uploads_dir = os.path.join(settings.DATA_DIR, "uploads", "receipts")
-    os.makedirs(uploads_dir, exist_ok=True)
+    # Convert file to base64 string
+    file_bytes = file.file.read()
     
-    # Generate unique filename
-    ext = os.path.splitext(file.filename)[1]
-    filename = f"receipt_{order.id}_{uuid.uuid4().hex[:8]}{ext}"
-    file_path = os.path.join(uploads_dir, filename)
-    
-    # Save the file
-    with open(file_path, "wb") as buffer:
-        import shutil
-        shutil.copyfileobj(file.file, buffer)
+    import base64
+    ext = os.path.splitext(file.filename)[1].lower()
+    mime_type = "image/jpeg"
+    if ext in [".png"]:
+        mime_type = "image/png"
+    elif ext in [".gif"]:
+        mime_type = "image/gif"
+    elif ext in [".webp"]:
+        mime_type = "image/webp"
+    elif ext in [".pdf"]:
+        mime_type = "application/pdf"
         
+    b64_encoded = base64.b64encode(file_bytes).decode('utf-8')
+    receipt_data_uri = f"data:{mime_type};base64,{b64_encoded}"
+    
     # Update payment record
-    receipt_url = f"/uploads/receipts/{filename}"
-    payment.receipt_url = receipt_url
+    payment.receipt_url = receipt_data_uri
     payment.status = PaymentStatus.PENDING # Awaiting admin approval
     
     # 5. Finally Clear Cart (if requested via bank transfer follow-up)
@@ -399,7 +402,7 @@ def upload_payment_receipt(
     
     return {
         "isSuccess": True,
-        "value": {"message": "Receipt uploaded successfully", "receipt_url": receipt_url},
+        "value": {"message": "Receipt uploaded successfully", "receipt_url": receipt_data_uri},
         "statusCode": 200
     }
 

app/api/settings.py

@@ -57,20 +57,24 @@ def upload_settings_image(
     db: Session = Depends(get_db),
     current_admin=Depends(get_current_admin_user)
 ) -> Any:
-    # 1. Create directory if not exists
-    settings_uploads = os.path.join(app_settings.DATA_DIR, "uploads", "settings")
-    os.makedirs(settings_uploads, exist_ok=True)
+    # Convert file to base64 string
+    file_bytes = file.file.read()
     
-    # 2. Save file
-    file_ext = os.path.splitext(file.filename)[1]
-    filename = f"settings_{int(datetime.now().timestamp())}{file_ext}"
-    file_path = os.path.join(settings_uploads, filename)
-    
-    with open(file_path, "wb") as buffer:
-        shutil.copyfileobj(file.file, buffer)
+    import base64
+    ext = os.path.splitext(file.filename)[1].lower()
+    mime_type = "image/jpeg"
+    if ext in [".png"]:
+        mime_type = "image/png"
+    elif ext in [".gif"]:
+        mime_type = "image/gif"
+    elif ext in [".webp"]:
+        mime_type = "image/webp"
         
+    b64_encoded = base64.b64encode(file_bytes).decode('utf-8')
+    data_uri = f"data:{mime_type};base64,{b64_encoded}"
+    
     return APIResponse(
         isSuccess=True,
-        value={"url": f"/uploads/settings/{filename}"},
+        value={"url": data_uri},
         statusCode=200
     )

app/core/config.py

@@ -8,6 +8,7 @@ class Settings(BaseSettings):
     # Base directory for persistent data (e.g., /data for Hugging Face persistent storage)
     DATA_DIR: str = os.getenv("DATA_DIR", ".")
     DATABASE_URL: str = os.getenv("DATABASE_URL", f"sqlite:///{os.path.join(os.getenv('DATA_DIR', '.'), 'vortex.db')}")
+    TURSO_AUTH_TOKEN: str = os.getenv("TURSO_AUTH_TOKEN", "")
     
     JWT_SECRET: str = "change-me-in-production"
     JWT_ALGORITHM: str = "HS256"

app/db/base.py

@@ -3,9 +3,20 @@ from sqlalchemy.orm import sessionmaker, DeclarativeBase
 
 from app.core.config import settings
 
+# Create connection args dynamically based on the URL type
+connect_args = {}
+if "sqlite" in settings.DATABASE_URL or "libsql" in settings.DATABASE_URL:
+    connect_args["check_same_thread"] = False
+    
+# Add Turso Auth Token if connecting remotely
+if settings.TURSO_AUTH_TOKEN and "turso.io" in settings.DATABASE_URL:
+    # Ensure URL uses sqlite+libsql if it's a bare libsql://
+    if settings.DATABASE_URL.startswith("libsql://"):
+        settings.DATABASE_URL = settings.DATABASE_URL.replace("libsql://", "sqlite+libsql://", 1)
+        
 engine = create_engine(
     settings.DATABASE_URL,
-    connect_args={"check_same_thread": False} if "sqlite" in settings.DATABASE_URL else {},
+    connect_args=connect_args,
     echo=False,
 )
 

requirements.txt

@@ -12,6 +12,8 @@ google-api-python-client==2.118.0
 python-multipart==0.0.9
 httpx==0.27.0
 aiosqlite==0.20.0
+libsql-client==0.1.4
+sqlalchemy-libsql==0.1.1
 python-dotenv==1.0.1
 reportlab==4.0.9
 email-validator==2.1.0.post1

test_turso.py

@@ -0,0 +1,20 @@
+import sys
+
+def test_uri():
+    db_url = "libsql://ofoq-ofoq.aws-ap-northeast-1.turso.io"
+    token = "eyJhbGciOiJFZERTQSIsInR5cCI6IkpXVCJ9..."
+    
+    # Normally we do:
+    if db_url.startswith("libsql://"):
+        db_url = db_url.replace("libsql://", "sqlite+libsql://", 1)
+    
+    # And we append the token as a query parameter
+    if "?" in db_url:
+        db_url += f"&authToken={token}"
+    else:
+        db_url += f"?authToken={token}"
+        
+    print("FINAL URL:", db_url)
+    
+if __name__ == "__main__":
+    test_uri()