Vh+4dZddlmZmZmZeZ ddlmZm Z ddl m Z dZ dZ dZ ddlZddlmZdd lmZdd lmZdd lmZdZ ddlZej6ej8j:dad Zd Z dZ!dZ"dZ#e dZ$e dZ%e dZ&e dZ'e dZ(e dZ)e dZ*e dZ+e dZ,e dZ-e ddZ.dZ/dZ0dZ1y#e$rZdZ eZ YdZ[dZ[wwxYw#e$rdZYe$rdZ YwxYw#e$rdZYwxYw) z Infinidat utilities )absolute_importdivisionprint_function) InfiniBoxcore)ObjectNotFoundTNFwraps)environ)path)datetimec6tj|dz dfS)z2 Convert unix time with ms to a datetime UTC time g@@UTC)r utcfromtimestamp)unix_mss v/home/dcms/DCMS/lib/python3.12/site-packages/ansible_collections/infinidat/infinibox/plugins/module_utils/infinibox.pyunixMillisecondsToDater6s  % %go 6 >>c.tfd}|S)z Catch API Errors Decoratorc|d} |i|S#tjj$r%}|jt |Yd}~yd}~wtjj $r%}|jt |Yd}~yd}~wt $r%}|jt |Yd}~yd}~wwxYw)Nrmsg)r exceptionsSystemNotFoundException fail_jsonstrAPICommandException Exception)argskwargsmoduleerrfuncs r __wrapperzapi_wrapper..__wrapper=sa +(( (66 +   S  * *  22 +   S  * * +   S  * * +s,B>A  B>-B  B>B99B>r )r#r$s` r api_wrapperr%;s! 4[   rc\ttdtdtddS)zTReturn standard base dictionary used for the argument_spec argument in AnsibleModuleT)required)r'no_log)systemuserpassword)dictrrinfinibox_argument_specr.Ls) T" 4 tD1 rc ddggS)zPReturn the default list used for the required_together argument to AnsibleModuler*r+r-r-rrinfinibox_required_togetherr0Us Z !!rcH|j}|j||S)zd Merge two dicts into one and return. result = {**dict1, **dict2} only works in py3.5+. )copyupdate)dict1dict2results rmerge_two_dictsr7Zs ZZ\F MM% Mrcts#|jd}|jjdd}|jjdd}|r|rt|||fdant jdrLt jdr7t|t jdt jdfdanKt j t jd d zrt|d an|jd  tjtStS#t$r|jd YtSwxYw)z Return System Object if it does not exist or Fail. Use a global system Infinibox object so that there will only be one system session used for this module instance. Enables execute_state() to log out of the only session properly. r)r*Nr+T)authuse_sslINFINIBOX_USERINFINIBOX_PASSWORD~z/.infinidat/infinisdk.ini)r:zrYou must set INFINIBOX_USER and INFINIBOX_PASSWORD environment variables or set username/password module argumentsrz7Infinibox authentication failed. Check your credentials) INFINIBOX_SYSTEMparamsgetrr r isfile expanduserrloginr)r!boxr*r+s r get_systemrEds0 mmH%}}  .==$$Z6 H(D(3CTR  [[) *w{{;O/P(/6{{;K/L/6{{;O/P/R15 7 [[-0KK L(d;    "V  W \  " " $   \   !Z  [  \sD11EEc |jd}|jj|S#t$r2 |jd}n#t$r|jd}YnwxYwYVwxYw#t$rYywxYw)zy Return Pool. Try key look up using 'pool', or if that fails, 'name'. If the pool is not found, return None. poolname object_namerHN)r?KeyErrorpoolsr@r)r!r)rHs rget_poolrMs  4==(D ||T**  4 4}}V, 4}}]3 4 4 sO.A, A)AA)A# A)"A##A)&A,(A))A,, A87A8c` |jj|jd}|S#t$rg |jj|jd}n8#t$r,|jj|jd}YnwxYwY|SwxYw#t$rYywxYw)zReturn Filesystem or None filesystemrJrHrIN) filesystemsr@r?rKrr!r)rOs rget_filesystemrRs  W++//V]]<5P/QJ   W W#//33v9N3O  W#//33}9U3V  W  W O).B! B)A"!B"2BBBBB!BB!! B-,B-c |jd}|jj|}|S#t$r|jd}Y8wxYw#t$rYywxYw)z+Return export if found or None if not foundexportrH) export_pathN)r?rKexportsr@r)r!r) export_namerUs r get_exportrYsl 0 --1K## #< M 0 --/K 0 s,0AA A A  A AAc` |jj|jd}|S#t$rg |jj|jd}n8#t$r,|jj|jd}YnwxYwY|SwxYw#t$rYywxYw)zReturn Volume or NonerHrJvolumerIN)volumesr@r?rKrr!r)r[s r get_volumer^s  O^^''V]]6-B'CF   O O++x1H+I O++}1M+N O  O rSc |jj|jd}|S#ttf$rYywxYw)zReturn network space or NonerHrJN)network_spacesr@r?rKr)r!r) net_spaces r get_net_spacerbsJ))--6==3H-I   n %s )-??cx |jj|jd}|S#t$rYywxYw)z-Return volume that matches the serial or NoneserialrdN)r\r@r?rr]s r get_vol_by_snrfsB##6==+B#C M  )- 99cx |jj|jd}|S#t$rYywxYw)z1Return filesystem that matches the serial or NonerdreN)rPr@r?rrQs r get_fs_by_snrisE''++6==3J+K   rgcd}|jjD],}|j} |jd}||k(s)|}|S|S#t$r2 |jd}n#t$r|jd}YnwxYwYHwxYw)z/Find a host by the name specified in the moduleNrHhostrI)hoststo_listget_namer?rK)r!r)rka_host a_host_name host_params rget_hostrrs D,,&&( oo'  :v.J * $D  K  K : :#]]62  :#]]=9  : :5A B A('B (BB BB B cd}|jjD],}|j} |jd}||k(s)|}|S|S#t$r2 |jd}n#t$r|jd}YnwxYwYHwxYw)z2Find a cluster by the name specified in the moduleNrHclusterrI) host_clustersrmrnr?rK)r!r)ru a_clustera_cluster_name cluster_params r get_clusterrzsG))113  "++- ="MM&1M ] *G  N  N = = & i 8  = & m <  = =rscd}|s|jd}n|} |jj|}|S#t$rY|SwxYw)z4Find a user by the user_name specified in the moduleN user_namerJ)r?usersr@r)r!r)user_name_to_findr*r|s rget_userrs[ D MM+. %  ||Y/ K   K s6 AAc.|jd}|rtj|}tj}||krd}|d|dz }|j |d}|j |}||k\rd|d zd zd }|j |y y y ) aE Check if specified options are feasible for a snapshot. Prevent very long lock times. max_delta_minutes limits locks to 30 days (43200 minutes). This functionality is broken out from manage_snapshot_locks() to allow it to be called by create_snapshot() before the snapshot is actually created. snapshot_lock_expires_atz5Cannot lock snapshot with a snapshot_lock_expires_at zof 'z' from the pastri)minutesz!snapshot_lock_expires_at exceeds <z days in the futureN)r?arrowr@utcnowrshift)r!rlock_expires_atnowrmax_delta_minutesmax_lock_expires_ats rcheck_snapshot_lock_optionsr"s &}}-GH))$<=lln c !IC T23?C CC     %"!ii0AiB 1 156G26MQS6S5TTghC     % 2 rcL|jd}|jdk(}|j}d}t||rbt j |}|r"||krd|d|d}|j ||S|r||k(r |S|js|j|d}|S) z Manage the locking of a snapshot. Check for bad lock times. See check_snapshot_lock_options() which has additional checks. rLOCKEDFzsnapshot_lock_expires_at 'z%' preceeds the current lock time of ''rT) r?get_lock_stateget_lock_expires_atrrr@r check_modeupdate_lock_expires_at)r!snapshotrsnap_is_lockedcurrent_lock_expires_atchangedrrs rmanage_snapshot_locksrAs &}}-GH,,.(:N&::<G'))$<= o0GG..??de|d}}~C     % N3J J  N$$//@G Nrcnd}ts|dz }ts|dz }ts|dz }|j|y)NzFailed to import arrow module. z#Failed to import infinisdk module. z!Failed to import urllib3 module. r) HAS_ARROW HAS_INFINISDK HAS_URLLIB3r)r!rs r!catch_failed_module_utils_importsr^sB C  00  44  22 r)N)2__doc__ __future__rrrtype __metaclass__ infinisdkrrinfinisdk.core.exceptionsrrINFINISDK_IMPORT_ERROR ImportErrorimp_excrrr functoolsr osr r r rurllib3disable_warningsrInsecureRequestWarningr>rr%r.r0r7rErMrRrYr^rbrfrirrrzrrrrr-rrrsBB ")8 M!    GW//FFG ? ""   D  $                    (  *    &>:O %M$%IMKs@C"C8*D "C5'C00C58D D  D  DD