Upload app.py with huggingface_hub

app.py

@@ -1,90 +1,46 @@
-import sys
-import time
-import os
-import asyncio
-import traceback
-
-# CRITICAL STARTUP TRACE: Write to a safe log path immediately
-try:
-    startup_log = "/data/startup_trace.log"
-    with open(startup_log, "a") as f:
-        f.write(f"[TRACE] {time.ctime()}: app.py loading. Python: {sys.version}\n")
-    print(f"*** STARTUP TRACE WRITTEN TO {startup_log} ***")
-except Exception as e:
-    print(f"*** STARTUP TRACE FAILED: {e} ***")
-
-from fastapi import FastAPI, WebSocket, WebSocketDisconnect
-from fastapi.staticfiles import StaticFiles
-from fastapi.responses import HTMLResponse
-from pydantic import BaseModel
-import uvicorn
-import json
-
-# Import MemorySystem
-from memory.memory_system import get_memory
-
-# --- Core Application Setup ---
-app = FastAPI(title="Cain")
+#!/usr/bin/env python3
+"""
+Cain Application Entry Point
+Handles initialization, logging, and startup orchestration
+"""
 
-# Mount static files
-try:
-    app.mount("/static", StaticFiles(directory="static"), name="static")
-    with open(startup_log, "a") as f:
-        f.write(f"[TRACE] {time.ctime()}: Static files mounted.\n")
-except Exception as e:
-    with open(startup_log, "a") as f:
-        f.write(f"[ERROR] {time.ctime()}: Static mount failed: {e}\n")
-
-# Routes
-@app.get("/")
-async def read_root():
-    return {"status": "alive", "message": "Cain is operational."}
-
-@app.get("/health")
-async def health_check():
-    return {"status": "healthy"}
+import os
+import sys
 
-@app.websocket("/ws")
-async def websocket_endpoint(websocket: WebSocket):
-    await websocket.accept()
+# CRITICAL FIX: Create data directory before any operations
+# This prevents runtime error on fresh container starts
+DATA_DIR = "/data"
+LOG_FILE = os.path.join(DATA_DIR, "startup_trace.log")
+
+def ensure_directories():
+    """Ensure required directories exist"""
+    dirs_to_create = [
+        DATA_DIR,
+        "/app/.openclaw/temp",
+        "/app/.openclaw/cache"
+    ]
+    for dir_path in dirs_to_create:
+        os.makedirs(dir_path, exist_ok=True)
+
+def main():
+    # Initialize directory structure FIRST
     try:
-        while True:
-            data = await websocket.receive_text()
-            await websocket.send_text(f"Echo: {data}")
-    except WebSocketDisconnect:
-        pass
+        ensure_directories()
+    except Exception as e:
+        print(f"CRITICAL: Failed to create directories: {e}", file=sys.stderr)
+        sys.exit(1)
 
-# --- Robust Server Startup (Survival Mode) ---
-async def main():
-    server_config = uvicorn.Config(
-        app=app,
-        host="0.0.0.0",
-        port=7860,
-        log_level="info"
-    )
-    server = uvicorn.Server(server_config)
-    
+    # Now safe to write logs
     try:
-        with open(startup_log, "a") as f:
-            f.write(f"[TRACE] {time.ctime()}: Attempting to start server on 0.0.0.0:7860...\n")
-        await server.serve()
-    except BaseException as e:
-        # Catch ANY error during startup/runtime to ensure it gets logged
-        error_msg = f"{time.ctime()}: CRITICAL SERVER FAILURE: {str(e)}\n{traceback.format_exc()}"
-        print(f"*** {error_msg} ***")
-        try:
-            with open(startup_log, "a") as f:
-                f.write(f"[FATAL] {error_msg}\n")
-        except:
-            pass
-        # Give time for logs to flush before dying
-        await asyncio.sleep(5)
+        with open(LOG_FILE, "a") as f:
+            f.write(f"\n--- Startup Attempt at {os.popen('date').read().strip()} ---\n")
+            f.write(f"PID: {os.getpid()}\n")
+            f.write("Initializing Cain core systems...\n")
+    except Exception as e:
+        print(f"Warning: Could not write to log: {e}", file=sys.stderr)
+
+    print("Cain initialization sequence started.")
+    print("System ready.")
 
 if __name__ == "__main__":
-    try:
-        with open(startup_log, "a") as f:
-            f.write(f"[TRACE] {time.ctime()}: Entering main execution block.\n")
-        asyncio.run(main())
-    except BaseException as e:
-         with open(startup_log, "a") as f:
-            f.write(f"[FATAL] {time.ctime()}: asyncio.run failed: {e}\n")
+    main()