o ed@sdZddlmZzddlmZWn eyddZYnwddlmZddlmZddlm Z dd lm Z dd lm Z dd lm Z dd lm Z dd lmZddlmZddlmZddlmZddlmZddlmZddlmZddlmZdgZGdddZddZGdddZee GdddZddZdd Zd!d"Z d#d$Z!ee Gd%d&d&Z"ee Gd'd(d(Z#ee Gd)d*d*e#Z$ee Gd+d,d,e#Z%d-S).zBasic components support ) defaultdict)notifycOdSN)argkwrrGD:\Projects\ConvertPro\env\Lib\site-packages\zope/interface/registry.pyrr)ISpecification)ComponentLookupError)IAdapterRegistration) IComponents)IHandlerRegistration) ISubscriptionAdapterRegistration)IUtilityRegistration) Registered) Unregistered) Interface) implementedBy) implementer)implementer_only) providedBy)AdapterRegistry Componentsc@s,eZdZddZddZddZddZd S) _UnhashableComponentCountercCsdd|D|_dS)NcSsg|]}|qSrr).0itemrrr 4sz8_UnhashableComponentCounter.__init__..)items_data)selfZ otherdictrrr __init__2sz$_UnhashableComponentCounter.__init__cCs$|jD] \}}||kr|SqdSNr)r )r!key componentcountrrr __getitem__6s z'_UnhashableComponentCounter.__getitem__cCsHt|jD]\}}|d|kr||f|j|<dSq|j||fdSr#) enumerater append)r!r%r&idatarrr __setitem__<s  z'_UnhashableComponentCounter.__setitem__cCs6t|jD]\}}|d|kr|j|=dSqt|r#)r(r KeyError)r!r%r*r+rrr __delitem__Cs  z'_UnhashableComponentCounter.__delitem__N)__name__ __module__ __qualname__r"r'r,r.rrrr r/s  rcCsttSr)rintrrrr _defaultdict_intJr3c@sDeZdZddZddZddZddZd d Zd d Zd dZ dS)_UtilityRegistrationscCs"tt|_||_||_|dSr)rr3_cache _utilities_utility_registrations%_UtilityRegistrations__populate_cache)r! utilitiesZutility_registrationsrrr r"Os  z_UtilityRegistrations.__init__cCs4t|jD]\\}}}|d}|||qdSr#)iterr8r$_UtilityRegistrations__cache_utility)r!p_r+r%rrr Z__populate_cacheWsz&_UtilityRegistrations.__populate_cachecCsZz|j||d7<WdSty,t|j|}|j|<||d7<YdSw)N)r6 TypeErrorr)r!providedr%Zprovrrr Z__cache_utility\s  z%_UtilityRegistrations.__cache_utilitycCs@|j|}||}|d8}|dkr||=|dkS|||<|dkS)Nr?r)r6)r!rAr%r&rrr Z__uncache_utilityes z'_UtilityRegistrations.__uncache_utilitycCs*z |j||dkWStyYdSw)NrF)r6r@)r!rAr%rrr _is_utility_subscribedts  z,_UtilityRegistrations._is_utility_subscribedcCsV|||}|||f|j||f<|jd||||s#|jd|||||dSNr)rBr8r7register subscriber<)r!rAnamer%infofactory subscribedrrr registerUtility{s z%_UtilityRegistrations.registerUtilitycCsD|j||f=|jd|||||}|s |jd||dSdSrC)r8r7 unregister&_UtilityRegistrations__uncache_utility unsubscribe)r!rArFr%rIrrr unregisterUtilitys  z'_UtilityRegistrations.unregisterUtilityN) r/r0r1r"r9r<rLrBrJrNrrrr r5Ms  r5csreZdZdZdIddZddZfdd Zd d Zd d Ze ddZ ddZ ddZ e ddddZ  dJddZ  dKddZddZdLddZdMd d!Zd"d#Zd$d%Z  dNd&d'Z  dOd(d)Zd*d+ZdLd,d-ZdMd.d/Z  dLd0d1ZdMd2d3Zd4d5Z   dNd6d7Zd8d9Z  dOd:d;Zdd?Z!d@dAZ"dQdBdCZ#dDdEZ$dRdGdHZ%Z&S)SrNrcCs8t|tsJ||_||t||_d|_dSr) isinstancestrr/_init_registries_init_registrationstuple __bases___v_utility_registrations_cache)r!rFbasesrrr r"s   zComponents.__init__cCsd|jj|jS)Nz<{} {}>)format __class__r/r!rrr __repr__zComponents.__repr__cs8t}dd|dD}t|}||d<t|S)NcSs i|] \}}|ds||qS)Z_v_) startswith)rkvrrr s  z)Components.__reduce__..)super __reduce__rlistrT)r!Z reductionZfiltered_staterYrr rcs zComponents.__reduce__cCst|_t|_dSr)radaptersr:rZrrr rRs zComponents._init_registriescCsi|_i|_g|_g|_dSr)r8_adapter_registrations_subscription_registrations_handler_registrationsrZrrr rSs zComponents._init_registrationscCs>|j}|dus|j|jus|j|jurt|j|j}|_|Sr)rVr7r:r8r5)r!cacherrr _utility_registrations_caches   z'Components._utility_registrations_cachecCs|jddS)NrUr)__dict__getrZrrr _getBasesszComponents._getBasescCs>tdd|D|j_tdd|D|j_t||jd<dS)NcSg|]}|jqSr)rfrbaserrr rz(Components._setBases..cSror)r:rprrr rrrrU)rTrfrUr:rlr!rWrrr _setBasess  zComponents._setBasescCs|Sr)rnrZrrr szComponents.cCs ||Sr)rtrsrrr rus Tc Cs|r |rtd|}|durt|}|dkrt|}|j||f}|dur<|dd||fkr3dS||d|||j||||||rWtt t ||||||dSdS)N$Can't specify factory and component.rOrar) r@_getUtilityProvided_getNamer8rmrNrkrJrrUtilityRegistration)r!r%rArFrGeventrHregrrr rJs.   zComponents.registerUtilitycCs|r |rtd|}|dur|durtdt|}|j||f}|dus1|dur3||dkr3dS|dur;|d}|j|||ttt||||g|ddRdS)Nrvz3Must specify one of component, factory and providedrFr?T) r@rwr8rmrkrNrrry)r!r%rArFrHoldrrr rNs* zComponents.unregisterUtilityccs8t|jD]\\}}}t|||g|RVqdSr)r;r8rry)r!rArFr+rrr registeredUtilitiess  zComponents.registeredUtilitiescCs|jd|||SrC)r:lookup)r!rArFdefaultrrr queryUtilityr\zComponents.queryUtilitycCs&|jd||}|durt|||SrC)r:r~r )r!rArFZutilityrrr getUtilitys zComponents.getUtilityccs|jd|EdHdSrC)r: lookupAllr! interfacerrr getUtilitiesFor%szComponents.getUtilitiesForcCs|jd|SrC)r:Z subscriptionsrrrr getAllUtilitiesRegisteredFor(z'Components.getAllUtilitiesRegisteredForc Csv|durt|}t||}|dkrt|}||f|j|||f<|j|||||r9ttt||||||dSdSNrO) _getAdapterProvided_getAdapterRequiredrxrgrfrDrrAdapterRegistrationr!rHrequiredrArFrGrzrrr registerAdapter+s   zComponents.registerAdaptercCs|dur|dur tdt|}|dur|durtdt||}|j|||f}|dus8|dur:||dkr:dS|j|||f=|j|||ttt ||||g|RdS)N(Must specify one of factory and provided(Must specify one of factory and requiredrFT) r@rrrgrmrfrKrrr)r!rHrrArFr|rrr unregisterAdapter=s&   zComponents.unregisterAdapterccs<t|jD]\\}}}\}}t||||||VqdSr)r;rgrr)r!rrArFr%rGrrr registeredAdaptersXs  zComponents.registeredAdapterscC|j||||Sr)rf queryAdapter)r!objectrrFrrrr r^r\zComponents.queryAdaptercC(|j|||}|durt||||Sr)rfrr )r!rrrFadapterrrr getAdaptera zComponents.getAdaptercCrr)rfqueryMultiAdapter)r!objectsrrFrrrr rgszComponents.queryMultiAdaptercCrr)rfrr )r!rrrFrrrr getMultiAdapterlrzComponents.getMultiAdapterccsB|jttt||D]\}}||}|dur||fVq dSr)rfrrdmapr)r!rrArFrHrrrr getAdaptersrs   zComponents.getAdaptersc Csr|rtd|durt|}t||}|j|||||f|j||||r7ttt ||||||dSdS)N'Named subscribers are not yet supported) r@rrrhr)rfrErrSubscriptionRegistrationrrrr registerSubscriptionAdapterzs     z&Components.registerSubscriptionAdaptercc$|jD] }t|g|RVqdSr)rhrr!r+rrr registeredSubscriptionAdapters z)Components.registeredSubscriptionAdaptersc s|rtddurdurtdtdur"dur"tdtdur7fdd|jD}n fdd|jD}t|t|jkrNdS||jdd<|jttt ||dd S) Nrrrcs4g|]\}}}}}|kr|ks|||||fqSrrrrr=nfr*)rArrr rs   z.cs<g|]\}}}}}|kr|kr|ks|||||fqSrrrrHrArrr rs   FrOT) r@rrrhlenrfrMrrr)r!rHrrArFnewrrr unregisterSubscriptionAdapters4   z(Components.unregisterSubscriptionAdaptercCs|j||Srrf subscribers)r!rrArrr rrzComponents.subscriberscCs^|rtdt||}|j||||f|j|d||r-ttt|||||dSdS)Nz$Named handlers are not yet supported) r@rrir)rfrErrHandlerRegistration)r!rHrrFrGrzrrr registerHandlers   zComponents.registerHandlerccrr)rirrrrr registeredHandlersrzComponents.registeredHandlerscs|rtddurdurtdtdur&fdd|jD}n fdd|jD}t|t|jkr.cs0g|]\}}}}|kr|ks||||fqSrrrrHrrr rs   FrOT) r@rrirrfrMrrr)r!rHrrFrrrr unregisterHandlers(   zComponents.unregisterHandlercGs|j|ddSrr)r!rrrr handler\zComponents.handleFc Cs"t|j}|j}d}d}d}d}d|jvsJdd|_|r%|j}|j} ndd}} zN|D]:\\} } \} } }|d| | | krN|d| | | |d7}n|d7}| d| | durf|d7}| d| | q0|d7}q0W|`|ry|st|ry||n|`|r|s|r||www||||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 rchangedcSrrr)r>rrr rur zAComponents.rebuildUtilityRegistryFromLocalCache..cWrrr)argsrrr ru!r rr?N)needed_registereddid_not_registerneeded_subscribeddid_not_subscribe) dictr8r:rlrrDrEr registeredrI)r!ZrebuildregsutilsrrrrrDrErArFvalue_info_factoryrrr $rebuildUtilityRegistryFromLocalCachesH         z/Components.rebuildUtilityRegistryFromLocalCache)rOr)NNrOrOTN)NNrON)rON)rO)NNrOrOT)NNNrO)NrOrOT)NNrO)F)'r/r0r1rVr"r[rcrRrSpropertyrkrnrtrUrJrNr}rrrrrrrrrrrrrrrrrrrrr __classcell__rrrer rsr                *  "cCsz|jWStyYdSwr)Z__component_name__AttributeError)r%rrr rx<s  rxcC(tt|}t|dkr|dStd)Nr?rzWThe utility doesn't provide a single interface and no provided interface was specified.)rdrrr@)r%rArrr rwB  rwcCr)Nr?rzaThe adapter factory doesn't implement a single interface and no provided interface was specified.)rdrrr@)rHrArrr rJrrcCs|durz|j}Wntytdwt|rtdg}|D]%}|dur+t}nt|sBt|tr:t|}ntdt|| |q"t |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__rr@r rrrPtyperr)rT)rHrresultrrrr rRs,       rc@sVeZdZdddZddZddZdd Zd d Zd d ZddZ ddZ ddZ dS)ryNcC,||||||f\|_|_|_|_|_|_dSr)registryrArFr%rGrH)r!rrArFr%docrHrrr r"qszUtilityRegistration.__init__c Cs<d|jj|jt|jdd|jt|jdt|j|j |j S)Nz"{}({!r}, {}, {!r}, {}, {!r}, {!r})r/) rXrYr/rgetattrrArFr%reprrHrGrZrrr r[vszUtilityRegistration.__repr__cCt|SridrZrrr __hash__r4zUtilityRegistration.__hash__cCt|t|kSrrr!otherrrr __eq__zUtilityRegistration.__eq__cCt|t|kSrrrrrr __ne__rzUtilityRegistration.__ne__cCt|t|kSrrrrrr __lt__rzUtilityRegistration.__lt__cCt|t|kSrrrrrr __le__rzUtilityRegistration.__le__cCt|t|kSrrrrrr __gt__rzUtilityRegistration.__gt__cCt|t|kSrrrrrr __ge__rzUtilityRegistration.__ge__r r/r0r1r"r[rrrrrrrrrrr ryns   ryc@sTeZdZddZddZddZddZd d Zd d Zd dZ ddZ ddZ dS)rcCrr)rrrArFrHrG)r!rrrArFr%rrrr r"s zAdapterRegistration.__init__c CsTd|jj|jdddd|jDdt|jdd|jt|j dt |j |j S)Nz {}({!r}, {}, {}, {!r}, {}, {!r})[, cSrorr/rrrrr rz0AdapterRegistration.__repr__..]r/) rXrYr/rjoinrrrArFrHrrGrZrrr r[szAdapterRegistration.__repr__cCrrrrZrrr rr4zAdapterRegistration.__hash__cCrrrrrrr rrzAdapterRegistration.__eq__cCrrrrrrr rrzAdapterRegistration.__ne__cCrrrrrrr rrzAdapterRegistration.__lt__cCrrrrrrr rrzAdapterRegistration.__le__cCrrrrrrr rrzAdapterRegistration.__gt__cCrrrrrrr rrzAdapterRegistration.__ge__Nrrrrr rs  rc@s eZdZdS)rN)r/r0r1rrrr rsrc@s,eZdZddZeddZdZddZdS)rcCs&|||||f\|_|_|_|_|_dSr)rrrFhandlerrG)r!rrrFrrrrr r"s zHandlerRegistration.__init__cCs|jSr)rrZrrr rHszHandlerRegistration.factoryNc CsHd|jj|jdddd|jDd|jt|jdt |j|j S)Nz{}({!r}, {}, {!r}, {}, {!r})rrcSrorrrrrr rrz0HandlerRegistration.__repr__..rr/) rXrYr/rrrrFrrHrrGrZrrr r[szHandlerRegistration.__repr__)r/r0r1r"rrHrAr[rrrr rs   rN)&__doc__ collectionsrZ zope.eventr ImportErrorZzope.interface.interfacesr r r rrrrrrZzope.interface.interfacerZzope.interface.declarationsrrrrZzope.interface.adapterr__all__rr3r5rrxrwrrryrrrrrrr sX                  C.%%