h=6ddlZddlZddlZddlZddlZddlZddlZddlmZddl m Z ddl m Z ddl mZddlmZddlmZmZGd d ZGd d ZGd deZefdZeZy)N)deepcopy)settings)setting_changed) import_string)DEFAULT_CHANNEL_LAYER) ChannelFullInvalidChannelLayerErrorcPeZdZdZdZdZedZdZdZ dZ dZ d Z d Z y ) ChannelLayerManagerzR Takes a settings dictionary of backends and initialises them on request. cPi|_tj|jyN)backendsrconnect_reset_backendsselfs K/var/www/Befach/backend/env/lib/python3.12/site-packages/channels/layers.py__init__zChannelLayerManager.__init__s  4 45c |dk(ri|_yy)zX Removes cached channel layers when the CHANNEL_LAYERS setting changes. CHANNEL_LAYERSN)r)rsettingkwargss rrz#ChannelLayerManager._reset_backendss & &DM 'rc$ttdiS)Nr)getattrrrs rconfigszChannelLayerManager.configs#sx!1266rcd|j|jdi}|j||S)z, Instantiate channel layer. CONFIG)rget _make_backendrnameconfigs r make_backendz ChannelLayerManager.make_backend(s2d#''"5!!$//rc |j|d}|j||S#t$rtd|zwxYw)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/sT U\\$' 6F!!$// U*+Lt+ST T Us&>c d|j|vrtd|z |j|d} t|}|di|S#t$r"td|j|dd|wxYw#t$rtd|zwxYw)NROUTINGzBROUTING key found for %s - this is no longer needed in Channels 2.BACKENDzCannot import BACKEND z specified for zNo BACKEND specified for %s)rr r ImportErrorr()rr#r$backend_module backend_classs rr!z!ChannelLayerManager._make_backend9s  T* **T  !\\$/ :N  -n = &v&& .||D))4d<   Q*+H4+OP P QsA5 A+A25B cx||jvr|j||j|<|j|Sr)rr%rkeys r __getitem__zChannelLayerManager.__getitem__Qs6 dmm #!%!2!23!7DMM# }}S!!rc||jvSr)rr2s r __contains__z ChannelLayerManager.__contains__Vsdll""rc\|jj|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)rr )rr3layerolds rsetzChannelLayerManager.setYs- mmT*" c rN)__name__ __module__ __qualname____doc__rrpropertyrr%r)r!r4r6r:r-rrr r sC67700'0" #rr ceZdZdZdZddZdZdZdZe jdZ e jd Z d d jezd zZdd ZdZddZdZdZdZdZdZdZdZdZddZdZy)BaseChannelLayerzf Base channel layer class that others can inherit from, with useful common functionality. dNc6||_||_|xsi|_yrexpirycapacitychannel_capacity)rrErFrGs rrzBaseChannelLayer.__init__ls   0 6Brcg}|jD]^\}}t|dr|j||f&|jtjt j ||f`|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)rrGresultpatternvalues rcompile_capacitiesz#BaseChannelLayer.compile_capacitiesqsi .446NGUw( w./ rzz'*;*;G*DEuMN 7 rcl|jD]\}}|j|s|cS|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. )rGrIrF)rchannelrRrFs r get_capacityzBaseChannelLayer.get_capacitys6"&!6!6 GX}}W%"7}}rcVt|trt||jkryy)NTF) isinstancestrlenMAX_NAME_LENGTHrr#s rmatch_type_and_lengthz&BaseChannelLayer.match_type_and_lengths# dC c$i$2F2F&Frz!^[a-zA-Z\d\-_.]+(\![\d\w\-_.]*)?$z^[a-zA-Z\d\-_.]+$z'{} name must be a valid unicode string zwith length < {} zFcontaining only ASCII alphanumerics, hyphens, underscores, or periods.cB|j|s$t|jjdt |j j |s$t|jjdd|vr|jds |r tdy)NChannel!z5Specific channel names in receive() must end at the !T)r^ TypeErrorinvalid_name_errorformatboolchannel_name_regexrIendswith)rr#receives rrequire_valid_channel_namez+BaseChannelLayer.require_valid_channel_names))$/D33::9EF FD++11$78D33::9EF F $;t}}S1gST Trc|j|s$t|jjdt |j j |s$t|jjdy)NGroupT)r^rbrcrdregroup_name_regexrIr]s rrequire_valid_group_namez)BaseChannelLayer.require_valid_group_namesd))$/D33::7CD DD))//56D33::7CD Drcz|rdnd}t|t}|r|sJd|D]}|j||y)NTFznames must be a non-empty list)rh)rYlistri)rnamesrh_non_empty_list _names_typerVs rvalid_channel_namesz$BaseChannelLayer.valid_channel_namessH"'$U - ;P0PP.G  + +GW + Erc<d|vr|d|jddzS|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. raNr)findr]s rnon_local_namezBaseChannelLayer.non_local_names+ $;,$))C.1,- -Krc Ktdw)Nz/send() should be implemented in a channel layerNotImplementedError)rrVmessages rsendzBaseChannelLayer.send!"STT c Ktdw)Nz2receive() should be implemented in a channel layerrx)rrVs rrhzBaseChannelLayer.receive!"VWWr}c Ktdw)Nz6new_channel() should be implemented in a channel layerrxrs r new_channelzBaseChannelLayer.new_channels! D  r}c Ktdw)Nz)flush() not implemented (flush extension)rxrs rflushzBaseChannelLayer.flushs!"MNNr}c Ktdw)Nz.group_add() not implemented (groups extension)rxrgrouprVs r group_addzBaseChannelLayer.group_adds!"RSSr}c Ktdw)Nz2group_discard() not implemented (groups extension)rxrs r group_discardzBaseChannelLayer.group_discardrr}c Ktdw)Nz/group_send() not implemented (groups extension)rx)rrrzs r group_sendzBaseChannelLayer.group_sendr|r}c\tjdtd|j|S)zE Deprecated: Use require_valid_channel_name instead. zIvalid_channel_name is deprecated, use require_valid_channel_name instead. stacklevel)warningswarnDeprecationWarningri)r channel_namerhs rvalid_channel_namez#BaseChannelLayer.valid_channel_names,  W  ..|<r\rrTrWr^rMrNrfrlrdrcrirmrsrvr{rhrrrrrrrr-rrrArAds O7  $$HI!rzz"671  $ $_ 5 6 R S  UX OTXU = 9rrAcreZdZdZ dfd ZddgZdZdZddZdZ d Z d Z d Z d Z d ZdZxZS)InMemoryChannelLayerz0 In-memory channel layer implementation c Vt|d|||d|i|_i|_||_y)NrDr-)superrchannelsgroups group_expiry)rrErrFrGr __class__s rrzInMemoryChannelLayer.__init__sB  -     (rrrcKt|tsJd|j|d|vsJ|jj |t j |j|} |jtj|jzt|fy#t jj$r t|wxYww)zF Send a message onto a (general or specific) channel. zmessage is not a dict__asgi_channel__maxsizeN)rYdictrir setdefaultasyncioQueuerW put_nowaittimerErqueues QueueFullr )rrVrzqueues rr{zInMemoryChannelLayer.sends '4(A*AA( ''0"000 (( W]]4+<+z3InMemoryChannelLayer.new_channel..9sKAFMM&"6"67Ks-/ )joinrange)rprefixs rrz InMemoryChannelLayer.new_channel2s+  GGKrK K  s')ct|jjD]\}}|jr|jddt j ks?|j |j||jr|jj|d|jr|jddt j krtt j |jz }|jjD]>}t|jD] \}}|s ||ks|j|d"@y)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) rorrJr_queuer get_nowait_remove_from_groupsrintrrvalues)rrVrtimeoutrr# timestamps rrz#InMemoryChannelLayer._clean_expired>s  #4==#6#6#89NGUkkm Q(:TYY[(H  "((1;;=MM%%gt4 kkm Q(:TYY[(H:diik"T%6%66 **,H#'(8#9iW!4LLt, $:-rc(Ki|_i|_ywr)rrrs rrzInMemoryChannelLayer.flushZs  sc Kywrr-rs rclosezInMemoryChannelLayer.close^s  scf|jjD]}|j|dy)zW Removes a channel from all groups. Used when a message on it expires. N)rrr)rrVrs rrz(InMemoryChannelLayer._remove_from_groupsbs) **,H LL$ '-rcK|j||j||jj|it j|j||<yw)z3 Adds the channel name to a group. N)rmrirrrrs rrzInMemoryChannelLayer.group_addksQ %%e, ''0 ub)&*iik E7#sA$A&cK|j||j||jj|d}|r2|j |d|s|jj |dyyywr)rirmrr r)rrrVgroup_channelss rrz"InMemoryChannelLayer.group_discardvsh ''0 %%e,5    w -! t," sA4A6c Kt|tsJd|j||jg}||jvrV|j|j D]6}|j tj|j||8tj|D] } |d{y7#t$rYwxYww)NzMessage is not a dict) rYrrmrrkeysrLr create_taskr{ as_completedr )rrrzopsrV send_results rrzInMemoryChannelLayer.group_sends'4(A*AA( %%e,  DKK ;;u-224 7..tyy'/JKL5"//4K !!!5!  s<B7C:C ?CC CC  CCCC)riQrBN)z specific.)r;r<r=r>r extensionsr{rhrrrrrrrr __classcell__)rs@rrrsY  )(G$J'(, -8 ( 2 -rrc4 t|S#t$rYywxYw)zL Returns a channel layer by alias, or None if it is not configured. N)channel_layersr()aliass rget_channel_layerrs$e$$ s  )rrOrrMrrrcopyr django.confrdjango.core.signalsrdjango.utils.module_loadingrrr exceptionsr r r rArrrr-rrrsj  /5*=NNbF9F9Rf+fR2%&r