3fiddlZddlZddlmZddlmZddlmZm Z ddl m Z ddl m Z mZddlmZdd lmZdd lmZdd lmZmZd Zd ZdZdZdZej:eZdZ GddeZ!Gdde!Z"GddeZ#GddeZ$GddeZ%Gdde&Z'GddZ(Gd d!Z)Gd"d#Z*Gd$d%Z+Gd&d'e+Z,Gd(d)Z-y)*N) OrderedDict)Enum)DictUnion)parse)ZoneInfoZoneInfoNotFoundError) QueryBuilder) to_snake_case)fluent) get_iana_tzget_windows_tzmeusersgroupssitesz@odata.nextLinkic&eZdZdZdZedZy)CaseEnumz7 A Enum that converts the value to a snake_case casing cPtj|}t||_|SN)object__new__r _value_)clsvalueobjs N/var/www/auto_recruiter/arenv/lib/python3.12/site-packages/O365/utils/utils.pyrzCaseEnum.__new__s!nnS!#E*  cD |t|S#t$rYywxYw)z. Gets a member by a snaked-case provided valueN)r ValueError)rrs r from_valuezCaseEnum.from_value$s) }U+, ,  s  N)__name__ __module__ __qualname____doc__r classmethodr"rrrrsA rrceZdZdZdZdZy)ImportanceLevelnormallowhighN)r#r$r%NormalLowHighr(rrr*r*-s F C Drr*cLeZdZdZdZdZdZdZdZdZ dZ d Z d Z d Z d Zd ZdZdZdZy)OutlookWellKnowFolderNamesInbox JunkEmail DeletedItemsDrafts SentItemsOutboxArchiveclutter conflictsconversationhistory localfailuresrecoverableitemsdeletions scheduled searchfoldersserverfailures syncissuesN)r#r$r%INBOXJUNKDELETEDDRAFTSSENTOUTBOXARCHIVECLUTTER CONFLICTSCONVERSATIONHISTORY LOCALFAILURESRECOVERABLEITEMSDELETIONS SCHEDULED SEARCHFOLDERSSERVERFAILURES SYNCISSUESr(rrr2r23sT E DG F D FGGI/#M ;I#M%NJrr2c$eZdZdZdZdZdZdZdZy)OneDriveWellKnowFolderNames documentsphotos camerarollapprootmusic attachmentsN) r#r$r% DOCUMENTSPHOTOS CAMERA_ROLLAPP_ROOTMUSIC ATTACHMENTSr(rrrTrTFs I FKH EKrrTceZdZdZdZy) ChainOperatorandorN)r#r$r%ANDORr(rrrbrbOs C Brrbc8eZdZddfd ZfdZfdZxZS) TrackerSetN)casingc2||_t||i|y)z A Custom Set that changes the casing of it's keys :param func casing: a function to convert into specified case N)ccsuper__init__)selfriargskwargs __class__s rrmzTrackerSet.__init__Us  $)&)rcF|j|}t| |yr)rkrladdrnrrqs rrszTrackerSet.add]s  ErcF|j|}t| |yr)rkrlremoverts rrvzTrackerSet.removeas ur)r#r$r%rmrsrv __classcell__rqs@rrhrhTs%)*rrhceZdZdZd dZdZdZdZdZe dZ e jd Z e d Z e jd Z y) Recipientz A single Recipient NcL|xsd|_|xsd|_||_||_y)a# Create a recipient with provided information :param str address: email address of the recipient :param str name: name of the recipient :param HandleRecipientsMixin parent: parent recipients handler :param str field: name of the field to update back N)_address_name_parent_field)rnaddressnameparentfields rrmzRecipient.__init__is( 2 ZR   rc,t|jSr)boolrrns r__bool__zRecipient.__bool__vsDLL!!rc"|jSr__repr__rs r__str__zRecipient.__str__y}}rc~|jr&dj|j|jS|jS)Nz{} <{}>)rformatrrs rrzRecipient.__repr__|s. 99##DIIt||< <<< rc|jrIt|jdd 0|jjj |jyyy)Y Update the track_changes on the parent to reflect a needed update on this field _track_changesN)rgetattrrrrsrs rrzRecipient._track_changessI ;;74<<1A#')045 LL ' ' + +DKK 85;rc|jS)z Email address of the recipient :getter: Get the email address :setter: Set and update the email address :type: str )r}rs rrzRecipient.addresss}}rc2||_|jyr)r}rrnrs rrzRecipient.addresss  rc|jS)zz Name of the recipient :getter: Get the name :setter: Set and update the name :type: str )r~rs rrzRecipient.nameszzrc2||_|jyr)r~rrs rrzRecipient.names  r)NNNN) r#r$r%r&rmrrrrpropertyrsetterrr(rrrzrzfsv " 9 ^^ [[rrzc`eZdZdZddZdZdZdZdZdZ d Z d Z d Z d Z d ZdZdZy) Recipientsz A Sequence of Recipients Ncp||_||_g|_d|_|r|j |d|_y)a Recipients must be a list of either address strings or tuples (name, address) or dictionary elements :param recipients: list of either address strings or tuples (name, address) or dictionary elements :type recipients: list[str] or list[tuple] or list[dict] or list[Recipient] :param HandleRecipientsMixin parent: parent recipients handler :param str field: name of the field to update back TFN)rr _recipientsuntrackrs)rn recipientsrrs rrmzRecipients.__init__s7    HHZ  rc,t|jSr)iterrrs r__iter__zRecipients.__iter__sD$$%%rc |j|Sr)r)rnkeys r __getitem__zRecipients.__getitem__s$$rcX||jDchc]}|jc}vScc}wrrr)rnitem recipients r __contains__zRecipients.__contains__s'4;K;KLi ))LLLLs'c>tt|jSr)rlenrrs rrzRecipients.__bool__sC(()**rc,t|jSr)rrrs r__len__zRecipients.__len__s4##$$rc"|jSrrrs rrzRecipients.__str__rrcJdjt|jS)NzRecipients count: {})rrrrs rrzRecipients.__repr__s%,,S1A1A-BCCrc|jrXt|jdd ?|jdur0|jjj |jyyyy)rrNF)rrrrrrsrs rrzRecipients._track_changess[ ;;74<<1A#')0459=9N LL ' ' + +DKK 8:O5;rc2g|_|jy)z Clear the list of recipients N)rrrs rclearzRecipients.clears rc,|rt|tr<|jjt ||j |j nt|tr|jj|nt|trD|\}}|rq|jjt |||j |j n4t|tr|D]}|j|n td|jyy)z Add the supplied recipients to the exiting list :param recipients: list of either address strings or tuples (name, address) or dictionary elements :type recipients: list[str] or list[tuple] or list[dict] )rrrrrrrz]Recipients must be an address string, a Recipient instance, a (name, address) tuple or a listN) isinstancestrrappendrzrrtuplelistrsr!r)rnrrrrs rrszRecipients.adds *c*  ''j$(KK12J 2  '' 3J. * g$$++!')-T[[JKJ-!+(IHHY'(!"344    !) rcDg}t|tr|h}n!t|ttfr t |}|j D]"}|j |vs|j|$t|t|j k7r|j||_y)z Remove an address or multiple addresses :param address: list of addresses to remove :type address: str or list[str] N) rrrrsetrrrrr)rnrrrs rrvzRecipients.removes  gs #iG $ /'lG)) -I  /!!), - z?c$"2"23 3    !%rcf|jDcgc]}|jr|}}|r|dSycc}w)z Returns the first recipient found with a non blank address :return: First Recipient :rtype: Recipient rNr)rnrrecipients_with_addresss r get_first_recipient_with_addressz+Recipients.get_first_recipient_with_addresssG ?C>N>N#9&/&7&7$-#9#9 "*1- - #9s.)NNN)r#r$r%r&rmrrrrrrrrrrsrvrr(rrrrsH$&&%M+%D9 "<&& rrc"eZdZddZddZdZy)HandleRecipientsMixinNctg}|D]$}|j|j||&t|||S)6 Transform a recipient from cloud data to object data )r)rr)r_recipient_from_cloudr)rnrrrecipients_datars r_recipients_from_cloudz,HandleRecipientsMixin._recipients_from_cloud"sK# DI  " "**9E*B D D/$eDDrc"|r|j|jdt|tr|ni}|j|jdd}|j|jdd}t ||||St S)r emailAddressrr|rr)get_ccrdictrz)rnrrrrs rrz+HandleRecipientsMixin._recipient_from_cloud*s ! dhh~&>3=i>B4DiIKMI mmDHHY$7z.ApiComponent._parse_resource..is$r/r:@z{}/{}zuser:r|r zgroup:zsite:) striprfiltersplitrUSERS_RESOURCE startswithreplaceGROUPS_RESOURCESITES_RESOURCE)resourceresource_starts r_parse_resourcezApiComponent._parse_resourcees(08>>#XT\f%6s8KLMaPbj n $N)BO . >>.(; ;   )''Q7H>>.(; ;   *''"a8H>>/8< <   )''Q7H>>.(; ;Orc|j||n|jj}dj|jj|}|j dr|dd}||fS)zz Builds the base url of this ApiComponent :param str resource: the resource to build the base url N{}{}r)rrdefault_resourcer service_urlendswith)rnrrbase_urls rrzApiComponent.build_base_urlsf ,,9MXSWS`S`SqSqr ==!:!:MJ   S !}Hh&&rc@|j|\|_|_y)zz Sets the base urls for this ApiComponent :param str resource: the resource to build the base url N)rrr)rnrs r set_base_urlzApiComponent.set_base_urls .2-@-@-J*DNrc:dj|j|S)z Returns a url for a given endpoint using the protocol service url :param str endpoint: endpoint to build the url for :return: final url :rtype: str r)rr)rnendpoints r build_urlzApiComponent.build_urls}}T^^X66rc8|jj|S)z( Alias for protocol.get_service_keyword )rget_service_keyword)rnkeywords r_gkzApiComponent._gks}}0099rc8|jj|S)z! Alias for protocol.convert_case )r convert_case)rndict_keys rrzApiComponent._ccs}}))(33rdate_time_time_zone is_all_dayreturnc|y|jj}t|tr t |j |j dd}|j |j dd} |rt|j|nd}|r,||k7r'|s|j|}|S|j|}|S |rt|j|}|Sd}|S#t$rtjd|}YwxYw#t$r'}tjd|d|d}Yd}~d}~wwxYw#t$r(}tjd|d|d}Yd}~|Sd}~wwxYw) a7 Parses and convert to protocol timezone a dateTimeTimeZone resource This resource is a dict with a date time and a windows timezone This is a common structure on Microsoft apis so it's included here. Returns a dt.datetime with the datime converted to protocol timezone NtimeZoneUTCz4TimeZone not found. Using protocol timezone instead.dateTimetzinfoz"Could not parse dateTimeTimeZone: z . Error: )rtimezonerrrrrr logdebugrr OverflowError astimezone Exception)rnrrlocal_tzr  date_timees r_parse_date_time_time_zonez'ApiComponent._parse_date_time_time_zones  &==)) )4 0 $&':'>'>txx ?SUZ'[\,//0DdKI !IRE),44H4EX\ X1! ) 4 4X >I!* 1 1 1 BI  !SfE"56>>h>O  mq /) $ PQ# $ ! ! >?R>SS\]^\_`a  ! ! >?R>SS\]^\_`a   !sG*C*7DE&E* D  D  ED;;E E4 E//E4rcJd}|j|t|jtr |j}nUt|jtjr& t|jj |}n tdt|xs|jj}|jd|jd|jd|iS#t $r8}t jd|jj ||d}~wwxYw)zU Converts a datetime to a dateTimeTimeZone resource Dict[datetime, windows timezone] Nz4Error while converting datetime.tzinfo to Zoneinfo: z3Unexpected tzinfo class. Can't convert to ZoneInfo.r z%Y-%m-%dT%H:%M:%Sr)r rrdttznamer r errorr!rrr rstrftime)rnrr rs r_build_date_time_time_zonez'ApiComponent._build_date_time_time_zones    ')**H5$++I,,bii8' (8(8(?(? (JKH !!VWW"("Ddmm.D.DE HHZ )"4"45H"I HHZ (  -II T!*!1!1!8!8!C DFGGs$C!! D"*3DD"c.t|jS)z Create a new query to filter results :param str attribute: attribute to apply the query for :return: new QueryBuilder :rtype: QueryBuilder )r)r rrs r new_queryzApiComponent.new_querysT]]33rF)r#r$r%r&_cloud_data_key _endpointsrmrr staticmethodrrrrrrrrrrrdatetimerrrr rqrwrxs@rrrDs 'OJ#'t$J: 'K7:4 7<(8=dCi8H(/3(@EbkkSWFW@X(T BKK DcN 44<4 ArrcNeZdZdZddddddfd ZdZdZdZdZd Z xZ S) Paginationz; Utility class that allows batching requests to the server N)rr constructor next_linklimitc j| tdt| |j|j||_|j |_||_||_||_ |r t|ngx|_ }t|}|r||kr||_ ||_n||_ ||_d|_||_y)aReturns an iterator that returns data until it's exhausted. Then will request more data (same amount as the original request) to the server until this data is exhausted as well. Stops when no more data exists or limit is reached. :param parent: the parent class. Must implement attributes: con, api_version, main_resource :param data: the start data to be return :param constructor: the data constructor for the next batch. It can be a function. :param str next_link: the link to request more data to :param int limit: when to stop retrieving more data :param kwargs: any extra key-word arguments to pass to the constructor. Nz$Parent must be another Api Componentrr)r!rlrmrrrconr&r'r(rrr data_count total_countstate extra_args) rnrrr&r'r(rpr+rqs rrmzPagination.__init__s" >CD D &//'-';';  = ::&" )-4:25 DY UZ'#DO$D (DO)D   rc"|jSrrrs rrzPagination.__str__-rrct|jrt|jtsydj |jr|jj SdS)NzPagination Iteratorz '{}' IteratorUnknown)callabler&rrrr#rs rrzPagination.__repr__0s` D$$ %j  $/(("))-1-=-=  ))N NCLN NrcZt|jxst|jSr)rrr'rs rrzPagination.__bool__8sDII6$t~~"66rc|Srr(rs rrzPagination.__iter__;s rc~|j|jkr0|j|j}|xjdz c_|S|jr#|j|jk\r t |j t |jj|j }|s t |j}|jtdxsd|_|jdg}|jrg|_i}|j|jt|jrmt|jt sS|D]M}|||j"<|jj%|j|dd|j&i|OnU|D]H}|||j"<|jj%|jdd|j&i|Jn||_t)|}|jrA|j|j|zz }|dkr |jd||_d|_||z}|rS||_|xj|z c_d|_|j|j}|xjdz c_|St )Nr rrrr()r-r+rr(r, StopIterationr'r*rjsonNEXT_LINK_KEYWORDr&updater.r2rrrrrr)rnrresponserrp items_countdifs r__next__zPagination.__next__>sI :: 'IIdjj)E JJ!OJLzzd..$**<#o% >> !/ !88<<// !}}"3T:Bdxx$   DIF MM$// *(()*T=M=Mt2T!\E38F4//0II$$%?CQw IIdsO !%)C/ )DO    + DJIIdjj)E JJ!OJL/ !r) r#r$r%r&rmrrrrr=rwrxs@rr%r%s2E!%Ddt/!bN73"rr%c eZdZdZdddddddd d Zd@d Zd ZdZedZ edZ edZ dZ e dZe dZe dZe dZdZdZdZdZdZdZeej2fdZdZdZed Zed!Zeej2fd"Zed#Z ed$Z!d%Z"d&Z#d'Z$e%dAd)Z&ed*Z'ed+Z(ed,Z)ed-Z*ed.Z+ed/Z,ed0Z-e%dAd1Z.ed2Z/ed3Z0ed4Z1ed5Z2ed d d d(d6d7Z3ed d d d(d6d8Z4ed d d d(d6d9Z5ed@d:d;d<Z6d=Z7d>Z8d?Z9y )BQueryz! Helper to conform OData filters zfrom/emailAddress/addressz!toRecipients/emailAddress/addresszstart/DateTimez end/DateTimezduedatetime/DateTimezreminderdatetime/DateTimezflag/flagStatusz body/content)fromtostartendduereminderflagbodyNct|tr|n||_d|_d|_|j |d|_g|_t|_ t|_ t|_ d|_ g|_g|_y)z Build a query to apply OData filters https://docs.microsoft.com/en-us/graph/query-parameters :param str attribute: attribute to apply the query for :param Protocol protocol: protocol to use for connecting NF)rrr _attribute_chainnew _negation_filtersr _order_byr_selects_expands_search_open_group_flag_close_group_flag)rn attributers rrmzQuery.__init__sr'14&@ h    $   "!#rcdj|j|j|j|j |j S)Nz5Filter: {} Order: {} Select: {} Expand: {} Search: {})r get_filters get_order get_selects get_expandsrQrs rrz Query.__str__sPJQQRVRbRbRdRVR`R`RbRVRbRbRdRVRbRbRdRVR^R^ ` `rc"|jSr)rrs rrzQuery.__repr__s||~rcj|r|D]x}|r+t|tr|jj|nd}|s5d|vr|j dd}|j |}|j j|z|S|jr%|j j|j|S)z Adds the attribute to the $select parameter :param str attributes: the attributes tuple to select. If empty, the on_attribute previously set is added. :rtype: Query Nrr) rrrrr_get_select_mappingrOrsrI)rn attributesrTs rselectz Query.selects ' 1 "+ 9;>1@!MM66EIi'$-OOC$8$; $ 8 8 CIMM%%i0 1  !!$//2 rc|D]L}|dk(r*dj|jjd}|jj |N|S)a Adds the relationships (e.g. "event" or "attachments") that should be expanded with the $expand parameter Important: The ApiComponent using this should know how to handle this relationships. eg: Message knows how to handle attachments, and event (if it's an EventMessage) Important: When using expand on multi-value relationships a max of 20 items will be returned. :param str relationships: the relationships tuple to expand. :rtype: Query eventz{}/eventevent_message_type)rrrrPrs)rn relationships relationships rexpandz Query.expandsY* ,Lw&)00MM556JK   MM  l +  , rc| d|_|S|j|jdj||_|S)aP Perform a search. Not from graph docs: You can currently search only message and person collections. A $search request returns up to 250 results. You cannot use $filter or $orderby in a search request. :param str text: the text to search :return: the Query instance Nz"{}")rQ clear_filters clear_orderr)rntexts rsearchz Query.searchsF <DL       !==.DL rcBi}|jr|j|d<|jr|j|d<|jr|j s|j |d<|j r|js|j|d<|jr=|j r1dj|j |j|d<|jr3|j|d<|jdd|jdd|S)zk Returns the filters, orders, select, expands and search as query parameters :rtype: dict z$filterz$orderbyz$expandz$selectz{}($select={})z$searchN) has_filtersrV has_orderrW has_expands has_selectsrYrXrrQpop)rnparamss r as_paramszQuery.as_paramss     $ 0 0 2F9  >>!%!1F:    D$4$4 $ 0 0 2F9    D$4$4 $ 0 0 2F9     0 0 0 7 78H8H8JDL\L\L^ _F9  << $ F9  JJy$ ' JJz4 ( rc,t|jS)zD Whether the query has filters or not :rtype: bool )rrMrs rrkzQuery.has_filters DMM""rc,t|jS)zE Whether the query has order_by or not :rtype: bool )rrNrs rrlzQuery.has_orders DNN##rc,t|jS)zK Whether the query has select filters or not :rtype: bool )rrOrs rrnzQuery.has_selectsrsrc,t|jS)zc Whether the query has relationships that should be expanded or not :rtype: bool )rrPrs rrmzQuery.has_expandsrsrc |jr|j}t|dtr|dd}dj|Dcgc]#}t|tr |jn|d%c}j }t |jDcgc] }|dus| c}}t|t |jz D]}|dz } |Sycc}wcc}w)zA Returns the result filters :rtype: str or None rN r F)) rMrrjoinrrrrRrangerS)rn filters_listfsfiltersx open_groupsis rrVzQuery.get_filterss ====L,r*D1+CR0 hhGSTZD1r!u<Teg  $*?*?NQ1:qNOK;T-C-C)DDE 3 NUOs(C CCc |jsydj|jjDcgc])\}}dj ||xsdj +c}}Scc}}w)zJ Returns the result order by clauses :rtype: str or None N,z{} {}r|)rlrzrNitemsrr)rnrT directions rrWzQuery.get_order4sh~~xx59^^5I5I5KM1Y ! 9?CIIKMN NMs.A, cR|jrdj|jSy)zG Returns the result select clause :rtype: str or None rN)rOrzrs rrXzQuery.get_selectsA! ==88DMM* *rcR|jrdj|jSy)zH Returns the result expand clause :rtype: str or None rN)rPrzrs rrYzQuery.get_expandsKrrc|r|jj|}|rIdj|jdDcgc]}|jj |c}}|S|jj |}|Sycc}w)Nr)_mappingrrzrrr)rnrTmappingsteps r _get_mappingzQuery._get_mappingUs mm'' 2GHH]]3')$T]]//5)*  !MM66yA   )s"Bcf|jdvr|jjdd|S|S)N)meetingMessageTyperar)lowerrkeyword_data_storernrTs rr\zQuery._get_select_mappingas> ??  6 6==334HIJ!I;W rct|tr t|}||_|r|j |nd|_d|_|S)z Combine with a new query :param str attribute: attribute of new query :param ChainOperator operation: operation to combine to new query :rtype: Query NF)rrrbrJrrIrL)rnrT operations rrKz Query.newhsA i %%i0I :C$++I6 rcg|_y)z Clear filters N)rMrs rrfzQuery.clear_filtersws  rc"t|_y)z Clears any order commands N)rrNrs rrgzQuery.clear_order{s $rcg|_t|_t|_d|_d|_d|_d|_g|_ g|_ |S)z1 Clear everything :rtype: Query FN) rMrrNrrOrLrIrJrQrRrSrs rrz Query.clearsN  $   "!# rc*|j |_|S)z5 Apply a not operator :rtype: Query )rLrs rnegatez Query.negates "^^+ rcJt|tr t|}||_|S)z Start a chain operation :param ChainOperator, str operation: how to combine with a new one :rtype: Query )rrrbrJ)rnrs rchainz Query.chains$ i %%i0I  rc2|j||_|S)z Apply query on attribute, to be used along with chain() :param str attribute: attribute name :rtype: Query )rrIrs r on_attributezQuery.on_attributes++I6 rcd|z|_|S)z Apply query on a list field, to be used along with chain() :param str field: field name (note: name is case sensitive) :rtype: Query zfields/)rI)rnrs r on_list_fieldzQuery.on_list_fields$e+ rc|j|}g}d}|jD]G}t|tr|d|k(rd}|j |0|dur|j |Fd}I||_y)z+ Removes a filter given the attribute name FrTN)rrMrrr)rn filter_attr new_filters remove_chainflts r remove_filterzQuery.remove_filters~'' 4   == )C#t$q6[(#'L&&s+ 5(&&s+#(L )$ rc|jr|jrBt|jdts%|jj |j |\}}t |jD]*\}}|dus| |durd|z}nd|z}d|j|<,|jj |j||gytd)NrT(znot (FIAttribute property needed. call on_attribute(attribute) or new(attribute)) rIrMrrbrrJ enumeraterRr!)rn filter_datasentenceattrsrgroups r _add_filterzQuery._add_filters ??}}Z b0A0=&? $$T[[1)OHe%d&;&;< 55D=EM}#&>#*X#5/4D))!, 5 MM $//8U!C D$% %rct|trdj|}|St|tjrt|tj r2|j &|j|jj}d|jvr!dj|j}|Sdj|j}|St|trt|j}|S|d}|S)z5 Converts the word parameter into the correct format z'{}'r rz{}null)rrrrdater"r rrr rI isoformatrrrnwords r_parse_filter_wordzQuery._parse_filter_words dC ==&D. -bgg &$ ,;;&<> "DN  # #DOOYh O  rc&|jd|S)z^ Add an equals check :param word: word to compare with :rtype: Query eqrrs requalsz Query.equals$$T400rc&|jd|S)z` Add an unequals check :param word: word to compare with :rtype: Query nerrs runequalz Query.unequal"rrc&|jd|S)zc Add a greater than check :param word: word to compare with :rtype: Query gtrrs rgreaterz Query.greater+rrc&|jd|S)zo Add a greater than or equal to check :param word: word to compare with :rtype: Query gerrs r greater_equalzQuery.greater_equal4rrc&|jd|S)z` Add a less than check :param word: word to compare with :rtype: Query ltrrs rlessz Query.less=rrc&|jd|S)zl Add a less than or equal to check :param word: word to compare with :rtype: Query lerrs r less_equalzQuery.less_equalFrrcb|rdnd}||||f}dj||||j|fS)Nrr|z {} {}({}, {})r) function_namerTrrrs r_prepare_functionzQuery._prepare_functionOs?$5"9mT:%%h y$OUUWY^^^rc|j|}|j}|rd|_|j|j||j|||S)z Apply a function on given word :param str function_name: function to apply :param str word: word to apply function on :rtype: Query F)rrLrrrI)rnrrrs rfunctionzQuery.functionUsU&&t,>> "DN  # #M4??D( S U rc&|jd|S)zb Adds a contains word check :param str word: word to check :rtype: Query containsrrs rrzQuery.containsf}}Z..rc&|jd|S)zd Adds a startswith word check :param str word: word to check :rtype: Query rrrs rrzQuery.startswithos}}\400rc&|jd|S)zb Adds a endswith word check :param str word: word to check :rtype: Query rrrs rrzQuery.endswithxrr)rTfuncrrc| | td| | td|j}||_|j|}|j|}|j|}|d}ndj |}||j ||||} n|j ||||} | \} } |jrdnd}|jrd|_dj |||| j| f} |j| ||_|S) a Performs a filter with the OData 'iterable_name' keyword on the collection For example: q.iterable('any', collection='email_addresses', attribute='address', operation='eq', word='george@best.com') will transform to a filter such as: emailAddresses/any(a:a/address eq 'george@best.com') :param str iterable_name: the OData name of the iterable :param str collection: the collection to apply the 'any' keyword on :param str word: the word to check :param str attribute: the attribute of the collection to check :param str func: the logical function to apply to the attribute inside the collection :param str operation: the logical operation to apply to the attribute inside the collection :param bool negation: negate the function or operation inside the iterable :rtype: Query z+Provide a function or an operation to applyz6Provide either a function or an operation but not bothaza/{}rr|Fz{} {}/{}(a:{})) r!rIrrrrrrLrr) rn iterable_name collectionrrTrrr current_attr filter_strrrs riterablezQuery.iterables%2 >"DN&--h MS]^ddfhmm +&% rc 2|jd||||||S)a9 Performs a filter with the OData 'any' keyword on the collection For example: q.any(collection='email_addresses', attribute='address', operation='eq', word='george@best.com') will transform to a filter such as: emailAddresses/any(a:a/address eq 'george@best.com') :param str collection: the collection to apply the 'any' keyword on :param str word: the word to check :param str attribute: the attribute of the collection to check :param str func: the logical function to apply to the attribute inside the collection :param str operation: the logical operation to apply to the attribute inside the collection :param bool negation: negates the function or operation inside the iterable :rtype: Query anyrrrTrrrrrnrrrTrrrs rrz Query.any*.}}Uz'0ty&.0 0rc 2|jd||||||S)a6 Performs a filter with the OData 'all' keyword on the collection For example: q.any(collection='email_addresses', attribute='address', operation='eq', word='george@best.com') will transform to a filter such as: emailAddresses/all(a:a/address eq 'george@best.com') :param str collection: the collection to apply the any keyword on :param str word: the word to check :param str attribute: the attribute of the collection to check :param str func: the logical function to apply to the attribute inside the collection :param str operation: the logical operation to apply to the attribute inside the collection :param bool negation: negate the function or operation inside the iterable :rtype: Query allrrrs rrz Query.allrrT) ascendingc|j|xs |j}|r|rdnd|j|<|Std)z Applies a order_by clause :param str attribute: attribute to apply on :param bool ascending: should it apply ascending order or descending :rtype: Query Ndescr)rrIrNr!)rnrTrs rorder_byzQuery.order_bysM%%i0CDOO 09vDNN9 %  $% %rc|jr$d|_|jjd|S|jjd|S)z3 Applies a precedence grouping in the next filters FNT)rLrRrrs r open_groupzQuery.open_groupsH >>"DN  ! ! ( ( .   ! ! ( ( . rcj|jrt|jt|jdzkr t dt |jdt r|jd}n|jd}|ddz|d<|jjd|St d)z( Closes a grouping for previous filters r z Not enough open groups to close.rryFz'No filters present. Can't close a group)rMrrRrS RuntimeErrorrrbr)rn flt_sentences r close_groupzQuery.close_groups ==4(()S1G1G-H1-LM"#EFF$--+];#}}R0 #}}R0 *1o3LO  " " ) )% 0 HI Irc|j}|jD]C}t|ts|d}|dd}|jj |sA|cSy)a" Returns a filter value by attribute name. It will match the attribute to the start of each filter attribute and return the first found. :param attribute: the attribute you want to search :return: The value applied to that attribute or None rN)rrMrrr)rnrT query_datafilter_attributers rget_filter_by_attributezQuery.get_filter_by_attributesmOO% -- Jj$/)!} a=#D%%'229=  rrr):r#r$r%r&rrmrrr r^rdrirqrrkrlrnrmrVrWrXrYrr\rbrerKrfrgrrrrrrrrr!rrrrrrrrrrrrrrrrrrrrr(rrr?r?ts++1!%/! H$*`  0  .  ,,##$$####, N  '4'8'8   '  "   +//       $*%(8   $ 1 1 1 1 1 1 1 1 1 1 1 1__     / / 1 1 / / EIPT%: :x 15DD[`0 04 15DD[`0 04 D   rr?).r"rlogging collectionsrenumrtypingrrdateutil.parserrzoneinforr queryr rir decoratorsr windows_tzrr ME_RESOURCErrrr8 getLoggerr#r MAX_RECIPIENTS_PER_MESSAGErr*r2rTrbrrhrzrrrr%r?r(rrr s#!4!3 &g! t"h & $ D $@@Fttn!!Hrrjx"x"vA A r