iv dZddlZddlZddlZddlmZddlmZddlm Z m Z m Z ddl m Z e rddlmZmZmZddlmZmZd Zd Zd Z ddlZd Z ddlZd Zn #e$rYnwxYwGd d ejZn #e$rYnwxYwes ddlZdd lmZddlm Z d Zn #e$rYnwxYwes es edddl!m"Z"ddl#m$Z$ddl#m%Z&ddl'm(Z(ddl)m*Z*ddl+m,Z,ddl-m.Z.ddl/m0Z0m1Z1ddl2m3Z3m4Z4m5Z5m6Z6ddl7m8Z8m9Z9m:Z:ddl;mZ>ej?dZ@ejAdkrddlBmCZCnddlmCZCGdd e>ZDGd!d"e$ZEd-d#eFd$e d%eEfd&Z% d.d'e dzd(e dzd)eFd$e d%eGd*f d+ZHd$e d%e d*fd,ZIdS)/z Async-first DAVClient implementation for the caldav library. This module provides the core async CalDAV/WebDAV client functionality. For sync usage, see the davclient.py wrapper. N)Mapping) TracebackType) TYPE_CHECKINGAnyOptional)unquote)CalendarObjectResourceEventTodo)Calendar PrincipalFTc(eZdZdZdeddfdZdZdS)_HttpxBearerAuthz#httpx-compatible bearer token auth.passwordreturnNc||_dSN)r)selfrs Q/root/projects/butler/venv/lib/python3.11/site-packages/caldav/async_davclient.py__init__z_HttpxBearerAuth.__init__)s $DMMMc#6Kd|j|jd<|VdS)NzBearer Authorization)rheaders)rrequests r auth_flowz_HttpxBearerAuth.auth_flow,s)/H/H/HGOO ,MMMMMr)__name__ __module__ __qualname____doc__strrrrrrr&sK11 %S %T % % % %     rr) AsyncSession)CaseInsensitiveDictz}Either httpx or niquests library is required for async_davclient. Install with: pip install httpx (or: pip install niquests)) __version__) BaseDAVClient) get_davclient) FeatureSet)error)to_wire)URL)CalendarQueryResultPropfindResult)_build_calendar_multiget_body_build_calendar_query_body_build_propfind_body_build_sync_collection_body)_parse_calendar_query_response_parse_propfind_response_parse_sync_collection_response)HTTPBearerAuth)BaseDAVResponsecaldav) )SelfcpeZdZUdZdZeeezdzed<dZ e dzed<d de de dddfd Z dS) AsyncDAVResponsea Response from an async DAV request. This class handles the parsing of DAV responses, including XML parsing. End users typically won't interact with this class directly. Response parsing methods are inherited from BaseDAVResponse. New protocol-based attributes: results: Parsed results from protocol layer (List[PropfindResult], etc.) sync_token: Sync token from sync-collection response Nresults sync_tokenresponse davclientAsyncDAVClientrc2|||dS)z4Initialize from httpx.Response or niquests.Response.N)_init_from_response)rr?r@s rrzAsyncDAVResponse.__init__ws   955555rr)rrrr r=listr-r,__annotations__r>r!rrrr"rrr<r<es  BFGT.#66 7$ >EEE!Jd !!!666:J1K6W[666666rr<c%eZdZUdZdZedzed<dZeed<dZ e ed< dWdedzdedzd edzd edzd e dzd edzd e dzde ezdee eefzdzdeeefdzde deezezdzde de dee dee dee ddf$dZdXdZdefdZdedzdedzdedzddfdZdXdZe dYd ed!e dzd"eeefdzdeeeffd#Z dZded ed&edeeefdzd'edef d(Z d[ded ed&edeeefdzdef d)Z d\dedzd&ed!e deeefdzd*e!edzdef d+Z" d]dedzd&ed!e dzdeeefdzdef d,Z# dYdedzdeeefdzdefd-Z$ d^ded&edeeefdzdefd.Z% d^ded&edeeefdzdefd/Z& d^ded&edeeefdzdefd0Z' d_ded&edeeefdzdefd1Z( d_ded&edeeefdzdefd2Z) d_dedeeefdzdefd3Z* d`dedzd5e dzd6e dzd7e d8e d9e d:e d!e deeefdzdefd;Z+ dadedzdedzd*e!edzd!e deeefdzdef d?Z-d_d@e!edzddfdAZ.dcdCZ/d_dDedBde!dEfdFZ0 dddGdEd7e d8e d9e d5e dzd6e dzdHe dzd:e dIe de!dJfdKZ1d_dLedzde!dBfdMZ2d_dLedzde!dBfdNZ3dcdOZ4dIe ddEfdPZ5dedzfdQZ6de fdRZ7de fdSZ8dedzfdTZ9de fdUZ:de fdVZ;dS)erAa Async WebDAV/CalDAV client. This is the core async implementation. For sync usage, see DAVClient in davclient.py which provides a thin wrapper around this class. The recommended way to create a client is via get_davclient(): async with await get_davclient(url="...", username="...", password="...") as client: principal = await client.get_principal() NproxyurlF huge_treeTusernamerauth auth_typetimeoutssl_verify_certssl_certrfeaturesenable_rfc6764 require_tlsrate_limit_handlerate_limit_default_sleeprate_limit_max_sleeprc f| pi} ddlm}|| } t| tr| |_nt| |_| |_d|_||_|jd|jvrd|jz|_||_| |_ ||_ |j do tpt|_n#ttf$r d|_YnwxYw|ddlm}|||j|pd || || \}}|r|s|}t'j||_d}d}|jjrt/|jj}|jjrt/|jj}||n||_||n||_|j|_||_||_|js"|jr||jg|j|_|j |_|j|_|j |_ d d tBi|_"|j"#| |j d tH}|4|r0|%drd}d|vr|d}d|vr|d}nd}||_&||_'||_(dS)a] Initialize an async DAV client. Args: url: CalDAV server URL, domain, or email address. proxy: Proxy server (scheme://hostname:port). username: Username for authentication. password: Password for authentication. auth: Custom auth object (httpx.Auth or niquests AuthBase). auth_type: Auth type ('bearer', 'digest', or 'basic'). timeout: Request timeout in seconds. ssl_verify_cert: SSL certificate verification (bool or CA bundle path). ssl_cert: Client SSL certificate (path or (cert, key) tuple). headers: Additional headers for all requests. huge_tree: Enable XMLParser huge_tree for large events (security consideration). features: FeatureSet for server compatibility workarounds. enable_rfc6764: Enable RFC6764 DNS-based service discovery. require_tls: Require TLS for discovered services (security consideration). rate_limit_handle: When True, automatically sleep and retry on 429/503 responses. When None (default), auto-detected from server features. When False, raise RateLimitError immediately. rate_limit_default_sleep: Fallback sleep seconds when the server's 429 response omits a Retry-After header. None (default) means raise rather than sleeping when no Retry-After is provided. rate_limit_max_sleep: Cap on sleep duration in seconds regardless of server's Retry-After value. None (default) means no cap. r)resolve_featuresNz://zhttp://http.multiplexingF) _auto_url )rNrOrRrKrSz User-Agentz caldav-async/z rate-limitenableT default_sleep max_sleep)) caldav.configrX isinstancer(rQrI_http2_proxy_ssl_verify_cert _ssl_cert_timeout is_supported _H2_AVAILABLE _USE_NIQUESTS TypeErrorAttributeError_create_sessioncaldav.davclientrZr+ objectifyrHrKrrunauthrLrMbuild_auth_objectrGrNrOrPr%rupdatedictgetrTrUrV)rrHrGrKrrLrMrNrOrPrrIrQrRrSrTrUrVrXrZurl_strdiscovered_username url_username url_password rate_limits rrzAsyncDAVClient.__init__s0^-R222222##H-- h + + 1$DMM&x00DM"  ; "uDK'?'?#dk1DK /!  -445HII. KK>*   DKKK   /.....'0y  MMr+)#( ( ( $$  +x +*H=))  8  6"48#455L 8  6"48#455L%-$8l $,$8l 8??$$ "y 5T^ 5  " "DN#3 4 4 4[ } #4  7+77(   G$$$]// dCC  $ *jnnX66 *$(!"j00/9//J,*,,+5k+B($)!!2(@%$8!!!s-B??CCctrDtj|jpd|j|j|jnd|j|j|_dS t|jpd|_dS#t$rt|_YdSwxYw)z?Create or recreate the async HTTP client with current settings.FNT)http2rGverifycertrN) multiplexed) _USE_HTTPXhttpx AsyncClientrarbrcrdresessionr#rirs rrkzAsyncDAVClient._create_session!s  . ,k*Uk040E0Qt,,W[^ DLLL .+ 8LuMMM  . . .+~~  .s A++B  B c K|S)zAsync context manager entry.r"rs r __aenter__zAsyncDAVClient.__aenter__2s  rexc_typeexc_valexc_tbc>K|d{VdS)zAsync context manager exit.N)close)rrrrs r __aexit__zAsyncDAVClient.__aexit__6s.jjllrcKt|drItr!|jd{VdS|jd{VdSdS)zClose the async client.rN)hasattrr}racloserrs rrzAsyncDAVClient.close?s 4 # # + +l))+++++++++++l((***********  + +rmethoddepth extra_headerscri}|t||d<|dvrd|d<|r|||S)a Build headers for WebDAV methods. Args: method: HTTP method name. depth: Depth header value (for PROPFIND/REPORT). extra_headers: Additional headers to merge. Returns: Dictionary of headers. NDepth)REPORTPROPFIND PROPPATCH MKCALENDARMKCOLz application/xml; charset="utf-8" Content-Type)r!rp)rrrrs r_build_method_headersz$AsyncDAVClient._build_method_headersGsZ"#%  "5zzGG  O O O&HGN #  * NN= ) ) )rGETrbodyrate_limit_time_sleptc K |||||d{VS#tj$r}|jstj|j|j|j}|r||dz z }||j ||jkrtj |d{V| ||||||zd{VcYd}~Sd}~wwxYw)a Send an async HTTP request, with optional rate-limit sleep-and-retry. Catches RateLimitError from _async_request. When rate_limit_handle is True and a usable sleep duration is available, sleeps then retries with adaptive backoff (each retry adds half the already-slept time). Stops retrying when rate_limit_max_sleep is exceeded or no sleep duration is available. Otherwise re-raises immediately. N) _async_requestr)RateLimitErrorrTcompute_sleep_secondsretry_after_secondsrUrVasynciosleepr)rrHrrrre sleep_secondss rrzAsyncDAVClient.requesthsE" ,,S&$HHHHHHHH H#   ) !7%-)M % ;!6!:: $)5)D,EEE- .. . . . . . . .VT7,AM,Q      ! s"CBB>8C>Cc K|||||\}}tr2|t||rt|nd||j|jd}nUd}|j|j|ji}|t||rt|nd||j|j||j|j d } |j j di|d{V} tr| j n| j } td| jd| | jdkrd|jdd vr|jsd } | jd rWd || jd D} | r+| d d| z } t| t/| |} n~#t0$rp|js|jstr7|j dt|||jd{V} nZd}|j|j|ji}|j dt|||j||j|j d{V} tr| j n| j } td| jd| | jdkrq| jd rW|| jd } || |j|d<|j j di|d{V} t/| |} YnwxYwt7j| jt|| jd|| j| jr>|| jd |||||d{VS| jdkrd | jvr|jr|j !dd{|"d{Vd|_#|$|j %dd|t||||d{VS| j&dvr#|'t|| | S)z Async HTTP request implementation with auth negotiation. Handles connection-abort workaround, 429/503 rate-limit detection, and 401 auth negotiation (including HTTP/2 fallback). N)rrHcontentrrLrN) rrHdatarrLrNproxiesrzr{zserver responded with  z text/htmlrrJzNo authentication object was provided. HTML was returned when probing the server for supported authentication types. To avoid logging errors, consider passing the auth_type connection parameterzWWW-Authenticatecg|]}|dv| S))basicdigestbearerr").0ts r z1AsyncDAVClient._async_request..s.""" ======rz# Supported authentication types: {}z, r)rrHrrN)rrHrrNrrzr{z+auth type detection: server responded with rLz Retry-AfterrYF)return_defaults)rir")(_prepare_requestr}r!r*rLrNrGschemerOrPrr reason_phrasereasonlogdebug status_coderrrextract_auth_typesformatjoinwarningr< Exceptionrror)raise_if_rate_limited_should_negotiate_auth_build_auth_from_401rrQrfrrark set_featurestatus_raise_authorization_error)rrHrrrurl_objcombined_headersrequest_kwargsrrrmsg auth_typesr?s rrzAsyncDAVClient._async_requests~%)$9$9#vtW$U$U!!   7||,0:74===d+ < ..NNGz%">4:6 7||)-7 4+ <".  . .N: 1*dl*<<^<<<<<<<PU*VV^**,,       DK  " " " M % %&95 A A A,,S\\64QQQQQQQQ Q ?j ( (  + +CLL( C C Cs-DG E8MMpropscK|$|s"t|d}|d||}||pt |jd||d{V}|jdvrb|jr[t|jtr|jn|j d}t||j|j |_ |S)a Send a PROPFIND request. Args: url: Target URL (defaults to self.url). body: XML properties request (legacy, use props instead). depth: Maximum recursion depth. headers: Additional headers. props: List of property names to request (uses protocol layer). Returns: AsyncDAVResponse with results attribute containing parsed PropfindResult list. Nutf-8r)r0decoderrr!rHr_rawr`bytesencoder3rIr=) rrHrrrr final_headersr? raw_bytess rpropfindzAsyncDAVClient.propfinds,  T '..55g>>D22:ugNN c&:S]]Jm\\\\\\\\ ?j ( (X] (!+HM5!A!Ad x}G[G[\cGdGd  88?H,>  H rcK|d||}||pt|jd||d{VS)a Send a REPORT request. Args: url: Target URL (defaults to self.url). body: XML report request. depth: Maximum recursion depth. None means don't send Depth header (required for calendar-multiget per RFC 4791 section 7.9). headers: Additional headers. Returns: AsyncDAVResponse rN)rrr!rH)rrHrrrrs rreportzAsyncDAVClient.report<sV(228UGLL \\#"6TX$ VVVVVVVVVrcjK||pt|jdd|d{VS)z Send an OPTIONS request. Args: url: Target URL (defaults to self.url). headers: Additional headers. Returns: AsyncDAVResponse OPTIONSrJN)rr!rHrrHrs roptionszAsyncDAVClient.optionsSs?\\#"6TX 2wOOOOOOOOOrcpK|d|}||d||d{VS)z Send a PROPPATCH request. Args: url: Target URL (required). body: XML property update request. headers: Additional headers. Returns: AsyncDAVResponse rrNrrrrHrrrs r proppatchzAsyncDAVClient.proppatchfsJ"22;g2VV \\#{D-HHHHHHHHHrcpK|d|}||d||d{VS)a5 Send a MKCOL request. MKCOL creates a WebDAV collection. For CalDAV, use mkcalendar instead. Args: url: Target URL (required). body: XML request (usually empty). headers: Additional headers. Returns: AsyncDAVResponse rrNrrs rmkcolzAsyncDAVClient.mkcolzsJ&227'2RR \\#wmDDDDDDDDDrcpK|d|}||d||d{VS)a Send a MKCALENDAR request. Args: url: Target URL (required). body: XML request (usually contains calendar properties). headers: Additional headers. Returns: AsyncDAVResponse rrNrrs r mkcalendarzAsyncDAVClient.mkcalendarsJ"228?H,>  H rhrefscKt|pg}|d||}||pt|jd|d|d{V}|jdvrb|jr[t|jtr|jn|j d}t||j|j |_ |S)a Execute a calendar-multiget REPORT to fetch specific calendar objects. Args: url: Target calendar URL (defaults to self.url). hrefs: List of object URLs to retrieve. depth: Search depth. headers: Additional headers. Returns: AsyncDAVResponse with results containing List[CalendarQueryResult]. rrNr)r.rrr!rHrrrr`rrr2rIr=) rrHrrrrrr?rs rcalendar_multigetz AsyncDAVClient.calendar_multigets&-U[b99228UGLL   3tx==(DKK,@,@-         ?j ( (X] (!+HM5!A!Ad x}G[G[\cGdGd  >8?H,>  H rr>cKt||}|d||}||pt|jd|d|d{V}|jdvru|jrnt|jtr|jn|j d} t| |j|j } | j |_| j|_|S)a Execute a sync-collection REPORT for efficient synchronization. Args: url: Target calendar URL (defaults to self.url). sync_token: Previous sync token (None for initial sync). props: Properties to include in response. depth: Search depth. headers: Additional headers. Returns: AsyncDAVResponse with results containing SyncCollectionResult. )r>rrrNr)r1rrr!rHrrrr`rrr4rIchangedr=r>) rrHr>rrrrrr?r sync_results rsync_collectionzAsyncDAVClient.sync_collection:s*+jNNN228UGLL   3tx==(DKK,@,@-         ?j ( (X] (!+HM5!A!Ad x}G[G[\cGdGd :8?H,>K +2H "-"8H rrc@||}|dkr=trt|j|_dSt |j|_dS|dkrPtr&t j|j|j|_dSddl m }||j|j|_dS|dkrPtr&t j |j|j|_dSddl m }||j|j|_dS|rtjd|dS) a!Build authentication object for the httpx/niquests library. Uses shared auth type selection logic from BaseDAVClient, then creates the appropriate auth object for this HTTP library. Args: auth_types: List of acceptable auth types from server. rrr)HTTPDigestAuthr) HTTPBasicAuthzUnsupported auth type: N)_select_auth_typer}rrrLr5r~ DigestAuthrK niquests.authr BasicAuthrr)AuthorizationError)rrrMrrs rroz AsyncDAVClient.build_auth_objectes>**:66    :,T];; *4=99 ( " " I!,T]DMJJ 888888*N4=$-HH ' ! ! H!ODM4=II 777777)M$-GG  R*+PY+P+PQQ Q R Rrr c$Kddlm}|t|jdgdd{V}d}|jr*|jD]"}|jd}|r|}n#|st|j}|||}|S)aGet the principal (user) for this CalDAV connection. This method fetches the current-user-principal from the server and returns a Principal object that can be used to access calendars and other resources. Returns: Principal object for the authenticated user. Example: async with await get_davclient(url="...", username="...", password="...") as client: principal = await client.get_principal() calendars = await client.get_calendars(principal) r)r z{DAV:}current-user-principalrrN)clientrH)caldav.collectionr rr!rHr= propertiesrr)rr r? principal_urlresultcup principals r get_principalzAsyncDAVClient.get_principals 0/////  MM12'            "*  '++,JKK$'ME *MMMIT}=== rrr cKddlmddlm}ddlm}|d{V}t|j j dd{V}||j }|sgS |}|j dd{V}||j }fd|DS) a'Get all calendars for the given principal. This method fetches calendars from the principal's calendar-home-set and returns a list of Calendar objects. Args: principal: Principal object (if None, fetches principal first) Returns: List of Calendar objects. Example: principal = await client.get_principal() calendars = await client.get_calendars(principal) for cal in calendars: print(f"Calendar: {cal.get_display_name()}") rr )(_extract_calendars_from_propfind_results)'_extract_calendar_home_set_from_resultsNr rcLg|] }|j|j|j!S))rrHnameid)rHrcal_id)rinfor rs rrz0AsyncDAVClient.get_calendars..sB    HDdhTY4; O O O   r)rr !caldav.operations.calendarset_opsrcaldav.operations.principal_opsrrrr!rHCALENDAR_HOME_SET_PROPSr=_make_absolute_urlCALENDAR_LIST_PROPS)rrextract_calendarsextract_home_setr?calendar_home_urlcalendar_infosr s` @r get_calendarszAsyncDAVClient.get_calendarss$ /.....              "0022222222I   .'         -,X-=>>  I!334EFF *'        +*8+;<<     &    rcalendarinclude_completedkwargsr c rKddlm} | ||||||} ||| _| j|fi| d{V} | S)aSearch a calendar for events, todos, or journals. This method provides a clean interface to calendar search using the operations layer for building queries and processing results. Args: calendar: Calendar to search event: Search for events (VEVENT) todo: Search for todos (VTODO) journal: Search for journals (VJOURNAL) start: Start of date range end: End of date range include_completed: Include completed todos (default: False for todos) expand: Expand recurring events **kwargs: Additional search parameters Returns: List of Event/Todo/Journal objects. Example: # Get all events in January 2024 events = await client.search_calendar( calendar, event=True, start=datetime(2024, 1, 1), end=datetime(2024, 1, 31), ) # Get pending todos todos = await client.search_calendar( calendar, todo=True, include_completed=False, ) r)CalDAVSearcher)rrrrrrN) caldav.searchr-r* async_search) rr)rrrrrr*rr+r-searcherr=s rsearch_calendarzAsyncDAVClient.search_calendars^ 100000">      ():H &.-hAA&AAAAAAAArrcFK||}|t|j|d{V}|jdkr+t j|jd|jd|j| | S)a= Search for principals on the server. Instead of returning the current logged-in principal, this method attempts to query for all principals (or principals matching a name). This may or may not work depending on the permissions and implementation of the calendar server. Args: name: Optional name filter to search for specific principals Returns: List of Principal objects found on the server Raises: ReportError: If the server doesn't support principal search Ni,rz - ) _build_principal_search_queryrr!rHrr) ReportErrorrraw _parse_principal_search_response_find_objects_and_props)rrrr?s rsearch_principalsz AsyncDAVClient.search_principals0s$11$77S]]D99999999 ?c ! !#x$[$[$[$[X\$[$[\\ \44X5U5U5W5WXXXrcKddl}|dtd||d{VS)z Deprecated. Use :meth:`search_principals` instead. This method searches for principals on the server. rNz;principals() is deprecated, use search_principals() insteadr) stacklevelr)warningswarnDeprecationWarningr8)rrr<s r principalszAsyncDAVClient.principalsHs`  I     +++666666666rc:K|d{VS)z Legacy method. Use :meth:`get_principal` for new code. Returns the Principal object for the authenticated user. N)rrs rrzAsyncDAVClient.principalWs, '')))))))))rc "ddlm}|dd|i|S)aLReturns a calendar object. Typically, a URL should be given as a named parameter (url) No network traffic will be initiated by this method. If you don't know the URL of the calendar, use ``await client.get_principal().get_calendars()`` instead, or ``await client.get_calendars()`` rrrr")rr )rr+r s rr)zAsyncDAVClient.calendar_s1 /.....x..t.v...rcK|t|jd{V}|jdS)z Check if the server supports DAV. Returns the DAV header from an OPTIONS request, or None if not supported. NDAV)rr!rHrrr)rr?s rcheck_dav_supportz AsyncDAVClient.check_dav_supportnsJ c$(mm44444444##E***rcJK|d{V}|duod|vS)z Check if the server supports CalDAV. Returns True if the server indicates CalDAV support in DAV header. Nzcalendar-accessrDr dav_headers rcheck_cdav_supportz!AsyncDAVClient.check_cdav_supportwsA  1133333333 %I*;z*IIrcJK|d{V}|duod|vS)z Check if the server supports RFC6638 scheduling. Returns True if the server indicates scheduling support in DAV header. Nzcalendar-auto-schedulerFrGs rcheck_scheduling_supportz'AsyncDAVClient.check_scheduling_supportsA  1133333333 %P*Bj*PPrc:K|d{VS)zl Check if the server supports DAV. This is an alias for :meth:`check_dav_support`. NrFrs r supports_davzAsyncDAVClient.supports_davs, ++---------rc:K|d{VS)zp Check if the server supports CalDAV. This is an alias for :meth:`check_cdav_support`. N)rIrs rsupports_caldavzAsyncDAVClient.supports_caldavs, ,,.........rc:K|d{VS)z Check if the server supports RFC6638 scheduling. This is an alias for :meth:`check_scheduling_support`. N)rKrs rsupports_schedulingz"AsyncDAVClient.supports_schedulings, 22444444444r)rJNNNNNNTNNFNTTNNN)rN)NN)rrJNr)rrJN)NrJrNN)NrJrN)rJNr) NNNFFFFrN)NNrN)NNNrN)rr )FFFNNNF)!Q9"#+3-#Q9$'sm%Q9& 'Q9Q9Q9Q9f...."$+%$   ++++!26TzsCx(4/ c3h \F,0'( %% %% % c"T) % % % %%%%T,0 AA AA A c"T) A  AAAAP,0"& %% 4Z%% % c"T) % Cy4 % %%%%R,0 WW 4ZWWTz W c"T) W  WWWW2,0PP 4ZPc"T)P  PPPP,,0 II IIc"T) I  IIII.,0 EE EEc"T) E  EEEE2,0 JJ JJc"T) J  JJJJ0-1 == ==c"T) =  ====.-1 >> >>c"T) >  >>>>,-1>> >c"T)>  >>>>, ,055 4Z5Tz54Z 5  5  5555c"T)5 5555r"&,0 ## 4Z#Cy4# # c"T) #  ####N!%"&,0 '' 4Z'$J'Cy4 '  ' c"T) ' ''''V!R!RDI,<!R!R!R!R!RL''''R8 8 Xk-B8 dS]N^8 8 8 8 z )-@@@@ @  @ Tz @4Z@ $;@@@ & '@@@@DYYC$JY${BSYYYY0 7 7S4Z 74 ;L 7 7 7 7**** / / / / / /+t++++J$JJJJQQQQQ.C$J..../t////54555555rrAprober+rcKttfi|}|td|r |d{V}td|j|jdd}|st dnt d|nL#t$r?}| d{Vtjd|jd ||d}~wwxYw|S) aB Get an async DAV client instance with configuration from multiple sources. See :func:`caldav.base_client.get_davclient` for full documentation. Args: probe: Verify connectivity with OPTIONS request (default: True). **kwargs: All other arguments passed to base get_davclient. Returns: AsyncDAVClient instance. Raises: ValueError: If no configuration is found. Example:: async with await get_davclient(url="...", username="...", password="...") as client: principal = await client.principal() NztNo configuration found. Provide connection parameters, set CALDAV_URL environment variable, or create a config file.zConnected to CalDAV server: rCrJz:Server did not return DAV header - may not be a DAV serverzServer DAV capabilities: z&Failed to connect to CalDAV server at : )_base_get_davclientrA ValueErrorrrrrHrrrrrrrr)DAVError)rYr+rr?rHrs rr'r'sO*! : :6 : :F ~ L    d d#^^--------H HH@FJ@@ A A A")--eR88J D XYYYY BjBBCCC d d d,,.. .![&*![![XY![![\\bc c d MsBB;; D:C??D calendar_url calendar_name raise_errorsr cNKddlm}fd} tdddi|d{V}n9#t$r,}rtd|gcYd}~Sd}~wwxYw |d{V}|s|ddgSg} ||} ||} | D]} d t| vr|| } n|| } | d{V}|| | s#t$r-}td | d |rYd}~d}~wwxYw| D]p} ||d{V} | r| | 7#t$r-}td|d|rYd}~id}~wwxYw| s[| sY| sW | d{V}|r|} n7#t$r*}td|rYd}~nd}~wwxYw| S#wxYw)a Get calendars from a CalDAV server asynchronously. This is the async version of :func:`caldav.get_calendars`. Args: calendar_url: URL(s) or ID(s) of specific calendars to fetch. calendar_name: Name(s) of specific calendars to fetch by display name. raise_errors: If True, raise exceptions on errors; if False, log and skip. **kwargs: Connection parameters (url, username, password, etc.) Returns: List of Calendar objects matching the criteria. Example:: from caldav.async_davclient import get_calendars calendars = await get_calendars(url="...", username="...", password="...") r)_normalize_to_listch|.td|rt||S)z)Handle errors based on raise_errors flag.Nz(Problems fetching calendar information: )rr)r]) coro_resulterrmsgras r_tryzget_calendars.._trys@   IIIII J J J ) (((rrYTNzFailed to create async client: zgetting principal/)cal_url)rzProblems fetching calendar r[r;z$Problems fetching calendar by name 'z': z!Problems fetching all calendars: r") caldav.base_clientrcr'rrr)rr!r)get_display_nameappendr()r_r`rar+rcrgrrr calendars calendar_urlscalendar_namesrir) display_namecal_nameall_calss ` rr(r(s4655555$::4:6::::::::     7A77888  4  ..00000000   D* + + +` ] **<88 ++M::%  Gc'll""$--g->>$--W-== %-%>%>%@%@@@@@@@ +$$X...    FFF1FFGGG  '  H !*!3!3!3!B!BBBBBBB/$$X...    QQQaQQRRR    ~  !*!8!8!:!:::::::) (I    AaAABBB   s% A!AAA)H" AH"$1DH" E  #EH"E  H"3F H" G#F;6H";G H" G)(H") H3 HH"HH""H$cBKtdi|d{V}|r|dndS)a Get a single calendar from a CalDAV server asynchronously. This is a convenience function for the common case where only one calendar is needed. It returns the first matching calendar or None. Args: Same as :func:`get_calendars`. Returns: A single Calendar object, or None if no calendars found. Example:: from caldav.async_davclient import get_calendar calendar = await get_calendar(calendar_name="Work", url="...", ...) Nrr")r()r+rms r get_calendarrt9s@&$--f--------I$ .9Q<<$.r)T)NNF)Jr rloggingsyscollections.abcrtypesrtypingrrr urllib.parsercaldav.calendarobjectresourcer r r rr r r}rhrgr~h2 ImportErrorAuthrniquestsr#niquests.structuresr$r7r%rjr&r'r\caldav.compatibility_hintsr( caldav.libr)caldav.lib.python_utilitiesr*caldav.lib.urlr+caldav.protocol.typesr,r-caldav.protocol.xml_buildersr.r/r0r1caldav.protocol.xml_parsersr2r3r4caldav.requestsr5caldav.responser6 getLoggerr version_infotyping_extensionsr:r<rArRrDr(rtr"rrrs ######////////// 6QQQQQQQQQQ55555555    LLLJ        5:   D   ))))));;;;;;      - + F   ,,,,,,CCCCCC111111//////  +*****++++++g!!g&&&&&&&666666662a5a5a5a5a5]a5a5a5N!..t.c.n....d $ $` ` *` :` `  `  * ` ` ` ` F//*)=//////sHA3 AA3AA3AA33A;:A;BBB