Create app/app.py

app/app.py

@@ -0,0 +1,179 @@
+from fastapi import FastAPI, HTTPException
+from fastapi.middleware.cors import CORSMiddleware
+from pydantic import BaseModel
+import os
+import importlib.util
+
+# -------------------------------------------------------
+# Explicit module loader (HF-safe)
+# -------------------------------------------------------
+BASE_DIR = os.path.dirname(os.path.abspath(__file__))
+
+def load_module(name):
+    path = os.path.join(BASE_DIR, f"{name}.py")
+    if not os.path.exists(path):
+        raise ImportError(f"Module file not found: {path}")
+
+    spec = importlib.util.spec_from_file_location(name, path)
+    module = importlib.util.module_from_spec(spec)
+    spec.loader.exec_module(module)
+    return module
+
+# -------------------------------------------------------
+# Load ALL local modules explicitly
+# -------------------------------------------------------
+common = load_module("common")
+stock = load_module("stock")
+indices_html = load_module("indices_html")
+index_live_html = load_module("index_live_html")
+preopen_html = load_module("preopen_html")
+eq_html = load_module("eq_html")
+bhavcopy_html = load_module("bhavcopy_html")
+build_nse_fno = load_module("build_nse_fno")
+
+# External libs (installed via requirements.txt)
+import nsepython
+import yahooinfo
+
+# -------------------------------------------------------
+# FastAPI app
+# -------------------------------------------------------
+app = FastAPI(title="Stock / Index Backend")
+
+app.add_middleware(
+    CORSMiddleware,
+    allow_origins=["*"],
+    allow_methods=["*"],
+    allow_headers=["*"],
+)
+
+# -------------------------------------------------------
+# Valid request types
+# -------------------------------------------------------
+STOCK_REQ = [
+    "info", "intraday", "daily", "nse_eq", "qresult", "result",
+    "balance", "cashflow", "dividend", "split", "other", "stock_hist"
+]
+
+INDEX_REQ = [
+    "indices", "nse_open", "nse_preopen", "nse_fno", "nse_fiidii",
+    "nse_events", "nse_future", "nse_bhav", "nse_highlow", "stock_highlow",
+    "index_history", "nse_largedeals", "nse_most_active",
+    "largedeals_historical", "nse_bulkdeals", "nse_blockdeals",
+    "index_pe_pb_div", "index_total_returns"
+]
+
+# -------------------------------------------------------
+# Request model
+# -------------------------------------------------------
+class FetchRequest(BaseModel):
+    mode: str
+    req_type: str
+    name: str
+    date_start: str
+    date_end: str
+
+# -------------------------------------------------------
+# Health
+# -------------------------------------------------------
+@app.get("/")
+def health():
+    return {"status": "ok", "service": "backend alive"}
+
+# -------------------------------------------------------
+# STOCK handler
+# -------------------------------------------------------
+def handle_stock(req: FetchRequest):
+    t = req.req_type.lower()
+
+    if t == "info":
+        return common.wrap(yahooinfo.fetch_info(req.name))
+    if t == "intraday":
+        return common.wrap(stock.fetch_intraday(req.name, req.date_start, req.date_end))
+    if t == "daily":
+        return common.wrap(stock.fetch_daily(req.name, req.date_start, req.date_end))
+    if t == "nse_eq":
+        return eq_html.build_eq_html(req.name)
+    if t == "qresult":
+        return common.wrap(stock.fetch_qresult(req.name))
+    if t == "result":
+        return common.wrap(stock.fetch_result(req.name))
+    if t == "balance":
+        return common.wrap(stock.fetch_balance(req.name))
+    if t == "cashflow":
+        return common.wrap(stock.fetch_cashflow(req.name))
+    if t == "dividend":
+        return common.wrap(stock.fetch_dividend(req.name))
+    if t == "split":
+        return common.wrap(stock.fetch_split(req.name))
+    if t == "other":
+        return common.wrap(stock.fetch_other(req.name))
+    if t == "stock_hist":
+        return nsepython.nse_stock_hist(
+            req.date_start, req.date_end, req.name
+        ).to_html()
+
+    return common.wrap(f"<h3>Unhandled stock req_type: {t}</h3>")
+
+# -------------------------------------------------------
+# INDEX handler
+# -------------------------------------------------------
+def handle_index(req: FetchRequest):
+    t = req.req_type.lower()
+
+    if t == "indices":
+        return indices_html.build_indices_html()
+    if t == "nse_open":
+        return index_live_html.build_index_live_html()
+    if t == "nse_preopen":
+        return preopen_html.build_preopen_html()
+    if t == "nse_fno":
+        return build_nse_fno.nse_fno_html(req.date_end, req.name)
+    if t == "nse_fiidii":
+        return nsepython.nse_fiidii().to_html()
+    if t == "nse_events":
+        return nsepython.nse_events().to_html()
+    if t == "nse_future":
+        return common.wrap(nsepython.nse_future(req.name))
+    if t == "nse_highlow":
+        return nsepython.nse_highlow(req.date_end).to_html()
+    if t == "stock_highlow":
+        return nsepython.stock_highlow(req.date_end).to_html()
+    if t == "nse_bhav":
+        return bhavcopy_html.build_bhavcopy_html(req.date_end)
+    if t == "nse_largedeals":
+        return nsepython.nse_largedeals().to_html()
+    if t == "nse_bulkdeals":
+        return nsepython.nse_bulkdeals().to_html()
+    if t == "nse_blockdeals":
+        return nsepython.nse_blockdeals().to_html()
+    if t == "nse_most_active":
+        return nsepython.nse_most_active().to_html()
+    if t == "index_history":
+        return nsepython.index_history("NIFTY", req.date_start, req.date_end).to_html()
+    if t == "largedeals_historical":
+        return nsepython.nse_largedeals_historical(
+            req.date_start, req.date_end
+        ).to_html()
+    if t == "index_pe_pb_div":
+        return nsepython.index_pe_pb_div(
+            "NIFTY", req.date_start, req.date_end
+        ).to_html()
+    if t == "index_total_returns":
+        return nsepython.index_total_returns(
+            "NIFTY", req.date_start, req.date_end
+        ).to_html()
+
+    return common.wrap(f"<h3>Unhandled index req_type: {t}</h3>")
+
+# -------------------------------------------------------
+# Main API
+# -------------------------------------------------------
+@app.post("/api/fetch")
+def fetch_data(req: FetchRequest):
+    if req.mode.lower() == "stock":
+        return handle_stock(req)
+    if req.mode.lower() == "index":
+        return handle_index(req)
+
+    raise HTTPException(status_code=400, detail="Invalid mode")