o _j)@sdZddlmZddlZddlZddlmZddlmZddl m Z m Z ddl m Z mZddlmZmZmZdd lmZmZmZmZmZdd lmZdd lmZdd lmZdd lm Z!e"dZ#dZ$GdddZ%dgZ&dS)uBSEClient — async client for BSE option chain data. Usage:: import asyncio from indiaopt import BSEClient async def main(): async with BSEClient() as client: # BSE uses numeric scrip codes, e.g. "999920" for SENSEX derivatives result = await client.fetch_option_chain("999920", is_index=True) print(f"Spot: {result.spot_price}, ATM: {result.atm_strike}") asyncio.run(main()) .. note:: BSE's option chain API uses scrip codes rather than symbol names. The mapping between names (e.g. "SENSEX") and scrip codes is not part of this library — you'll need to maintain your own mapping or use BSE's instrument list API. ) annotationsN)ThreadPoolExecutor)Any)CircuitBreakerget_default_breaker)Settings get_settings) BSE_BASE_URLBSE_OPTION_CHAIN_PATHRATE_LIMIT_STATUS_CODES) FetchErrorFetchTimeoutError NetworkError ParseErrorRateLimitError) RetryPolicy)create_bse_session)OptionChainResult)bsezindiaopt.exchanges.bseBSEc@seZdZdZ  d.d/d d Zd0d d Zd1ddZd2ddZdddd3ddZdddd4dd Z d5d"d#Z d6d$d%Z d7d'd(Z d8d*d+Z d3d,d-ZdS)9 BSEClienta?Async client for BSE option chain data. Mirrors the :class:`~indiaopt.exchanges.nse.NSEClient` interface exactly so the two are interchangeable when accessed through the :class:`~indiaopt.exchanges.base.ExchangeClient` Protocol. Args: settings: Optional :class:`~indiaopt.config.settings.Settings` override. breaker: Optional :class:`~indiaopt.circuit.CircuitBreaker` override. Context manager (recommended):: async with BSEClient() as client: result = await client.fetch_option_chain("999920", is_index=True) NsettingsSettings | NonebreakerCircuitBreaker | NonereturnNonecCsP|pt|_|pt|jj|jjd|_t|j|_t |jj dd|_ d|_ dS)N)failure_thresholdbackoff_secondsz indiaopt-bse) max_workersthread_name_prefix) r _settingsrcircuit_failure_thresholdcircuit_backoff_seconds_breakerr from_settings _retry_policyrthread_pool_workers_pool_session)selfrrr+Q/home/dinkstrade/pdmp/venv/lib/python3.10/site-packages/indiaopt/exchanges/bse.py__init__Gs  zBSEClient.__init__cs|SNr+r*r+r+r, __aenter__XszBSEClient.__aenter___objectcs|IdHdSr.)close)r*r1r+r+r, __aexit__[szBSEClient.__aexit__csF|jdurz|jWn tyYnwd|_|jjdddS)z-Release all resources (session, thread pool).NF)wait)r)r3 Exceptionr(shutdownr/r+r+r,r3^s  zBSEClient.closeT)is_indexexpirysymbolstrr8boolr9 str | Nonedict[str, Any]cs~|}|jt|t}ztj||j|j ||||j j dIdHWStj y>|j t|t||j j tdw)z=Fetch the unparsed raw JSON dictionary for *symbol* from BSE.timeoutNr: timeout_sexchange)stripr$ raise_if_openEXCHANGEasyncioget_running_loopwait_forrun_in_executorr( _fetch_syncr! async_timeout TimeoutErrorrecord_failurer )r*r:r8r9loopr+r+r,fetch_raw_option_chainhs. z BSEClient.fetch_raw_option_chainrcs|}|jt|t}ztj||j|j ||||j j dIdH}Wntj y?|j t|t||j j tdwt||S)aFetch the full option chain for *symbol* from BSE. Args: symbol: BSE scrip code (e.g. ``"999920"`` for SENSEX derivatives). is_index: ``True`` for index instruments, ``False`` for equities. expiry: Specific expiry date string. Uses today's date when not provided. Returns: :class:`~indiaopt.models.option_chain.OptionChainResult` r?NrA)rDr$rErFrGrHrIrJr(rKr!rLrMrNr bse_parserparse_option_chain)r*r:r8r9rOrawr+r+r,fetch_option_chains0  zBSEClient.fetch_option_chain list[str]cstdgS)uReturn available expiry dates for *symbol*. BSE does not have a standard public expiry endpoint — returns an empty list with a warning. zgBSE does not expose a public expiry-dates API. Pass the expiry date explicitly to fetch_option_chain().)loggerwarningr*r:r+r+r,get_expiry_datess zBSEClient.get_expiry_datescCs|jt|dS)z0Manually reset the circuit breaker for *symbol*.N)r$resetrFrXr+r+r, reset_circuitszBSEClient.reset_circuitdict[str, dict[str, object]]cCs |jS)z?Return a snapshot of all circuit breaker states for monitoring.)r$statsr/r+r+r, circuit_statss zBSEClient.circuit_statsrcCs&|jdurt|jj|jjd|_|jS)N) proxy_urlswarmup_timeout)r)rr!r_r`r/r+r+r,_get_or_create_sessions z BSEClient._get_or_create_sessionc Csddlm}|}|rdnd}|p|d}ttd|d|d|}d}t|jjD]} z|j ||j j d } | j d krz| } Wn+tyr} ztd || d | d|_|}td | |t| d d| d} ~ ww|jt|| WS| j tvrtd| j d||t| j | d d}td|| d |jj| j | |jjd kr|j| Wq0td| j d||t| j | d dttfyty} z+td|d| |t| d d}d|_|}| |jjd kr|j| WYd} ~ q0d} ~ wty+} z| }| |jjd kr!|j| WYd} ~ q0d} ~ ww|jt|td|jjd||t|jjd|)Nr)datetimeIndicesEquitiesz%d-%b-%Yz ?Scripcode=z &ExpiryDate=z&Type=r?zCJSON decode failed for BSE/%s (attempt %d): %s. Refreshing session.zInvalid JSON from BSE: )r:rCattemptszHTTP z from BSE for )r:rC status_codergz4Rate-limited by BSE for %s (attempt %d/%d, HTTP %d).zUnexpected HTTP zNetwork error for BSE/z: zAll z attempts failed for BSE/)rbranowstrftimer r ranger& max_retriesgetr! fetch_timeoutrhjsonr6rVrWr)rrFr$record_successr r sleep_forr OSErrorrrN)r*r:r8r9rbsessiontype_strurllast_excattemptrespdatajson_excexcr+r+r,rKs          zBSEClient._fetch_sync)NN)rrrrrr)rr)r1r2rr)rr)r:r;r8r<r9r=rr>)r:r;r8r<r9r=rr)r:r;rrU)r:r;rr)rr\)rr)__name__ __module__ __qualname____doc__r-r0r4r3rPrTrYr[r^rarKr+r+r+r,r6s&   # *  r)'r __future__rrGloggingconcurrent.futuresrtypingrindiaopt.circuitrrindiaopt.config.settingsrrindiaopt.constantsr r r indiaopt.exceptionsr r rrrindiaopt.http.retryrindiaopt.http.sessionrindiaopt.models.option_chainrindiaopt.parsersrrQ getLoggerrVrFr__all__r+r+r+r,s&         {