OwlCyberSecurity - MANAGER
Edit File: __init__.cpython-312.pyc
� f��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