♻️ Add GetEntryParams model and utility functions for default entry parameters

Author: yezz123

pragma/models/schemas.py

@@ -32,3 +32,13 @@ class AggregatedOnchainResponse(BaseModel):
     macd: str = Field(default="N/A", description="Moving Average Convergence Divergence")
     error: str | None = Field(default=None, description="Error message if any")
     isUnsupported: bool = Field(default=False, description="Flag indicating if the pair is unsupported")
+
+
+class GetEntryParams(BaseModel):
+    """Parameters for entry requests."""
+
+    aggregation: str | None = None
+    entry_type: str | None = None
+    interval: str | None = None
+    routing: bool = True
+    timestamp: int | None = None

pragma/models/utils.py

@@ -0,0 +1,12 @@
+"""Utility functions for the models"""
+
+DEFAULT_PAIRS = ["ETH/USD", "BTC/USD"]
+
+# Default entry parameters matching API.devnet
+DEFAULT_ENTRY_PARAMS = {
+    "aggregation": "median",
+    "entry_type": None,  # Changeable from the frontend
+    "interval": None,  # Changeable from the frontend
+    "routing": True,
+    "timestamp": None,
+}

pragma/routers/endpoints/streaming.py

@@ -4,39 +4,18 @@
 import httpx
 from fastapi import APIRouter, Depends, Query
 from fastapi.responses import StreamingResponse
-from pydantic import BaseModel
 
 from pragma.client.client import PragmaApiClient
 from pragma.client.token import get_api_client
+from pragma.models.schemas import GetEntryParams
+from pragma.models.utils import DEFAULT_ENTRY_PARAMS
 from pragma.utils.logging import logger
 
 app = APIRouter(
     prefix="/data/multi",
 )
 
 
-class GetEntryParams(BaseModel):
-    """Parameters for entry requests."""
-
-    aggregation: str | None = None
-    entry_type: str | None = None
-    interval: str | None = None
-    routing: bool = True
-    timestamp: int | None = None
-
-
-DEFAULT_PAIRS = ["ETH/USD", "BTC/USD"]
-
-# Default entry parameters matching API.devnet
-DEFAULT_ENTRY_PARAMS = {
-    "aggregation": "median",
-    "entry_type": None,  # Changeable from the frontend
-    "interval": None,  # Changeable from the frontend
-    "routing": True,
-    "timestamp": None,
-}
-
-
 @app.get(
     "/stream",
     responses={