o UgM3@sddlZddlZddlZddlZddlZddlZddlmZddlm Z ddl m Z ddl m Z ddlmZddlmZmZGd d d ZGd d d ZGd ddeZefddZeZdS)N)deepcopy)settings)setting_changed) import_string)DEFAULT_CHANNEL_LAYER) ChannelFullInvalidChannelLayerErrorc@s\eZdZdZddZddZeddZdd Zd d Z d d Z ddZ ddZ ddZ dS)ChannelLayerManagerzR Takes a settings dictionary of backends and initialises them on request. cCsi|_t|jdSN)backendsrconnect_reset_backendsselfr[/var/www/html/Testing_prj/Navya-Bakers/venv/lib/python3.10/site-packages/channels/layers.py__init__szChannelLayerManager.__init__cKs|dkr i|_dSdS)zX Removes cached channel layers when the CHANNEL_LAYERS setting changes. CHANNEL_LAYERSN)r )rsettingkwargsrrrrs z#ChannelLayerManager._reset_backendscCs ttdiS)Nr)getattrrrrrrconfigs"s zChannelLayerManager.configscCs|j|di}|||S)z, Instantiate channel layer. CONFIG)rget _make_backendrnameconfigrrr make_backend's z ChannelLayerManager.make_backendcCs:z |j|d}Wn tytd|w|||S)zB Instantiate channel layer using its test config. TEST_CONFIGzNo TEST_CONFIG specified for %s)rKeyErrorr rrrrrmake_test_backend.s    z%ChannelLayerManager.make_test_backendcCsd|j|vr td|z t|j|d}Wn ty%td|ty8td|j|d|fw|di|S)NROUTINGzBROUTING key found for %s - this is no longer needed in Channels 2.BACKENDzNo BACKEND specified for %sz)Cannot import BACKEND %r specified for %sr)rr rr! ImportError)rrr backend_classrrrr8s$   z!ChannelLayerManager._make_backendcCs$||jvr |||j|<|j|Sr )r rrkeyrrr __getitem__Ls  zChannelLayerManager.__getitem__cCs ||jvSr )rr'rrr __contains__Qs z ChannelLayerManager.__contains__cCs|j|d}||j|<|S)z Sets an alias to point to a new ChannelLayerWrapper instance, and returns the old one that it replaced. Useful for swapping out the backend during tests. N)r r)rr(layeroldrrrsetTs zChannelLayerManager.setN)__name__ __module__ __qualname____doc__rrpropertyrrr"rr)r*r-rrrrr s   r c@seZdZdZdZd*ddZddZd d Zd d Ze d Z e dZ dd eddZd+ddZddZd+ddZddZddZddZd d!Zd"d#Zd$d%Zd&d'Zd(d)ZdS),BaseChannelLayerzf Base channel layer class that others can inherit from, with useful common functionality. d<NcCs||_||_|p i|_dSr expirycapacitychannel_capacity)rr7r8r9rrrrgszBaseChannelLayer.__init__cCsNg}|D]\}}t|dr|||fq|tt||fq|S)z Takes an input channel_capacity dict and returns the compiled list of regexes that get_capacity will look for as self.channel_capacity match)itemshasattrappendrecompilefnmatch translate)rr9resultpatternvaluerrrcompile_capacitiesls  z#BaseChannelLayer.compile_capacitiescCs(|jD] \}}||r|Sq|jS)a Gets the correct capacity for the given channel; either the default, or a matching result from channel_capacity. Returns the first matching result; if you want to control the order of matches, use an ordered dict as input. )r9r:r8)rchannelrCr8rrr get_capacity{s  zBaseChannelLayer.get_capacitycCs t|trt||jkrdSdS)NTF) isinstancestrlenMAX_NAME_LENGTHrrrrrmatch_type_and_lengthsz&BaseChannelLayer.match_type_and_lengthz!^[a-zA-Z\d\-_.]+(\![\d\w\-_.]*)?$z^[a-zA-Z\d\-_.]+$z'{} name must be a valid unicode string zwith length < {} zGcontaining only ASCII alphanumerics, hyphens, underscores, or periods, znot {}FcCsN||rt|j|rd|vr|ds|rtddSt|jd|)N!z5Specific channel names in receive() must end at the !TChannel)rMboolchannel_name_regexr:endswith TypeErrorinvalid_name_errorformat)rrreceiverrrvalid_channel_names z#BaseChannelLayer.valid_channel_namecCs0||rt|j|rdSt|jd|)NTGroup)rMrPgroup_name_regexr:rSrTrUrLrrrvalid_group_names z!BaseChannelLayer.valid_group_namecsF|rdnd}t|t}|r|sJdtfdd|Ds!JdS)NTFznames must be a non-empty listc3s|] }j|dVqdS))rVN)rW).0rFrVrrr s z7BaseChannelLayer.valid_channel_names..)rHlistall)rnamesrV_non_empty_list _names_typerr\rvalid_channel_namess   z$BaseChannelLayer.valid_channel_namescCs"d|vr|d|ddS|S)z Given a channel name, returns the "non-local" part. If the channel name is a process-specific channel (contains !) this means the part up to and including the !; if it is anything else, this means the full name. rNNr)findrLrrrnon_local_nameszBaseChannelLayer.non_local_namec td)Nz/send() should be implemented in a channel layerNotImplementedError)rrFmessagerrrsendzBaseChannelLayer.sendcrf)Nz2receive() should be implemented in a channel layerrg)rrFrrrrVrkzBaseChannelLayer.receivecrf)Nz6new_channel() should be implemented in a channel layerrgrrrr new_channelszBaseChannelLayer.new_channelcrf)Nz)flush() not implemented (flush extension)rgrrrrflushrkzBaseChannelLayer.flushcrf)Nz.group_add() not implemented (groups extension)rgrgrouprFrrr group_addrkzBaseChannelLayer.group_addcrf)Nz2group_discard() not implemented (groups extension)rgrnrrr group_discardrkzBaseChannelLayer.group_discardcrf)Nz/group_send() not implemented (groups extension)rg)rrorirrr group_sendrkzBaseChannelLayer.group_send)r5r4N)F)r.r/r0r1rKrrErGrMr>r?rQrYrUrTrWrZrcrerjrVrlrmrprqrrrrrrr3_s8        r3cseZdZdZ    dfdd Zdd gZd d Zd d Zd ddZddZ ddZ ddZ ddZ ddZ ddZddZZS)!InMemoryChannelLayerz0 In-memory channel layer implementation r5Qr4Nc s0tjd|||d|i|_i|_||_dS)Nr6r)superrchannelsgroups group_expiry)rr7rxr8r9r __class__rrrs zInMemoryChannelLayer.__init__rwrmcst|ts Jd||sJdd|vsJ|j|tj||d}z|t |j t |fWdStj j yEt|w)zF Send a message onto a (general or specific) channel. zmessage is not a dictChannel name not valid__asgi_channel__maxsizeN)rHdictrWrv setdefaultasyncioQueuerG put_nowaittimer7rqueues QueueFullr)rrFriqueuerrrrjs "zInMemoryChannelLayer.sendc s~||sJ||j|tj||d}z|IdH\}}W|r0|j |d|S|r>|j |dww)z Receive the first message that arrives on the channel. If more than one coroutine waits on the same channel, a random one of the waiting coroutines will get the result. r}N) rW_clean_expiredrvrrrrGremptypop)rrFr_rirrrrVszInMemoryChannelLayer.receive specific.cs"d|dddtdDfS)zx Returns a new channel name that can be used by something in our process as a specific channel. z%s.inmemory!%scss|] }ttjVqdSr )randomchoicestring ascii_letters)r[irrrr]!sz3InMemoryChannelLayer.new_channel.. )joinrange)rprefixrrrrls z InMemoryChannelLayer.new_channelcCst|jD]6\}}|s=|jddtkr=||||r.|j|d|s=|jddtksqt t|j }|j D]}t|D]\}}|rd||krd||dqTqLdS)z Goes through all messages and groups and removes those that are expired. Any channel with an expired message is removed from all groups. rN) r^rvr;r_queuer get_nowait_remove_from_groupsrintrxrwvalues)rrFrtimeoutrvr timestamprrrr&s     z#InMemoryChannelLayer._clean_expiredcsi|_i|_dSr )rvrwrrrrrmBs zInMemoryChannelLayer.flushcsdSr rrrrrcloseFszInMemoryChannelLayer.closecCs |jD]}||dqdS)zW Removes a channel from all groups. Used when a message on it expires. N)rwrr)rrFrvrrrrJsz(InMemoryChannelLayer._remove_from_groupscsJ||s Jd||sJd|j|it|j||<dS)z3 Adds the channel name to a group. zGroup name not validr{N)rZrWrwrrrnrrrrpSs zInMemoryChannelLayer.group_addcsb||s Jd||sJd|j|d}|r-||d|s/|j|ddSdSdS)NzInvalid channel nameInvalid group name)rWrZrwrr)rrorFgroup_channelsrrrrq^s z"InMemoryChannelLayer.group_discardc st|ts Jd||sJd|g}||jvr4|j|D]}|t| ||q%t |D]}z|IdHWq9t yKYq9wdS)NzMessage is not a dictr) rHrrZrrwkeysr=r create_taskrj as_completedr)rroriopsrF send_resultrrrrrks  zInMemoryChannelLayer.group_send)r5rtr4N)r)r.r/r0r1r extensionsrjrVrlrrmrrrprqrr __classcell__rrryrrss$     rscCs zt|WStyYdSw)zL Returns a channel layer by alias, or None if it is not configured. N)channel_layersr!)aliasrrrget_channel_layer~s   r)rr@rr>rrcopyr django.confrdjango.core.signalsrdjango.utils.module_loadingrrvr exceptionsrr r r3rsrrrrrrs$     Mv *