o gHdd@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)argkwrr^/var/www/html/facialservice/flask-venv/lib/python3.10/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)self 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_intJr4c@sDeZdZddZddZddZddZd d Zd d Zd dZ dS)_UtilityRegistrationscCs"tt|_||_||_|dSr)rr4_cache _utilities_utility_registrations%_UtilityRegistrations__populate_cache)r! utilitiesutility_registrationsrrr r#Os  z_UtilityRegistrations.__init__cCs4t|jD]\\}}}|d}|||qdSr$)iterr9r$_UtilityRegistrations__cache_utility)r!p_r,r&rrr __populate_cacheWsz&_UtilityRegistrations.__populate_cachecCsZz|j||d7<WdSty,t|j|}|j|<||d7<YdSw)N)r7 TypeErrorr)r!providedr&provrrr __cache_utility\s  z%_UtilityRegistrations.__cache_utilitycCs@|j|}||}|d8}|dkr||=|dkS|||<|dkS)NrBr)r7)r!rDr&r'rrr __uncache_utilityes z'_UtilityRegistrations.__uncache_utilitycCs*z |j||dkWStyYdSw)NrF)r7rC)r!rDr&rrr _is_utility_subscribedts  z,_UtilityRegistrations._is_utility_subscribedcCsV|||}|||f|j||f<|jd||||s#|jd|||||dSNr)rHr9r8register subscriber>)r!rDnamer&infofactory subscribedrrr registerUtility{s z%_UtilityRegistrations.registerUtilitycCsD|j||f=|jd|||||}|s |jd||dSdSrI)r9r8 unregister&_UtilityRegistrations__uncache_utility unsubscribe)r!rDrLr&rOrrr unregisterUtilitys  z'_UtilityRegistrations.unregisterUtilityN) r0r1r2r#r:r>rRrHrPrTrrrr r6Ms  r6csreZdZdZdIddZddZfdd 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) isinstancestrr0_init_registries_init_registrationstuple __bases___v_utility_registrations_cache)r!rLbasesrrr r#s   zComponents.__init__cCsd|jj|jS)Nz<{} {}>)format __class__r0r!rrr __repr__zComponents.__repr__cs8t}dd|dD}t|}||d<t|S)NcSs i|] \}}|ds||qS)_v_) startswith)rkvrrr s  z)Components.__reduce__..)super __reduce__rlistrZ)r! reductionfiltered_stater_rr rjs zComponents.__reduce__cCst|_t|_dSr)radaptersr;r`rrr rXs zComponents._init_registriescCsi|_i|_g|_g|_dSr)r9_adapter_registrations_subscription_registrations_handler_registrationsr`rrr rYs zComponents._init_registrationscCs>|j}|dus|j|jus|j|jurt|j|j}|_|Sr)r\r8r;r9r6)r!cacherrr _utility_registrations_caches   z'Components._utility_registrations_cachecCs|jddS)Nr[r)__dict__getr`rrr _getBasesszComponents._getBasescCs>tdd|D|j_tdd|D|j_t||jd<dS)NcSg|]}|jqSr)rorbaserrr rz(Components._setBases..cSrxr)r;ryrrr rr{r[)rZror[r;rur!r]rrr _setBasess  zComponents._setBasescCs|Sr)rwr`rrr szComponents.cCs ||Sr)r}r|rrr r~s Tc Cs|r |rtd|}|durt|}|dkrt|}|j||f}|dur<|dd||fkr3dS||d|||j||||||rWtt t ||||||dSdS)N$Can't specify factory and component.rUrhr) rC_getUtilityProvided_getNamer9rvrTrtrPrrUtilityRegistration)r!r&rDrLrMeventrNregrrr rPs.   zComponents.registerUtilitycCs|r |rtd|}|dur|durtdt|}|j||f}|dus1|dur3||dkr3dS|dur;|d}|j|||ttt||||g|ddRdS)Nrz3Must specify one of component, factory and providedrFrBT) rCrr9rvrtrTrrr)r!r&rDrLrNoldrrr rTs, zComponents.unregisterUtilityccs8t|jD]\\}}}t|||g|RVqdSr)r=r9rr)r!rDrLr,rrr registeredUtilitiess  zComponents.registeredUtilitiescCs|jd|||SrI)r;lookup)r!rDrLdefaultrrr queryUtilityrbzComponents.queryUtilitycCs&|jd||}|durt|||SrI)r;rr )r!rDrLutilityrrr getUtilitys zComponents.getUtilityccs|jd|EdHdSrI)r; lookupAllr! interfacerrr getUtilitiesFor%szComponents.getUtilitiesForcCs|jd|SrI)r; subscriptionsrrrr getAllUtilitiesRegisteredFor(z'Components.getAllUtilitiesRegisteredForc Csv|durt|}t||}|dkrt|}||f|j|||f<|j|||||r9ttt||||||dSdSNrU) _getAdapterProvided_getAdapterRequiredrrprorJrrAdapterRegistrationr!rNrequiredrDrLrMrrrr 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) rCrrrprvrorQrrr)r!rNrrDrLrrrr unregisterAdapter=s(   zComponents.unregisterAdapterccs<t|jD]\\}}}\}}t||||||VqdSr)r=rprr)r!rrDrLr&rMrrr registeredAdaptersXs  zComponents.registeredAdapterscC|j||||Sr)ro queryAdapter)r!objectrrLrrrr r^rbzComponents.queryAdaptercC(|j|||}|durt||||Sr)rorr )r!rrrLadapterrrr getAdaptera zComponents.getAdaptercCrr)roqueryMultiAdapter)r!objectsrrLrrrr rgszComponents.queryMultiAdaptercCrr)rorr )r!rrrLrrrr getMultiAdapterlrzComponents.getMultiAdapterccsB|jttt||D]\}}||}|dur||fVq dSr)rorrkmapr)r!rrDrLrNrrrr getAdaptersrs   zComponents.getAdaptersc Csr|rtd|durt|}t||}|j|||||f|j||||r7ttt ||||||dSdS)N'Named subscribers are not yet supported) rCrrrqr*rorKrrSubscriptionRegistrationrrrr registerSubscriptionAdapterzs     z&Components.registerSubscriptionAdaptercc$|jD] }t|g|RVqdSr)rqrr!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+)rDrrr rs  z.cs<g|]\}}}}}|kr|kr|ks|||||fqSrrrrNrDrrr rs FrUT) rCrrrqlenrorSrrr)r!rNrrDrLnewrrr unregisterSubscriptionAdapters4   z(Components.unregisterSubscriptionAdaptercCs|j||Srro subscribers)r!rrDrrr rrzComponents.subscriberscCs^|rtdt||}|j||||f|j|d||r-ttt|||||dSdS)Nz$Named handlers are not yet supported) rCrrrr*rorKrrHandlerRegistration)r!rNrrLrMrrrr registerHandlers   zComponents.registerHandlerccrr)rrrrrrr registeredHandlersrzComponents.registeredHandlerscs|rtddurdurtdtdur&fdd|jD}n fdd|jD}t|t|jkr.cs0g|]\}}}}|kr|ks||||fqSrrrrNrrr rs  FrUT) rCrrrrrorSrrr)r!rNrrLrrrr unregisterHandlers(   zComponents.unregisterHandlercGs|j|ddSrr)r!rrrr handlerbzComponents.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 r~r zAComponents.rebuildUtilityRegistryFromLocalCache..cWrrr)argsrrr r~!r rrBN)needed_registereddid_not_registerneeded_subscribeddid_not_subscribe) dictr9r;rurrJrKr registeredrO)r!rebuildregsutilsrrrrrJrKrDrLvalue_info_factoryrrr $rebuildUtilityRegistryFromLocalCachesH         z/Components.rebuildUtilityRegistryFromLocalCache)rUr)NNrUrUTN)NNrUN)rUN)rU)NNrUrUT)NNNrU)NrUrUT)NNrU)F)'r0r1r2r\r#rarjrXrYpropertyrtrwr}r[rPrTrrrrrrrrrrrrrrrrrrrrrr __classcell__rrrnr rsr                *  "cCsz|jWStyYdSwr)__component_name__AttributeError)r&rrr r<s  rcC(tt|}t|dkr|dStd)NrBrzWThe utility doesn't provide a single interface and no provided interface was specified.)rkrrrC)r&rDrrr rB  rcCr)NrBrzaThe adapter factory doesn't implement a single interface and no provided interface was specified.)rkrrrC)rNrDrrr 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) __component_adapts__rrCr rrrVtyperr*rZ)rNrresultrrrr rRs,       rc@sVeZdZdddZddZddZdd Zd d Zd d ZddZ ddZ ddZ dS)rNcC,||||||f\|_|_|_|_|_|_dSr)registryrDrLr&rMrN)r!rrDrLr&docrNrrr r#qszUtilityRegistration.__init__c Cs<d|jj|jt|jdd|jt|jdt|j|j |j S)Nz"{}({!r}, {}, {!r}, {}, {!r}, {!r})r0) r^r_r0rgetattrrDrLr&reprrNrMr`rrr ravszUtilityRegistration.__repr__cCt|Sridr`rrr __hash__r5zUtilityRegistration.__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 r0r1r2r#rarrrrrrrrrrr rns   rc@sTeZdZddZddZddZddZd d Zd d Zd dZ ddZ ddZ dS)rcCrr)rrrDrLrNrM)r!rrrDrLr&rrrr r#s zAdapterRegistration.__init__c CsTd|jj|jdddd|jDdt|jdd|jt|j dt |j |j S)Nz {}({!r}, {}, {}, {!r}, {}, {!r})[, cSrxrr0rrrrr rz0AdapterRegistration.__repr__..]r0) r^r_r0rjoinrrrDrLrNrrMr`rrr raszAdapterRegistration.__repr__cCrrrr`rrr rr5zAdapterRegistration.__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)r0r1r2rrrr rsrc@s,eZdZddZeddZdZddZdS)rcCs&|||||f\|_|_|_|_|_dSr)rrrLhandlerrM)r!rrrLrrrrr r#s zHandlerRegistration.__init__cCs|jSr)rr`rrr rNszHandlerRegistration.factoryNc CsHd|jj|jdddd|jDd|jt|jdt |j|j S)Nz{}({!r}, {}, {!r}, {}, {!r})rrcSrxrrrrrr rrz0HandlerRegistration.__repr__..rr0) r^r_r0rrrrLrrNrrMr`rrr raszHandlerRegistration.__repr__)r0r1r2r#rrNrDrarrrr rs   rN)&__doc__ collectionsr zope.eventr ImportErrorzope.interface.interfacesr r r rrrrrrzope.interface.interfacerzope.interface.declarationsrrrrzope.interface.adapterr__all__rr4r6rrrrrrrrrrrrr sX                  C.%%