gM3ddlZddlZddlZddlZddlZddlZddlmZddlm Z ddl m Z ddl m Z ddlmZddlmZmZGd 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 M/var/www/skyplay_api_hub/venv/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&>cd|j|vrtd|z t|j|d}|di|S#t$rtd|zt$r"td|j|dd|wxYw)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..s& BID # #GW # = s )rXlistall)rnamesrg_non_empty_list _names_types` ` rvalid_channel_namesz$BaseChannelLayer.valid_channel_namessM"'$U - ;P0PP. MR    rc<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. r_Nr)findr\s rnon_local_namezBaseChannelLayer.non_local_names+ $;,$))C.1,- -Krc Ktdw)Nz/send() should be implemented in a channel layerNotImplementedError)rrUmessages rsendzBaseChannelLayer.send!"STT c Ktdw)Nz2receive() should be implemented in a channel layerr{)rrUs rrgzBaseChannelLayer.receive!"VWWrc Ktdw)Nz6new_channel() should be implemented in a channel layerr{rs r new_channelzBaseChannelLayer.new_channels! D  rc Ktdw)Nz)flush() not implemented (flush extension)r{rs rflushzBaseChannelLayer.flushs!"MNNrc Ktdw)Nz.group_add() not implemented (groups extension)r{rgrouprUs r group_addzBaseChannelLayer.group_adds!"RSSrc Ktdw)Nz2group_discard() not implemented (groups extension)r{rs r group_discardzBaseChannelLayer.group_discardrrc Ktdw)Nz/group_send() not implemented (groups extension)r{)rrr}s r group_sendzBaseChannelLayer.group_sendrr)<rAN)F)r:r;r<r=r[rrSrVr]rLrMrbrkrfrerhrlrvryr~rgrrrrrr-rrr@r@_s O7  $$HI!rzz"671  $ $_ 5 6 S T   IG  UX OTXUrr@creZdZdZ 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)NrCr-)superrchannelsgroups group_expiry)rrDrrErFr __class__s rrzInMemoryChannelLayer.__init__sB  -     (rrrcKt|tsJd|j|sJdd|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 dictChannel name not valid__asgi_channel__maxsizeN)rXdictrhr setdefaultasyncioQueuerV put_nowaittimerDrqueues QueueFullr )rrUr}queues rr~zInMemoryChannelLayer.sends '4(A*AA(&&w/I1II/"000 (( W]]4+<+.!sKAFMM&"6"67Ks-/ )joinrange)rprefixs rrz InMemoryChannelLayer.new_channels+  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) rqrrIr_queuer get_nowait_remove_from_groupsrintrrvalues)rrUrtimeoutrr# timestamps rrz#InMemoryChannelLayer._clean_expired&s #4==#6#6#89 5NGUkkm Q(:TYY[(H  "((1;;=MM%%gt4 kkm Q(:TYY[(H 5diik"T%6%66 **, -H#'(8#9 -iW!4LLt,  - -rc(Ki|_i|_ywr)rrrs rrzInMemoryChannelLayer.flushBs  sc Kywrr-rs rclosezInMemoryChannelLayer.closeFs  scf|jjD]}|j|dy)zW Removes a channel from all groups. Used when a message on it expires. N)rrr)rrUrs rrz(InMemoryChannelLayer._remove_from_groupsJs. **, (H LL$ ' (rcK|j|sJd|j|sJd|jj|it j|j||<yw)z3 Adds the channel name to a group. zGroup name not validrN)rlrhrrrrs rrzInMemoryChannelLayer.group_addSsi $$U+C-CC+&&w/I1II/ ub)&*iik E7#sA2A4c K|j|sJd|j|sJd|jj|d}|r2|j |d|s|jj |dyyyw)NzInvalid channel nameInvalid group name)rhrlrr r)rrrUgroup_channelss rrz"InMemoryChannelLayer.group_discard^s&&w/G1GG/$$U+A-AA+5    w -! t," sBBc Kt|tsJd|j|sJd|jg}||jvrV|j|j D]6}|j tj|j||8tj|D] } |d{y7#t$rYwxYww)NzMessage is not a dictr) rXrrlrrkeysrKr create_taskr~ as_completedr )rrr}opsrU send_results rrzInMemoryChannelLayer.group_sendks'4(A*AA($$U+A-AA+  DKK ;;u-224 M 7..tyy'/JKL M"//4 K !!! !  s<B>CCCC CC CCCC)riQrAN)z specific.)r:r;r<r=r extensionsr~rgrrrrrrrr __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_layerr~s$e$$ s  )rrNrrLrrcopyr django.confrdjango.core.signalsrdjango.utils.module_loadingrrr exceptionsr r r r@rrrr-rrrsi  /5*=JJZsUsUlf+fR2%&r