summaryrefslogtreecommitdiff
path: root/shared/src
diff options
context:
space:
mode:
Diffstat (limited to 'shared/src')
-rw-r--r--shared/src/shared/alpaca.py15
1 files changed, 10 insertions, 5 deletions
diff --git a/shared/src/shared/alpaca.py b/shared/src/shared/alpaca.py
index 3dd752b..7821592 100644
--- a/shared/src/shared/alpaca.py
+++ b/shared/src/shared/alpaca.py
@@ -1,6 +1,6 @@
"""Alpaca Markets API client for US stock trading."""
+
import logging
-from datetime import datetime, timezone
from decimal import Decimal
from typing import Any
@@ -107,7 +107,8 @@ class AlpacaClient:
async def get_orders(self, status: str = "open", limit: int = 50) -> list:
return await self._request(
- "GET", f"{self._base_url}/v2/orders",
+ "GET",
+ f"{self._base_url}/v2/orders",
params={"status": status, "limit": limit},
)
@@ -155,19 +156,23 @@ class AlpacaClient:
params["end"] = end
data = await self._request(
- "GET", f"{self._data_url}/v2/stocks/{symbol}/bars", params=params,
+ "GET",
+ f"{self._data_url}/v2/stocks/{symbol}/bars",
+ params=params,
)
return data.get("bars", [])
async def get_latest_quote(self, symbol: str) -> dict:
data = await self._request(
- "GET", f"{self._data_url}/v2/stocks/{symbol}/quotes/latest",
+ "GET",
+ f"{self._data_url}/v2/stocks/{symbol}/quotes/latest",
)
return data.get("quote", {})
async def get_snapshot(self, symbol: str) -> dict:
return await self._request(
- "GET", f"{self._data_url}/v2/stocks/{symbol}/snapshot",
+ "GET",
+ f"{self._data_url}/v2/stocks/{symbol}/snapshot",
)
# --- Market Status ---