}i#(ddlmZmZGddZy))authutilsceZdZejdej ddZejdddZejdddZejdddZ ejddZ ejddd Z ejdd Z ejdd Z ejdej dd Zejdej ddd Zejdej ddZy)PluginApiMixinz1.25namec|jd|}|}t|tr'|jDcgc] \}}|d|}}}|j ||}|j |ycc}}w)aC Configure a plugin. Args: name (string): The name of the plugin. The ``:latest`` tag is optional, and is the default if omitted. options (dict): A key-value mapping of options Returns: ``True`` if successful z/plugins/{0}/set=)dataT)_url isinstancedictitems _post_json_raise_for_status)selfroptionsurlr kvress X/home/factor_ks/STREAMA2026/tests/venv/lib/python3.12/site-packages/docker/api/plugin.pyconfigure_pluginzPluginApiMixin.configure_pluginssii*D1 dD !+/::<841aqc1#J8D8ooco- s#9sA1c |jd}tj||ttjj |g5}|j |d|i|}ddd|jy#1swYxYw)a* Create a new plugin. Args: name (string): The name of the plugin. The ``:latest`` tag is optional, and is the default if omitted. plugin_data_dir (string): Path to the plugin data directory. Plugin data directory must contain the ``config.json`` manifest file and the ``rootfs`` directory. gzip (bool): Compress the context using gzip. Default: False Returns: ``True`` if successful z/plugins/create)rootgzipfilesr)paramsr NT)r rcreate_archivesetbuildwalk_postr)rrplugin_data_dirrrarchvrs r create_pluginzPluginApiMixin.create_plugins ii)*  ! ! tekk&&;<  E**S&$e*DC  E s#  E Es BB ct|jd|}|j|d|i}|j|y)aP Disable an installed plugin. Args: name (string): The name of the plugin. The ``:latest`` tag is optional, and is the default if omitted. force (bool): To enable the force query parameter. Returns: ``True`` if successful z/plugins/{0}/disableforcerTr r"rrrr'rrs rdisable_pluginzPluginApiMixin.disable_plugin5s=ii.5jjgu%5j6 s#cx|jd|}d|i}|j||}|j|y)aV Enable an installed plugin. Args: name (string): The name of the plugin. The ``:latest`` tag is optional, and is the default if omitted. timeout (int): Operation timeout (in seconds). Default: 0 Returns: ``True`` if successful z/plugins/{0}/enabletimeoutr(Tr))rrr.rrrs r enable_pluginzPluginApiMixin.enable_pluginGsBii-t4W%jjVj, s#r,ch|jd|}|j|j|dS)a Retrieve plugin metadata. Args: name (string): The name of the plugin. The ``:latest`` tag is optional, and is the default if omitted. Returns: A dict containing plugin info z/plugins/{0}/jsonTr _result_get)rrrs rinspect_pluginzPluginApiMixin.inspect_pluginZs.ii+T2||DIIcND11r,Nc|jd}d|i}|r||d<i}tj|\}}tj||} | r| |d<|j ||||d} |j | |j | dS)a Pull and install a plugin. After the plugin is installed, it can be enabled using :py:meth:`~enable_plugin`. Args: remote (string): Remote reference for the plugin to install. The ``:latest`` tag is optional, and is the default if omitted. privileges (:py:class:`list`): A list of privileges the user consents to grant to the plugin. Can be retrieved using :py:meth:`~plugin_privileges`. name (string): Local name for the pulled plugin. The ``:latest`` tag is optional, and is the default if omitted. Returns: An iterable object streaming the decoded API logs z /plugins/pullremoterX-Registry-AuthTrheadersr streamdecoder rresolve_repository_nameget_config_headerrr_stream_helper) rr6 privilegesrrrr9registry repo_nameheaderresponses r pull_pluginzPluginApiMixin.pull_pluginis&ii( f  !F6N"::6B)''h7 )/G% &?? j#  x(""8D"99r,cf|jd}|j|j|dS)z Retrieve a list of installed plugins. Returns: A list of dicts, one per plugin z/pluginsTr1)rrs rpluginszPluginApiMixin.pluginss+ii #||DIIcND11r,cd|i}i}tj|\}}tj||}|r||d<|jd}|j |j |||dS)al Retrieve list of privileges to be granted to a plugin. Args: name (string): Name of the remote plugin to examine. The ``:latest`` tag is optional, and is the default if omitted. Returns: A list of dictionaries representing the plugin's permissions r6r7z/plugins/privileges)rr9T)rr>r?r r2r3)rrrr9rBrCrDrs rplugin_privilegesz PluginApiMixin.plugin_privilegess d "::4@)''h7 )/G% &ii-.|| IIc&'I :D  r,c|jd|}i}tj|\}}tj||}|r||d<|j ||}|j ||j |dS)a Push a plugin to the registry. Args: name (string): Name of the plugin to upload. The ``:latest`` tag is optional, and is the default if omitted. Returns: ``True`` if successful z/plugins/{0}/pullr7)r9Tr;)r rr>r?r"rr@)rrrr9rBrCrDrs r push_pluginzPluginApiMixin.push_pluginsii+T2"::4@)''h7 )/G% &jjgj. s#""3t"44r,ct|jd|}|j|d|i}|j|y)a Remove an installed plugin. Args: name (string): Name of the plugin to remove. The ``:latest`` tag is optional, and is the default if omitted. force (bool): Disable the plugin before removing. This may result in issues if the plugin is in use by a container. Returns: ``True`` if successful z /plugins/{0}r'r(T)r _deleterr*s r remove_pluginzPluginApiMixin.remove_plugins<ii-ll3'7l8 s#r,z1.26c|jd|}d|i}i}tj|\}}tj||} | r| |d<|j ||||d} |j | |j | dS)a Upgrade an installed plugin. Args: name (string): Name of the plugin to upgrade. The ``:latest`` tag is optional and is the default if omitted. remote (string): Remote reference to upgrade to. The ``:latest`` tag is optional and is the default if omitted. privileges (:py:class:`list`): A list of privileges the user consents to grant to the plugin. Can be retrieved using :py:meth:`~plugin_privileges`. Returns: An iterable object streaming the decoded API logs z/plugins/{0}/upgrader6r7Tr8r;r=) rrr6rArrr9rBrCrDrEs rupgrade_pluginzPluginApiMixin.upgrade_plugins&ii.5 f "::6B)''h7 )/G% &?? j#  x(""8D"99r,)F))N)__name__ __module__ __qualname__rminimum_versioncheck_resourcerr%r+r/r4rFrHrJrLrOrQr,rrrsU6"U&!"#(U6"#2U6"#"U6"#$U6" 2# 2U6"#:##:JU6"2#2U6" # 8U6"U&!5"#5,U6"U&!"#$U6"U&! :"# :r,rN)rrrrXr,rrZsA:A:r,