tj2ddlZddlZddlmZmZmZddlmZddlm Z eje Z dZ GddZGd d ZGd d ZGd deZy)N) asynchronous is_dundershare)reload) Translatorcrt|tjr|xr ||i|S||i|SN) isinstanceweakref WeakMethod)fargskwargss D/DATA/.local/lib/python3.12/site-packages/trame_server/controller.py _safe_callr sG a++ , $T$V$  ceZdZddZdZy)TriggerCounterc||_yr _count)selfinits r__init__zTriggerCounter.__init__s  rcD|xjdz c_|jS)Nrrrs rnextzTriggerCounter.nexts q {{rN)r)__name__ __module__ __qualname__rrrrrrs rrcpeZdZdZdfd ZdZdZdZdZdZ fdZ d Z dd Z d Z dd Zdd ZxZS) ControlleraYController acts as a container for function proxies It allows functions to be passed around that are not yet defined, and can be defined or re-defined later. For example: >>> ctrl.trigger_name(fn) trigger__12 >>> f = ctrl.hello_func # function is currently undefined >>> ctrl.hello_func = lambda: print("Hello, world!") >>> f() Hello, world! >>> ctrl.hello_func = lambda: print("Hello again!") >>> f() Hello again! >>> ctrl.on_data_change.add(lambda: print("Update pipeline!")) >>> ctrl.on_data_change.add(lambda: print("Update view!")) >>> ctrl.on_data_change.add(lambda: print("Wow that is pretty cool!")) >>> ctrl.on_data_change() "Update pipeline!" "Wow that is pretty cool!" "Update view!" >>> ctrl.on_data_change.clear(set_only=True) # add, remove, discard, clear c Ft|d|t|d|r|n tt|dt|dit|dt|dit|dt|dt t|dt|diy)N__trame_hot_reload__ _translator _triggers_triggers_fn2name_triggers_name_id _func_dict)super __setattr__rrr)r translatorinternal hot_reload __class__s rrzController.__init__8s 2J? M:V Kxb)IJ  x1Db!I   x1DnFV!W  L%,*KLrcnjdsjjfd}|S)z Use as decorator `@server.trigger(name)` so the decorated function will be able to be called from the client by doing `click="trigger(name)"`. :param name: A name to use for that trigger :type name: str trigger__cptjd|j<j|<|S)Nz trigger(%s))loggerinfor(r)funcnamers rregister_triggerz,Controller.trigger..register_triggerOs4 KK t ,#'DNN4 +/D " "4 (Kr) startswithr' translate_key)rr9r:s`` rtriggerzController.triggerDs4{+##11$7D   rc||jvr|j|Sd|jj}|j|||S)z Given a function this method will register a trigger and returned its name. If manually registered, the given name at the time will be returned. :return: The trigger name for that function :rtype: str r3)r)r*rr=)rfnr9s r trigger_namezController.trigger_nameWsW '' '))"- -4116689: T2 rc8|jj|S)z Given a trigger name get its attached function/method. :return: The trigger function for that name :rtype: function )r(getrr9s r trigger_fnzController.trigger_fnfs~~!!$''rc$|j|Sr ) __getattr__rCs r __getitem__zController.__getitem__os%%rc(|j||yr )r-)rr9values r __setitem__zController.__setitem__rs u%rct|rt| |S|jj |}||j vrt |||j |<|j |Sr )rr,rFr'r<r+ControllerFunction)rr9r1s rrFzController.__getattr__us` T?7&t, ,--d3 t &$6tT$BDOOD !t$$rc||jvs|tjvrd|d}t||jj |}||j vr||j |_yt||||j |<y)N'zA' is a special attribute on Controller that cannot be re-assigned)__dict__r$ NameErrorr'r<r+r8rL)rr9r8msgs rr-zController.__setattr__s 4== DJ,?,?$?D6!! C. --d3 4?? ")-DOOD ! &$6tT4$HDOOD !rcfd}|S)a1 Use as decorator `@ctrl.add(name)` so the decorated function will be added to a given controller name :param name: Controller method name to be added to :type name: str .. code-block:: ctrl = server.controller @ctr.add("on_server_ready") def on_ready(**state): pass # or ctrl.on_server_ready.add(on_ready) You can also make sure when the method get registered we clear any previous content. .. code-block:: ctrl = server.controller @ctr.add("on_server_ready", clear=True) def on_ready(**state): pass # or ctrl.on_server_ready.clear() ctrl.on_server_ready.add(on_ready) cZrjj||Sr )clearaddr8rTr9rs rregister_ctrl_methodz,Controller.add..register_ctrl_methods+T   " JNN4 Krr"rr9rTrWs``` rrUzController.addH $#rcfd}|S)a Use as decorator `@ctrl.once(name)` so the decorated function will be added to a given controller name and will only execute once. :param name: Controller method name to be added to :type name: str .. code-block:: ctrl = server.controller @ctr.once("on_server_ready") def on_ready(**state): pass # or ctrl.on_server_ready.once(on_ready) c0j||Sr )oncer7s rrWz-Controller.once..register_ctrl_methods JOOD !Krr")rr9rWs`` rr\zController.onces* $#rcfd}|S)aV Use as decorator `@ctrl.add_task(name)` so the decorated function will be added to a given controller name :param name: Controller method name to be added to :type name: str .. code-block:: ctrl = server.controller @ctr.add_task("on_server_ready") async def on_ready(**state): pass # or ctrl.on_server_ready.add_task(on_ready) You can also make sure when the method get registered we clear any previous content. .. code-block:: ctrl = server.controller @ctr.add_task("on_server_ready", clear=True) async def on_ready(**state): pass # or ctrl.on_server_ready.clear() ctrl.on_server_ready.add_task(on_ready) cZrjj||Sr )rTadd_taskrVs rrWz1Controller.add_task..register_ctrl_methods-T   " J   %Krr"rXs``` rr_zController.add_taskrYrcfd}|S)a) Use as decorator `@ctrl.set(name)` so the decorated function will be added to a given controller name :param name: Controller method name to be set to :type name: str .. code-block:: ctrl = server.controller @ctr.set("on_server_ready") def on_ready(**state): pass # or ctrl.on_server_ready = on_ready You can also make sure when the method get registered we clear any previous content. .. code-block:: ctrl = server.controller @ctr.set("on_server_ready", clear=True) def on_ready(**state): pass # or ctrl.on_server_ready.clear() ctrl.on_server_ready = on_ready c<rj|<|Sr )rTrVs rrWz,Controller.set..register_ctrl_method(s$T   "DJKrr"rXs``` rsetzController.setrYr)NNFF)rr r!__doc__rr=r@rDrGrJrFr-rUr\r_rb __classcell__)r1s@rr$r$sH6 M & (&&%I +$Z$6+$Z+$rr$cheZdZdZddZdZdZdZdZdZ d Z d Z dd Z d Z dd ZedZy)rLaController functions are callable function proxy objects Any calls are forwarded to the internal function, which may be undefined or dynamically changed. If a call is made when the internal function is undefined, a FunctionNotImplementedError is raised. Nc||_||_||_t|_t|_t|_d|_y)NF) controllerr9r8rbfuncs task_funcs funcs_once can_be_empty)rrhr9r8s rrzControllerFunction.__init__;s<$  U %%!rc j|jPt|jt|jzdk(r"|jryt |j t|jt|jz}|jjd}|j=|jrt|j}n |j}t|g|i|}|jrttt|}|Dcgc]}t|g|i|}}t|jD]3}|jtj t|g|i|5|j|St|r|g|St|jr|S|Scc}w)Nr)r8lenrirjrlFunctionNotImplementedErrorr9listrkrTr0rrmapappendr create_task)rrr copy_listresultrresultstask_fns r__call__zControllerFunction.__call__Gsq 99 TZZ3t3G!G1!L  -dii8 8$tDOO'<<   99 499%II3D3F3F ??S34I%W% % t N FsF0c:|jj|y)z Add function to the set of functions to be called when the current ControllerFunction is called. After first execution, the function will automatically be removed. :param func: Function to add N)rkrUrr8s rr\zControllerFunction.onceos D!rc:|jj|y)z Add function to the set of functions to be called when the current ControllerFunction is called. :param func: Function to add N)rirUrzs rrUzControllerFunction.addys trc:|jj|y)z Add task to the set of coroutine to be called when the current ControllerFunction is called. :param func: Function to add N)rjrUrzs rr_zControllerFunction.add_tasks D!rc|jj||jj||jj|y)z Discard function to the set of functions to be called when the current ControllerFunction is called. :param func: Function to discard N)ridiscardrkrjrzs rr~zControllerFunction.discards: 4  % %rc:|jj|y)z Remove function to the set of functions to be called when the current ControllerFunction is called. :param func: Function to remove N)riremoverzs rrzControllerFunction.removes $rc:|jj|y)z Remove task function to the set of functions to be called when the current ControllerFunction is called. :param func: Function to remove N)rjrrzs r remove_taskzControllerFunction.remove_tasks t$rc|sd|_|jj|jj|jjy)z Clear all the functions registered to the current ControllerFunction. :param set_only: (default: False) If true only the "added" one will be removed. N)r8rirTrkrj)rset_onlys rrTzControllerFunction.clears> DI   rcx|jyt|jt|jzdkDS)z Check if at least a function was registered to the current ControllerFunction. :return: True if either a function was set or added Tr)r8rnrirjrs rexistszControllerFunction.existss2 99 4::T__!5599rc||_|S)z Enable entry to be empty. Useful for events when you don't know if someone will be listening. :return: self so it can be used inline like a builder. )rl)rrIs r enable_emptyzControllerFunction.enable_emptys" rc.|jjSr )rhr&rs rr0zControllerFunction.hot_reloads333rr rc)T)rr r!rdrrxr\rUr_r~rrrTrrpropertyr0r"rrrLrL2sS "&P"" & %  :44rrLc eZdZy)roN)rr r!r"rrrorosrro)loggingr utilsrrrutils.hot_reloadrutils.namespacer getLoggerrr5rrr$rL Exceptionror"rrrs^11$'   8 $S$S$lY4Y4x ) r