+j2ddlZddlZddlmZmZmZddlmZddlm Z ej e Z dZ GddZGd d ZGd d ZGd deZdS)N) asynchronous is_dundershare)reload) Translatorczt|tjr|o||i|n||i|SN) isinstanceweakref WeakMethod)fargskwargss Q/DATA/AppData/hermes/venv/lib/python3.11/site-packages/trame_server/controller.py _safe_callr sS a+ , , $T$V$$ Q   ceZdZddZdZdS)TriggerCounterrc||_dSr _count)selfinits r__init__zTriggerCounter.__init__s  rc0|xjdz c_|jS)Nrrrs rnextzTriggerCounter.nexts q {rN)r)__name__ __module__ __qualname__rrrrrrs7rrcpeZdZdZdfd ZdZdZdZdZd Z fd Z d Z dd Z d Z ddZddZxZS) 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 NFc Ptd|td|r|n ttdt|ditdt|ditdt|dt tdt|didS)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+U::VVV Kxb)I)IJJJ  x1Db!I!I     x1DnFVFV!W!W    L%,*K*KLLLLLrctdsjfd}|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__cftd|j<j|<|S)Nz trigger(%s))loggerinfor(r)funcnamers rregister_triggerz,Controller.trigger..register_triggerOs5 KK t , , ,#'DN4 +/D "4 (Kr) startswithr' translate_key)rr9r:s`` rtriggerzController.triggerDsV{++ 8#11$77D        rc||jvr |j|Sd|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_nameWs] ' ' ')"- -:416688:: T2 rc6|j|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,||Sr ) __getattr__rCs r __getitem__zController.__getitem__os%%%rc2|||dSr )r-)rr9values r __setitem__zController.__setitem__rs u%%%%%rct|r!t|S|j|}||jvrt |||j|<|j|Sr )rr,rFr'r<r+ControllerFunction)rr9r1s rrFzController.__getattr__uso T?? -77&&t,, ,--d33 t & &$6tT$B$BDOD !t$$rc||jvs|tjvrd|d}t||j|}||jvr||j|_dSt||||j|<dS)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,?$?$?!D!!! C.. --d33 4? " ")-DOD ! & & &$6tT4$H$HDOD ! ! !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) cvr||Sr )clearaddr8rTr9rs rregister_ctrl_methodz,Controller.add..register_ctrl_methods< #T   """ JNN4 Krr"rr9rTrWs``` rrUzController.add1H       $#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) c>||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) cvr||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 cJr|<|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$s6 M M M M M M   &   (((&&&&&&%%%%%III +$+$+$+$Z$$$6+$+$+$+$Z+$+$+$+$+$+$+$+$rr$cpeZdZdZddZdZdZdZdZdZ d Z d Z dd Z d Z ddZedZdS)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|_dS)NF) controllerr9r8rbfuncs task_funcs funcs_once can_be_empty)rrhr9r8s rrzControllerFunction.__init__;sH$  UU %%%%!rc |jJt|jt|jzdkr|jrdSt |jt|jt|jz}|j d}|j3|j rt|j}n|j}t|gRi}|j r"ttt|}fd|D}t|jD]7}|tjt|gRi8|j|St|r|g|St|jr|S|S)Nrc0g|]}t|gRiSr")r).0rrrs r z/ControllerFunction.__call__..^s1EEEa:a1$111&11EEEr)r8lenrirjrlFunctionNotImplementedErrorr9listrkrTr0rrmapappendr create_task)rrr copy_listresultrresultstask_fns `` r__call__zControllerFunction.__call__Gs 9 TZ3t3G3G!G1!L!L  t-di88 8$$tDO'<'<<   9  49%%I3D333F33F ? 5S3344IFEEEE9EEEDO,,  G NN(G)Md)M)M)Mf)M)MNN     9 N y>> &%W% % t   N rc:|j|dS)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:|j|dS)z Add function to the set of functions to be called when the current ControllerFunction is called. :param func: Function to add N)rirUr}s rrUzControllerFunction.addys trc:|j|dS)z Add task to the set of coroutine to be called when the current ControllerFunction is called. :param func: Function to add N)rjrUr}s rr_zControllerFunction.add_tasks  D!!!!!rc|j||j||j|dS)z Discard function to the set of functions to be called when the current ControllerFunction is called. :param func: Function to discard N)ridiscardrkrjr}s rrzControllerFunction.discardsL 4    %%% %%%%%rc:|j|dS)z Remove function to the set of functions to be called when the current ControllerFunction is called. :param func: Function to remove N)riremover}s rrzControllerFunction.removes  $rc:|j|dS)z Remove task function to the set of functions to be called when the current ControllerFunction is called. :param func: Function to remove N)rjrr}s r remove_taskzControllerFunction.remove_tasks  t$$$$$rFc|sd|_|j|j|jdS)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.clearsU  DI   rcn|jdSt|jt|jzdkS)z Check if at least a function was registered to the current ControllerFunction. :return: True if either a function was set or added NTr)r8rqrirjrs rexistszControllerFunction.existss3 9 44:T_!5!5599rTc||_|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_reloads 33rr rc)T)rr r!rdrr{r\rUr_rrrrTrrpropertyr0r"rrrLrL2s " " " "&&&P"""""" & & &   %%%     :::44X444rrLceZdZdS)rrN)rr r!r"rrrrrrsDrrr)loggingr utilsrrrutils.hot_reloadrutils.namespacer getLoggerrr5rrr$rL Exceptionrrr"rrrs81111111111$$$$$$''''''  8 $ $S$S$S$S$S$S$S$S$lY4Y4Y4Y4Y4Y4Y4Y4x     )     r