Vhk#ddlmZmZmZeZddlZddlmZdZ ddl m Z ddl m Z dZddlmZmZdd lmZd Zd Zd ZGd deZy#e$rdZej Z Y=wxYw))absolute_importdivisionprint_functionN)sleep) ProxmoxAPI) __version__TF) env_fallbackmissing_required_lib) 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/general/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)8sA: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 expiredcdts |jtdt||_t |_|j |_ |jjjy#t$r2}|jd|ztjYd}~yd}~wwxYw)N proxmoxermsg exception%s) HAS_PROXMOXER fail_jsonr PROXMOXER_IMP_ERRmoduleproxmoxer_version_connect proxmox_apiversionget Exception traceback format_exc)selfr9es r#__init__zProxmoxAnsible.__init__Ls   !5k!BN_  ` !2==? M    $ $ ( ( * M   Y5I5I5K  L L Ms$A44 B/=(B**B/c|jjd}|jjd}|jjd}|jjd}|jjd}|jjd}|jjd}d|i}|r||d <|r||d <n=|jtd kr|jj d ||d <||d< t |fd|i|S#t $r<} |jj d| ztjYd} ~ yd} ~ wwxYw)Nrrrrrrruserportpasswordz1.1.0z=Using "token_name" and "token_value" require proxmoxer>=1.1.0 token_name token_value verify_sslr5r2) r9paramsr:r r7rr?r@rA) rBrrrrrrr auth_argsrCs r#r;zProxmoxAnsible._connectYsC;;%%j1;;%%j1;;%%j1{{)).9 {{)).9 ;;--.@A++,<=X&  (If  $0Ij !%% W(== %%&ef&2Il #'7Im $ RhO>OYO O R KK ! !dQh):N:N:P ! Q Q Rs D E2EEc |jjj}t|dS#t$r)}|j j d|zYd}~yd}~wwxYw)Nr=z)Unable to retrieve Proxmox VE version: %sr3)r<r=r>r r?r9r7)rB apiversionrCs r#r=zProxmoxAnsible.versiontsc 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: %srOr)r<nodesr>r?r9r7)rBrRnrSrCs 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: %srO)r<clusternextidr>r?r9r7)rBrCs 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 : rOzNo VM with name %s foundr&z5Multiple VMs with name %s found, provide vmid insteadr)r<rW resourcesr>r?r9r7len)rBr]ignore_missingchoose_first_if_multipler[vmsrCs 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_rOrz)VM with vmid %s does not exist in cluster)r<rWr`r>rr?r9r7)rBr^rbr[rdrCs 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 "B00B5c |jj|j|jj }|ddk(xr|ddk(S#t $r,}|j jd|d|Yd}~yd}~wwxYw)Nstatusstopped exitstatusOK)Unable to retrieve API task ID from node r_rOr<rStasksrir>r?r9r7rBrRtaskidrirCs r# api_task_okzProxmoxAnsible.api_task_oks e%%++D177?FFJJLF(#y0QVL5IT5Q Q e KK ! ![_ab&c ! d d eAA B "BB c |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 rirjrkrlrmr_rONrnrps r#api_task_failedzProxmoxAnsible.api_task_faileds e%%++D177?FFJJLF(#y0QVL5IT5Q Q e KK ! ![_ab&c ! d d ersci}|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. rmr_rONrirjrkrl)TNFr&r) r<rSrorir>r?r9r7r/TASK_TIMED_OUTr)rB node_nametask_idtimeoutrirCs 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: rON)r<poolsr>r?r9r7)rBpoolidrCs 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_rON)r<storager>r?r9r7)rBrrCs 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_rO)r<rSrrr>r?r9r7)rBrRrrr^rCs r#get_storage_contentz"ProxmoxAnsible.get_storage_contents}   &&t,!W40     KK ! !'44 "   sAA B +BB )FF)F)NN)__name__ __module__ __qualname____doc__rwrDr;r=rUrYrergrrrur{rrrr!r"r#r/r/HsT(&N MR6W+S  Zee4 b n r"r/) __future__rrrr __metaclass__r@timerr8r1rrr:r6 ImportErrorrAansible.module_utils.basicr r Bansible_collections.community.general.plugins.module_utils.versionr r$r)r-objectr/r!r"r#rs}A@ /$:M J[:) jVjm/M, ,,./sA A&%A&