Mf.ddlZddlZddlZddlZddlZddlZddlmZddlm Z ddl m Z ddl m Z ddlmZddlmZmZGd d ZGd d ZGd deZefdZeZdS)N)deepcopy)settings)setting_changed) import_string)DEFAULT_CHANNEL_LAYER) ChannelFullInvalidChannelLayerErrorcXeZdZdZdZdZedZdZdZ dZ dZ d Z d Z d S) ChannelLayerManagerzR Takes a settings dictionary of backends and initialises them on request. cFi|_tj|jdSN)backendsrconnect_reset_backendsselfs N/var/www/surfInsights/venv3-11/lib/python3.11/site-packages/channels/layers.py__init__zChannelLayerManager.__init__s#  455555c $|dkr i|_dSdS)zX Removes cached channel layers when the CHANNEL_LAYERS setting changes. CHANNEL_LAYERSN)r)rsettingkwargss rrz#ChannelLayerManager._reset_backendss# & & &DMMM ' &rc.ttdiS)Nr)getattrrrs rconfigszChannelLayerManager.configs"sx!12666rcp|j|di}|||S)z, Instantiate channel layer. CONFIG)rget _make_backendrnameconfigs r make_backendz ChannelLayerManager.make_backend's6d#''"55!!$///rc |j|d}n #t$rtd|zwxYw|||S)zB Instantiate channel layer using its test config. TEST_CONFIGzNo TEST_CONFIG specified for %s)rKeyErrorr r!r"s rmake_test_backendz%ChannelLayerManager.make_test_backend.sd U\$' 6FF U U U*+Lt+STT T U!!$///s3c6d|j|vrtd|z t|j|d}nO#t$rtd|zt$r'td|j|dd|wxYw|di|S)NROUTINGzBROUTING key found for %s - this is no longer needed in Channels 2.BACKENDzNo BACKEND specified for %szCannot import BACKEND z specified for )rr rr( ImportError)rr#r$ backend_classs rr!z!ChannelLayerManager._make_backend8s  T* * **T   )$,t*z7BaseChannelLayer.valid_channel_names..sG  BID # #GW # = =      r)rYlistall)rnamesrh_non_empty_list _names_types` ` rvalid_channel_namesz$BaseChannelLayer.valid_channel_namess"'2$$U -- P;PP0PPPP     MR        trcNd|vr |d|ddzS|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. r`Nr)findr]s rnon_local_namezBaseChannelLayer.non_local_names2 $;;,$))C..1,,- -Kr)rBrAN)F)r:r;r<r=r\rrTrWr^rMrNrcrlrgrfrirmrwrzr-rrr@r@_s  O7777      $$HII!rz"6771  $ $_ 5 5 6 S T   I I I IGGG      rr@creZdZdZ dfd ZddgZd Zd Zdd Zd Z dZ dZ dZ dZ dZdZxZS)InMemoryChannelLayerz0 In-memory channel layer implementation rBQrANc ltjd|||d|i|_i|_||_dS)NrDr-)superrchannelsgroups group_expiry)rrErrFrGr __class__s rrzInMemoryChannelLayer.__init__s[  -        (rrflushcKt|ts Jd||s Jdd|vsJ|j|t j}||jkrt|| tj |j zt|fd{VdS)zF Send a message onto a (general or specific) channel. zmessage is not a dictChannel name not valid__asgi_channel__N)rYdictrir setdefaultasyncioQueueqsizerFr puttimerEr)rrVmessagequeues rsendzInMemoryChannelLayer.sends '4((AA*AAAA&&w//II1IIII"0000 (('-//BB ;;==DM ) )g&& &iit{2HW4E4EFGGGGGGGGGGGrcpK||sJ||j|t j} |d{V\}}|r|j|=n!#|r|j|=wxYw|S)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. N)ri_clean_expiredrrrrr empty)rrVr_rs rrhzInMemoryChannelLayer.receives &&w/////  (('-//BB +$yy{{******JAw{{}} +M'*{{}} +M'*****s BB3 specific.chK|dddtdDS)zx Returns a new channel name that can be used by something in our process as a specific channel. z .inmemory!c3RK|]"}tjtjV#dSr)randomchoicestring ascii_letters)rpis rrqz3InMemoryChannelLayer.new_channel..s/KKAFM&"677KKKKKKr )joinrange)rprefixs r new_channelz InMemoryChannelLayer.new_channels@ FF GGKKrKKK K K K  rc4t|jD]\}}|s|jddt jkr||||r|j|=|s(|jddt jktt j|j z }|j D]~}t|j |tD]G}|j ||r2t|j |||kr|j ||=HdS)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) rrrrJr_queuer get_nowait_remove_from_groupsintrrr r9)rrVrtimeoutgroups rrz#InMemoryChannelLayer._clean_expired su #4=#6#6#8#899 / /NGUkkmm / Q(:TY[[(H(H  """((111;;==/ g. kkmm / Q(:TY[[(H(Hdikk""T%66[ 4 4E suu = =>> 4 4K&w/4DK.w7887BB E*73 4 4 4rc&Ki|_i|_dSr)rrrs rrzInMemoryChannelLayer.flush*s  rc KdSrr-rs rclosezInMemoryChannelLayer.close.s  rcL|jD] }||vr||= dS)zW Removes a channel from all groups. Used when a message on it expires. N)rvalues)rrVrs rrz(InMemoryChannelLayer._remove_from_groups2s? **,, & &H(""W% & &rcK||s Jd||s Jd|j|it j|j||<dS)z3 Adds the channel name to a group. zGroup name not validrN)rmrirrrrrrVs r group_addzInMemoryChannelLayer.group_add<s $$U++CC-CCCC&&w//II1IIII ub)))&*ikk E7###rcK||s Jd||s Jd||jvr4||j|vr|j||=|j|s |j|=dSdSdS)NzInvalid channel nameInvalid group name)rirmrrs r group_discardz"InMemoryChannelLayer.group_discardGs&&w//GG1GGGG$$U++AA-AAAA DK  $+e,,,K&w/;u% 'K&&&  ' 'rc\Kt|ts Jd||s Jd||j|t D]/} |||d{V #t$rY,wxYwdS)NzMessage is not a dictr) rYrrmrrr r9rr )rrrrVs r group_sendzInMemoryChannelLayer.group_sendRs'4((AA*AAAA$$U++AA-AAAA {ucee44  G ii1111111111      s?B B)(B))rBr}rAN)r)r:r;r<r=r extensionsrrhrrrrrrrr __classcell__)rs@rr|r|s  ))))))(G$JHHH&(    444<   &&& 2 2 2 ' ' '       rr|c@ t|S#t$rYdSwxYw)zL Returns a channel layer by alias, or None if it is not configured. N)channel_layersr()aliass rget_channel_layerr`s4e$$ tts  )rrOrrMrrcopyr django.confrdjango.core.signalsrdjango.utils.module_loadingrrr exceptionsr r r r@r|rrr-rrrsp  //////555555******========JJJJJJJJZ\\\\\\\\~_____+___D2%$&&r