Upd debug logs

app/main.py

@@ -18,6 +18,18 @@
 from fastapi import FastAPI, WebSocket
 from app.routers import search, import_doc
 
+# Debugger
+import logging
+logging.basicConfig(
+    level=logging.DEBUG,
+    format="%(asctime)s — %(name)s — %(levelname)s — %(message)s",
+    force=True
+)
+logger = logging.getLogger("book-query")
+logger.setLevel(logging.DEBUG)
+logger.info("🚀 Starting Tutor Book Querier...")
+
+
 app = FastAPI()
 
 app.include_router(search.router, prefix="/search")

app/routers/import_doc.py

@@ -8,6 +8,9 @@ import aiofiles, uuid, os
 import asyncio
 import httpx
 
+import logging
+logger = logging.getLogger("book-query")
+
 router = APIRouter()
 
 class ImportRequest(BaseModel):
@@ -18,45 +21,62 @@ class ImportRequest(BaseModel):
 
 @router.post("")
 async def import_book(req: ImportRequest):
+    logger.info(f"📥 Received import request: {req.dict()}")
     source_lookup = {
         "google": google_books.fetch,
         "openlibrary": open_library.fetch,
         "ia": internet_archive.fetch
     }
     if req.source not in source_lookup:
+        logger.warning(f"❌ Invalid source: {req.source}")
         raise HTTPException(400, "Invalid source")
 
     result = await source_lookup[req.source](req.ref)
-    print(f"[DEBUG] Import source result: {result}")  # We need to debug out the result from Google API
+    logger.debug(f"🔎 Fetch result for ref {req.ref}: {result}")
     
     # Debugs
     if not result:
-        print("[INFO] No download result returned from fetch().")
+        logger.warning(f"⛔️ No fetch result for {req.source} with ref {req.ref}")
         raise HTTPException(403, "Download not permitted")
     if not result.get("download_url"):
-        print(f"[INFO] No download URL. Viewability: {result.get('viewability', 'N/A')}")
+        logger.warning(f"📄 No download URL from {req.source}. Viewability: {result.get('viewability', 'unknown')}")
         raise HTTPException(403, "Download not permitted")
 
     # Write temp file and save as Pdf from downloadable link
     download_url = result["download_url"]
     file_path = f"/tmp/{req.candidate_id}.pdf"
+    logger.info(f"⬇️ Downloading from: {download_url}")
 
-    async with aiofiles.open(file_path, mode='wb') as f:
-        async with httpx.AsyncClient() as client:
-            r = await client.get(download_url)
-            await f.write(r.content)
-
-    with open(file_path, "rb") as f:
-        await grid_fs_bucket.upload_from_stream(f"{req.candidate_id}.pdf", f)
-
-    os.remove(file_path)
+    # Read and write file 
+    try:
+        async with aiofiles.open(file_path, mode='wb') as f:
+            async with httpx.AsyncClient() as client:
+                r = await client.get(download_url)
+                r.raise_for_status()
+                await f.write(r.content)
+        logger.info(f"✅ PDF saved to {file_path}")
+    except Exception as e:
+        logger.error(f"🚨 Failed to download or write PDF: {e}")
+        raise HTTPException(500, "Failed to download PDF")
+    
+    # Save to bucket
+    try:
+        with open(file_path, "rb") as f:
+            await grid_fs_bucket.upload_from_stream(f"{req.candidate_id}.pdf", f)
+        os.remove(file_path)
+    except Exception as e:
+        logger.error(f"💥 Failed to upload to GridFS: {e}")
+        raise HTTPException(500, "Storage failed")
+    
+    # Doc tags
     doc = {
         "_id": req.candidate_id,
         "title": req.title,
         "status": "queued",
         "metadata": result
     }
+    await db.documents.insert_one(doc)
     asyncio.create_task(parse_and_index(req.candidate_id))
-
+    logger.info(f"📚 Document {req.candidate_id} queued for indexing")
     return {"document_id": req.candidate_id, "status": "queued"}
 

app/services/google_books.py

@@ -1,6 +1,8 @@
 # app/services/google_books.py
 import httpx, os
 from tenacity import retry, stop_after_attempt, wait_fixed
+import logging
+logger = logging.getLogger("book-query")
 
 @retry(stop=stop_after_attempt(3), wait=wait_fixed(1))
 async def search(q):
@@ -25,4 +27,7 @@ async def search(q):
         ]
 
 async def fetch(ref):
-    return None  # Google doesn't permit download
+    logger = logging.getLogger("book-query")
+    logger.debug(f"[Google] fetch() called with ref={ref}")
+    return None  # Always returns None, so import will 403
+