�
d��g�+ � � � d Z ddlZddlZddlZddlZddlmZ ddlm Z ddl
m Z ddl m
Z
G d� d e� Z G d
� d e� Z G d � d
e� Z G d� de� Z G d� de� Z G d� de� Z G d� de� Z e ddd�� Z e ddd�� Z e dd d�� Z e d d d�� Z e d d d�� Z e d!d"d�� Z e d#d$d�� Z e d%d&d�� Z e d'd(d�� Z e d)d*d�� Z e d+d,d�� Z e d-d.d�� Z! e d/d0d�� Z" e d1d2d�� Z#dd3l$m%Z% G d4� d5ejL jN � Z( G d6� d7ejL jR � Z*y)8z=
PyONE is an implementation of Open Nebula XML-RPC bindings.
� N)� string_types)�IntEnum)�bindings� )�cast2onec � � e Zd Zy)� OneExceptionN��__name__�
__module__� __qualname__� � �=/opt/hc_python/lib/python3.12/site-packages/pyone/__init__.pyr r ! � � �r r c � � e Zd Zy)�OneAuthenticationExceptionNr
r r r r r % r r r c � � e Zd Zy)�OneAuthorizationExceptionNr
r r r r r ) r r r c � � e Zd Zy)�OneNoExistsExceptionNr
r r r r r - r r r c � � e Zd Zy)�OneActionExceptionNr
r r r r r 1 r r r c � � e Zd Zy)�OneApiExceptionNr
r r r r r 5 r r r c � � e Zd Zy)�OneInternalExceptionNr
r r r r r 9 r r r �DATASTORE_TYPESzIMAGE SYSTEM FILE)�start�DATASTORE_STATESzREADY DISABLED�
DISK_TYPESzFILE CD_ROM BLOCK RBD�HISTORY_ACTIONa none migrate live-migrate
shutdown shutdown-hard undeploy undeploy-hard hold release stop
suspend resume boot delete delete-recreate reboot reboot-hard resched
unresched poweroff poweroff-hard disk-attach disk-detach nic-attach
nic-detach disk-snapshot-create disk-snapshot-delete terminate
terminate-hard disk-resize deploy chown chmod updateconf rename resize
update snapshot-resize snapshot-delete snapshot-revert disk-saveas
disk-snapshot-revert recover retry monitor� HOST_STATESzINIT MONITORING_MONITORED MONITORED
ERROR DISABLED MONITORING_ERROR MONITORING_INIT MONITORING_DISABLED
OFFLINE� HOST_STATUSzENABLED DISABLED OFFLINE� IMAGE_STATESzaINIT READY USED DISABLED LOCKED ERROR
CLONE DELETE USED_PERS LOCKED_USED LOCKED_USED_PERS� IMAGE_TYPESz1OS CDROM DATABLOCK KERNEL RAMDISK
CONTEXT� LCM_STATEa
LCM_INIT
PROLOG
BOOT
RUNNING
MIGRATE
SAVE_STOP
SAVE_SUSPEND
SAVE_MIGRATE
PROLOG_MIGRATE
PROLOG_RESUME
EPILOG_STOP
EPILOG
SHUTDOWN
CANCEL
FAILURE
CLEANUP_RESUBMIT
UNKNOWN
HOTPLUG
SHUTDOWN_POWEROFF
BOOT_UNKNOWN
BOOT_POWEROFF
BOOT_SUSPENDED
BOOT_STOPPED
CLEANUP_DELETE
HOTPLUG_SNAPSHOT
HOTPLUG_NIC
HOTPLUG_SAVEAS
HOTPLUG_SAVEAS_POWEROFF
HOTPLUG_SAVEAS_SUSPENDED
SHUTDOWN_UNDEPLOY
EPILOG_UNDEPLOY
PROLOG_UNDEPLOY
BOOT_UNDEPLOY
HOTPLUG_PROLOG_POWEROFF
HOTPLUG_EPILOG_POWEROFF
BOOT_MIGRATE
BOOT_FAILURE
BOOT_MIGRATE_FAILURE
PROLOG_MIGRATE_FAILURE
PROLOG_FAILURE
EPILOG_FAILURE
EPILOG_STOP_FAILURE
EPILOG_UNDEPLOY_FAILURE
PROLOG_MIGRATE_POWEROFF
PROLOG_MIGRATE_POWEROFF_FAILURE
PROLOG_MIGRATE_SUSPEND
PROLOG_MIGRATE_SUSPEND_FAILURE
BOOT_UNDEPLOY_FAILURE
BOOT_STOPPED_FAILURE
PROLOG_RESUME_FAILURE
PROLOG_UNDEPLOY_FAILURE
DISK_SNAPSHOT_POWEROFF
DISK_SNAPSHOT_REVERT_POWEROFF
DISK_SNAPSHOT_DELETE_POWEROFF
DISK_SNAPSHOT_SUSPENDED
DISK_SNAPSHOT_REVERT_SUSPENDED
DISK_SNAPSHOT_DELETE_SUSPENDED
DISK_SNAPSHOT
DISK_SNAPSHOT_REVERT
DISK_SNAPSHOT_DELETE
PROLOG_MIGRATE_UNKNOWN
PROLOG_MIGRATE_UNKNOWN_FAILURE
DISK_RESIZE
DISK_RESIZE_POWEROFF
DISK_RESIZE_UNDEPLOYED
HOTPLUG_NIC_POWEROFF
HOTPLUG_RESIZE
HOTPLUG_SAVEAS_UNDEPLOYED
HOTPLUG_SAVEAS_STOPPED�MARKETPLACEAPP_STATESz(INIT READY LOCKED
ERROR DISABLED�MARKETPLACEAPP_TYPESz1UNKNOWN IMAGE
VMTEMPLATE SERVICE_TEMPLATE�PAGINATED_POOLSzLVM_POOL IMAGE_POOL
TEMPLATE_POOL VN_POOL DOCUMENT_POOL SECGROUP_POOL�REMOVE_VNET_ATTRSzgAR_ID BRIDGE CLUSTER_ID
IP MAC TARGET NIC_ID NETWORK_ID VN_MAD SECURITY_GROUPS VLAN_ID
�VM_STATEzjINIT PENDING HOLD ACTIVE STOPPED SUSPENDED
DONE FAILED POWEROFF UNDEPLOYED CLONING CLONING_FAILURE)�marketapp_exportc �< � e Zd ZdZd
d�Zd� Zd� Zd� Zd� Zd� Z d � Z
y) � OneServerzB
XML-RPC OpenNebula Server
Slightly tuned ServerProxy
Nc �* � || _ |rt j |� dt i| _ t � }|j
|j d� � |j |� t j j j | |fd|i|�� y)a�
Override the constructor to take the authentication or session
Will also configure the socket timeout
:param uri: OpenNebula endpoint
:param session: OpenNebula authentication session
:param timeout: Socket timetout
:param https_verify: if https cert should be verified
:param options: additional options for ServerProxy
zmarketapp.export�https� transportN)
�_OneServer__session�socket�setdefaulttimeoutr- �_OneServer__helpers�RequestsTransport� set_https�
startswith�set_https_verify�xmlrpc�client� ServerProxy�__init__)�self�uri�session�timeout� https_verify�optionsr2 s r r> zOneServer.__init__� s� � � !��� � � $� $�W� -�
� 0�
��� &�'� ����C�N�N�7� 3�4��"�"�<�0��
�
�!�!�*�*� � � � � � � r c � � || j v r | j | | g|��� S | j d|z | j |� � }| j |� S )a�
Override/patch the (private) request method to:
- structured parameters will be casted to attribute=value or XML
- automatically prefix all methodnames with "one."
- automatically add the authentication info as first parameter
- process the response
:param methodname: XMLRPC method name
:param params: XMLRPC parameters
:return: opennebula object or XMLRPC returned value
zone.)r6 � _do_request� _cast_parms�_OneServer__response)r? �
methodname�params�rets r �_ServerProxy__requestz OneServer._ServerProxy__request� s\ � � �� � � '�-�4�>�>�*�-�d�<�V�<� <�� � �v�j� 0�$�2B�2B�6�2J�K�����s�#�#r c �� � t j j j | ||� S # t j j $ r}t t
|� � �d }~ww xY w�N)r; r< r= rL �Faultr �str)r? �methodrJ �es r rF zOneServer._do_request� sT � � '��=�=�,�,�B�B��f�f�&�
&���}�}�"�"� '� �s�1�v�&� &�� '�s �*- � A#�
A � A#c � � t |� }t |� D ] \ }}t |� ||< � t |� }| j f|z }|S )za
cast parameters, make them one-friendly
:param params:
:return:
)�list� enumerater �tupler3 )r? rJ �lparams�i�params r rG zOneServer._cast_parms� sL � � �v�,��!�'�*�H�A�u�!�%� �G�A�J� +��w� ���.�.�"�V�+���
r c � � |d }|d }|rC|d }t |t � r,|d dk( r$t j |j d� � S |S |d }|dk( r t |� �|dk( r t
|� �|dk( r t |� �|d k( r t |� �|d
k( r t |� �|d k( r t |� �t |� �) Nr � r �<zutf-8� i i i i i ) �
isinstancer r � parseString�encoder r r r r r r )r? � raw_response�sucess�coderK �messages r �
__responsezOneServer.__response s� � � �a� ���A��� � �q�/�C��#�|�,��q�6�S�=�#�/�/��
�
�7�0C�D�D��J� �q�/�� �6�>�,�W�5� 5� �6�>�+�G�4� 4� �6�>�&�w�/� /� �6�>�$�W�-� -� �6�>�!�'�*� *� �6�>�&�w�/� /��7�#�#r c � � y)z�returns the recommended wait time between attempts to check if
the opennebula platform has reached a desired state, in secondsr r �r? s r �server_retry_intervalz OneServer.server_retry_interval' s � � r c � � y rN r rg s r � server_closezOneServer.server_close, s � � r )NT) r r r
�__doc__r> rL rF rG rH rh rj r r r r/ r/ � s+ � ��
�B$�*'� �"$�6�
r r/ c �: � e Zd ZdZdZdZd
d�Zd� Zd
d�Zd� Z d� Z
y ) r7 zO
Drop in Transport for xmlrpclib that uses Requests instead of httplib
z1Python XMLRPC with Requests (python-requests.org)Fc � � || _ y rN )� use_https)r? r1 s r r8 zRequestsTransport.set_https8 s � � ��r c � � || _ y rN )rC )r? rC s r r: z"RequestsTransport.set_https_verify; s
� � (��r c � � | j ddd�}| j ||� }d| j i}t j |f||d�|��} |j � | j
|� S # t j $ rD} t j j ||j t | � |j � �d} ~ ww xY w)z)
Make an xmlrpc request.
ztext/xmlz*/*)z
User-Agentz Content-Type�Accept�verify)�data�headersN)�
user_agent�
_build_urlrC �requests�post�raise_for_status�parse_response�RequestExceptionr; r< �
ProtocolError� status_coderP rt )
r? �host�handler� request_body�verbosert �url�kwargs�resprR s
r �requestzRequestsTransport.request> s� � � "&� � �#-� "���
�o�o�d�G�,���D� -� -�/���}�}�S� '�|�W� '� %�'�� -� � !� !� #�
�&�&�t�,� ,�� �(�(� D��-�-�-�-�c�4�3C�3C�.1�!�f�d�l�l�D�
D�� D�s � A, �,C�??B>�>Cc � � | j � \ }}|j |j � |j � |j � S )z,
Parse the xmlrpc response.
)� getparser�feed�content�close)r? �response�p�us r rz z RequestsTransport.parse_responseU s; � � �~�~� ���1� ���x� � � � ��� ��w�w�y�r c �X � | j rdnd}|j d� }|�d|�d|��S )zf
Build a url for our request based on the host, handler and use_http
property
r1 �http�/z://)rn �lstrip)r? r~ r �schemes r rv z RequestsTransport._build_url` s, � �
!�N�N�����.�.��%�� %�t�W�5�5r N)F) r r r
rk ru rn r8 r: r� rz rv r r r r7 r7 0 s- � �� E�J��I� �)�-�. �6r r7 )+rk �
xmlrpc.clientr; r4 rw �requests.utils�sixr �enumr �pyoner �utilr � Exceptionr r r r r r r r r r! r" r# r$ r% r& r' r( r) r* r+ r, �helpersr- r< r= r/ � Transportr7 r r r �<module>r� s� �� � �
� � � � � � � �9� � � � � � � � �<� � � � � �l� � �<� � �+�-@��J���-�/?�q�I� �
�\�#:�!�
D�
��)� ,6� >?�@�� �m� &�� � � �m�%?�q�I� ��~� (?�FG�I� � �m� &�� � �
�K� E"&�J ./�KE
0� �N � 7� :�!"�$� � � 5� 8'�./�1� � �+� .=�DE�G�� � /� 2 ��� � �:� C�JK� M�� &�u
��
�
�)�)� u
�p86��
�
�/�/� 86r