3 \]@sLddlmZddlZddlZddlZddlZddlmZGdddeZdS))partialN) BaseManagercseZdZdZdZdfdd Zfdd Zdfd d Zdd d ZddZ ddZ fddZ ddZ ddZ fddZddZZS) PubSubManagera=Manage a client list attached to a pub/sub backend. This is a base class that enables multiple servers to share the list of clients, with the servers communicating events through a pub/sub backend. The use of a pub/sub backend also allows any client connected to the backend to emit events addressed to Socket.IO clients. The actual backends must be implemented by subclasses, this class only provides a pub/sub generic framework. :param channel: The channel name on which the server sends and receives notifications. ZpubsubsocketioFNcs0tt|j||_||_tjj|_||_ dS)N) superr__init__channel write_onlyuuiduuid4hexhost_idlogger)selfr r r) __class__B/tmp/pip-build-mqc4i71p/python-socketio/socketio/pubsub_manager.pyrs  zPubSubManager.__init__cs<tt|j|js$|jj|j|_|jj |j ddS)Nz backend initialized.) rr initializer serverZstart_background_task_threadthreadZ _get_loggerinfoname)r)rrrr"szPubSubManager.initializec s|jdr&tt|j||||||dS|p,d}|dk rr|jdkrHtd|dkrXtd|j|||}|||f}nd}|jd|||||||j ddS) a/Emit a message to a single client, a room, or all the clients connected to the namespace. This method takes care or propagating the message to all the servers that are connected through the message queue. The parameters are the same as in :meth:`.Server.emit`. Z ignore_queue) namespaceroomskip_sidcallback/Nz:Callbacks can only be issued from the context of a server.z'Cannot use callback without a room set.emit)methodeventdatarrrrr) getrrrr RuntimeError ValueErrorZ_generate_ack_id_publishr) rr!r"rrrrkwargsid)rrrr(s"      zPubSubManager.emitcCs|jd||pdddS)N close_roomr)r rr)r&)rrrrrrr)FszPubSubManager.close_roomcCs tddS)zPublish a message on the Socket.IO channel. This method needs to be implemented by the different subclasses that support pub/sub backends. z.This method must be implemented in a subclass.N)NotImplementedError)rr"rrrr&JszPubSubManager._publishcCs tddS)zReturn the next message published on the Socket.IO channel, blocking until a message is available. This method needs to be implemented by the different subclasses that support pub/sub backends. z.This method must be implemented in a subclass.N)r*)rrrr_listenSszPubSubManager._listencsz|jd}|jd}|dk rs