Modified project structure

Author: dimtics

.gitignore

@@ -1,6 +1,7 @@
 # Python-generated files
 __pycache__/
 .mypy_cache
+.ruff_cache
 *.py[cod]
 *$py.class
 *.so

pyproject.toml

@@ -9,7 +9,6 @@ authors = [
 requires-python = ">=3.12"
 dependencies = [
     "asyncio>=3.4.3",
-    "dash>=2.18.2",
     "duckdb>=1.1.3",
     "fastapi>=0.115.4",
     "httpx>=0.27.2",
@@ -18,6 +17,8 @@ dependencies = [
     "pydantic>=2.9.2",
     "python-dotenv>=1.0.1",
     "pyyaml>=6.0.2",
+    "streamlit>=1.40.1",
+    "uvicorn>=0.32.0",
 ]
 
 [project.scripts]

src/stock_valuation_app/__init__.py src/api/__init__.pysrc/stock_valuation_app/__init__.py renamed to src/api/__init__.py

@@ -4,7 +4,7 @@
 from typing import Any
 import httpx
 import utils
-from stock_valuation_app.models.stock import CombinedModel
+from models.stock_data import CombinedModel
 
 
 def get_endpoint(url: str) -> str:
@@ -37,6 +37,7 @@ async def get_data(self, client: httpx.Client, url: str) -> dict[str, Any]:
         return data
 
     async def fetch_data(self, ticker: str) -> dict[str, list[dict[str, Any]]]:
+        """Extracts data asynchronously from multiple FMP endpoints"""
         urls = []
         for metric in self.metric_types:
             if metric in ["profile", "rating"]:
@@ -60,4 +61,4 @@ async def fetch_data(self, ticker: str) -> dict[str, list[dict[str, Any]]]:
             records = dict(zip(new_metric_types, results))
 
             # Validate the combined records
-            return CombinedModel(**records).model_dump()
+            return CombinedModel(**records).model_dump()

…c/stock_valuation_app/data/fmp_client.py src/api/fmp_client.pysrc/stock_valuation_app/data/fmp_client.py renamed to src/api/fmp_client.py src/stock_valuation_app/data/fmp_client.py renamed to src/api/fmp_client.py

@@ -1,13 +0,0 @@
-import asyncio
-from stock_valuation_app.data import fmp_client
-
-async def main() -> None:
-    """Main function to fetch data from the Financial Modeling Prep API."""
-    api_client = fmp_client.FMPClient()
-    rating_endpoint = fmp_client.get_endpoint("annual_ratios")
-    data = await api_client.fetch_data(rating_endpoint, "AAPL")
-    print(data)
-
-
-if __name__ == "__main__":
-    asyncio.run(main())

src/main.py

@@ -0,0 +1,50 @@
+import asyncio
+import polars as pl
+# from stock_valuation_app.data.fmp_client import FMPClient
+
+
+
+
+raw_data = asyncio.run(extract_source_data("PAYS"))
+
+profile_df = pl.DataFrame(raw_data["profile"])
+rating_df = pl.DataFrame(raw_data["rating"])
+metric_df = pl.DataFrame(raw_data["key_metrics"])
+growth_df = pl.DataFrame(raw_data["growth"])
+
+# Pivot the DataFrame
+pivoted_df = profile_df.unpivot(variable_name="Column", value_name="Value")
+# Sort the result to maintain the original order
+pivoted_df = pivoted_df.sort("Column")
+
+# Convert DataFrame to formatted text
+formatted_text = []
+for row in pivoted_df.iter_rows():
+    column, value = row
+    formatted_text.append(html.Div([html.Strong(f"{column}: "), f"{value}"]))
+
+# async def extract_source_data(ticker: str):
+#     source_data = await FMPClient().fetch_data(ticker)
+#     return {
+#         "profile": source_data["profile"],
+#         "rating": source_data["rating"],
+#         "key_metrics": source_data["key_metrics"],
+#         "growth": source_data["growth"],
+#     }
+
+# async def extract_source_data(ticker: str):
+#     source_data = await FMPClient().fetch_data(ticker)
+#     return source_data
+
+
+# if __name__ == "__main__":
+#     pass
+    # raw_data = asyncio.run(extract_source_data('PAYS'))
+
+    # def get_dataframes():
+    #     """Captures source dataframes"""
+    #     profile_df = pl.DataFrame(raw_data["profile"])
+    #     rating_df = pl.DataFrame(raw_data["rating"])
+    #     metric_df = pl.DataFrame(raw_data["key_metrics"])
+    #     growth_df = pl.DataFrame(raw_data["growth"])
+    #     return (profile_df, rating_df, metric_df, growth_df)