get_instrumets for cryptofeed.FeedHandler

Nelson Torres 2025-01-30 01:38:59 +00:00
parent 9976dbd1f6
commit 7ffdbeecde
1 changed files with 29 additions and 0 deletions

View File

@ -361,6 +361,35 @@ class Client:
return flat
async def get_instruments(
self,
currency: str = 'btc',
kind: str = 'option',
expired: bool = False,
) -> list[Symbol]:
"""
Get instruments for cryptoFeed.FeedHandler.
"""
params: dict[str, str] = {
'currency': currency.upper(),
'kind': kind,
'expired': expired,
}
r: JSONRPCResult = await self._json_rpc_auth_wrapper(
'public/get_instruments',
params,
)
resp = r.result
response_list = []
for i in range(len(resp) // 10):
element = resp[i]
response_list.append(piker_sym_to_cb_sym(element['instrument_name']))
return response_list
async def submit_limit(
self,
symbol: str,