(i=7zddlZddlZddlmZmZmZmZmZmZm Z m Z m Z m Z ddl mZddlmZmZddlmZmZmZddlmZddlmZmZmZddlmZerdd lmZe d Z ejBd k\rGd d ejDe ee Z#nGdd ejDee Z#Gdde#e Z$GddZ%y)N) TYPE_CHECKINGAnyCallableDictGenericListOptionalTupleTypeVarUnion)BATCH_REQUEST_ID)RequestInformationgenerate_cache_key)SubscriptionProcessingFinishedTaskNotRunningWeb3ValueError)SubscriptionContainer) RPCEndpointRPCId RPCResponse) SimpleCache)PersistentConnectionProviderT) c eZdZy_TaskReliantQueueN__name__ __module__ __qualname__\/var/www/br/venv/lib/python3.12/site-packages/web3/providers/persistent/request_processor.pyrr3 r$rc eZdZyrrr#r$r%rr8r&r$c(eZdZdZdeffd ZxZS)TaskReliantQueuezT A queue that relies on a task to be running to process items in the queue. returncdKt|d{}t|tr||S7w)N)superget isinstance Exception)selfitem __class__s r%r-zTaskReliantQueue.getAs0W[]" dI &J #s 0.0)r r!r"__doc__rr- __classcell__)r2s@r%r)r)<s1r$r)ceZdZUdZeed<dZeeed< dddde de d dfd Z e d e e effd Zd eed ededeee e edeffedeffedefedeffd ee f dZde d eefdZded efdZdededefd dfdZdeeeefd efdZ d deded dfdZ d!de ded efdZd"dZd"dZ y)#RequestProcessorF)_subscription_queue_synced_with_ws_streamN_subscription_containerproviderr subscription_response_queue_sizerequest_information_cache_sizer*c||_t||_td|_t ||_t ||_y)Nmaxsize) _providerr_request_information_cache_request_response_cacher)_subscription_response_queue_handler_subscription_queue)r0r9r:r;s r%__init__zRequestProcessor.__init__PsQ "7B *8 '5@4D$ %E F ) %E F (r$c|jjDcic]-\}}|jdk(r|jd|ji/c}}Scc}}w)N eth_subscribeparams)rAitemsmethodsubscription_idrH)r0keyvalues r%active_subscriptionsz%RequestProcessor.active_subscriptionsbsW#==CCE U||.  ! !Hell#; ;   s2A request_idrJrHresponse_formatters.ct||f}||jjjvru|jjj|}|j d}t|}||j vr(|jj jd||y|!|jjs tdt|}t|||} |jj jd||| j|j j|| |j jr%|jj jd|S)NidziThis is a cached request, not caching request info because it is not unique: method=%s, params=%sz7Request id must be provided when not batching requests.zNCaching request info: request_id=%s, cache_key=%s, request_info=%szRequest information cache is full. This may result in unexpected behavior. Consider increasing the ``request_information_cache_size`` on the provider.)rr@_request_cache_datar-rAloggerdebug _is_batchingrr__dict__cacheis_fullwarning) r0rOrJrHrPcached_requests_keycached_responsecached_response_id cache_key request_infos r%cache_request_informationz*RequestProcessor.cache_request_informationls_1&&1AB $.."?"?"E"E E"nn;;AABUVO!0!4!4T!: *+=>ID;;;%%++A    >>..$M'z2 )    ## 5    ! !   ''--     * * 2 2 4 NN ! ! ) )#  r$r_c|jj|}|1|jjj d||j |S)NzERequest info popped from cache: cache_key=%s, request_info=%s)rApopr@rUrVrX)r0r_r`s r%pop_cached_request_informationz/RequestProcessor.pop_cached_request_informationsQ66::9E  # NN ! ! ' '9%%   r$responsec0d|vrW|ddk(rOd|vr tdd|dvr tdt|dd}|jj|}|St|d}||jj j jvr|jj|}n|j|}|M|jdk(r>|jd d ur+|jd }t|}|j||S) NrJeth_subscriptionrHz,Subscription response must have params field subscriptionz9Subscription response params must have subscription fieldrReth_unsubscriberesultTr) rrrAget_cache_entryr@rSrTvaluesrdrJr-rH)r0rer_r`rKsubscribe_cache_keys r%$get_request_information_for_responsez5RequestProcessor.get_request_information_for_responses? x HX$6:L$Lx'$%STTXh%77$O +8H+=n+MNI //?? J D5+8D>:I4>>88>>EEGG 33CCIN 77 B( ''+<<LL*d2#/"5"5a"8&8&I#334GHr$middleware_response_processorcP|jdd}|lt|}|jj|}||jj |y|j jjd||y|j jjd|y)NrRziNo cached request info for response id `%s`. Cannot append middleware response processor for response: %szZNo response `id` in response. Cannot append middleware response processor for response: %s) r-rrArkmiddleware_response_processorsappendr@rUrV)r0rero response_idr_cached_request_info_for_ids r%$append_middleware_response_processorz5RequestProcessor.append_middleware_response_processors ll4.  "*;7I//?? J '*5*IIPP1%%++L  NN ! ! ' '- r$ raw_responsect|txs=t|txr+|jdduxr|jj S)NrR)r.listdictr-r@rW)r0rvs r%_is_batch_responsez#RequestProcessor._is_batch_responsesL,- |T * ,  &$. ,++ r$rhc"K|r=|jjru|jjj d|jj j |jj jd{|jjj d||jdijd}|j}|r5|j|r$|jj|d{y|jj|d{y|j|rStt}|jjj d|||j j#||y|jd}t|}|jjj d||||j j#||y7x77ϭw)NzTSubscription queue is full. Waiting for provider to consume messages before caching.z.Caching subscription response: response=%srHrhz9Caching batch response: cache_key=%s, response=%srRzGCaching response: response_id=%s, cache_key=%s, response=%s)rCfullr@rUrV _listen_eventclearwaitr-r8get_handler_subscription_by_idrDputrzrr rBrY)r0rvrhrK sub_containerr_rss r%cache_raw_responsez#RequestProcessor.cache_raw_response s 00557%%++/,,224nn2277999 NN ! ! ' 'A< +..x<@@PO 88M!M!M"66::<HHH77;;LIII  $ $\ 2++;C H H HcK|r#|jj}|jjd{}|jjj s$|jjj |dk(r9|jsfd|_|jjjdn9|jrd|_|jjjd||jjjd||S|s td|jj|}|'|jjjd|||S7?w) NrTzASubscription response queue synced with websocket message stream.FzESubscription response queue has %s subscriptions. Processing as FIFO.zLSubscription response popped from queue to be processed: raw_response=%sz@Must provide cache key when popping a non-subscription response.zXCached response popped from cache to be processed: cache_key=%s, raw_response=%s)rCqsizer-r@r}is_setsetr7rUinforVrrBrc)r0r_rhrrvs r%pop_raw_responsez!RequestProcessor.pop_raw_response<sY 55;;=E!%!B!B!F!F!HHL>>//668,,002zEEEIDBNN)).." AAEJDB%%*** NN ! ! ' '& ($V 77;;IFL'%%++= SIs;E?E<D?E?cNt|jj|_y)Nr>)r)rDr?r0s r%!_reset_handler_subscription_queuez2RequestProcessor._reset_handler_subscription_queuens+;44<<, (r$c|jj|jjt|jj |_|j y)z#Clear the request processor caches.r>N)rAr~rBr)rCr?rrs r% clear_cacheszRequestProcessor.clear_cachesssP ''--/ $$**,,<55==- ) ..0r$)r=r=)F)NF)r*N)!r r!r"r7bool__annotations__r8r rintrEpropertyrstrrrNrrr r rrarrdrrnrurrzrrrrr#r$r%r6r6Js6;-t;@DX&;<C 14.1 G0G+.G), G  G$ d38n  6UO66 6 # $sHS#X../#s(1CC D S#X  S#X   6 #6p   $ % 00 0d(0S'9  @ !${"3["@A  7<.H.H/3.H .Hb;@..37. .d 1r$r6)&asynciosystypingrrrrrrr r r r web3._utils.batchingr web3._utils.cachingrrweb3.exceptionsrrr.web3.providers.persistent.subscription_managerr web3.typesrrr web3.utilsrweb3.providers.persistentrr version_infoQueuerr)r6r#r$r%rs       CLv GMM!,gaj  GMM71:  (+ p1p1r$