Vh$ddlmZmZmZeZddlZddlmZdZ ddl m Z ddl m Z dZddlmZmZdd lmZdd lmZd Zd Zd ZGddeZy#e$rdZej Z YCwxYw))absolute_importdivisionprint_functionN)sleep) ProxmoxAPI) __version__TF) env_fallbackmissing_required_lib) to_native) LooseVersionc ttddtdgftdtdgftddtdgftddtd gf tdd tdd td d S)NstrT PROXMOX_HOST)typerequiredfallbackint PROXMOX_PORT)rr PROXMOX_USERPROXMOX_PASSWORD)rno_logrF)rrbool)rdefault)api_hostapi_portapi_user api_password api_token_idapi_token_secretvalidate_certs)dictr r/home/dcms/DCMS/lib/python3.12/site-packages/ansible_collections/community/proxmox/plugins/module_utils/proxmox.pyproxmox_auth_argument_specr%s 5# ,~.>?5 ,~.>?5# ,~.>?u!%$03E2F#Gu!&5%) $)- r#c|dk(rdSdS)zBConvert Proxmox representation of a boolean to be ansible-friendlyTFr"values r$proxmox_to_ansible_boolr*9sA:4(5(r#cf|yt|tst|dt||rdSdS)zBConvert Ansible representation of a boolean to be proxmox-friendlyNz must be of type bool not r'r) isinstancer ValueErrorrr(s r$ansible_to_proxmox_boolr.>s5 } eT "UDKPQQ11r#cheZdZdZdZdZdZdZdZdZ ddZ dd Z d Z d Z d Zd ZdZddZy)ProxmoxAnsiblezBase class for Proxmox modulesztimeout expiredcts |jtdttt dkr"|j jdt||_t|_|j|_ |jjjy#t$r2}|jd|ztjYd}~yd}~wwxYw)N proxmoxermsg exceptionz2.0z/Requires proxmoxer 2.0 or newer; found version %s) HAS_PROXMOXER fail_jsonr PROXMOXER_IMP_ERRproxmoxer_versionr module_connect proxmox_apiversionget Exception traceback format_exc)selfr;es r$__init__zProxmoxAnsible.__init__Ms   !5k!BN_  ` |E2 2 KK ! !$STeSf"g h !2==? M    $ $ ( ( * M   Y5I5I5K  L L Ms$B(( C#1(CC#cH|jjd}|jjd}|jjd}|jjd}|jjd}|jjd}|jjd}d|i}|r||d <|r||d <n ||d <||d < t|fd |i|S#t$r<} |jj d| zt j Yd} ~ yd} ~ wwxYw)Nrrrrrrr userportpassword token_name token_value verify_sslr6r3)r;paramsrr@r8rArB) rCrrrrrrr auth_argsrDs r$r<zProxmoxAnsible._connect\s;;%%j1;;%%j1;;%%j1{{)).9 {{)).9 ;;--.@A++,<=X&  (If  $0Ij !&2Il #'7Im $ RhO>OYO O R KK ! !dQh):N:N:P ! Q Q Rs C D!%2DD!c |jjj}t|dS#t$r)}|j j d|zYd}~yd}~wwxYw)Nr>z)Unable to retrieve Proxmox VE version: %sr4)r=r>r?r r@r;r8)rC apiversionrDs r$r>zProxmoxAnsible.versionusc W))11557J 9 56 6 W KK ! !&QTU&U ! V V Ws14 A&A!!A&c |jjjDcgc] }|d|k(s |}}r|dSdScc}w#t$r)}|jj d|zYd}~;d}~wwxYw)Nnodez&Unable to retrieve Proxmox VE node: %srPr)r=nodesr?r@r;r8)rCrSnrTrDs r$get_nodezProxmoxAnsible.get_node|s T $ 0 0 6 6 : : <R1& T@QQRER!uQx*d*S T KK ! !&NQR&R ! S S Ts,&A AAA A A<A77A<c |jjjjS#t$r)}|j j d|zYd}~yd}~wwxYw)Nz%Unable to retrieve next free vmid: %srP)r=clusternextidr?r@r;r8)rCrDs r$ get_nextvmidzProxmoxAnsible.get_nextvmidsZ S##++22668 8 S KK ! !&MPQ&Q ! R R Ss-0 A"AA"c |jjjjdDcgc]}|jd|k(s|d}}s'|ry|j j d|z|d St|d kDr!|s|j j d |z|d Scc}w#t$r,}|j j d|d|Yd}~d}~wwxYw) Nvmrnamevmidz0Unable to retrieve list of VMs filtered by name : rPzNo VM with name %s foundr'z5Multiple VMs with name %s found, provide vmid insteadr)r=rX resourcesr?r@r;r8len)rCr^ignore_missingchoose_first_if_multipler\vmsrDs r$get_vmidzProxmoxAnsible.get_vmids l(,(8(8(@(@(J(J(N(NTX(N(Yt"]_]c]cdj]kos]s2f:tCt KK ! !&@4&G ! H1v X\": KK ! !&]`d&d ! e1v u l KK ! !bfhi&j ! k k ls.2B9B4B4B94B99 C."C))C.cp |jjjjdDcgc]}|dt |k(s|}}r|dS|ry|j jd|zycc}w#t $r,}|j jd|d|Yd}~_d}~wwxYw) Nr\r]r_z0Unable to retrieve list of VMs filtered by vmid r`rPrz)VM with vmid %s does not exist in cluster)r=rXrar?rr@r;r8)rCr_rcr\rerDs r$get_vmzProxmoxAnsible.get_vms l $ 0 0 8 8 B B F FD F Qm"UWX^U_cfgkclUl2mCm q6M KK ! !&QTX&X ! Yn l KK ! !bfhi&j ! k k ls.2BA; A;B;B B5 "B00B5cx |jj|j|jj }t |j dxsd}|ddk(xr|dk(xs|j dS#t$r,}|jjd|d| Yd}~yd}~wwxYw) N exitstatusstatusstoppedOKWARN)Unable to retrieve API task ID from node r`rP) r=rTtasksrlr?r startswithr@r;r8)rCrStaskidrlrjrDs r$ api_task_okzProxmoxAnsible.api_task_oks e%%++D177?FFJJLF"6::l#;#ArBJ(#y0jjD6H6iJLaLabhLi j e KK ! ![_ab&c ! d d esBB B9 "B44B9c |jj|j|jj }|ddk(xr|ddk7S#t $r,}|j jd|d|Yd}~yd}~wwxYw) zK Explicitly check if the task stops but exits with a failed status rlrmrjrnrpr`rPN)r=rTrqrlr?r@r;r8)rCrSrsrlrDs r$api_task_failedzProxmoxAnsible.api_task_faileds e%%++D177?FFJJLF(#y0QVL5IT5Q Q e KK ! ![_ab&c ! d d esAA B "BB ci}|r |jj|j|jj }|ddk(r|ddk(ry d |dfS|d z}|d krd tjfStd |ryy#t $r,}|j jd|d|Yd}~td}~wwxYw) aXWait until the task stops or times out. :param node_name: Proxmox node name where the task is running. :param task_id: ID of the running task. :param timeout: Timeout in seconds to wait for the task to complete. :return: Task completion status (True/False) and ``exitstatus`` message when status=False. rpr`rPNrlrmrjrn)TNFr'r) r=rTrqrlr?r@r;r8r0TASK_TIMED_OUTr)rC node_nametask_idtimeoutrlrDs r$api_task_completez ProxmoxAnsible.api_task_completes n))// :@@IPPTTVh9,,'4/% &"6661 a< ."?"???a n %%_hjk*l%mm nsAB C"B<<Cc |jj|jS#t$r,}|jj d|d|Yd}~yd}~wwxYw)zzRetrieve pool information :param poolid: str - name of the pool :return: dict - pool information zUnable to retrieve pool z information: rPN)r=poolsr?r@r;r8)rCpoolidrDs r$get_poolzProxmoxAnsible.get_poolsY  b##))&1557 7 b KK ! !V\^_&` ! a a bs(+ A "AA c |jjj|S#t$r,}|jj d|d|Yd}~yd}~wwxYw)zRetrieve storages information :param type: str, optional - type of storages :return: list of dicts - array of storages r]z2Unable to retrieve storages information with type r`rPN)r=storager?r@r;r8)rCrrDs r$ get_storageszProxmoxAnsible.get_storagessY  n##++//T/: : n KK ! !dhjk&l ! m m ns%( A"AANc  |jj|j|jj ||S#t $r5}|j jd|d|d|d|d| Yd}~yd}~wwxYw)N)contentr_zUnable to list content on z, z for z and r`rP)r=rTrrr?r@r;r8)rCrSrrr_rDs r$get_storage_contentz"ProxmoxAnsible.get_storage_contents}   &&t,!W40     KK ! !'44 "   sAA B +BB )FF)F)NN)__name__ __module__ __qualname____doc__rxrEr<r>rVrZrfrhrtrvr|rrrr"r#r$r0r0IsT(&N MR2W+S  Zee4 b n r#r0) __future__rrrr __metaclass__rAtimerr9r2rrr:r7 ImportErrorrBansible.module_utils.basicr r +ansible.module_utils.common.text.convertersr Bansible_collections.community.proxmox.plugins.module_utils.versionr r%r*r.objectr0r"r#r$rsA@ /$:M JA[:) kVko/M, ,,./sAA,+A,