Spaces:
Sleeping
Sleeping
File size: 4,057 Bytes
63de3ab | 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 | import re
import os
import sys
import logging
import asyncio
import zipfile
import io
from fastapi import FastAPI, HTTPException, WebSocket, WebSocketDisconnect
from fastapi.responses import HTMLResponse, FileResponse, StreamingResponse
from fastapi.staticfiles import StaticFiles
from pydantic import BaseModel
from typing import List
# PROJECT_ROOT = os.getcwd()
# if PROJECT_ROOT not in sys.path:
# sys.path.append(PROJECT_ROOT)
# from src.logger import *
from src.graph.Compile_graph import run
from src.utils.blog_utils import delete_blog_content
app = FastAPI()
os.makedirs("images", exist_ok=True)
os.makedirs("results", exist_ok=True)
# Mount static files
app.mount("/images", StaticFiles(directory="images"), name="images")
app.mount("/results", StaticFiles(directory="results"), name="results")
class BlogDeleteRequest(BaseModel):
data: dict
@app.get("/")
async def home():
with open("api/templates/index.html", "r", encoding="utf-8") as f:
return HTMLResponse(f.read())
@app.get("/blogs")
async def list_blogs():
results_dir = "results"
if not os.path.exists(results_dir):
return []
blogs = [f[:-3] for f in os.listdir(results_dir) if f.endswith(".md") and f != "README.md"]
return blogs
@app.get("/blog/{title}")
async def get_blog(title: str):
file_path = os.path.join("results", f"{title}.md")
if not os.path.exists(file_path):
raise HTTPException(status_code=404, detail="Blog not found")
with open(file_path, "r", encoding="utf-8") as f:
content = f.read()
return {"title": title, "content": content}
from fastapi.encoders import jsonable_encoder
@app.websocket("/ws/generate_blog")
async def generate_blog_ws(websocket: WebSocket):
await websocket.accept()
try:
data = await websocket.receive_json()
topic = data.get("topic")
if not topic:
await websocket.send_json({"error": "Topic is required"})
await websocket.close()
return
logging.info(f"WebSocket: Starting blog generation for topic: {topic}")
async for step in run(topic):
serializable_step = jsonable_encoder(step)
await websocket.send_json(serializable_step)
await websocket.send_json({"status": "completed"})
except WebSocketDisconnect:
logging.info("WebSocket disconnected")
except Exception as e:
logging.error(f"WebSocket error: {str(e)}")
await websocket.send_json({"error": str(e)})
finally:
try:
await websocket.close()
except:
pass
@app.delete("/delete_blog")
async def delete_blog(request: BlogDeleteRequest):
success = delete_blog_content(request.data)
if success:
return {"message": "Blog and associated images deleted successfully"}
else:
raise HTTPException(status_code=404, detail="Blog not found or could not be deleted")
@app.get("/download_blog/{title}")
async def download_blog(title: str):
md_path = os.path.join("results", f"{title}.md")
if not os.path.exists(md_path):
raise HTTPException(status_code=404, detail="Blog not found")
with open(md_path, "r", encoding="utf-8") as f:
content = f.read()
# Find images
image_pattern = r"!\[.*?\]\(\.\./images/(.*?)\)"
image_filenames = re.findall(image_pattern, content)
# Create zip in memory
zip_buffer = io.BytesIO()
with zipfile.ZipFile(zip_buffer, "a", zipfile.ZIP_DEFLATED, False) as zip_file:
# Add markdown file
zip_file.writestr(f"{title}.md", content)
# Add images
for img_name in image_filenames:
img_path = os.path.join("images", img_name)
if os.path.exists(img_path):
zip_file.write(img_path, os.path.join("images", img_name))
zip_buffer.seek(0)
return StreamingResponse(
zip_buffer,
media_type="application/x-zip-compressed",
headers={"Content-Disposition": f"attachment; filename={title}.zip"}
)
|