File manager - Edit - /opt/saltstack/salt/lib/python3.10/site-packages/salt/modules/__pycache__/glassfish.cpython-310.pyc
Back
o ;j�M � @ s d Z ddlZddlZddlZddlmZ zddlZdZ W n e y' dZ Y nw dZ dddddd �Z d d � Z d d � Zdd� Zdd� Zdd� Zdd� Zdd� Zdcdd�Zdcdd�Zdcd d �Zdcd d �Zdcd d!�Zddd"d#�Zdcd$d%�Zdcd&d'�Zdcd(d)�Z dcd*d+�Z dcd,d-�Z dcd.d/�Z dcd0d1�Z ded3d4�Z!dcd5d6�Z"dcd7d8�Z#dcd9d:�Z$dcd;d<�Z%dfd=d>�Z&dcd?d@�Z'dcdAdB�Z(dcdCdD�Z)dcdEdF�Z*dfdGdH�Z+dcdIdJ�Z,dcdKdL�Z-dcdMdN�Z.dcdOdP�Z/dgdQdR�Z0dcdSdT�Z1dcdUdV�Z2dcdWdX�Z3dcdYdZ�Z4dfd[d\�Z5dcd]d^�Z6dcd_d`�Z7dcdadb�Z8dS )hzp Module for working with the Glassfish/Payara 4.x management API .. versionadded:: 2016.11.0 :depends: requests � N)�CommandExecutionErrorTFZ glassfishZ localhosti� )�ssl�url�port�user�passwordc C s t rtS dd�t�fS )z, Only load if requests is installed FzAThe "{}" module could not be loaded: "requests" is not installed.)�HAS_LIBS�__virtualname__�format� r r �J/opt/saltstack/salt/lib/python3.10/site-packages/salt/modules/glassfish.py� __virtual__ s ��r c C s dddd�S )zV Return fixed dict with headers (JSON data + mandatory "Requested by" header) zapplication/jsonz GlassFish REST HTML interface)ZAcceptz Content-TypezX-Requested-Byr r r r r � _get_headers/ s �r c C s | r |r t j�| |�S dS )z& Returns the HTTP auth header N)�requests�authZ HTTPBasicAuth)�usernamer r r r � _get_auth: s r c C s0 | r d|� d|� d|� �S d|� d|� d|� �S )z) Returns the URL of the endpoint zhttps://�:z/management/domain/zhttp://r )r r r �pathr r r �_get_urlD s r c C s | r| S t S )zE Returns the server information if provided, or the defaults )�DEFAULT_SERVER��serverr r r � _get_serverN � r c C s" t | �D ] }|�d�r| |= q| S )z0 Removes SaltStack params from **kwargs Z__pub)�list� startswith)�data�keyr r r � _clean_dataU s �r c C s� | j dkrtjjjtd< td��| j dkr tjjjtd< td��| j dks*| j dkr[z tjj� | j �}|d d krFtjjjtd< t|d ��|W S t yZ tjjjtd< td ��w | � � d S ) zI Check response status code + success_code returned by glassfish i� �retcodezElement doesn't existsi� zBad username or password�� i� Z exit_code�SUCCESS�messagezThe server returned no dataN) Z status_code�salt�defaults� exitcodes�SALT_BUILD_FAIL� __context__r �utils�json�loads�content� ValueErrorZraise_for_status)�responser r r r � _api_response_ s$ � r/ c C sJ t |�}tjt|d |d |d | �t|d |d �t� ddd�}t|�S ) z% Do a GET request to the API r r r r r T�x )r r �headers�verify�timeout)r r �getr r r r/ )r r r. r r r �_api_getw s �r5 c C sV t |�}tjt|d |d |d | �t|d |d �t� tjj� |�ddd�}t |�S ) z& Do a POST request to the API r r r r r Tr0 )r r r1 r r2 r3 ) r r Zpostr r r r$ r) r* �dumpsr/ �r r r r. r r r � _api_post� s �r8 c C sL t |�}tjt|d |d |d | �t|d |d �t� |ddd�}t|�S ) z( Do a DELETE request to the API r r r r r Tr0 )r r r1 �paramsr2 r3 )r r �deleter r r r/ r7 r r r � _api_delete� s �r; c C sB g }t | |�}t|d d �r |d d D ]}|�|� q|S dS )z Enum elements �extraPropertiesZchildResourcesN)r5 �any�append)�namer �elementsr �elementr r r �_enum_elements� s rB c C sT i }t |� d| � d�|�}t|d d �r(|d d D ] }|d ||d < q|S i S )z% Get an element's properties �/� /propertyr< � properties�valuer? �r5 r= )r? � element_typer rE r rA r r r �_get_element_properties� s rI c C st i }t jj| dd�} t|� d| � �|�}t|d d �r8|d d �� D ]\}}|||< q$|r6t| |�|d< |S dS )z3 Get an element with or without properties � ��saferC r< ZentityrE N)�urllib�parse�quoter5 r= �itemsrI )r? rH r �with_propertiesrA r r rF r r r � _get_element� s rR c C s� d|v r;d|d< |d � � D ])\}}|d s'|d d�||�dd��7 < q|d d�||�dd��7 < q|d= t|t|�|� tj�| �S )z Create a new element rE rJ �propertyz{}={}r z\:z:{}={})rP r �replacer8 r rM rN �unquote)r? rH r r r rF r r r �_create_element� s "" rV c C s� t jj| dd�} d|v r8g }|d �� D ] \}}|�||d�� qt|� d| � d�||� |d= |s8t j�| �S t| ||dd�}|rH|�|� nt j j j t d < td | � ���t|� d| � �t|�|� t j�| �S ) z5 Update an element, including its properties rJ rK rE )r? rF rC rD F)rQ r zCannot update )rM rN rO rP r> r8 rU rR �updater$ r% r& r' r( r r )r? rH r r rE r rF Z update_datar r r �_update_element� s rX c C s$ t d�|tjj| dd��||� | S )z Delete an element z{}/{}rJ rK )r; r rM rN rO )r? rH r r r r r �_delete_element s �rY c C � t d| �S )z Enum connection pools �#resources/connector-connection-pool�rB r r r r �enum_connector_c_pool � r] c C � t | d|�S )z( Get a specific connection pool r[ �rR �r? r r r r �get_connector_c_pool r rb c K s� i dd�dd�dd�dd�d d�d d�d d�d d �dd�d| �dd�dd�dd�dd�dd�dd�dd�ddddd d d dd ��}|}|� |� |d rU|d d vrUtd!��t| d"||�S )#z" Create a connection pool ZconnectionDefinitionNamezjavax.jms.ConnectionFactoryZresourceAdapterName�jmsra�associateWithThreadF� connectionCreationRetryAttemptsr �(connectionCreationRetryIntervalInSeconds�connectionLeakReclaim� connectionLeakTimeoutInSeconds� descriptionrJ �failAllConnections�id�idleTimeoutInSecondsi, � isConnectionValidationRequired�lazyConnectionAssociation�lazyConnectionEnlistment�matchConnectionsT�maxConnectionUsageCount� maxPoolSize� �`� � � r )�maxWaitTimeInMillis�ping�poolResizeQuantity�pooling�steadyPoolSize�target�transactionSupport�!validateAtmostOncePeriodInSecondsr} �Z XATransactionZLocalTransactionZ NoTransaction�Invalid transaction supportr[ �rW r rV �r? r �kwargsr% r r r r �create_connector_c_pool" sb �������� � � � � ������ r� c K s* d|v r|d dvrt d��t| d||�S )z" Update a connection pool r} r r� r[ )r rX �r? r r� r r r �update_connector_c_poolQ s r� r c C � ||d�}t | d||�S )z" Delete a connection pool �r| �cascader[ �rY �r? r| r� r r r r r �delete_connector_c_pool^ � r� c C rZ )z# Enum connection resources � resources/connector-resourcer\ r r r r �enum_connector_resourceg r^ r� c C r_ )z, Get a specific connection resource r� r` ra r r r �get_connector_resourcen r r� c K sf dd| dddd�}|}|� |� |d std��t|�� �D ] \}}||= |||�� < q t| d||�S ) �& Create a connection resource rJ Tr r )ri �enabledrk �poolNameZ objectTyper| r� � No pool name!r� )rW r r rP �lowerrV )r? r r� r% r r rF r r r �create_connector_resourceu s � r� c K � d|v r|d= t | d||�S )z& Update a connection resource �jndiNamer� �rX r� r r r �update_connector_resource� � r� c C � t | dd|i|�S )z& Delete a connection resource r� r| r� �r? r| r r r r �delete_connector_resource� � �r� c C rZ )z Enum JMS destinations � resources/admin-object-resourcer\ r r r r �enum_admin_object_resource� r^ r� c C r_ )z( Get a specific JMS destination r� r` ra r r r �get_admin_object_resource� r r� c K s� ddd| dddd�}|}|� |� |d dkr d|d < n|d d kr'd |d < ntd ��|d dkr5td��d|v rB|d |d< |d= d |v rO|d |d< |d = t| d||�S )z" Create a JMS destination rJ zcom.sun.messaging.QueueTrc zjavax.jms.Queuer )ri � classNamer� rk � resAdapter�resTyper| r� r� zjavax.jms.Topiczcom.sun.messaging.Topicz9resType should be "javax.jms.Queue" or "javax.jms.Topic"!r� z resAdapter should be "jmsra"!�restypeZ classnamer� r� r� r r r � create_admin_object_resource� s4 � � r� c K r� )z" Update a JMS destination r� r� r� r� r r r � update_admin_object_resource� s r� c C r� )z" Delete a JMS destination r� r| r� r� r r r � delete_admin_object_resource� r� r� c C rZ )z Enum JDBC pools � resources/jdbc-connection-poolr\ r r r r �enum_jdbc_connection_pool� r^ r� c C r_ )z" Get a specific JDBC pool r� r` ra r r r �get_jdbc_connection_pool� r r� c K s| i dd�dd�dd�dd�dd�d d�d d �d d �dd �dd �dd�dd�dd �dd�dd�dd�dd�i dd�dd�dd �d d �d | �d d�d!d�d"d#�d$d�d%d �d&d �d'd�d(d�d)d�d*d+�d,d-�d.d/��d dd d dd0��}|}|� |� |d% d1vr�td2��|d d3vr�td4��|d5 r�|d5 d6vr�td7��|d s�|d% d8v r�td9��|d s�|d% d:kr�td;��t| d<||�S )=r� ZallowNonComponentCallersFrd re �0rf �10rg rh ZconnectionValidationMethod�tableZdatasourceClassnamerJ ri ZdriverClassnamerj rl Z300ZinitSqlrm ZisIsolationLevelGuaranteedTrn ro rp rq rr Z32rw rt r? ZnonTransactionalConnectionsrx ry �2rz r� ZsqlTraceListenersZstatementCacheSizeZstatementLeakReclaimZ statementLeakTimeoutInSecondsZstatementTimeoutInSecondsz-1r{ �8r| r )�transactionIsolationLevelr~ ZvalidationClassnameZvalidationTableNameZwrapJdbcObjects)�javax.sql.DataSource�javax.sql.XADataSource�"javax.sql.ConnectionPoolDataSource�java.sql.DriverzInvalid resource type)z auto-commitz meta-datar� zcustom-validationz$Invalid connection validation methodr� )zread-uncommittedzread-committedzrepeatable-readZ serializablez#Invalid transaction isolation level)r� r� r� z7No datasource class name while using datasource resTyper� z/No driver class nime while using driver resTyper� r� r� r r r �create_jdbc_connection_pool� s� �������� � � � � ��������������� � � � � �!�"�#�+ �r� c K s t | d||�S )z Update a JDBC pool r� r� r� r r r �update_jdbc_connection_poolX s r� c C r� )z Delete a JDBC pool r� r� r� r� r r r �delete_jdbc_connection_pool_ r� r� c C rZ )z Enum JDBC resources �resources/jdbc-resourcer\ r r r r �enum_jdbc_resourceh r^ r� c C r_ )z& Get a specific JDBC resource r� r` ra r r r �get_jdbc_resourceo r r� c K s< dd| ddd�}|}|� |� |d std��t| d||�S )z Create a JDBC resource rJ Tr )ri r� rk r� r| r� r� r� r� r� r r r �create_jdbc_resourcev s � r� c K r� )z Update a JDBC resource r� r� r� r� r r r �update_jdbc_resource� r� r� c C r� )z Delete a JDBC resource r� r| r� r� r r r �delete_jdbc_resource� s r� c C sH i }t d| �}t|d d �r"|d d D ] }|d ||d < q|S i S )z Get system properties �system-propertiesr< ZsystemPropertiesrF r? rG )r rE r rA r r r �get_system_properties� s r� c C s t dt| �|� | S )z" Update system properties r� )r8 r )r r r r r �update_system_properties� s r� c C s t d| � �d|� dS )z" Delete a system property zsystem-properties/N)r; ra r r r �delete_system_properties� s r� )N)NT)r TN)r N)r FN)9�__doc__� urllib.parserM Zsalt.defaults.exitcodesr$ Zsalt.utils.jsonZsalt.exceptionsr r r � ImportErrorr r r r r r r r r/ r5 r8 r; rB rI rR rV rX rY r] rb r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r r r r �<module> s| �� / * Z
| ver. 1.4 |
Github
|
.
| PHP 8.2.30 | Generation time: 0 |
proxy
|
phpinfo
|
Settings