VhZddlmZmZmZeZdZddlZddlZddl Z ddl Z ddl m Z ddl mZmZmZddlmZmZddlmZeZGdd eZy) )absolute_importdivisionprint_functionae short_description: Interact with an existing buildah container description: - Run commands or put/fetch files to an existing container using buildah tool. author: Tomas Tomecek (@TomasTomecek) name: buildah options: remote_addr: description: - The ID of the container you want to access. default: inventory_hostname vars: - name: ansible_host - name: inventory_hostname # keyword: # - name: hosts remote_user: description: - User specified via name or ID which is used to execute commands inside the container. ini: - section: defaults key: remote_user env: - name: ANSIBLE_REMOTE_USER vars: - name: ansible_user # keyword: # - name: remote_user N) AnsibleError)to_bytes to_nativeto_text)ConnectionBaseensure_connect)DisplaycveZdZdZdZdZfdZdZd dZfdZ e d fd Z fd Z fd Z fd ZxZS) Connectionzi This is a connection plugin for buildah: it uses buildah binary to interact with the containers zcontainers.podman.buildahTctt| ||g|i||jj|_d|_d|_|jj|_ tjdy)NFz(Using buildah connection from collection) superr__init__ _play_context remote_addr _container_id _connected _mount_point remote_useruserdisplayvvvv)self play_context new_stdinargskwargs __class__s p/home/dcms/DCMS/lib/python3.12/site-packages/ansible_collections/containers/podman/plugins/connection/buildah.pyrzConnection.__init__Csc j$(yR4R6R!//;; &&22  ?@cZ|jddt|jdzgy)Nsconfigs--user=surrogate_or_stricterrors)_buildahrr)rs r! _set_userzConnection._set_userOs$ i*x J_/`"`!abr"cFd}|g}t|tr|j|n|j||jrT|jdk7rE|dk(r|jd|jfn"|dk(r|jd|jf|j|j |r3t|tr|j|n|j||Dcgc]}t |d}}tjd ||j |r t|d }ntj}tj|d tj|tj } | j|\} } tjdt| ztjdt| ztjd| j zt | d} t | d} | j | | fScc}w)aT run buildah executable :param cmd: buildah's command to execute (str) :param cmd_args: list of arguments to pass to the command (list of str/bytes) :param in_data: data passed to buildah's stdin :param outfile_stdout: file for writing STDOUT to :return: return code, stdout, stderr buildahrootrunz--usercopyz--chownr$r%zRUN hostwbF)shellstdinstdoutstderr)inputz STDOUT %sz STDERR %sz RC CODE %s) isinstancestrappendextendrrrrvvvopen subprocessPIPEPopen communicaterr returncode) rcmdcmd_argsin_dataoutfile_stdout buildah_exec local_cmdi stdout_fdpr3r4s r!r'zConnection._buildahRs! !N c3    S !   S ! 99f,e|  (DII!67  )TYY!78++, (C(  *  *()a(=>) )  +$2D2D E ^T2I"I   Ye:??$-joo GW5 [76?23 [76?23 \ALL01&)>?&)>?||VV++#)s-Hctt| |jd\}|_}|dk7r;t j d|jd|jd |_y |jjttjjdz|_t jd|jd|d |d |_y ) z no persistent connection is being maintained, mount container's filesystem so we can easily access it mountrzFailed to mount container z: r$r%z MOUNTPOINT z RC  STDERR TN)rr_connectr'rrvrstriprospathseprr)rrcr4r s r!rMzConnection._connects j$(*(, g(>%D v 7 IID?66!!r"c tt| ||tj d|d||j |j r |jr?|jd||g\}}}|dk7r!td|d|d|j d |y |j t|d z}tjt|d t|d y ) zH Place a local file located in 'in_path' inside container at 'out_path' zPUT  TO r.r-rzFailed to copy file from  to z in container  r$r%N) rrput_filerr:rrrr'rrshutilcopyfile)rin_pathout_pathrSr3r4 real_out_pathr s r!r^zConnection.put_files j$((; gx8t?Q?Q R  DII!%(+"- BQw"4+=+=vG !--J_0``M OO)>?/DE r"c tt| ||tj d|d||j |j sL|jddt|dg|\}}}|d k7r!td |d |d |j d |y|j t|dz}tjt|dt|dy)zS obtain file specified via 'in_path' from the container and place it at 'out_path' zFETCH r[r.r,catr$r%)rDrzFailed to fetch file from r\z from container r]N) rr fetch_filerr:rrr'rrr_r`)rrarbrSr3r4 real_in_pathr s r!rfzConnection.fetch_files j$*7H= h(.2.@.@  B  !%1FGH'"/") BQw"Xt'9'96$CDD ,,)>?@L OO.CD*?@ r"ctt| |jd\}}}tj d|d|d|d|_y)z unmount container's filesystem umountzRC z STDOUT rLFN)rrcloser'rrr)rrSr3r4r s r!rjzConnection.closes? j$%'!]]84FF BGHr")NNN)NF)__name__ __module__ __qualname____doc__ transporthas_pipeliningrr(r'rMr rVr^rfrj __classcell__)r s@r!rr:sS ,IN Ac/,b  " "&*  r"r) __future__rrrtype __metaclass__ DOCUMENTATIONrPrWr_r<ansible.errorsransible.module_utils._textrrr ansible.plugins.connectionr r ansible.utils.displayr rrr"r!r{sLCB  < 'CCE) )Q Q r"