File: //opt/saltstack/salt/lib/python3.10/site-packages/salt/states/__pycache__/glassfish.cpython-310.pyc
o
�N�g6U � @ s� d Z ddlZddlmZ zddlZdZW n ey dZY nw dd� Zdd � Z d
d � Z
d,d d
�Z d,dd�Z d-dd�Z
d.dd�Z d/d d �Zd,d d �Z ! " # d0d$d%�Zd.d&d'�Zd,d(d)�Zd,d*d+�ZdS )1a)
Manage Glassfish/Payara server
.. versionadded:: 2016.11.0
Management of glassfish using its RESTful API
You can setup connection parameters like this
.. code-block:: yaml
- server:
- ssl: true
- url: localhost
- port: 4848
- user: admin
- password: changeit
� N)�CommandExecutionErrorTFc C s dt v rtrdS dS )z4
Only load if glassfish module is available
z glassfish.enum_connector_c_poolT)Fz$glassfish module could not be loaded)�__salt__�HAS_LIBS� r r �I/opt/saltstack/salt/lib/python3.10/site-packages/salt/states/glassfish.py� __virtual__ s r c C sV i }| � � D ]"\}}t|t�s$t|t�rt|�||< qt|��� ||< q|||< q|S )z@
Encode json values in unicode to match that of the API
)�items�
isinstance�str�dict�_json_to_unicode�lower)�data�ret�key�valuer r r r & s
r c C s� i }t tjj�tjjj|dd���}tjj�tjjj| dd��} | �� D ]/\}}t|��� }||v r:t|| ��� }|dksB|dkrDd}||v rS||krS||d�||< q$|S )z?
Compare the API results to the current statefile data
F)� ensure_ascii�nullZnone� )�old�new) r �salt�utils�json�loads�dumpsr r
r
)Zold_confZnew_conf�changedr r ZoldvalZnewvalr r r � _is_updated6 s" �� �r c
C s� i dddd�}z
t d|� � � }W n0 tjyA } z#td r1| |d�|d< d|d < |W Y d}~S d
|d < |W Y d}~S d}~ww |rH| |vr�| |d�|d< d|d < td s�zt d |� � | fd
|i|�� W |S ty� } z ||d < |W Y d}~S d}~ww |S |r�t|�r�t d|� � | |d�}t||�}|r�d|d< ||d< td s�zt d|� � | fd
|i|�� W |S ty� } z ||d < W Y d}~|S d}~ww |S )z9
Generic function to create or update an element
FN)�changes�update�create�error�glassfish.enum_�test)�NameZParamsr Tr �Can't connect to the serverr! zglassfish.create_�serverzglassfish.get_�r& r zglassfish.update_)r �requests�ConnectionError�__opts__r �anyr ) �name� elem_typer r& r �elementsr! Z current_dataZ data_diffr r r �_do_element_presentO s^ �� ��� �
������r/ c
C s� ddd�}z
t d|� � � }W n) tjy8 } z td r(d|d< |W Y d}~S d|d < |W Y d}~S d}~ww |rq| |v rqd|d
< td sqzt d |� � | fd |i|�� W |S typ } z ||d < W Y d}~|S d}~ww |S )
z/
Generic function to delete an element
FN)�deleter! r" r# Tr r% r! r0 zglassfish.delete_r& �r r( r) r* r )r, r- r r& r r. r! r r r �_do_element_absentx s.
�� ���r2 �connection_factoryr � � � �, �< c
C s4 | ddi d�}
i }i }| � d�}|dkrd|d< n |dkr"d|d< n|d kr+d
|d< n
d |
d < d
|
d< |
S ||d< ||d< ||d< ||d< ||d< ||d< ||d< ||d< |d |d< | |d< |
r�|
dkrjd|d< n |
d krsd |d< n|
d kr|d |d< n
d |
d < d |
d< |
S | |d!< t |d"|| �}t | d#|| �}|d$ �s|d$ �std% s�d&|
d < |d' s�|d' r�|d( |
d( d)< |d( |
d( d*< td% r�d+|
d< |
S d,|
d< |
S |d- s�|d- r�|d( |
d( d)< |d( |
d( d*< td% r�d.|
d< |
S d/|
d< |
S d&|
d < i |
d(< d0|
d< |
S d |
d < d1�|d$ |d$ �|
d< |
S )2a:
Ensures that the Connection Factory is present
name
Name of the connection factory
restype
Type of the connection factory, can be either ``connection_factory``,
``queue_connection_factory` or ``topic_connection_factory``,
defaults to ``connection_factory``
description
Description of the connection factory
enabled
Is the connection factory enabled? defaults to ``true``
min_size
Minimum and initial number of connections in the pool, defaults to ``1``
max_size
Maximum number of connections that can be created in the pool, defaults to ``250``
resize_quantity
Number of connections to be removed when idle_timeout expires, defaults to ``2``
idle_timeout
Maximum time a connection can remain idle in the pool, in seconds, defaults to ``300``
wait_timeout
Maximum time a caller can wait before timeout, in seconds, defaults to ``60``
reconnect_on_failure
Close all connections and reconnect on failure (or reconnect only when used), defaults to ``false``
transaction_support
Level of transaction support, can be either ``XATransaction``, ``LocalTransaction`` or ``NoTransaction``
connection_validation
Connection validation is required, defaults to ``false``
N�r, �result�commentr �-Connection-PoolZtopic_connection_factoryz javax.jms.TopicConnectionFactoryZconnectionDefinitionNameZqueue_connection_factoryz javax.jms.QueueConnectionFactoryr3 zjavax.jms.ConnectionFactoryFr: �Invalid restyper; � description�enabled�poolName�steadyPoolSize� maxPoolSize�poolResizeQuantity�idleTimeoutInSeconds�� �maxWaitTimeInMillisZfailAllConnectionsZxa_transactionZ
XATransactionZtransactionSupportZlocal_transactionZLocalTransactionZno_transactionZ
NoTransactionzInvalid transaction_supportZ isConnectionValidationRequired�connector_c_poolZconnector_resourcer! r# Tr r �pool�resourcez$Connection factory set to be createdzConnection factory createdr z$Connection factory set to be updatedzConnection factory updatedz(Connection factory is already up-to-date�ERROR: {} // {}�r/ r* �format)r, �restyper> r? �min_size�max_size�resize_quantity� idle_timeout� wait_timeoutZreconnect_on_failureZtransaction_supportZconnection_validationr& r � pool_data�res_data� pool_name�pool_ret�res_retr r r �connection_factory_present� s| 7
�� � ��rX c C s� | ddi d�}| � d�}t |dd|i|�}|d s?td r'|d r'd |d
< |S |d r5d |d < d
|d
< |S d |d < d|d
< |S d|d < d�|d �|d
< |S )z�
Ensures the transaction factory is absent.
name
Name of the connection factory
both
Delete both the pool and the resource, defaults to ``true``
Nr9 r< rG �cascader! r# r0 z$Connection Factory set to be deletedr; Tr: zConnection Factory deletedz Connection Factory doesn't existF� Error: {}�r2 r* rL )r, �bothr& r rU rV r r r �connection_factory_absent s&
�
���r] �queuec C sF | ddi d�}i }|dkrd|d< d|d< n|dkr#d |d< d
|d< n
d |d < d
|d< |S d|i|d< ||d< ||d< t | d||�}|d s�td sNd|d < |d r\td r\d|d< |S |d rl|d |d< d|d< |S |d rztd rzd |d< |S |d r�|d |d< d |d< |S d|d < d |d< |S d |d < d �|d �|d< |S ) a|
Ensures that the JMS Destination Resource (queue or topic) is present
name
The JMS Queue/Topic name
physical
The Physical destination name
restype
The JMS Destination resource type, either ``queue`` or ``topic``, defaults is ``queue``
description
A description of the resource
enabled
Defaults to ``True``
Nr9 r^ zjavax.jms.Queue�resTypezcom.sun.messaging.QueueZ classNameZtopiczjavax.jms.Topiczcom.sun.messaging.TopicFr: r= r; r$ �
propertiesr> r? �admin_object_resourcer! r# Tr zJMS Queue set to be createdr zJMS queue createdr zJMS Queue set to be updatedzJMS Queue updatedz JMS Queue already up-to-datezError from API: {}rK ) r, ZphysicalrM r> r? r& r �params�jms_retr r r �destination_present. sL
� �
� ��rd c C s� | ddi d�}t | di |�}|d s8td r |d r d|d< |S |d r.d |d
< d |d< |S d |d
< d |d< |S d
|d
< d�|d �|d< |S )zg
Ensures that the JMS Destination doesn't exists
name
Name of the JMS Destination
Nr9 ra r! r# r0 zJMS Queue set to be deletedr; Tr: zJMS Queue deletedzJMS Queue doesn't existFrZ r[ )r, r& r rc r r r �destination_absentl s
���re �
datasource�mysql� � c C sv | ddi d�}d| � �}i }i }i }|dkrd|d< n|dkr$d|d< n|d kr-d
|d< n|d kr5d |d< i }d
dddd�|d< ddddd�|d< ddddd�|d < |d kr_|| d |d < n|| | |d < ||d < ||d < ||d!< ||d"< ||d#< ||d#< | |d$< ||d%< ||d&< | |d'< |
|d(< | |d)< | d* |d+< |
|d,< ||d-< ||d.< t | d/||�}t |d0||�}|d1 �s)|d1 �s)td2 s�d3|d4< |d5 s�|d5 r�|d6 |d6 d7< |d6 |d6 d8< td2 r�d9|d:< |S d;|d:< |S |d< s�|d< �r|d6 |d6 d7< |d6 |d6 d8< td2 �rd=|d:< |S d>|d:< |S d3|d4< i |d6< d?|d:< |S d@|d4< dA�|d1 |d1 �|d:< |S )Bas
Ensures that the JDBC Datasource exists
name
Name of the datasource
description
Description of the datasource
enabled
Is the datasource enabled? defaults to ``true``
restype
Resource type, can be ``datasource``, ``xa_datasource``,
``connection_pool_datasource`` or ``driver``, defaults to ``datasource``
vendor
SQL Server type, currently supports ``mysql``,
``postgresql`` and ``mssql``, defaults to ``mysql``
sql_url
URL of the server in jdbc form
sql_user
Username for the server
sql_password
Password for that username
min_size
Minimum and initial number of connections in the pool, defaults to ``8``
max_size
Maximum number of connections that can be created in the pool, defaults to ``32``
resize_quantity
Number of connections to be removed when idle_timeout expires, defaults to ``2``
idle_timeout
Maximum time a connection can remain idle in the pool, in seconds, defaults to ``300``
wait_timeout
Maximum time a caller can wait before timeout, in seconds, defaults to ``60``
non_transactional
Return non-transactional connections
transaction_isolation
Defaults to the JDBC driver default
isolation_guaranteed
All connections use the same isolation level
Nr9 zjdbc/rf zjavax.sql.DataSourcer_ �
xa_datasourcezjavax.sql.XADataSource�connection_pool_datasourcez"javax.sql.ConnectionPoolDataSource�driverzjavax.sql.Driverzcom.mysql.jdbc.Driverz-com.mysql.jdbc.jdbc2.optional.MysqlDataSourcez/com.mysql.jdbc.jdbc2.optional.MysqlXADataSourcez;com.mysql.jdbc.jdbc2.optional.MysqlConnectionPoolDataSource)rl rf rj rk rg zorg.postgresql.Driverz$org.postgresql.ds.PGSimpleDataSourcez org.postgresql.xa.PGXADataSourcez,org.postgresql.ds.PGConnectionPoolDataSourceZ
postgresqlz,com.microsoft.sqlserver.jdbc.SQLServerDriverz0com.microsoft.sqlserver.jdbc.SQLServerDataSourcez2com.microsoft.sqlserver.jdbc.SQLServerXADataSourcez>com.microsoft.sqlserver.jdbc.SQLServerConnectionPoolDataSourceZmssqlZdriverClassnameZdatasourceClassname�url�user�passwordr` r> r@ r? rA rB rC rD rE rF ZnonTransactionalConnectionsZtransactionIsolationLevelZisIsolationLevelGuaranteed�jdbc_connection_poolZ
jdbc_resourcer! r# Tr: r r rH rI z!JDBC Datasource set to be createdr; zJDBC Datasource createdr z!JDBC Datasource set to be updatedzJDBC Datasource updatedz%JDBC Datasource is already up-to-dateFrJ rK )r, r> r? rM �vendorZsql_urlZsql_userZ sql_passwordrN rO rP rQ rR Znon_transactionalZtransaction_isolationZisolation_guaranteedr& r Zres_namerS Zpool_data_propertiesrT Z datasourcesrV rW r r r �jdbc_datasource_present� s� H
�
�
� ��
� ��rr c C s� | ddi d�}t | dd|i|�}|d s:td r"|d r"d|d < |S |d r0d
|d < d |d < |S d
|d < d
|d < |S d|d < d�|d �|d < |S )z�
Ensures the JDBC Datasource doesn't exists
name
Name of the datasource
both
Delete both the pool and the resource, defaults to ``true``
Nr9 rp rY r! r# r0 z!JDBC Datasource set to be deletedr; Tr: zJDBC Datasource deletedz JDBC Datasource doesn't existFrZ r[ )r, r\ r& r rV r r r �jdbc_datasource_absent* s$ �
���rs c
K sH dddi d�}|d= z t d | d�}W n- tjy@ } z td r0||d< d|d < |W Y d}~S d
|d < |W Y d}~S d}~ww ||d �|d< ||ks�|�|� td s�zt d
|| d� ||d< d|d < d|d< W |S ty� } z||d< d|d < W Y d}~|S d}~ww d|d < ||d< d|d< |S i |d< d|d < d|d< |S )zf
Ensures that the system properties are present
properties
The system properties
r Nr9 r, � glassfish.get_system_propertiesr' r# r r: r% r! )r �kwargsz"glassfish.update_system_propertiesTzSystem properties updatedr; Fz)System properties would have been updatedZcomentz(System properties are already up-to-date)r r( r) r* r r )r& ru r r r! r r r �system_properties_presentG sJ ��
� ���rv c
C s dddi d�}z t d |d�}W n/ tjy? } z"td r/d| i|d< d|d < |W Y d}~S d
|d < |W Y d}~S d}~ww | |v r�td suzt d | |d� d
|d < d|d< W n" tyt } z||d< d|d < W Y d}~n
d}~ww d|d < d|d< d| i|d< |S d
|d < d|d< |S )zg
Ensures that the system property doesn't exists
name
Name of the system property
r Nr9 rt r' r# r$ r r: r% r! z"glassfish.delete_system_propertiesTzSystem properties deletedr; Fz)System properties would have been deletedz$System properties are already absentr1 )r, r& r r r! r r r �system_properties_absents s< �� �� �rw )N) r3 r Tr4 r5 r6 r7 r8 Fr FN)TN)r^ r TN)r Trf rg r r r rh ri r6 r7 r8 Fr TN)�__doc__Zsalt.utils.jsonr Zsalt.exceptionsr r( r � ImportErrorr r r r/ r2 rX r] rd re rr rs rv rw r r r r �<module> sh �
)
�
~
�
>
�
'
,