MfddlZddlmZddlmZddlmZddlmZddl m Z ddl m Z d Z Gd d ZGd d eZdS)N) async_to_sync)DEFAULT_CHANNEL_LAYER)database_sync_to_async) StopConsumer)get_channel_layer)await_many_dispatchcd|vrtd|ddd}|drtd|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 P/var/www/surfInsights/venv3-11/lib/python3.11/site-packages/channels/consumer.pyget_handler_namer sc WCDDD6?**344Ls##KIJJJ cBeZdZdZdZeZdZdZdZ e dZ dS) 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. FcK||_t|j|_|jM|jd{V|_t j|jj|j|_ |j rt||_ n||_ |j$t||j g|jd{VdSt|g|jd{VdS#t$rYdSwxYw)U Dispatches incoming messages to type-based handlers asynchronously. N)scoperchannel_layer_alias channel_layer new_channel channel_name functoolspartialreceivechannel_receive_syncr base_sendr dispatchr)selfrr!sends r__call__zAsyncConsumer.__call__%sD /t/GHH   )&*&8&D&D&F&F F F F F F FD #,#4"*D,=$$D  : "*400DNN!DN !-)d23T]*7)T]CCCCCCCCCCC    DD s)C$C$$ C21C2cKt|t|d}|r||d{VdStd|dz)z6 Works out what to do with a message. NNo handler for message type %sr getattrrrr&rhandlers rr%zAsyncConsumer.dispatchCsk$ 0 9 94@@  Q''"" " " " " " " " " "=OPP Prc@K||d{VdSzB Overrideable/callable-by-subclasses send method. Nr$r&rs rr'zAsyncConsumer.sendMs2nnW%%%%%%%%%%%rc `fd}|_|_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. c>Kdi}||||d{VS)Nr5)rr!r'consumercls initkwargss rappz"AsyncConsumer.as_asgi..app\sBs((Z((H!%$77777777 7rr5)updated)consumer_classconsumer_initkwargsrupdate_wrapper)r7r8r9s`` ras_asgizAsyncConsumer.as_asgiSsS 8 8 8 8 8 8!",  c26666 rN) __name__ __module__ __qualname____doc__r#rrr(r%r' classmethodr>r5rrrrsv E/<QQQ&&& [rrc2eZdZdZdZedZdZdS) 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. Tct|t|d}|r ||dStd|dz)rNr*r r+r-s rr%zSyncConsumer.dispatchusU $ 0 9 94@@  Q GG     =OPP Prc0||dSr0r1r2s rr'zSyncConsumer.sends wrN)r?r@rArBr#rr%r'r5rrrErEhsQ E Q Q Q     rrE)r asgiref.syncrrdbr exceptionsrlayersrutilsr rrrEr5rrrNs&&&&&&######&&&&&&$$$$$$%%%%%%&&&&&&   JJJJJJJJZ     =     r