gddlZddlmZddlmZddlmZmZddlm Z ddl m Z ddl m Z d ZGd d ZGd d eZy)N) async_to_sync)DEFAULT_CHANNEL_LAYER)aclose_old_connectionsdatabase_sync_to_async) StopConsumer)get_channel_layer)await_many_dispatchcd|vr td|djdd}|jdr td|S)zl Looks at a message, checks it has a sensible type, and returns the handler name for that type. typez(Incoming message has no 'type' attribute._z.Malformed type in message (leading underscore)) ValueErrorreplace startswith)message handler_names O/var/www/skyplay_api_hub/venv/lib/python3.12/site-packages/channels/consumer.pyget_handler_namer sN WCDD6?**34Ls#IJJ c:eZdZdZdZeZdZdZdZ e dZ y) AsyncConsumerz Base consumer class. Implements the ASGI application spec, and adds on channel layer management and routing of events to named methods based on their type. FcFK||_t|j|_|j`|jj d{|_t j|jj|j |_ |jrt||_ n||_ |j+t||jg|jd{yt|g|jd{y77'7 #t$rYywxYww)U Dispatches incoming messages to type-based handlers asynchronously. N)scoper channel_layer_alias channel_layer new_channel channel_name functoolspartialreceivechannel_receive_syncr base_sendr dispatchr)selfrr"sends r__call__zAsyncConsumer.__call__%s /t/G/GH    )&*&8&8&D&D&F FD #,#4#4""**D,=,=$D  ::*40DN!DN !!-)d223T]]*7)T]]CCC!!GD   sgA D! D A&D!51D&D'D+D!,DDD D!DD DD!DD!cKt|t|d}|r#td{||d{ytd|dz7&7w)z6 Works out what to do with a message. NNo handler for message type %sr )getattrrrrr'rhandlers rr&zAsyncConsumer.dispatchCsW$ 0 94@ (* * *'" " "=OP P + "s&AAAAAAcBK|j|d{y7wzB Overrideable/callable-by-subclasses send method. Nr%r'rs rr(zAsyncConsumer.sendNsnnW%%%s c bfd}|_|_tj|d|S)z Return an ASGI v3 single callable that instantiates a consumer instance per scope. Similar in purpose to Django's as_view(). initkwargs will be used to instantiate the consumer instance. cDKdi}||||d{S7w)Nr5)rr"r(consumercls initkwargss rappz"AsyncConsumer.as_asgi..app]s)(Z(H!%$77 77s   r5)updated)consumer_classconsumer_initkwargsr update_wrapper)r7r8r9s`` ras_asgizAsyncConsumer.as_asgiTs3 8!",   c26 rN) __name__ __module__ __qualname____doc__r$rrr)r&r( classmethodr>r5rrrrs8 E/< Q& rrc*eZdZdZdZedZdZy) SyncConsumera Synchronous version of the consumer, which is what we write most of the generic consumers against (for now). Calls handlers in a threadpool and uses CallBouncer to get the send method out to the main event loop. It would have been possible to have "mixed" consumers and auto-detect if a handler was awaitable or not, but that would have made the API for user-called methods very confusing as there'd be two types of each. Tcft|t|d}|r ||ytd|dz)rNr+r )r,rrr-s rr&zSyncConsumer.dispatchvs8 $ 0 94@  G =OP Prc&|j|yr0r1r2s rr(zSyncConsumer.sends wrN)r?r@rArBr$rr&r(r5rrrErEis' E Q Q rrE)r asgiref.syncrrdbrr exceptionsrlayersr utilsr rrrEr5rrrNs8&#>$%& KK\ = r