Mi"SSKJrJrJrJrJrJrJr SSKrSSK r SSK J r SSK r SSK JrJr SSKJr SSKJrJr SSKJr "S S \5r"S S \5r"S S\5r"SS5rSr\S:Xa\ R<"\"55 gg))ListOptionalUnionAsyncGeneratorDictAnyCallableN)urljoin) BrowserConfigCrawlerRunConfig) CrawlResult) AsyncLoggerLogLevel)hooks_to_stringc\rSrSrSrSrg)Crawl4aiClientError z1Base exception for Crawl4ai Docker client errors.N__name__ __module__ __qualname____firstlineno____doc____static_attributes__rp/var/www/eduai.edurigo.com/storigo/production/storigo_env/lib/python3.13/site-packages/crawl4ai/docker_client.pyrr ;rrc\rSrSrSrSrg)ConnectionErrorz2Raised when connection to the Docker server fails.rNrrrrr!r!s<rr!c\rSrSrSrSrg) RequestErrorz1Raised when the server returns an error response.rNrrrrr$r$rrr$c\rSrSrSrS S\S\S\S\S\\4 S jjr S \S S4S jr S!S jr S"S\ \S\\ S\\S\\\\\4\\\44S\S \\\44 SjjrS\S\S \R,4SjrS"S\ \S\\ S\\S\\\\\4\\\44S\S \\\ \\\S444 SjjrS \\\44SjrS!SjrS#SjrS\\S\\S\\S S4Sjr Sr!g)$Crawl4aiDockerClientzMClient for interacting with Crawl4AI Docker server with token authentication.Nbase_urltimeout verify_sslverboselog_filecURS5UlX l[U[R US9Ul[R"UUSS0S9Ul SUl g)N/)r- log_levelr,z Content-Typeapplication/json)r*verifyheaders) rstripr)r*rrDEBUGloggerhttpx AsyncClient _http_client_token)selfr)r*r+r,r-s r__init__Crawl4aiDockerClient.__init__sY!,  !8x~~W^_ !--#%78  &* remailreturncR# [URS5nURRSU3SS9 URR USU0S9IShvN nUR 5 UR5nUSUlS UR3URRS 'URRS SS9 gNo![R[R4a8nS [U53nURRUS S9 [!U5eSnAff=f7f)z1Authenticate with the server and store the token.z/tokenzAuthenticating with email: AUTHtagr>jsonN access_tokenBearer AuthorizationzAuthentication successfulzAuthentication failed: ERROR)r r)r6infor9postraise_for_statusrEr:r3successr7r$HTTPStatusErrorstrerrorr!)r;r>urlresponsedatae error_msgs r authenticate!Crawl4aiDockerClient.authenticate1sdmmX. - KK  :5'B  O!..33Cw>N3OOH  % % '==?D~.DK;B4;;-9PD   % %o 6 KK   ;  H P ""E$9$9: -1#a&:I KK  iW  5!), , -s;D's1vh"GH H Is8B>2A%A#+A%"B>#A%%B;9=B66B;;B>urlsbrowser_configcrawler_confighooks hooks_timeoutc`UR(a&SUR3URRS'UU(aUR5O0U(aUR5O0S.nU(a;[ SUR 555(a [ U5nOUnUUS.US'U$)z"Prepare request data from configs.rGrH)r]r^r_c38# UHn[U5v M g7fN)callable).0vs r 8Crawl4aiDockerClient._prepare_request.._s718A;;s)coder*r`)r:r9r3dumpanyvaluesr)r;r]r^r_r`ra request_data hooks_codes r_prepare_request%Crawl4aiDockerClient._prepare_requestJs ;;;B4;;-9PD   % %o 67En11327En1132  7 777,U3 # #(%L ! rmethodendpointc# [URU5nURR"X40UD6IShvN nUR 5 U$N![ R an[S[U535eSnAf[ Ran[S[U535eSnAf[ RanSURRRSS5;a3URR5RS[U55O [U5n[SURRS U35eSnAff=f7f) z)Make an HTTP request with error handling.NzRequest timed out: zFailed to connect: r1z content-typedetailz Server error z: )r r)r9requestrLr7TimeoutExceptionr!rOr$rNrRr3rZrE status_code)r;rrrskwargsrQrRrTrUs r_requestCrawl4aiDockerClient._requestms)dmmX. V!..66vMfMMH  % % 'ON%% B!$7Ax"@A A!! B!$7Ax"@A A$$ V-1C1C1G1GXZ1[[*..xQ@ V qzz/E/E.Fb TU U  VsQE AAAEAE'A>>EB,,EB EEEc^^ # TR5IShvN TRXX4U5m U=(a URnTRR S[ U5SU(aSOS3SS9 U(aS[ [S44U U4S jjnU"5$TRS S T US 9IShvN nUR5n U RS S5(d[SU RSS535eU RS/5V s/sHn [S0U D6PM n n TRRS[ U 5S3SS9 [ U 5S:XaU S$U $GNLNs sn f7f)a3 Execute a crawl operation. Args: urls: List of URLs to crawl browser_config: Browser configuration crawler_config: Crawler configuration hooks: Optional hooks - can be either: - Dict[str, Callable]: Function objects that will be converted to strings - Dict[str, str]: Already stringified hook code hooks_timeout: Timeout in seconds for each hook execution (1-120) Returns: Single CrawlResult, list of results, or async generator for streaming Example with function hooks: >>> async def my_hook(page, context, **kwargs): ... await page.set_viewport_size({"width": 1920, "height": 1080}) ... return page >>> >>> result = await client.crawl( ... ["https://example.com"], ... hooks={"on_page_context_created": my_hook} ... ) Nz Crawling z URLs z (streaming)ruCRAWLrBr?c ># TRRSTRS3TS9IShvN nUR5 UR 5ShvN nUR 5(dM [ R"U5nSU;a/TRRURSS5USS9 MkTRRURSS5SURS S 5S 9 URS 5S :XaM[S0UD67v MNN SSS5IShvN g!,IShvN (df  g=f7f)NPOSTz /crawl/streamrDrPrQunknown)rQrPTtimingg)rQrMrstatus completedr) r9streamr)rL aiter_linesstriprEloadsr6 error_statusrZ url_statusr)rRlineresultrSr;s rstream_results2Crawl4aiDockerClient.crawl..stream_resultss$,,33Ft}}o]<[bf3ggks--/&.&:&:&< R_`%?.*?*?  9SYKv|mY[5\]cjk  <.d9J*K < <"# #vxdMZZmmo y%00 0W/XYZ Z-8__Y-KL-K;##-KL 3CL>JPWX \Q.wqz;G;? #0[ Ms6E.E$BE.2E'3AE.E)%AE.'E.)E.cb# URSS5IShvN nUR5$N7f)zRetrieve configuration schemas.GETz/schemaN)r{rE)r;rRs r get_schemaCrawl4aiDockerClient.get_schemas)ui88}}9s /-/c# URRSSS9 URR5IShvN gN7f)zClose the HTTP client session.zClosing clientCLOSErBN)r6rJr9acloser;s rcloseCrawl4aiDockerClient.closes5 )w7&&(((s8AAAc# U$7frdrrs r __aenter__Crawl4aiDockerClient.__aenter__s  sexc_typeexc_valexc_tbc@# UR5IShvN gN7frd)r)r;rrrs r __aexit__Crawl4aiDockerClient.__aexit__sjjls )r9r:r)r6r*)zhttp://localhost:8000g>@TTN)r?N)NNN)r?r')"rrrrrrOfloatboolrr<rVr[rr r rrr intrrpr7Responser{rrrrrrtype Exceptionrrrrrr'r'sW0"& *** *  * 3- *$--- I3759FJ !3i!!/!!!12 ! d3=14S>ABC !  ! c3h!FVSVCVennV(3759FJ @<3i@<!/@<!!12 @< d3=14S>ABC @<  @< {D-~k4>O/PP Q@rs{MMM :/" )  )  & rrl z KKr