iz<dZddlZddlZddlZddlZddlZddlZddlZddlZddl Z ddl m Z ddddZ dZ d ZGd d ejZGd d eZGddeZy)z( General utility functions and classes. N)queuezRPlease make sure that you have Python bindings for the system frameworks installedzYPlease make sure that you are running as root, and that the utility dumpkeys is installedznPlease make sure that you have an X server running, and that the DISPLAY environment variable is set correctly)darwinuinputxorgctjjdj|j ddj tjjdd}|r|g}n1t jdk(rdg}nt jdk(rdg}ndg}g}g}|D]} tjd |z|cSt|rGd jd jd |Dd djd|Dzzd#t$r;}|j||tvr|jt|Yd}~d}~wwxYw)zpReturns the backend module for a package. :param str package: The package for which to load a backend. zPYNPUT_BACKEND_{}.PYNPUT_BACKENDNrwin32rz._z"this platform is not supported: {}z; c32K|]}t|ywN)str).0es _/home/obispo/Crisostomo_bridge/mision_env/lib/python3.12/site-packages/pynput/_util/__init__.py zbackend..Os)Q#a&)sz) Try one of the following resolutions: z c3>K|]}dj|yw)z * {}Nformat)rss rrzbackend..Qs!&q!&s)osenvirongetrrsplituppersysplatform importlib import_module ImportErrorappend RESOLUTIONSjoin)package backend_namemoduleserrors resolutionsmodulers rbackendr+3sc ::>>""7>>##6r#:#@#@#BC '.0L.  !*  )( FK8 8**4&='B B8   ;AA )&))+/8kk&$&&/&' $$ !#  $$  8 MM! $"";v#67 8s/D E#(1EE#ctfd|jddD]?}|ur'|jjddddddzcSt |}|=|cSy)zCalculates the prefix to use for platform specific options for a specific class. The prefix if the name of the module containing the class that is an immediate subclass of ``base`` among the super classes of ``cls``. ct|Sr ) issubclass)clsbases rzprefix.._s 3-Nrr _)filter__mro__ __module__rprefix)r0r/ super_clsresults` rr8r8Wsr - KKO   >>((a04QR83> >D),F! r2ceZdZdZGddeZeZdfd Ze dZ e dZ dZ dZ d Zd Zd Zed Zd ZdZdZdZdfd ZxZS)AbstractListeneraA class implementing the basic behaviour for event listeners. Instances of this class can be used as context managers. This is equivalent to the following code:: listener.start() listener.wait() try: with_statements() finally: listener.stop() Actual implementations of this class must set the attribute ``_log``, which must be an instance of :class:`logging.Logger`. :param bool suppress: Whether to suppress events. Setting this to ``True`` will prevent the input events from being passed to the rest of the system. :param kwargs: A mapping from callback attribute to callback handler. All handlers will be wrapped in a function reading the return value of the callback, and if it ``is False``, raising :class:`StopException`. Any callback that is falsy will be ignored. ceZdZdZy)AbstractListener.StopExceptionzfIf an event listener callback raises this exception, the current listener is stopped. N)__name__r7 __qualname____doc__r2r StopExceptionr>s   r2rCc \tt fd}|_d_t j _t j_ d_ tjd_ d_|jD]\}}t!|||y)Ncfd}|S)Nc4|durjy)NF)rC)argsfselfs rinnerz9AbstractListener.__init__..wrapper..inners#d8u$,,..%r2rB)rHrJrIs` rwrapperz*AbstractListener.__init__..wrappers /Lr2F T)superr<__init__ _suppress_running threadingcurrent_thread_thread Condition _condition_readyrQueue_queuedaemonitemssetattr)rIsuppresskwargsrKnamecallback __class__s` rrNzAbstractListener.__init__s .0  "  //1 #--/ kk"o  $lln 3ND( D$ 1 2 3r2c|jS)z$Whether to suppress events. )rOrIs rr\zAbstractListener.suppresss~~r2c|jS)z3Whether the listener is currently running. )rPrbs rrunningzAbstractListener.runnings}}r2c|jr3d|_|jjd|jyy)atStops listening for events. When this method returns, no more events will be delivered. Once this method has been called, the listener instance cannot be used any more, since a listener is a :class:`threading.Thread`, and once stopped it cannot be restarted. To resume listening for event, a new listener must be created. FN)rPrXput_stop_platformrbs rstopzAbstractListener.stops3 ==!DM KKOOD !    ! r2cF|j|j|Sr )startwaitrbs r __enter__zAbstractListener.__enter__s   r2c$|jyr )rh)rIexc_typevalue tracebacks r__exit__zAbstractListener.__exit__s  r2c|jj|js'|jj|js'|jj y)z1Waits for this listener to become ready. N)rUacquirerVrkreleaserbs rrkzAbstractListener.waitsD !++ OO "++ !r2cd|_tj|_|j |j j dy)z"The thread runner method. TN)rPrQrRrS_runrXrfrbs rrunzAbstractListener.runs6  //1   r2cFtjfd}|S)aaA decorator to mark a method as the one emitting the callbacks. This decorator will wrap the method and catch exception. If a :class:`StopException` is caught, the listener will be stopped gracefully. If any other exception is caught, it will be propagated to the thread calling :meth:`join` and reraised there. c |g|i|S#t$r}t||jst|tjs|j j d|jjt|jrdntj|jd}~wwxYw)Nz(Unhandled exception in listener callback) Exception isinstance_HANDLED_EXCEPTIONSr<rC_log exceptionrXrfrexc_inforh)rIrGr]rr/rHs rrJz(AbstractListener._emitter..inners //// !!T%=%=>%a)9)G)GH ++FHKKOO *1c.?.? @ \\^-IIK s  B>B!B99B> functoolswraps)r/rHrJs`` r_emitterzAbstractListener._emitters'       r2c|jjd|_|jj|jj y)zMarks this listener as ready to receive events. This method must be called from :meth:`_run`. :meth:`wait` will block until this method is called. TN)rUrsrVnotifyrtrbs r _mark_readyzAbstractListener._mark_readys; !    !r2ct)zlThe implementation of the :meth:`run` method. This is a platform dependent implementation. NotImplementedErrorrbs rrvzAbstractListener._run "##r2ct)zmThe implementation of the :meth:`stop` method. This is a platform dependent implementation. rrbs rrgzAbstractListener._stop_platformrr2c(dStj}ttjj|j rt|j nd}|z |kDr t |k\s |jSfdS)a4Wraps a callable to make it accept ``args`` number of arguments. :param f: The callable to wrap. If this is ``None`` a no-op wrapper is returned. :param int args: The number of arguments to accept. :raises ValueError: if f requires more than ``args`` arguments cyr rB)as rr1z(AbstractListener._wrap..sr2rc|dSr rB)ractualrHs rr1z(AbstractListener._wrap..#s!QwZ.r2)inspectgetfullargspeclen signature parametersdefaults ValueErrorvarargs)rIrHrGargspecrrs ` @r_wrapzAbstractListener._wraps 9" ",,Q/G**1-889F070@0@s7++,aH 4' m#47??#>00r2c\tj}tt||g||$t d|tj|z z nd} |j j |\}}}tj|||y#tj$rYyt$rYywxYw)Ngtimeout) timerMr<r$maxrXrsixreraiserEmpty TypeError)rIrrGrjrn exc_value exc_tracebackr`s rr$zAbstractListener.join%s  *7:T:"c7diikE&9:;   152A2! .Hi KK)] ;{{     s7B B+ B+*B+)Fr )r?r7r@rArzrCtupler|rNpropertyr\rdrhrlrqrkrw classmethodrrrvrgrr$ __classcell__r`s@rr<r<is2   '3.  " "6 "$$1.r2r<cbeZdZdZdZGddeZfdZdZdZ dZ d Z d d Z d Z xZS) Eventsz2A base class to enable iterating over events. NceZdZdZdZy) Events.Eventc dj|jjdjdt |j DS)Nz{}({})z, c3FK|]\}}dj||yw)z{}={}Nr)rkvs rrz'Events.Event.__str__..Bs'6ANN1a(6s!)rr`r?r$varsrZrbs r__str__zEvents.Event.__str__?sF??'' 6"&t*"2"2"4667 7r2cjjk(xr7ttk(xrtfdtDS)Nc3PK|]}t|t|k(ywr )getattr)rrotherrIs rrz&Events.Event.__eq__..Is,(D!$q(99(s#&)r`dirall)rIrs``r__eq__zEvents.Event.__eq__FsK>>U__4(IU+(( Y(( (r2N)r?r7r@rrrBr2rEventr>s  7 (r2rc Ltt| tj|_t |_|j|i|jDcic]\}}||j|c}}|_ |jj|_ ycc}}wr ) rMrrNrrW _event_queueobject _sentinel _ListenerrZ _event_mapper _listenerrj)rIrGr]keyror`s rrNzEvents.__init__Ms fd$&!KKM'1 & 20e ##E* *201^^)) 20sB c:|jj|Sr )rrlrbs rrlzEvents.__enter__Vs   " r2c|jj| |jj#tj $rYnwxYw|jj |jyr )rrqr get_nowaitrrrfr)rIrGs rrqzEvents.__exit__Zsi& !!,,.;;   dnn-s7A  A c|Sr rBrbs r__iter__zEvents.__iter__fs r2c>|j}||Str )r StopIteration)rIevents r__next__zEvents.__next__is    L/ !r2c |jj|}||jur|SdS#tj$rYywxYw)aAttempts to read the next event. :param int timeout: An optional timeout. If this is not provided, this method may block infinitely. :return: the next event, or ``None`` if the source has been stopped or no events were received rN)rrrrr)rIrrs rrz Events.getpsL %%))'):E!75 AT A{{  s+00AAcFtjfd}|S)zGenerates an event callback to transforms the callback arguments to an event and then publishes it. :param callback event: A function generating an event object. :return: a callback cz jj|dy#tj$rYywxYw)NF)block)rrfrFull)rGrrIs rrJz#Events._event_mapper..inners; !!%%eTl%%@::  s $::r)rIrrJs`` rrzEvents._event_mappers'       r2r )r?r7r@rArrrrNrlrqrrrrrrs@rrr8s>I ( (* ." r2rcVeZdZdZdZedZedZedZedZ y) NotifierMixinzA mixin for notifiers of fake events. This mixin can be used for controllers on platforms where sending fake events does not cause a listener to receive a notification. cg}|jD]} t||||D]}|j y#|j$r|j|YOwxYw)aSends a notification to all registered listeners. This method will ensure that listeners that raise :class:`StopException` are stopped. :param str action: The name of the notification. :param args: The arguments to pass. N) _listenersrrCr"rh)rIactionrGstoppedlisteners r_emitzNotifierMixin._emitsr) )H ))&)40 )   H MMO )) )x( )sA A#"A#ctjd}||_||_t |ds(t |_tj|_ |S)aeA decorator to make a class able to receive fake events from a controller. This decorator will add the method ``_receive`` to the decorated class. This method is a context manager which ensures that all calls to :meth:`_emit` will invoke the named method in the listener instance while the block is active. c3K|jj| d|jj|y#|jj|wxYww)zyExecutes a code block with this listener instance registered as a receiver of fake input events. N)_controller_class _add_listener_remove_listenerrbs rreceivez(NotifierMixin._receiver..receivesL  " " 0 0 6 >&&77=&&77=sA?AAA_listener_cache) contextlibcontextmanager_receiverhasattrsetrrQLock_listener_lock)r/listener_classrs r _receiverzNotifierMixin._receiversZ  " " > # >#*+.(s-."%%C !*!1C r2c#K|jsy|j5|jD]}| dddy#1swYyxYww)a0Iterates over the set of running listeners. This method will quit without acquiring the lock if the set is empty, so there is potential for race conditions. This is an optimisation, since :class:`Controller` will need to call this method for every control event. N)rrr/rs rrzNotifierMixin._listenerssK""     //     sA< AAAc||j5|jj|dddy#1swYyxYw)zqAdds a listener to the set of running listeners. :param listener: The listener for fake events. N)rraddrs rrzNotifierMixin._add_listeners6    .    # #H - . . .2;c||j5|jj|dddy#1swYyxYw)zyRemoves this listener from the set of running listeners. :param listener: The listener for fake events. N)rrremovers rrzNotifierMixin._remove_listeners6    1    & &x 0 1 1 1rN) r?r7r@rArrrrrrrBr2rrrs\ &>  ..11r2r)rArrrrrrrQrr six.movesrr#r+r8Threadr<rrrrBr2rrs}"   &, < = !$H$Ly''L^VVVrX1FX1r2