File: //home/arjun/projects/env/lib/python3.10/site-packages/kombu/__pycache__/matcher.cpython-310.pyc
o
'we� � @ s� d Z ddlmZ ddlmZ ddlmZ ddlmZm Z ddl
m Z ddl m
Z
eeegef ZG d d
� d
e�ZG d d � d �Ze� Z ejZ ejZ ejZddd�Zddd�Ze� e� e�d� e d�D ]
\ZZeej ge�R � qgdS )zPattern matching registry.� )� annotations)�fnmatch)�match)�Callable�cast� )� entrypoints)� bytes_to_strc @ s e Zd ZdZdS )�MatcherNotInstalledz Matcher not installed/found.N)�__name__�
__module__� __qualname__�__doc__� r r �F/home/arjun/projects/env/lib/python3.10/site-packages/kombu/matcher.pyr
s r
c @ sR e Zd ZdZeZdgZddd�Zd d d �Zd d
d�Zd dd�Z d d dd�Z
dS ) �MatcherRegistryz#Pattern matching function registry.�pcre�return�Nonec C s i | _ d | _d S )N)� _matchers�_default_matcher)�selfr r r �__init__ s
zMatcherRegistry.__init__�name�str�matcher�MatcherFunctionc C s || j |< dS )z$Add matcher by name to the registry.N)r )r r r r r r �register s zMatcherRegistry.registerc C s2 z | j �|� W dS ty | �d|� ���w )z)Remove matcher by name from the registry.�No matcher installed for N)r �pop�KeyErrorr
�r r r r r �
unregister! s ��zMatcherRegistry.unregisterc C s2 z | j | | _W dS ty | �d|� ���w )aH Set the default matching method.
:param name: The name of the registered matching method.
For example, `glob` (default), `pcre`, or any custom
methods registered using :meth:`register`.
:raises MatcherNotInstalled: If the matching method requested
is not available.
r N)r r r r
r! r r r �_set_default_matcher* s
��z$MatcherRegistry._set_default_matcherN�data�bytes�pattern�
str | None�matcher_kwargs�dict[str, str] | None�boolc C sp |r| j �|�s| �d|� ���| j |pd }|| jv r%t|�}t|�}nt|�}t|�}|||fi |p5i ��S )zCall the matcher.r �glob)r �getr
�matcher_pattern_firstr )r r$ r& r r( �
match_func� first_arg�
second_argr r r r ; s �
zMatcherRegistry.match�r r )r r r r r r )r r r r )NN)
r$ r% r& r% r r' r( r) r r* ) r r r
r r
r- r r r" r# r r r r r r s
�r r r c C s t �dt� dS )z$Register glob into default registry.r+ N)�registryr r r r r r �
register_glob} s r3 c C s t �dttt�� dS )z$Register pcre into default registry.r N)r2 r r r �rematchr r r r �
register_pcre� s r5 r+ zkombu.matchersNr1 ) r �
__future__r r �rer r4 �typingr r � utils.compatr �utils.encodingr r r* r � Exceptionr
r r2 r r" r3 r5 r# �ep�argsr r r r r �<module> s2 ?
�