F2j} dZddlZddlZddlZddlmZddlmZddlm Z m Z m Z ddl m Z e rddlmZddlmZmZd Zd Zd Zd Z ddlZdd lmZdd lmZd Zn #e$rYnwxYwes; ddlZd Zd Z ddlZd Zn #e$rYnwxYwGd dejZ n #e$rYnwxYwes;es9 ddlZd Z ddlZd Zn #e$rYnwxYwGddejZ n #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/m0Z0ddl1m2Z2m3Z3m4Z4ej5dZ6ej7dkrddl8m9Z9nddlm9Z9Gdde$Z:d*de;d e d!e:fd"Z% d+d#e dzd$e dzd%e;d e d!d&f d'Zedzd*e edzd!e deeefdzdef d?Z,d@Z-dAZ.d`dBe edzddfdCZ/dddEZ0d`dFe1dDde dGfdHZ2 dedIdGd7e d8e d9e d5e dzd6e dzdJe dzd:e dKe de dLfdMZ3d`dNedzde dDfdOZ4d`dNedzde dDfdPZ5dddQZ6dedzfdRZ7de fdSZ8de fdTZ9dedzfdUZ:de fdVZ;de fdWZ*   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??CCc4trO|jpd|j|jnd|j|jd}|j |j|d<t jdi||_dS t|jpd|_dS#t$rt|_YdSwxYw)z?Create or recreate the async HTTP client with current settings.FNT)http2verifycertrFr?) multiplexedr*) _USE_HTTPXrYr[r\r]rZhttpx AsyncClientsessionr ra)r client_kwargss rrczAsyncDAVClient._create_sessions  .-373H3T$//Z^= ##M {&)- g& ,==}==DLLL .+ 8LuMMM  . . .+~~  .sA66BBc K|S)zAsync context manager entry.r*rs r __aenter__zAsyncDAVClient.__aenter__&s  rexc_typeexc_valexc_tbc>K|d{VdS)zAsync context manager exit.N)close)rr}r~rs r __aexit__zAsyncDAVClient.__aexit__*s.jjllrcKt|drItr!|jd{VdS|jd{VdSdS)zClose the async client.rxN)hasattrrurxacloserr{s rrzAsyncDAVClient.close3s 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)rh)rrrrs r_build_method_headersz$AsyncDAVClient._build_method_headers;sZ"#%  "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_requestr2RateLimitErrorrLcompute_sleep_secondsretry_after_secondsrMrNasynciosleepr!)rr@rrrre sleep_secondss rr!zAsyncDAVClient.request\sE" ,,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|| t6j(rt7j)||||| | 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)rr@contentrrDrF) rr@datarrDrFproxiesrrrszserver responded with  z text/htmlrrBzNo 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)rr@rrF)rr@rrFrrrrsz+auth type detection: server responded with rDz Retry-AfterrQF)return_defaults)rir*)*_prepare_requestrur)r3rDrFr?schemerGrHrxr! reason_phrasereasonlogdebug status_coderrjextract_auth_typesformatjoinwarningr7 Exceptionrrgr2raise_if_rate_limited_should_negotiate_auth_build_auth_from_401rrIr^rrYrc set_featurestatus_raise_authorization_errordebug_dump_communication_dump_communication)rr@rrrurl_objcombined_headersrequest_kwargsrrrmsg auth_typesresponses rrzAsyncDAVClient._async_requests%)$9$9#vtW$U$U!!   7||,0:74===d+ < ..NNGz%">4:6 7||)-7 4+ <".  . .N: ,*dl*<<^<<<<<<<PU*VV^**,,       DK  " " " M % %&95 A A A,,S\\64QQQQQQQQ Q ?j ( (  + +CLL( C C C  ) U  %fc3CT8 T T Ts-DG E8MMpropscFK|*|s(||d}|d||}||pt |jd||d{V}|jdvr |jr||_ |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: DAVResponse with results attribute containing parsed PropfindResult list. Nutf-8r) _build_propfind_bodydecoderr!r)r@r_rawparse_propfindresults)rr@rrrr final_headersrs rpropfindzAsyncDAVClient.propfind s,  T ,,U33::7CCD22:ugNN c&:S]]Jm\\\\\\\\ ?j ( (X] ('6688H 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: DAVResponse rN)rr!r)r@)rr@rrrrs 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: DAVResponse OPTIONSrBN)r!r)r@rr@rs roptionszAsyncDAVClient.optionsDs?\\#"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: DAVResponse rrNrr!rr@rrrs r proppatchzAsyncDAVClient.proppatchWsJ"22;g2VV \\#{D-HHHHHHHHHrcpK|d|}||d||d{VS)a0 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: DAVResponse rrNrrs rmkcolzAsyncDAVClient.mkcolksJ&227'2RR \\#wmDDDDDDDDDrcpK|d|}||d||d{VS)z Send a MKCALENDAR request. Args: url: Target URL (required). body: XML request (usually contains calendar properties). headers: Additional headers. Returns: DAVResponse rrNrrs r mkcalendarzAsyncDAVClient.mkcalendarsJ"22>H rhrefscBK||pg}|d||}||pt|jd|d|d{V}|jdvr |jr||_ |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: DAVResponse with results containing List[CalendarQueryResult]. rrNr) _build_calendar_multiget_bodyrr!r)r@rrrrr)rr@rrrrrrs rcalendar_multigetz AsyncDAVClient.calendar_multigets&11%+2>>228UGLL   3tx==(DKK,@,@-         ?j ( (X] ('<<>>H r sync_tokenchK|||}|d||}||pt|jd|d|d{V}|jdvr3|jr,|} | 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: DAVResponse with results containing SyncCollectionResult. )rrrrNr) _build_sync_collection_bodyrr!r)r@rrrparse_sync_collectionchangedrr) rr@rrrrrrr sync_results rsync_collectionzAsyncDAVClient.sync_collections*//:U/SS228UGLL   3tx==(DKK,@,@-         ?j ( (X] ("88::K*2H "-"8H rc,||Sr)_async_value_or_coroutinervalues r_value_or_coroutinez"AsyncDAVClient._value_or_coroutineBs--e444rc K|Srr*rs rrz(AsyncDAVClient._async_value_or_coroutineEs  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)AsyncHTTPDigestAuthr) HTTPBasicAuthzUnsupported auth type: N)_select_auth_typerurrrDr5rv DigestAuthrC niquests.authr  BasicAuthrr2AuthorizationError)rrrEr rs rrgz AsyncDAVClient.build_auth_objectJs?**:66    :,T];; *4=99 ( " " N!,T]DMJJ ======// t}MM ' ! ! 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)clientr@)caldav.collectionr rr)r@r propertiesrj)rr r principal_urlresultcup principals r get_principalzAsyncDAVClient.get_principalps 0/////  MM12'            "*  '++,JKK$'ME *MMMIT}=== rrr cKddlmddlm}ddlm}|d{V}t |jjdd{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()}") r)r )'_extract_calendar_home_set_from_results)(_extract_calendars_from_propfind_resultsNrrcLg|] }|j|j|j!S))rr@nameid)r@r"cal_id)rinfor rs rrz0AsyncDAVClient.get_calendars..sB    HDdhTY4; O O O   r) rr rr rrr)r@CALENDAR_HOME_SET_PROPSr_make_absolute_urlCALENDAR_LIST_PROPS)rrextract_home_setextract_calendarsrcalendar_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.searchr2r/ async_search) rr.rrrrrr/rr0r2searcherrs rsearch_calendarzAsyncDAVClient.search_calendars^ 100000">      ():H &.-hAA&AAAAAAAArr"cFK||}|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)r@rr2 ReportErrorrraw _parse_principal_search_response_find_objects_and_props)rr"rrs rsearch_principalsz AsyncDAVClient.search_principalss$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")warningswarnDeprecationWarningr=)rr"rAs r principalszAsyncDAVClient.principals-s`  I     +++666666666rc:K|d{VS)z Legacy method. Use :meth:`get_principal` for new code. Returns the Principal object for the authenticated user. N)rr{s rrzAsyncDAVClient.principal<s, '')))))))))rc,K |d{V}||jd{V}n=#t$r0|t |jd{V}YnwxYw|jdS)z Check if the server supports DAV. Returns the DAV header from an OPTIONS request, or None if not supported. NDAV)rrr@rr)rrj)rrrs rcheck_dav_supportz AsyncDAVClient.check_dav_supportDs  9"nn........I!\\)-88888888HH 9 9 9!\\#dh--88888888HHH 9##E***s:?7A98A9cJK|d{V}|duod|vS)z Check if the server supports CalDAV. Returns True if the server indicates CalDAV support in DAV header. Nzcalendar-accessrHr dav_headers rcheck_cdav_supportz!AsyncDAVClient.check_cdav_supportQsA  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-schedulerJrKs rcheck_scheduling_supportz'AsyncDAVClient.check_scheduling_supportZsA  1133333333 %P*Bj*PPrc:K|d{VS)zl Check if the server supports DAV. This is an alias for :meth:`check_dav_support`. NrJr{s r supports_davzAsyncDAVClient.supports_davcs, ++---------rc:K|d{VS)zp Check if the server supports CalDAV. This is an alias for :meth:`check_cdav_support`. N)rMr{s rsupports_caldavzAsyncDAVClient.supports_caldavks, ,,.........rc:K|d{VS)z Check if the server supports RFC6638 scheduling. This is an alias for :meth:`check_scheduling_support`. N)rOr{s rsupports_schedulingz"AsyncDAVClient.supports_schedulingss, 22444444444r)rBNNNNNNTNNFNTTNNN)rN)NN)rrBNr)rrBN)NrBrNN)NrBrN)rBNr) NNNFFFFrN)NNrN)NNNrN)rr )FFFNNNF)=r%r&r'r(r?r)__annotations__r@r4rAboolrinttuplerr1rirrcr<r|type BaseExceptionrrr staticmethodrfloatr7r!rlistrrrrrrrrrrrrr rrgrrr-r6r=rDrrHrMrOrQrSrUr*rrr>r>ps   E3:COOOIt ## $"&*15,037# )-/3+/%Q9Q9 4ZQ9TzQ9* Q9 * Q9 Dj Q9:Q9tQ9Q9c3h'$.Q9c"T)Q9Q9t#c)D0Q9Q9Q9  $;!Q9"#&*#Q9$"Dj%Q9& 'Q9Q9Q9Q9f....&$+%$   ++++!26TzsCx(4/ c3h \F,0'( %% %% % c"T) % % % %%%%T,0 DD DD D c"T) D  DDDDV,0"&  4Z  c"T)  Cy4  F,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)>  >>>>, ,0// 4Z/Tz/4Z /  /  ////c"T)/ ////f"&,0  4ZCy4  c"T)   B!%"&,0 !! 4Z!$J!Cy4 !  ! c"T) ! !!!!F555 !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////54555555rr>prober0rcKttfi|}|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: rGrBz:Server did not return DAV header - may not be a DAV serverzServer DAV capabilities: z&Failed to connect to CalDAV server at : )_base_get_davclientr> ValueErrorrrr%r@rrjrrrrr2DAVError)r_r0rrrLrs rr0r0sO*! : :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_errorsCalendarCollectioncKddlm}m}fd} tdddi|d{V}nA#t$r4}rt d||cYd}~Sd}~wwxYw |d{V} | s|dd|| Sg} ||} ||} | D]} d t| vr| | }n| | } | d{V}|| |s#t$r-}t d | d|rYd}~d}~wwxYw| D]p} | |d{V}|r| |7#t$r-}t d|d|rYd}~id}~wwxYw| s[| sY| sW | d{V}|r|} n7#t$r*}t d|rYd}~nd}~wwxYw|| | S#t$r| dddd{VwxYw)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: :class:`~caldav.base_client.CalendarCollection` of matching calendars. Use as an async context manager to auto-close the connection:: async with await aio.get_calendars() as calendars: for cal in calendars: print(await cal.get_display_name()) r)rh_normalize_to_listch|.td|rt||S)z)Handle errors based on raise_errors flag.Nz(Problems fetching calendar information: )rr2rc) coro_resulterrmsgrgs r_tryzget_calendars.._trys@   IIIII J J J ) (((rr_TNzFailed to create async client: zgetting principalr/)cal_url)r$zProblems fetching calendar rar@z$Problems fetching calendar by name 'z': z!Problems fetching all calendars: r*)caldav.base_clientrhrjr0rrr2rr)r.get_display_nameappendr-r)rerfrgr0rhrjrnrrr calendars calendar_urlscalendar_namesrqr. display_namecal_nameall_calss ` rr-r-s2JIIIIIII$$::4:6:::::::: $$$    7A77888!!######## $ 4 ..00000000  5 D* + + +%%V444 4 **<88 ++M::%  Gc'll""$--g->>$--W-== %-%>%>%@%@@@@@@@ +$$X...    FFF1FFGGG  '  H !*!3!3!3!B!BBBBBBB/$$X...    QQQaQQRRR    ~  !*!8!8!:!:::::::) (I    AaAABBB  "!)F;;;; tT4000000000 s' A%)A A% A%)3IAI81D*)I* E!4#EIE!!I)3FI G'#G IG IG=<I= H1 H,'I,H11I)I*CalendarResultcrKddlm}tdi|d{V}|r|dnd}|||jS)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. Use as an async context manager to auto-close the connection:: async with await aio.get_calendar() as cal: events = await cal.search(event=True) Args: Same as :func:`get_calendars`. Returns: :class:`~caldav.base_client.CalendarResult` wrapping the first matching calendar (or None). Behaves like the calendar via ``__getattr__`` delegation when not used as a context manager. r)r{Nror*)rrr{r-r)r0r{ collectioncals r get_calendarrsi&211111$..v........J% /*Q--4C >#j&7 8 8 88r)T)NNF)>r(rloggingsyscollections.abcrtypesrtypingrrr urllib.parsercaldav.calendarobjectresourcer rr r ru _USE_HTTPXYZr`r_niquestsr niquests.structuresr ImportErrorhttpxyzrvh2Authrr9r.rrr/r0rbcaldav.compatibility_hintsr1 caldav.libr2caldav.lib.python_utilitiesr3caldav.lib.urlr4caldav.requestsr5caldav.responser6r7r8 getLoggerr version_infotyping_extensionsr<r>rWr-rr*rrrs ######////////// 6DDDDDD55555555     OOO%%%%%%777777MM   D       III MM    D      uz           \      III MM    D      uz          - + _   ,,,,,,CCCCCC111111//////******LLLLLLLLLLg!!g&&&&&&&I5I5I5I5I5]I5I5I5^ ..t.c.n....d $ $__*_:__ _  ____D99)9999999s~AAA%B.A54B5A=:B<A==BBB$C+B21C2B:7C9B::CCC