update

app.py

@@ -34,9 +34,10 @@ app = FastAPI()
 
 # === Vault Path Helper ===
 def get_user_vault_path(user_id: str) -> str:
-    base_path = os.path.join(tempfile.gettempdir(), "vaults", f"user_{user_id}")
-os.makedirs(base_path, exist_ok=True)
-    return base_path
+    base_path = os.path.join(tempfile.gettempdir(), "vaults")
+    user_path = os.path.join(base_path, f"user_{user_id}")
+    os.makedirs(user_path, exist_ok=True)
+    return user_path
 
 # === Request Models ===
 class AskRequest(BaseModel):
@@ -97,71 +98,108 @@ async def ask(req: AskRequest):
 async def save_note(req: NoteRequest):
     try:
         path = get_user_vault_path(req.user_id)
-        note_path = os.path.join(path, f"{req.title}.md")
-        with open(note_path, "w", encoding="utf-8") as f:
+        with open(os.path.join(path, f"{req.title}.md"), "w", encoding="utf-8") as f:
             f.write(req.content)
+        return {"status": "Note saved."}
+    except Exception as e:
+        return JSONResponse(status_code=500, content={"error": str(e)})
 
-        supabase_client.table("user_files").upsert({
-            "user_id": req.user_id,
-            "path": f"{req.title}.md",
-            "content": req.content
-        }).execute()
+@app.post("/profile")
+async def save_profile(req: ProfileRequest):
+    try:
+        path = get_user_vault_path(req.user_id)
+        with open(os.path.join(path, "user_profile.json"), "w", encoding="utf-8") as f:
+            json.dump(req.profile_data, f, indent=2)
 
-        return {"status": "Note saved."}
+        write_profile_to_obsidian(req.user_id, req.profile_data)
+        return {"status": "Profile saved & Obsidian updated."}
     except Exception as e:
         return JSONResponse(status_code=500, content={"error": str(e)})
-    
-@app.post("/add_resource")
-async def add_resource(
+
+@app.post("/obsidian")
+async def upload_obsidian_file(user_id: str, file: UploadFile = File(...)):
+    try:
+        path = get_user_vault_path(user_id)
+        with open(os.path.join(path, file.filename), "wb") as f:
+            f.write(await file.read())
+        return {"status": "File uploaded."}
+    except Exception as e:
+        return JSONResponse(status_code=500, content={"error": str(e)})
+
+@app.post("/sync_from_obsidian")
+async def sync_from_obsidian(user_id: str):
+    try:
+        path = get_user_vault_path(user_id)
+        profile_path = os.path.join(path, "Profile/user_profile.md")
+
+        if not os.path.exists(profile_path):
+            return JSONResponse(status_code=404, content={"error": "Profile not found."})
+
+        with open(profile_path, "r", encoding="utf-8") as f:
+            content = f.read()
+
+        return {"status": "Profile loaded.", "content": content}
+    except Exception as e:
+        return JSONResponse(status_code=500, content={"error": str(e)})
+
+@app.post("/script")
+async def generate_script(req: GenerateRequest):
+    return await generate_with_role(req, "You are a creative screenwriter.")
+
+@app.post("/concepts")
+async def generate_concepts(req: GenerateRequest):
+    return await generate_with_role(req, "You are an innovation engine.")
+
+@app.post("/ideas")
+async def generate_ideas(req: GenerateRequest):
+    return await generate_with_role(req, "You are a content strategist.")
+
+async def generate_with_role(req: GenerateRequest, role: str):
+    try:
+        response = openai.chat.completions.create(
+            model="gpt-4",
+            messages=[
+                {"role": "system", "content": role},
+                {"role": "user", "content": req.prompt}
+            ],
+            temperature=0.9
+        )
+        return {"response": response.choices[0].message.content}
+    except Exception as e:
+        return JSONResponse(status_code=500, content={"error": str(e)})
+
+@app.post("/update_file")
+async def update_file(
     user_id: str = Form(...),
-    title: str = Form(...),
-    link: str = Form(...),
-    resource_type: str = Form(...)
+    file_path: str = Form(...),
+    new_content: str = Form(...)
 ):
     try:
-        safe_title = title.replace(" ", "_").lower()
-        file_path = f"Resources_and_Skills/resources/{safe_title}.md"
-        content = f"# 🔗 {title}\n\nType: {resource_type}\n\nLink: {link}"
-
         vault_path = get_user_vault_path(user_id)
         full_path = os.path.join(vault_path, file_path)
         os.makedirs(os.path.dirname(full_path), exist_ok=True)
 
         with open(full_path, "w", encoding="utf-8") as f:
-            f.write(content.strip())
+            f.write(new_content.strip())
 
         supabase_client.table("vault_files").upsert({
             "user_id": user_id,
             "path": file_path,
-            "content": content.strip()
+            "content": new_content.strip()
         }).execute()
 
-        return {"status": "Resource added", "file": file_path}
+        return {"status": "File updated successfully", "file": file_path}
     except Exception as e:
         return JSONResponse(status_code=500, content={"error": str(e)})
 
-@app.post("/profile")
-async def save_profile(req: ProfileRequest):
+@app.post("/add_resource")
+async def add_resource(
+    user_id: str = Form(...),
+    title: str = Form(...),
+    link: str = Form(...),
+    resource_type: str = Form(...)
+):
     try:
-        path = get_user_vault_path(req.user_id)
-        with open(os.path.join(path, "user_profile.json"), "w", encoding="utf-8") as f:
-            json.dump(req.profile_data, f, indent=2)
-
-        write_profile_to_obsidian(req.user_id, req.profile_data, supabase_client=supabase_client)
-        return {"status": "Profile saved & Obsidian updated."}
-    except Exception as e:
-        return JSONResponse(status_code=500, content={"error": str(e)})
-
-@app.get("/debug/list_user_files")
-def list_user_files(user_id: str = Query(...)):
-    path = get_user_vault_path(user_id)
-    if not os.path.exists(path):
-        return {"error": f"User path {path} not found"}
-
-    files = []
-    for root, _, filenames in os.walk(path):
-        for name in filenames:
-            rel_path = os.path.relpath(os.path.join(root, name), path)
-            files.append(rel_path)
-
-    return {"user_id": user_id, "files": files, "message": f"{len(files)} files found."}
+        safe_title = title.replace(" ", "_").lower()
+        file_path = f"Resources_and_Skills/resources/{safe_title}.md"
+        content = f"# 

profile_writer.py

@@ -1,41 +1,95 @@
 import os
-from datetime import datetime
 
 def write_file(user_path, relative_path, content):
     full_path = os.path.join(user_path, relative_path)
     os.makedirs(os.path.dirname(full_path), exist_ok=True)
     with open(full_path, "w", encoding="utf-8") as f:
         f.write(content.strip() + "\n")
-    return full_path
 
-def write_profile_to_obsidian(user_id: str, data: dict, supabase_client=None):
-    base_path = os.path.join(tempfile.gettempdir(), "vaults", f"user_{user_id}")
+def write_profile_to_obsidian(user_id: str, data: dict, base_path=None):
+    if base_path is None:
+        base_path = os.path.join("/data", "vaults", f"user_{user_id}")
     os.makedirs(base_path, exist_ok=True)
+    print(f"[WRITE] Creating Obsidian structure for user: {user_id} at {base_path}")
 
-    files = {
-        "Profile/user_profile.md": f"# 👤 User Profile\n- Experience Level: {data.get('experienceLevel', '')}\n- Main Goal: {data.get('contentGoal', '')}\n- Location: {data.get('country', '')}, {data.get('city', '')}",
-        "Profile/business_profile.md": f"# 🏢 Business Profile\n- Type: {data.get('businessType', '')}\n- Description: {data.get('businessDescription', '')}\n- Niche: {data.get('niche', '')}",
-        "Profile/creator_personality.md": "# ✨ Creator Personality\nTo be discovered...",
-        "Content_Strategy/content_goals.md": f"# 🎯 Content Goals\n- Goal: {data.get('contentGoal', '')}\n- Niche: {data.get('niche', '')}",
-        "Content_Strategy/platforms_and_audience.md": f"# 📣 Platforms & Audience\n- Platforms: {', '.join(data.get('platforms', []))}\n- Target Generation: {data.get('targetGeneration', '')}\n- Time Available: {data.get('timeAvailable', '')}\n- Monetization Intent: {data.get('monetizationIntent', '')}",
-        "Content_Strategy/content_types_and_niche.md": f"# 📦 Content Types & Niche\n- Types: {', '.join(data.get('contentTypes', []))}\n- Challenges: {data.get('mainChallenges', '')}",
-        "Content_Strategy/social_accounts.md": "# 🔗 Social Accounts\nAdd your accounts here.",
-        "Resources_and_Skills/current_challenges.md": f"# ❗ Current Challenges\n{data.get('mainChallenges', '')}",
-        "Resources_and_Skills/available_resources.md": f"# 🛠️ Available Resources\n{data.get('resources', '')}",
-        "Resources_and_Skills/learning_preferences.md": "# 📚 Learning Preferences\nTo define.",
-        "Resources_and_Skills/existing_skills.md": "# 💡 Existing Skills\nList them here.",
-        "Goals_and_Metrics/impact_goals.md": "# 🌍 Impact Goals\nTo define.",
-        "Goals_and_Metrics/success_metrics.md": "# 📈 Success Metrics\nTo define.",
-        "Goals_and_Metrics/monetization_strategy.md": "# 💰 Monetization Strategy\nTo define.",
-        "AI_Context/onboarding_summary.md": f"# 🤖 AI Onboarding Summary\n## Overview\n- Goal: {data.get('contentGoal', '')}\n- Experience: {data.get('experienceLevel', '')}\n- Niche: {data.get('niche', '')}\n- Audience: {data.get('targetGeneration', '')}\n- Platforms: {', '.join(data.get('platforms', []))}\n## Intentions\n- Monetization: {data.get('monetizationIntent', '')}\n- Available Time: {data.get('timeAvailable', '')}\n## Notes\nAutomatically generated. Use for AI context."
-    }
-
-    for relative_path, content in files.items():
-        write_file(base_path, relative_path, content)
-        if supabase_client:
-            supabase_client.table("user_files").upsert({
-                "user_id": user_id,
-                "path": relative_path,
-                "content": content.strip(),
-                "created_at": datetime.utcnow().isoformat()
-            }).execute()
+    # === Profile Folder ===
+    write_file(base_path, "Profile/user_profile.md", f"""
+# 👤 User Profile
+- Experience Level: {data.get("experienceLevel", "")}
+- Main Goal: {data.get("contentGoal", "")}
+- Location: {data.get("country", "")}, {data.get("city", "")}
+""")
+
+    write_file(base_path, "Profile/business_profile.md", f"""
+# 🏢 Business Profile
+- Type: {data.get("businessType", "")}
+- Description: {data.get("businessDescription", "")}
+- Niche: {data.get("niche", "")}
+""")
+
+    write_file(base_path, "Profile/creator_personality.md", "# ✨ Creator Personality\nTo be discovered...")
+
+    # === Content Strategy ===
+    write_file(base_path, "Content_Strategy/content_goals.md", f"""
+# 🎯 Content Goals
+- Goal: {data.get("contentGoal", "")}
+- Niche: {data.get("niche", "")}
+""")
+
+    write_file(base_path, "Content_Strategy/platforms_and_audience.md", f"""
+# 📣 Platforms & Audience
+- Platforms: {", ".join(data.get("platforms", []))}
+- Target Generation: {data.get("targetGeneration", "")}
+- Time Available: {data.get("timeAvailable", "")}
+- Monetization Intent: {data.get("monetizationIntent", "")}
+""")
+
+    write_file(base_path, "Content_Strategy/content_types_and_niche.md", f"""
+# 📦 Content Types & Niche
+- Types: {", ".join(data.get("contentTypes", []))}
+- Challenges: {data.get("mainChallenges", "")}
+""")
+
+    write_file(base_path, "Content_Strategy/social_accounts.md", "# 🔗 Social Accounts\nAdd your accounts here.")
+
+    # === Resources & Skills ===
+    write_file(base_path, "Resources_and_Skills/current_challenges.md", f"""
+# ❗ Current Challenges
+{data.get("mainChallenges", "")}
+""")
+
+    write_file(base_path, "Resources_and_Skills/available_resources.md", f"""
+# 🛠️ Available Resources
+{data.get("resources", "")}
+""")
+
+    write_file(base_path, "Resources_and_Skills/learning_preferences.md", "# 📚 Learning Preferences\nTo define.")
+
+    write_file(base_path, "Resources_and_Skills/existing_skills.md", "# 💡 Existing Skills\nList them here.")
+
+    # === Goals & Metrics ===
+    write_file(base_path, "Goals_and_Metrics/impact_goals.md", "# 🌍 Impact Goals\nTo define.")
+
+    write_file(base_path, "Goals_and_Metrics/success_metrics.md", "# 📈 Success Metrics\nTo define.")
+
+    write_file(base_path, "Goals_and_Metrics/monetization_strategy.md", "# 💰 Monetization Strategy\nTo define.")
+
+    # === AI Context ===
+    write_file(base_path, "AI_Context/onboarding_summary.md", f"""
+# 🤖 AI Onboarding Summary
+This file summarizes the user context.
+
+## Overview
+- Goal: {data.get("contentGoal", "")}
+- Experience: {data.get("experienceLevel", "")}
+- Niche: {data.get("niche", "")}
+- Audience: {data.get("targetGeneration", "")}
+- Platforms: {", ".join(data.get("platforms", []))}
+
+## Intentions
+- Monetization: {data.get("monetizationIntent", "")}
+- Available Time: {data.get("timeAvailable", "")}
+
+## Notes
+Automatically generated. Use for AI context.
+""")