[Feature] Add the 13f data directly from the FMP

openbb_platform/extensions/equity/integration/test_equity_api.py

@@ -1985,6 +1985,14 @@ def test_equity_fundamental_reported_financials(params, headers):
                 "provider": "sec",
             }
         ),
+        (
+            {
+                "symbol": "NVDA",
+                "date": None,
+                "limit": 10,
+                "provider": "fmp",
+            }
+        ),
     ],
 )
 @pytest.mark.integration

openbb_platform/extensions/equity/integration/test_equity_python.py

@@ -1884,6 +1884,14 @@ def test_equity_fundamental_reported_financials(params, obb):
                 "provider": "sec",
             }
         ),
+        (
+                {
+                    "symbol": "NVDA",
+                    "date": None,
+                    "limit": 10,
+                    "provider": "fmp",
+                }
+        ),
     ],
 )
 @pytest.mark.integration

openbb_platform/providers/fmp/openbb_fmp/__init__.py

@@ -39,6 +39,7 @@
 from openbb_fmp.models.etf_sectors import FMPEtfSectorsFetcher
 from openbb_fmp.models.executive_compensation import FMPExecutiveCompensationFetcher
 from openbb_fmp.models.financial_ratios import FMPFinancialRatiosFetcher
+from openbb_fmp.models.form_13FHR import FMPForm13FHRFetcher
 from openbb_fmp.models.forward_ebitda_estimates import FMPForwardEbitdaEstimatesFetcher
 from openbb_fmp.models.forward_eps_estimates import FMPForwardEpsEstimatesFetcher
 from openbb_fmp.models.government_trades import FMPGovernmentTradesFetcher
@@ -138,6 +139,7 @@
         "WorldNews": FMPWorldNewsFetcher,
         "EtfHistorical": FMPEquityHistoricalFetcher,
         "YieldCurve": FMPYieldCurveFetcher,
+        "Form13FHR": FMPForm13FHRFetcher,
         "GovernmentTrades": FMPGovernmentTradesFetcher,
     },
     repr_name="Financial Modeling Prep (FMP)",

openbb_platform/providers/fmp/openbb_fmp/models/form_13FHR.py

@@ -0,0 +1,138 @@
+"""Form 13f Model."""
+
+import asyncio
+from datetime import date as dateType, datetime
+from typing import Any, Dict, List, Optional
+from warnings import warn
+
+from openbb_core.app.model.abstract.error import OpenBBError
+from openbb_fmp.models.equity_profile import FMPEquityProfileFetcher
+from pydantic import Field
+
+from openbb_core.provider.abstract.fetcher import Fetcher
+from openbb_core.provider.standard_models.form_13FHR import (
+    Form13FHRData,
+    Form13FHRQueryParams,
+)
+from openbb_core.provider.utils.descriptions import DATA_DESCRIPTIONS
+from openbb_core.provider.utils.errors import EmptyDataError
+from openbb_core.provider.utils.helpers import amake_request
+from openbb_fmp.utils.helpers import create_url, response_callback
+
+
+class FMPForm13FHRQueryParams(Form13FHRQueryParams):
+    """Form 13f Query Parameters.
+
+    Source: https://financialmodelingprep.com/api/v3/form-thirteen/0001388838?date=2021-09-30
+    """
+
+
+class FMPForm13FHRData(Form13FHRData):
+    """Form13 FHR Data Model."""
+
+    __alias_dict__ = {
+        "period_ending": "date",
+        "issuer": "nameOfIssuer",
+        "principal_amount": "shares",
+        "asset_class": "titleOfClass",
+        "filling_date": "fillingDate",
+        "accepted_date": "acceptedDate",
+        "symbol": "tickercusip",
+        "final_link": "finalLink",
+    }
+    symbol: Optional[str] = Field(
+        default=None, description=DATA_DESCRIPTIONS.get("symbol", "")
+    )
+    filling_date: Optional[dateType] = Field(
+        default=None, description="Date when the filing was submitted to the SEC."
+    )
+    accepted_date: Optional[dateType] = Field(
+        default=None, description="Date when the filing was accepted by the SEC."
+    )
+    link: Optional[str] = Field(
+        default=None, description="URL link to the SEC filing on the SEC website."
+    )
+    final_link: Optional[str] = Field(
+        default=None,
+        description="URL link to the XML information table of the SEC filing.",
+    )
+
+
+class FMPForm13FHRFetcher(
+    Fetcher[
+        FMPForm13FHRQueryParams,
+        List[FMPForm13FHRData],
+    ]
+):
+    """Fetches and transforms data from the Form 13f endpoints."""
+
+    @staticmethod
+    def transform_query(params: Dict[str, Any]) -> FMPForm13FHRQueryParams:
+        """Transform the query params."""
+        return FMPForm13FHRQueryParams(**params)
+
+    @staticmethod
+    async def aextract_data(
+        query: FMPForm13FHRQueryParams,
+        credentials: Optional[Dict[str, str]] = None,
+        **kwargs: Any,
+    ) -> List[Dict]:
+        """Return the raw data from the Form 13f endpoint."""
+        api_key = credentials.get("fmp_api_key") if credentials else ""
+        if query.symbol.isnumeric():
+            cik = query.symbol
+        else:
+            try:
+                profile = await FMPEquityProfileFetcher.fetch_data({"symbol": query.symbol}, {"fmp_api_key": api_key})
+                cik = getattr(profile[0], "cik", "")
+                if not cik:
+                    raise OpenBBError(f"Invalid symbol -> {query.symbol}")
+            except OpenBBError as e:
+                raise OpenBBError(f"Invalid symbol -> {query.symbol} -> {e}")
+        date_url = create_url(
+            3,
+            f"form-thirteen-date/{cik}",
+            api_key,
+            query,
+            exclude=["symbol", "limit"],
+        )
+        dates = await amake_request(date_url, response_callback=response_callback, **kwargs)
+        if not dates:
+            raise EmptyDataError("No data returned for the given symbol.")
+        if not dates or len(dates) == 0:
+            warn(f"Symbol Error: No data found for symbol {cik}")
+        results: List[Dict] = []
+
+        async def get_one(date):
+            """Get data for the given date."""
+            date = datetime.strptime(date, "%Y-%m-%d").date()
+            query.date = date
+            url = create_url(
+                3,
+                f"form-thirteen/{cik}",
+                api_key,
+                query,
+                exclude=["symbol", "limit"],
+            )
+            result = await amake_request(url, response_callback=response_callback, **kwargs)
+            if not result or len(result) == 0:
+                warn(f"Symbol Error: No data found for symbol {symbol}")
+            if result:
+                results.extend(result)
+
+        await asyncio.gather(*[get_one(date) for date in dates])
+
+        if not results:
+            raise EmptyDataError("No data returned for the given symbol.")
+        if query.limit:
+            return results[:query.limit]
+        return results
+
+    @staticmethod
+    def transform_data(
+        query: FMPForm13FHRQueryParams, data: List[Dict], **kwargs: Any
+    ) -> List[FMPForm13FHRData]:
+        """Return the transformed data."""
+        if query.symbol.isnumeric():
+            [d.pop("cik", None) for d in data]
+        return [FMPForm13FHRData(**d) for d in data]

openbb_platform/providers/fmp/tests/test_fmp_fetchers.py

@@ -5,6 +5,7 @@
 
 import pytest
 from openbb_core.app.service.user_service import UserService
+from openbb_fmp.models.form_13FHR import FMPForm13FHRFetcher
 from openbb_fmp.models.analyst_estimates import FMPAnalystEstimatesFetcher
 from openbb_fmp.models.available_indices import FMPAvailableIndicesFetcher
 from openbb_fmp.models.balance_sheet import FMPBalanceSheetFetcher
@@ -765,6 +766,19 @@ def test_fmp_historical_market_cap_fetcher(credentials=test_credentials):
     assert result is None
 
 
+
+@pytest.mark.record_http
+def test_fmp_form_13f_fetcher(credentials=test_credentials):
+    """Test FMP form 13f fetcher."""
+    params = {
+        "symbol": "NVDA",
+        "limit": 1,
+    }
+    fetcher = FMPForm13FHRFetcher()
+    result = fetcher.test(params, credentials)
+    assert result is None
+
+
 @pytest.mark.record_http
 def test_fmp_government_trades_fetcher(credentials=test_credentials):
     """Test FMP government trades fetcher.