o hd@sdZddlmZzddlmZWn eyddZYnwddlmZddlm Z ddlm Z dd lm Z dd lm Z dd l mZdd lmZdd lmZddlmZddlmZddlmZddlmZddlmZddlmZddlmZdgZGdddZddZGdddZe eGdddZddZdd Zd!d"Z d#d$Z!e eGd%d&d&Z"e eGd'd(d(Z#e eGd)d*d*e#Z$e eGd+d,d,e#Z%d-S).zBasic components support ) defaultdict)notifycOdSN)argkwrrJ/var/www/html/venv/lib/python3.10/site-packages/zope/interface/registry.pyrsr)AdapterRegistry) implementedBy) implementer)implementer_only) providedBy) Interface)ComponentLookupError)IAdapterRegistration) IComponents)IHandlerRegistration)ISpecification) ISubscriptionAdapterRegistration)IUtilityRegistration) Registered) Unregistered Componentsc@s,eZdZddZddZddZddZd S) _UnhashableComponentCountercCsdd|D|_dS)NcSsg|]}|qSrr).0itemrrr 7sz8_UnhashableComponentCounter.__init__..)items_data)selfZ otherdictrrr __init__5sz$_UnhashableComponentCounter.__init__cCs$|jD] \}}||kr|SqdSNr)r)r key componentcountrrr __getitem__9s z'_UnhashableComponentCounter.__getitem__cCsHt|jD]\}}|d|kr||f|j|<dSq|j||fdSr") enumeraterappend)r r$r%idatarrr __setitem__?s  z'_UnhashableComponentCounter.__setitem__cCs6t|jD]\}}|d|kr|j|=dSqt|r")r'rKeyError)r r$r)r*rrr __delitem__Fs  z'_UnhashableComponentCounter.__delitem__N)__name__ __module__ __qualname__r!r&r+r-rrrr r2s  rcCsttSr)rintrrrr _defaultdict_intNr2c@sDeZdZddZddZddZddZd d Zd d Zd dZ dS)_UtilityRegistrationscCs"tt|_||_||_|dSr)rr2_cache _utilities_utility_registrations%_UtilityRegistrations__populate_cache)r utilitiesZutility_registrationsrrr r!Ts  z_UtilityRegistrations.__init__cCs4t|jD]\\}}}|d}|||qdSr")iterr7r$_UtilityRegistrations__cache_utility)r p_r*r$rrr Z__populate_cache\sz&_UtilityRegistrations.__populate_cachecCsZz|j||d7<WdSty,t|j|}|j|<||d7<YdSw)N)r5 TypeErrorr)r providedr$Zprovrrr Z__cache_utilityas z%_UtilityRegistrations.__cache_utilitycCs@|j|}||}|d8}|dkr||=|dkS|||<|dkS)Nr>r)r5)r r@r$r%rrr Z__uncache_utilityls z'_UtilityRegistrations.__uncache_utilitycCs*z |j||dkWStyYdSw)NrF)r5r?)r r@r$rrr _is_utility_subscribed{s  z,_UtilityRegistrations._is_utility_subscribedcCsV|||}|||f|j||f<|jd||||s#|jd|||||dSNr)rAr7r6register subscriber;)r r@namer$infofactory subscribedrrr registerUtilitys z%_UtilityRegistrations.registerUtilitycCsD|j||f=|jd|||||}|s |jd||dSdSrB)r7r6 unregister&_UtilityRegistrations__uncache_utility unsubscribe)r r@rEr$rHrrr unregisterUtilitys  z'_UtilityRegistrations.unregisterUtilityN) r.r/r0r!r8r;rKrArIrMrrrr r4Rs  r4cspeZdZdZdIddZddZfdd 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 rEbasesrrr r!s   zComponents.__init__cCsd|jjd|jdS)N< >) __class__r.r rrr __repr__szComponents.__repr__cs8t}dd|dD}t|}||d<t|S)NcSs i|] \}}|ds||qS)Z_v_) startswith)rkvrrr s  z)Components.__reduce__..)super __reduce__rlistrS)r Z reductionZfiltered_staterZrr rcs zComponents.__reduce__cCst|_t|_dSr)r adaptersr9r[rrr rQs zComponents._init_registriescCsi|_i|_g|_g|_dSr)r7_adapter_registrations_subscription_registrations_handler_registrationsr[rrr rRs zComponents._init_registrationscCs>|j}|dus|j|jus|j|jurt|j|j}|_|Sr)rUr6r9r7r4)r cacherrr _utility_registrations_caches  z'Components._utility_registrations_cachecCs|jddS)NrTr)__dict__getr[rrr _getBasesszComponents._getBasescCs>tdd|D|j_tdd|D|j_t||jd<dS)NcSg|]}|jqSr)rfrbaserrr rz(Components._setBases..cSror)r9rprrr rrrrT)rSrfrTr9rlr rVrrr _setBasess  zComponents._setBasescCs|Sr)rnr[rrr 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.rNrar) r?_getUtilityProvided_getNamer7rmrMrkrIrrUtilityRegistration)r r$r@rErFeventrGregrrr rIs.   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?rwr7rmrkrMrrry)r r$r@rErGoldrrr rMs* zComponents.unregisterUtilityccs8t|jD]\\}}}t|||g|RVqdSr)r:r7rry)r r@rEr*rrr registeredUtilities$s  zComponents.registeredUtilitiescCs|jd|||SrB)r9lookup)r r@rEdefaultrrr queryUtility)zComponents.queryUtilitycCs&|jd||}|durt|||SrB)r9r~r)r r@rEZutilityrrr getUtility,s zComponents.getUtilityccs|jd|EdHdSrB)r9 lookupAllr interfacerrr getUtilitiesFor2szComponents.getUtilitiesForcCs|jd|SrB)r9Z subscriptionsrrrr getAllUtilitiesRegisteredFor5z'Components.getAllUtilitiesRegisteredForc Csv|durt|}t||}|dkrt|}||f|j|||f<|j|||||r9ttt||||||dSdSNrN) _getAdapterProvided_getAdapterRequiredrxrgrfrCrrAdapterRegistrationr rGrequiredr@rErFrzrrr registerAdapter8s   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?rrrgrmrfrJrrr)r rGrr@rEr|rrr unregisterAdapterJs"  zComponents.unregisterAdapterccs<t|jD]\\}}}\}}t||||||VqdSr)r:rgrr)r rr@rEr$rFrrr registeredAdaptersds  zComponents.registeredAdapterscC|j||||Sr)rf queryAdapter)r objectrrErrrr rjrzComponents.queryAdaptercC(|j|||}|durt||||Sr)rfrr)r rrrEadapterrrr getAdapterm zComponents.getAdaptercCrr)rfqueryMultiAdapter)r objectsrrErrrr rsszComponents.queryMultiAdaptercCrr)rfrr)r rrrErrrr getMultiAdapterxrzComponents.getMultiAdapterccsB|jttt||D]\}}||}|dur||fVq dSr)rfrrdmapr)r rr@rErGrrrr getAdapters~s  zComponents.getAdaptersc Csr|rtd|durt|}t||}|j|||||f|j||||r7ttt ||||||dSdS)N'Named subscribers are not yet supported) r?rrrhr(rfrDrrSubscriptionRegistrationrrrr registerSubscriptionAdapters     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))r@rrr rs   z.cs<g|]\}}}}}|kr|kr|ks|||||fqSrrrrGr@rrr rs   FrNT) r?rrrhlenrfrLrrr)r rGrr@rEnewrrr unregisterSubscriptionAdapters4   z(Components.unregisterSubscriptionAdaptercCs|j||Srrf subscribers)r rr@rrr rrzComponents.subscriberscCs^|rtdt||}|j||||f|j|d||r-ttt|||||dSdS)Nz$Named handlers are not yet supported) r?rrir(rfrDrrHandlerRegistration)r rGrrErFrzrrr registerHandlers   zComponents.registerHandlerccrr)rirrrrr registeredHandlersrzComponents.registeredHandlerscs|rtddurdurtdtdur&fdd|jD}n fdd|jD}t|t|jkr.cs0g|]\}}}}|kr|ks||||fqSrrrrGrrr rs   FrNT) r?rrirrfrLrrr)r rGrrErrrr unregisterHandlers(   zComponents.unregisterHandlercGs|j|ddSrr)r rrrr handlerzComponents.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 ru(zAComponents.rebuildUtilityRegistryFromLocalCache..cWrrr)argsrrr ru.rrr>N)needed_registereddid_not_registerneeded_subscribeddid_not_subscribe) dictr7r9rlrrCrDr registeredrH)r ZrebuildregsutilsrrrrrCrDr@rEvalue_info_factoryrrr $rebuildUtilityRegistryFromLocalCachesH         z/Components.rebuildUtilityRegistryFromLocalCache)rNr)NNrNrNTN)NNrNN)rNN)rN)NNrNrNT)NNNrN)NrNrNT)NNrN)F)'r.r/r0rUr!r\rcrQrRpropertyrkrnrtrTrIrMr}rrrrrrrrrrrrrrrrrrrrr __classcell__rrrer rsp               *  "cCsz|jWStyYdSwr)Z__component_name__AttributeError)r$rrr rxJs  rxcC(tt|}t|dkr|dStd)Nr>rzWThe utility doesn't provide a single interface and no provided interface was specified.)rdrrr?)r$r@rrr rwQ  rwcCr)Nr>rzaThe adapter factory doesn't implement a single interface and no provided interface was specified.)rdr rr?)rGr@rrr r[rrcCs|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?rrrrOtyper r(rS)rGrresultrrrr res4       rc@sVeZdZdddZddZddZdd Zd d Zd d ZddZ ddZ ddZ dS)ryNcCs(||_||_||_||_||_||_dSr)registryr@rEr$rFrG)r rr@rEr$docrGrrr r!s  zUtilityRegistration.__init__c Cs<d|jj|jt|jdd|jt|jdt|j|j |j S)Nz"{}({!r}, {}, {!r}, {}, {!r}, {!r})r.) formatrZr.rgetattrr@rEr$reprrGrFr[rrr r\szUtilityRegistration.__repr__cCt|Sridr[rrr __hash__r3zUtilityRegistration.__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.r/r0r!r\rrrrrrrrrrr rys   ryc@sTeZdZddZddZddZddZd d Zd d Zd dZ ddZ ddZ dS)rcCs,||||||f\|_|_|_|_|_|_dSr)rrr@rErGrF)r rrr@rEr$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.) rrZr.rjoinrrr@rErGrrFr[rrr r\szAdapterRegistration.__repr__cCrrrr[rrr rr3zAdapterRegistration.__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.r/r0rrrr rsrc@s,eZdZddZeddZdZddZdS)rcCs&|||||f\|_|_|_|_|_dSr)rrrEhandlerrF)r rrrErrrrr r!s zHandlerRegistration.__init__cCs|jSr)rr[rrr rGszHandlerRegistration.factoryNc CsHd|jj|jdddd|jDd|jt|jdt |j|j S)Nz{}({!r}, {}, {!r}, {}, {!r})rrcSrorrrrrr rrz0HandlerRegistration.__repr__..rr.) rrZr.rrrrErrGrrFr[rrr r\szHandlerRegistration.__repr__)r.r/r0r!rrGr@r\rrrr rs   rN)&__doc__ collectionsrZ zope.eventr ImportErrorZzope.interface.adapterr Zzope.interface.declarationsr r r rZzope.interface.interfacerZzope.interface.interfacesrrrrrrrrr__all__rr2r4rrxrwrrryrrrrrrr sX                  G3  )&