i"ddlZddlZddlmZ ddlZddlmZn#e$rdZdZYnwxYw ddlZddl m Z n#e$rdZdZ YnwxYwddl m Z ej dZdZGd d e ZdS) N)urlparse) RedisError) ValkeyError) PubSubManagersocketioct|}|jdvrtdg}|jdddD]?}|dd\}}||t|f@i}|jr |j|d<|j r |j |d <d }|j rx|j d }t|d kr$|dd krt|d|d<t|dkr|d d kr|d }|||fS)z}Parse a Redis Sentinel URL with the format: redis+sentinel://[:password]@host1:port1,host2:port2,.../db/service_name redis+sentinelvalkey+sentinelzInvalid Redis Sentinel URL@,:rusernamepasswordN/db) rscheme ValueErrornetlocsplitrsplitappendintrrpathlen) url parsed_url sentinels host_porthostportkwargs service_namepartss A/usr/local/lib/python3.11/dist-packages/socketio/redis_manager.pyparse_redis_sentinel_urlr+sX#J EEE5666I&,,S11"5;;C@@,, %%c1-- d$D *++++ F1'0z1'0zL$%%c** u::??uQx2~~uQx==F4L u::??uQx2~~ 8L lF **cTeZdZdZdZ dfd ZfdZd Zd Zd Z d Z d Z xZ S) RedisManagera6Redis based client manager. This class implements a Redis backend for event sharing across multiple processes. Only kept here as one more example of how to build a custom backend, since the kombu backend is perfectly adequate to support a Redis message queue. To use a Redis backend, initialize the :class:`Server` instance as follows:: url = 'redis://hostname:port/0' server = socketio.Server(client_manager=socketio.RedisManager(url)) :param url: The connection URL for the Redis server. For a default Redis store running on the same host, use ``redis://``. To use a TLS connection, use ``rediss://``. To use Redis Sentinel, use ``redis+sentinel://`` with a comma-separated list of hosts and the service name after the db in the URL path. Example: ``redis+sentinel://user:pw@host1:1234,host2:2345/0/myredis``. :param channel: The channel name on which the server sends and receives notifications. Must be the same in all the servers. :param write_only: If set to ``True``, only initialize to emit events. The default of ``False`` initializes the class for emitting and receiving. A write-only instance can be used independently of the server to emit to clients from an external process. :param logger: a custom logger to log it. If not given, the server logger is used. :param json: An alternative JSON module to use for encoding and decoding packets. Custom json modules must have ``dumps`` and ``loads`` functions that are compatible with the standard library versions. This setting is only used when ``write_only`` is set to ``True``. Otherwise the JSON module configured in the server is used. :param redis_options: additional keyword arguments to be passed to ``Redis.from_url()`` or ``Sentinel()``. redisredis://localhost:6379/0rFNct||||||_|pi|_d|_d|_d|_dS)N)channel write_onlyloggerjsonF)super__init__ redis_url redis_options connectedr/pubsub)selfr!r2r3r4r5r9 __class__s r*r7zRedisManager.__init__ZsZ Z"  $ $ $*0b  r,c td}|jjdkrddlm}|d}nd|jjvrddlm}|d}|std|jjzdS) NTeventletr)is_monkey_patchedsocketgevent)is_module_patchedz[%8&(>??? ";..j((=V== ###r,c|\}}t|j}|jdvrit |j\}}}|j}|||jj|fi|}| |p|j |_ n"|j j |jfi|j|_ |j d|_d|_dS)Nr T)ignore_subscribe_messages)rSrr8rr+r9updatesentinelSentinel master_forr2r/Redisfrom_urlr;r:) r<module_r"r#r(connection_kwargsr'rWs r*_redis_connectzRedisManager._redis_connects4466 dn--   E E E(88 7I|%6'F MM+ , , ,/v/ DDVDDH!,,\-IT\JJDJJ..t~EE151CEEDJj''$'GG r,c |\}}tdddD]} |js||j|j|j|cS#|$ru}|dkr3t ddt|id|_n2t ddt|iYd}~dSYd}~d}~wwxYwdS) Nrrrz#Cannot publish to redis... retryingredis_exceptionextraFz$Cannot publish to redis... giving up) rSranger:r_r/publishr2r5dumpsr4errorstr)r<datar]rg retries_leftexcs r*_publishzRedisManager._publishs633555!!R,,  L ~*'')))z))$, 8M8MNNNNN   !##LL=0#c((;!&+DNNLL>0#c((;!EEEEEE #NNNN    sABC;A$C66C;c#K|\}}d}d} |s5||j|jd}|jEd{Vnd#|$r\}t d|ddt|id}tj ||dz}|d krd }Yd}~nd}~wwxYw) NrFTz)Cannot receive from redis... retrying in z secsrarbr<) rSr_r; subscriber2listenr4rgrhtimesleep)r<r]rg retry_sleep subscribedrks r*_redis_listen_with_retriesz'RedisManager._redis_listen_with_retriess,33555   % %!$'')))K))$,777"#K;--////////// % % % ?,7???$5s3xx#@BBB#  ;'''q ##"$K % %sAA77Crs4 !!!!!!LLL+++++++ EJJJMMM------- FKKK*)))))  : & &+++4^.^.^.^.^.=^.^.^.^.^.s  '' 6 AA