d?i.4SrSSKJrJr SSKrSSKrSSKrSSKrSSKJ r SSK J r SSK J r SSKJrJr SS KJrJrJrJrJrJrJr SS KJr SS KJr SS KJrJrJrJ r J!r! "S S5r"g)zQ Main API client asynchronous handler for fetching data from the IPinfo service. ) IPv4Address IPv6AddressN)APIError) DefaultCache)Details)RequestQuotaExceededErrorTimeoutExceededError)API_URLBATCH_MAX_SIZE CACHE_MAXSIZE CACHE_TTLREQUEST_TIMEOUT_DEFAULTBATCH_REQ_TIMEOUT_DEFAULT cache_key) handler_utils)is_bogon) continents countriescountries_currencies eu_countriescountries_flagscd\rSrSrSrSSjrSrSrSSjrS\ SS4S jr S r S r SS jr S rg) AsyncHandler$zt Allows client to request data for specified IP address asynchronously. Instantiates and maintains access to cache. Nc XlURS5=(d [UlURS5=(d [UlURS5=(d [UlURS5=(d [ UlURS5=(d [ UlURS05UlSUR;a[URS'SUl S U;a US Ul O@URS 05nS U;a [US 'S U;a [US '[S0UD6Ul URS S5Ulg)zQ Initialize the Handler object with country name list and the cache initialized. rrrr continentrequest_optionstimeoutNcache cache_optionsmaxsizettlheaders) access_tokengetrrrrrrrhttpsessr r rrr$)selfr&kwargsr!s X/var/www/html/livechat/backend/venv/lib/python3.13/site-packages/ipinfo/handler_async.py__init__AsyncHandler.__init__*s/ ) K0=I#JJ~6F, &zz*;<O JJ- . F2F ! !**[1?Z &zz*;R@ D00 0.ED  +  f DJ"JJ;M -+8 i(M)'0 e$%6 6DJzz)T2 c@# UR5IShvN gN7f)z Initializes internal aiohttp connection pool. This isn't _required_, as the pool is initialized lazily when needed. But in case you require non-lazy initialization, you may await this. This is idempotent. N)_ensure_aiohttp_readyr)s r+initAsyncHandler.initXs((***s c# UR(a*URR5IShvN SUlggN 7f)z Deinitialize the async handler. This is required in case you need to let go of the memory/state associated with the async handler in a long-running process. This is idempotent. N)r(closer1s r+deinitAsyncHandler.deinitcs3 ==--%%' ' ' DM  's/A?Ac# UR5 [U[5(d[U[5(a URnU(a [ U5(aUSS.n[ U5$UR[U5n[ U5$![a Of=f[nU(aUSU-- n[R"URUR5n0nUbX'S'URR "U4SU0UD6IShvN nUR"S:Xa [%5eUR"S:adUR"n URR!S 5n U S :XaUR'5IShvN n OS UR)50n [+X5eUR'5IShvN nSSS5IShvN O!,IShvN (df  O=f[R,"WUR.UR0UR2UR4UR65 X0R[U5'[ U5$7f) z9Get details for specified IP address as a Details object.Tipbogon/Nrr$iz Content-Typeapplication/jsonerror)r0 isinstancerrexplodedrrr rKeyErrorr r get_headersr&r$r(r'statusr jsontextrformat_detailsrrrrr) r) ip_addressrdetails cached_ipaddrurlr$req_optsresp error_code content_typeerror_responses r+ getDetailsAsyncHandler.getDetailsps ""$ j+ . .*  3 3 $,,J (:..'$7G7# #  JJy'<=M=) )     3# #C++D,=,=t||L  ")Y ==$$SF'FXFF${{c!/11{{c!![[ #||//? #55+/99;%6%6N&-tyy{%;Nz:: IIK''GGFFFFF $$  NN      % % OO  -4 9Z()wsA.I1"BI B!I B!!A/IDIA+GF6G7F:8G= IG  IG&G  G&"A6ITc # UR5 Uc[n0n/nUHVn[U[5(d[U[5(a UR nUR [U5n XU'MX U(dU$Ub[R"5n [S-n [R"URUR5n SU S'[!S[#U5U5V s/sHn UR%X}X-U U UUU5PM nn [&R("1UkU[&R*S9IShvN unnU(dU$UHnUR-5 UIShvN M [R0"U[35U5$![a URU5 GMf=fs sn fN|NR![&R.a Mf=f![4a"n[R0"UUU5sSnA$SnAff=f7f)a Get details for a batch of IP addresses at once. There is no specified limit to the number of IPs this function can accept; it can handle as much as the user can fit in RAM (along with all of the response data, which is at least a magnitude larger than the input list). The input list is broken up into batches to abide by API requirements. The batch size can be adjusted with `batch_size` but is clipped to `BATCH_MAX_SIZE`. Defaults to `BATCH_MAX_SIZE`. For each batch, `timeout_per_batch` indicates the maximum seconds to spend waiting for the HTTP request to complete. If any batch fails with this timeout, the whole operation fails. Defaults to `BATCH_REQ_TIMEOUT_DEFAULT` seconds. `timeout_total` is a seconds-denominated hard-timeout for the time spent in HTTP operations; regardless of whether all batches have succeeded so far, if `timeout_total` is reached, the whole operation will fail by raising `TimeoutExceededError`. Defaults to being turned off. `raise_on_fail`, if turned off, will return any result retrieved so far rather than raise an exception when errors occur, including timeout and quota errors. Defaults to on. The concurrency level is currently unadjustable; coroutines will be created and consumed for all batches at once. N/batchr> content-typer)r return_when)r0r r@rrrAr rrBappendtimer rrCr&r$rangelen _do_batch_reqasynciowaitFIRST_EXCEPTIONcancelCancelledErrorreturn_or_failr Exception)r) ip_addresses batch_sizetimeout_per_batch timeout_total raise_on_failresultlookup_addressesrHrJ start_timerKr$ireqs_pendingcoes r+getBatchDetailsAsyncHandler.getBatchDetailssP ""$  'J&J*k22jK77(00  4 $ 9Z+@ A %2z"'  M  $J ++D,=,=t||L"41c"23Z@  A    Q^4!  A   J&||$%#33 JAw IIKHH!//35v c 4 '' 33 4"  --  J // q&I I JsAH F8A6H .$F6H )G>F;?GH GF?*F=+F?/#GH F3.H 2F33H ;G=F??GGGG H$H;H<H HH c # URRU[R"U5UUS9IShvN nURS:Xa [5eUR5 UR5IShvN n U R5Hup[U [5(dM[ R"U URURUR UR"UR$5 XR&[)U 5'M UR+U 5 gN![a!n[ R "XXS5sSnA$SnAff=f![a!n[ R "XXS5sSnA$SnAff=fGN 7f)zF Coroutine which will do the actual POST request for getBatchDetails. )datar$rNr=)r(postrEdumpsrbrrarDr raise_for_statusitemsr@dictrGrrrrrr rupdate) r)chunkrKr$rergrhrMrp json_resprHrIs r+r[AsyncHandler._do_batch_req!sK  H++ZZ&) ,D H{{c!/11  ! ! #))+% $-??#4 J'4((,,NN%%((--OO 5< 9Z01$5  i C  H // $G G H H // $G G H&sF3D'D%D'*E'F:F;,F+A:F%D'' E1E EF EF FE;5F6F;FFcUR(ag[R"URSS9n[R"US9Ulg)z.Ensures aiohttp internal state is initialized.Nr)total)r)r(aiohttp ClientTimeoutr ClientSession)r)rs r+r0"AsyncHandler._ensure_aiohttp_readyKs9 == ''d.B.B9.MN--g> r.c ^^ ^ ^ # Uc[n0m /nUHn[U[5(d[U[5(a URnU(a%[ U5(aUSS.n[ U57v MeTR[U5nUT U'M U(dT R57v [S-m [R"TRTR 5m ST S'U U UU 4Sjn[#S[%U5U5Hn XIX-n U"U 5IShvN T R5HmupV[U[&5(aM[R("UTR*TR,TR.TR0TR25 XV47v Mo M g![a URU5 GMf=fN7f)NTr9rTr>rUc># [R"TS9IShvN nURT US9IShvN nUR5 UR 5IShvN nUR 5H"upEUTR [U5'UTU'M$ SSS5IShvN gNNuNON !,IShvN (df  g=f7f)N)r$)rE)rrrurwrErxr r) batchsessionresponse json_responserHrIr$resultsr)rKs r+ process_batch7AsyncHandler.getBatchDetailsIter..process_batchus,,W==!(c!>>))+&.mmo 5 +8+>+>+@'J8?DJJy45*1GJ',A >==> 5>===sfC B(C B0B*'B0B,:B0 C "B.#C *B0,B0.C 0C6B9 7 CC r)r r@rrrArrr rrBrWrxr rrCr&r$rYrZryrGrrrrr)r)rcrdrgrirHrIrJrrkrr$rrKs` @@@r+getBatchDetailsIter AsyncHandler.getBatchDetailsIterSs  'J&J*k22jK77(00 hz22!+d;g&&8$(JJy/D$EM*7GJ''  --/ ! ++D,=,=t||L"4 2 2q#./rsT/ 'Gh*h*r.