B 0²ô`§eã@sÔdZddlmZyddlmZWnek r<dd„ZYnXddlmZddlmZddlm Z dd lm Z dd lmZddlmZddlm Z dd lmZddlmZddlmZddlmZddlmZddlmZddlmZddlmZddlmZddlmZdgZGdd„deƒZdd„ZGdd„deƒZ ee ƒGdd„deƒƒZ!dd „Z"d!d"„Z#d#d$„Z$d%d&„Z%ee ƒGd'd(„d(eƒƒZ&ee ƒGd)d*„d*eƒƒZ'eeƒGd+d,„d,e'ƒƒZ(eeƒGd-d.„d.e'ƒƒZ)d/S)0zBasic components support é)Údefaultdict)ÚnotifycOsdS)N©)ÚargÚkwrrúF/home/dcms/DCMS/lib/python3.7/site-packages/zope/interface/registry.pyrór)ÚISpecification)ÚComponentLookupError)ÚIAdapterRegistration)ÚIComponents)ÚIHandlerRegistration)Ú ISubscriptionAdapterRegistration)ÚIUtilityRegistration)Ú Registered)ÚUnregistered)Ú Interface)Ú implementedBy)Úimplementer)Úimplementer_only)Ú providedBy)ÚAdapterRegistry)ÚCLASS_TYPES)ÚSTRING_TYPESÚ Componentsc@s,eZdZdd„Zdd„Zdd„Zdd„Zd S) Ú_UnhashableComponentCountercCsdd„| ¡Dƒ|_dS)NcSsg|]}|‘qSrr)Ú.0Úitemrrrú 6sz8_UnhashableComponentCounter.__init__..)ÚitemsÚ_data)ÚselfZ otherdictrrrÚ__init__4sz$_UnhashableComponentCounter.__init__cCs$x|jD]\}}||kr|SqWdS)Nr)r )r!ÚkeyÚ componentÚcountrrrÚ__getitem__8sz'_UnhashableComponentCounter.__getitem__cCsJx4t|jƒD]&\}}|d|kr||f|j|<dSqW|j ||f¡dS)Nr)Ú enumerater Úappend)r!r$r%ÚiÚdatarrrÚ__setitem__>s z'_UnhashableComponentCounter.__setitem__cCs<x.t|jƒD] \}}|d|kr|j|=dSqWt|ƒ‚dS)Nr)r'r ÚKeyError)r!r$r)r*rrrÚ__delitem__Es z'_UnhashableComponentCounter.__delitem__N)Ú__name__Ú __module__Ú__qualname__r"r&r+r-rrrrr1srcCsttƒS)N)rÚintrrrrÚ_defaultdict_intLsr2c@sDeZdZdd„Zdd„Zdd„Zdd„Zd d „Zdd„Zd d„Z dS)Ú_UtilityRegistrationscCs"ttƒ|_||_||_| ¡dS)N)rr2Ú_cacheÚ _utilitiesÚ_utility_registrationsÚ%_UtilityRegistrations__populate_cache)r!Ú utilitiesZutility_registrationsrrrr"Qs z_UtilityRegistrations.__init__cCs8x2t|j ¡ƒD] \\}}}|d}| ||¡qWdS)Nr)Úiterr6rÚ$_UtilityRegistrations__cache_utility)r!ÚpÚ_r*r$rrrZ__populate_cacheYsz&_UtilityRegistrations.__populate_cachecCs\y|j||d7<Wn<tk rVt|j|ƒ}|j|<||d7<YnXdS)Né)r4Ú TypeErrorr)r!Úprovidedr$ZprovrrrZ__cache_utility^s z%_UtilityRegistrations.__cache_utilitycCs:|j|}||}|d8}|dkr*||=n|||<|dkS)Nr=r)r4)r!r?r$r%rrrZ__uncache_utilitygs z'_UtilityRegistrations.__uncache_utilitycCs,y|j||dkStk r&dSXdS)NrF)r4r>)r!r?r$rrrÚ_is_utility_subscribedvsz,_UtilityRegistrations._is_utility_subscribedcCsV| ||¡}|||f|j||f<|j d|||¡|sF|j d||¡| ||¡dS)Nr)r@r6r5ÚregisterÚ subscriber:)r!r?Únamer$ÚinfoÚfactoryÚ subscribedrrrÚregisterUtility}sz%_UtilityRegistrations.registerUtilitycCs@|j||f=|j d||¡| ||¡}|s<|j d||¡dS)Nr)r6r5Ú unregisterÚ&_UtilityRegistrations__uncache_utilityÚunsubscribe)r!r?rCr$rFrrrÚunregisterUtilityˆs z'_UtilityRegistrations.unregisterUtilityN) r.r/r0r"r7r:rIr@rGrKrrrrr3Os r3csNeZdZdZdIdd„Zdd„Z‡fdd „Zd d„Zdd „Ze dd„ƒZ dd„Zdd„Ze dd„dd„ƒZ dJdd„ZdKdd„Zdd„ZdLdd„ZdMd d!„Zd"d#„Zd$d%„ZdNd&d'„ZdOd(d)„Zd*d+„ZdPd,d-„ZdQd.d/„ZdRd0d1„ZdSd2d3„Zd4d5„ZdTd6d7„Zd8d9„ZdUd:d;„Zdd?„Z!d@dA„Z"dWdBdC„Z#dDdE„Z$dXdGdH„Z%‡Z&S)YrNÚrcCs8t|tƒst‚||_| ¡| ¡t|ƒ|_d|_dS)N) Ú isinstancerÚAssertionErrorr.Ú_init_registriesÚ_init_registrationsÚtupleÚ __bases__Ú_v_utility_registrations_cache)r!rCÚbasesrrrr"—s zComponents.__init__cCsd|jj|jfS)Nz<%s %s>)Ú __class__r.)r!rrrÚ__repr__¡szComponents.__repr__cs<tt|ƒ ¡}dd„|d ¡Dƒ}t|ƒ}||d<t|ƒS)NcSs i|]\}}| d¡s||“qS)Z_v_)Ú startswith)rÚkÚvrrrú sz)Components.__reduce__..é)ÚsuperrÚ __reduce__rÚlistrQ)r!Z reductionZfiltered_state)rUrrr]¤s zComponents.__reduce__cCstƒ|_tƒ|_dS)N)rÚadaptersr8)r!rrrrO³szComponents._init_registriescCsi|_i|_g|_g|_dS)N)r6Ú_adapter_registrationsÚ_subscription_registrationsÚ_handler_registrations)r!rrrrP¹szComponents._init_registrationscCs>|j}|dks&|j|jk s&|j|jk r:t|j|jƒ}|_|S)N)rSr5r8r6r3)r!ÚcacherrrÚ_utility_registrations_cache¿sz'Components._utility_registrations_cachecCs|j dd¡S)NrRr)Ú__dict__Úget)r!rrrÚ _getBasesÌszComponents._getBasescCs>tdd„|Dƒƒ|j_tdd„|Dƒƒ|j_t|ƒ|jd<dS)NcSsg|] }|j‘qSr)r_)rÚbaserrrrÓsz(Components._setBases..cSsg|] }|j‘qSr)r8)rrhrrrrÕsrR)rQr_rRr8re)r!rTrrrÚ _setBasesÐs zComponents._setBasescCs| ¡S)N)rg)r!rrrÚÙrzComponents.cCs | |¡S)N)ri)r!rTrrrrjÚrTc Cs®|r|rtdƒ‚|ƒ}|dkr&t|ƒ}|dkr6t|ƒ}|j ||f¡}|dk rx|dd…||fkrfdS| |d||¡|j |||||¡|rªtt t ||||||ƒƒƒdS)Nz$Can't specify factory and component.rLr[r)r>Ú_getUtilityProvidedÚ_getNamer6rfrKrdrGrrÚUtilityRegistration)r!r$r?rCrDÚeventrEÚregrrrrGÝs&zComponents.registerUtilitycCs®|r|rtdƒ‚|ƒ}|dkr6|dkr.tdƒ‚t|ƒ}|j ||f¡}|dksb|dk rf||dkrfdS|dkrv|d}|j |||¡ttt||||f|dd…žŽƒƒdS)Nz$Can't specify factory and component.z3Must specify one of component, factory and providedrFr=T) r>rkr6rfrdrKrrrm)r!r$r?rCrEÚoldrrrrKús& zComponents.unregisterUtilityccs8x2t|j ¡ƒD] \\}}}t|||f|žŽVqWdS)N)r9r6rrm)r!r?rCr*rrrÚregisteredUtilitiesszComponents.registeredUtilitiescCs|j d|||¡S)Nr)r8Úlookup)r!r?rCÚdefaultrrrÚqueryUtilityszComponents.queryUtilitycCs&|j d||¡}|dkr"t||ƒ‚|S)Nr)r8rrr )r!r?rCÚutilityrrrÚ getUtility!s zComponents.getUtilityccs*x$|j d|¡D]\}}||fVqWdS)Nr)r8Ú lookupAll)r!Ú interfacerCrurrrÚgetUtilitiesFor'szComponents.getUtilitiesForcCs|j d|¡S)Nr)r8Z subscriptions)r!rxrrrÚgetAllUtilitiesRegisteredFor+sz'Components.getAllUtilitiesRegisteredForc Csr|dkrt|ƒ}t||ƒ}|dkr*t|ƒ}||f|j|||f<|j ||||¡|rnttt||||||ƒƒƒdS)NrL) Ú_getAdapterProvidedÚ_getAdapterRequiredrlr`r_rArrÚAdapterRegistration)r!rEÚrequiredr?rCrDrnrrrÚregisterAdapter.s zComponents.registerAdaptercCs²|dkr |dkrtdƒ‚t|ƒ}|dkr8|dkr8tdƒ‚t||ƒ}|j |||f¡}|dksp|dk rt||dkrtdS|j|||f=|j |||¡ttt ||||f|žŽƒƒdS)Nz(Must specify one of factory and providedz(Must specify one of factory and requiredrFT) r>r{r|r`rfr_rHrrr})r!rEr~r?rCrprrrÚunregisterAdapter@s" zComponents.unregisterAdapterccs>x8t|j ¡ƒD]&\\}}}\}}t||||||ƒVqWdS)N)r9r`rr})r!r~r?rCr$rDrrrÚregisteredAdapters[s zComponents.registeredAdapterscCs|j ||||¡S)N)r_ÚqueryAdapter)r!ÚobjectrxrCrsrrrr‚aszComponents.queryAdaptercCs(|j |||¡}|dkr$t|||ƒ‚|S)N)r_r‚r )r!rƒrxrCÚadapterrrrÚ getAdapterdszComponents.getAdaptercCs|j ||||¡S)N)r_ÚqueryMultiAdapter)r!ÚobjectsrxrCrsrrrr†jszComponents.queryMultiAdaptercCs(|j |||¡}|dkr$t|||ƒ‚|S)N)r_r†r )r!r‡rxrCr„rrrÚgetMultiAdapteroszComponents.getMultiAdapterccsDx>|j ttt|ƒƒ|¡D]"\}}||Ž}|dk r||fVqWdS)N)r_rwr^Úmapr)r!r‡r?rCrEr„rrrÚgetAdaptersuszComponents.getAdaptersc Csn|rtdƒ‚|dkrt|ƒ}t||ƒ}|j |||||f¡|j |||¡|rjttt ||||||ƒƒƒdS)Nz'Named subscribers are not yet supported) r>r{r|rar(r_rBrrÚSubscriptionRegistration)r!rEr~r?rCrDrnrrrÚregisterSubscriptionAdapter}s z&Components.registerSubscriptionAdapterccs$x|jD]}t|f|žŽVqWdS)N)rar‹)r!r*rrrÚregisteredSubscriptionAdapters‘sz)Components.registeredSubscriptionAdaptersc sØ|rtdƒ‚ˆdkr,ˆdkr$tdƒ‚tˆƒ‰ˆdkrDˆdkrDtdƒ‚tˆˆƒ‰ˆdkrn‡‡fdd„|jDƒ}n‡‡‡fdd„|jDƒ}t|ƒt|jƒkrœdS||jdd…<|j ˆˆˆ¡ttt |ˆˆ|ˆdƒƒƒd S) Nz'Named subscribers are not yet supportedz(Must specify one of factory and providedz(Must specify one of factory and requiredcs4g|],\}}}}}|ˆkr"|ˆks|||||f‘qSrr)rÚrr;ÚnÚfr))r?r~rrr¥sz.cs<g|]4\}}}}}|ˆkr*|ˆkr*|ˆks|||||f‘qSrr)rrŽr;rrr))rEr?r~rrr«sFrLT) r>r{r|raÚlenr_rJrrr‹)r!rEr~r?rCÚnewr)rEr?r~rÚunregisterSubscriptionAdapter•s, z(Components.unregisterSubscriptionAdaptercCs|j ||¡S)N)r_Úsubscribers)r!r‡r?rrrr”¿szComponents.subscriberscCsZ|rtdƒ‚t||ƒ}|j ||||f¡|j |d|¡|rVttt|||||ƒƒƒdS)Nz$Named handlers are not yet supported) r>r|rbr(r_rBrrÚHandlerRegistration)r!rEr~rCrDrnrrrÚregisterHandlerÂs zComponents.registerHandlerccs$x|jD]}t|f|žŽVqWdS)N)rbr•)r!r*rrrÚregisteredHandlersÓszComponents.registeredHandlerscs²|rtdƒ‚ˆdkr$ˆdkr$tdƒ‚tˆˆƒ‰ˆdkrL‡fdd„|jDƒ}n‡‡fdd„|jDƒ}t|ƒt|jƒkrxdS||jdd…<|j ˆdˆ¡ttt|ˆ|ˆdƒƒƒdS) Nz'Named subscribers are not yet supportedz(Must specify one of factory and requiredcs(g|] \}}}}|ˆkr||||f‘qSrr)rrŽrrr))r~rrrás z0Components.unregisterHandler..cs0g|](\}}}}|ˆkr |ˆks||||f‘qSrr)rrŽrrr))rEr~rrrçs FrLT) r>r|rbr‘r_rJrrr•)r!rEr~rCr’r)rEr~rÚunregisterHandler×s" zComponents.unregisterHandlercGs|j |d¡dS)N)r_r”)r!r‡rrrÚhandleùszComponents.handleFc Cst|jƒ}|j}d}d}d}d}d|jks.t‚dd„|_|rJ|j}|j} ndd„}} z†x€| ¡D]t\\} }\}} }| d| |¡|krž|d| ||ƒ|d7}n|d7}| d| |¡dkrÎ|d7}| d| |ƒqb|d7}qbWWd|`|rø|sî|rø| |¡X||||d œS) aá Emergency maintenance method to rebuild the ``.utilities`` registry from the local copy maintained in this object, or detect the need to do so. Most users will never need to call this, but it can be helpful in the event of suspected corruption. By default, this method only checks for corruption. To make it actually rebuild the registry, pass `True` for *rebuild*. :param bool rebuild: If set to `True` (not the default), this method will actually register and subscribe utilities in the registry as needed to synchronize with the local cache. :return: A dictionary that's meant as diagnostic data. The keys and values may change over time. When called with a false *rebuild*, the keys ``"needed_registered"`` and ``"needed_subscribed"`` will be non-zero if any corruption was detected, but that will not be corrected. .. versionadded:: 5.3.0 rÚchangedcSsdS)Nr)r<rrrrjrzAComponents.rebuildUtilityRegistryFromLocalCache..cWsdS)Nr)Úargsrrrrj$rrr=N)Úneeded_registeredÚdid_not_registerÚneeded_subscribedÚdid_not_subscribe)Údictr6r8rerNršrArBrZ registeredrF)r!ZrebuildÚregsÚutilsrœrržrŸrArBr?rCÚvalueÚ_infoÚ_factoryrrrÚ$rebuildUtilityRegistryFromLocalCacheüs: z/Components.rebuildUtilityRegistryFromLocalCache)rLr)NNrLrLTN)NNrLN)rLN)rL)NNrLrLT)NNNrL)rLN)rL)rLN)rL)NNrLrLT)NNNrL)NrLrLT)NNrL)F)'r.r/r0rSr"rVr]rOrPÚpropertyrdrgrirRrGrKrqrtrvryrzrr€rr‚r…r†rˆrŠrŒrr“r”r–r—r˜r™r¦Ú __classcell__rr)rUrr’s\ ) "cCs y|jStk rdSXdS)NrL)Z__component_name__ÚAttributeError)r$rrrrl?srlcCs,tt|ƒƒ}t|ƒdkr |dStdƒ‚dS)Nr=rzWThe utility doesn't provide a single interface and no provided interface was specified.)r^rr‘r>)r$r?rrrrkEs rkcCs,tt|ƒƒ}t|ƒdkr |dStdƒ‚dS)Nr=rzaThe adapter factory doesn't implement a single interface and no provided interface was specified.)r^rr‘r>)rEr?rrrr{Ms r{cCs¤|dkr2y |j}WqDtk r.tdƒ‚YqDXnt |¡rDtdƒ‚g}xR|D]J}|dkr`t}n.t |¡sŽt|tƒr~t|ƒ}ntdt |ƒƒ‚| |¡qNWt|ƒS)NzoThe adapter factory doesn't have a __component_adapts__ attribute and no required specifications were specifiedzLthe required argument should be a list of interfaces, not a single interfacez?Required specification must be a specification or class, not %r)Z__component_adapts__r©r>r rrrMrrÚtyper(rQ)rEr~ÚresultrŽrrrr|Us& r|c@sVeZdZddd„Zdd„Zdd„Zdd „Zd d„Zdd „Zdd„Z dd„Z dd„ZdS)rmNcCs,||||||f\|_|_|_|_|_|_dS)N)Úregistryr?rCr$rDrE)r!r¬r?rCr$ÚdocrErrrr"tszUtilityRegistration.__init__c Cs<d|jj|jt|jddƒ|jt|jdt|jƒƒ|j|j fS)Nz%s(%r, %s, %r, %s, %r, %r)r.) rUr.r¬Úgetattrr?rCr$ÚreprrErD)r!rrrrVyszUtilityRegistration.__repr__cCst|ƒS)N)Úid)r!rrrÚ__hash__‚szUtilityRegistration.__hash__cCst|ƒt|ƒkS)N)r¯)r!ÚotherrrrÚ__eq__…szUtilityRegistration.__eq__cCst|ƒt|ƒkS)N)r¯)r!r²rrrÚ__ne__ˆszUtilityRegistration.__ne__cCst|ƒt|ƒkS)N)r¯)r!r²rrrÚ__lt__‹szUtilityRegistration.__lt__cCst|ƒt|ƒkS)N)r¯)r!r²rrrÚ__le__ŽszUtilityRegistration.__le__cCst|ƒt|ƒkS)N)r¯)r!r²rrrÚ__gt__‘szUtilityRegistration.__gt__cCst|ƒt|ƒkS)N)r¯)r!r²rrrÚ__ge__”szUtilityRegistration.__ge__)N)r.r/r0r"rVr±r³r´rµr¶r·r¸rrrrrmqs rmc@sTeZdZdd„Zdd„Zdd„Zdd„Zd d „Zdd„Zd d„Z dd„Z dd„ZdS)r}cCs,||||||f\|_|_|_|_|_|_dS)N)r¬r~r?rCrErD)r!r¬r~r?rCr$rrrrr"šszAdapterRegistration.__init__cCsTd|jj|jdd dd„|jDƒ¡dt|jddƒ|jt|jdt |jƒƒ|j fS)Nz%s(%r, %s, %s, %r, %s, %r)ú[z, cSsg|] }|j‘qSr)r.)rrŽrrrr£sz0AdapterRegistration.__repr__..ú]r.)rUr.r¬Újoinr~r®r?rCrEr¯rD)r!rrrrVŸszAdapterRegistration.__repr__cCst|ƒS)N)r°)r!rrrr±¨szAdapterRegistration.__hash__cCst|ƒt|ƒkS)N)r¯)r!r²rrrr³«szAdapterRegistration.__eq__cCst|ƒt|ƒkS)N)r¯)r!r²rrrr´®szAdapterRegistration.__ne__cCst|ƒt|ƒkS)N)r¯)r!r²rrrrµ±szAdapterRegistration.__lt__cCst|ƒt|ƒkS)N)r¯)r!r²rrrr¶´szAdapterRegistration.__le__cCst|ƒt|ƒkS)N)r¯)r!r²rrrr··szAdapterRegistration.__gt__cCst|ƒt|ƒkS)N)r¯)r!r²rrrr¸ºszAdapterRegistration.__ge__N)r.r/r0r"rVr±r³r´rµr¶r·r¸rrrrr}—s r}c@seZdZdS)r‹N)r.r/r0rrrrr‹½sr‹c@s,eZdZdd„Zedd„ƒZdZdd„ZdS)r•cCs&|||||f\|_|_|_|_|_dS)N)r¬r~rCÚhandlerrD)r!r¬r~rCr¼rrrrr"ÅszHandlerRegistration.__init__cCs|jS)N)r¼)r!rrrrEÉszHandlerRegistration.factoryNc CsHd|jj|jdd dd„|jDƒ¡d|jt|jdt|jƒƒ|j fS)Nz%s(%r, %s, %r, %s, %r)r¹z, cSsg|] }|j‘qSr)r.)rrŽrrrrÓsz0HandlerRegistration.__repr__..rºr.) rUr.r¬r»r~rCr®rEr¯rD)r!rrrrVÏszHandlerRegistration.__repr__)r.r/r0r"r§rEr?rVrrrrr•Âsr•N)*Ú__doc__ÚcollectionsrZ zope.eventrÚImportErrorZzope.interface.interfacesr r rrr rrrrZzope.interface.interfacerZzope.interface.declarationsrrrrZzope.interface.adapterrZzope.interface._compatrrÚ__all__rƒrr2r3rrlrkr{r|rmr}r‹r•rrrrÚsVC/%%