| Server IP : 198.38.94.13 / Your IP : 216.73.217.33 Web Server : Apache System : Linux d4744.dxb1.stableserver.net 5.14.0-611.49.1.el9_7.x86_64 #1 SMP PREEMPT_DYNAMIC Tue Apr 21 16:39:08 EDT 2026 x86_64 User : revivere ( 1140) PHP Version : 8.2.33 Disable Function : NONE MySQL : OFF | cURL : ON | WGET : ON | Perl : ON | Python : OFF | Sudo : OFF | Pkexec : OFF Directory : /opt/saltstack/salt/lib/python3.10/site-packages/salt/states/__pycache__/ |
Upload File : |
o
;j6U � @ 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�null�none� )�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^ �� ��� �
������r0 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" r1 zglassfish.delete_r' �r r) r* r+ r )r- r. r r' r r/ r" r r r �_do_element_absentx s.
�� ���r3 �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.QueueConnectionFactoryr4 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: {} // {}�r0 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
�� � ��rY 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``
Nr: r= rH �cascader" r$ r1 z$Connection Factory set to be deletedr< Tr; zConnection Factory deletedz Connection Factory doesn't existF� Error: {}�r3 r+ rM )r- �bothr' r rV rW 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``
Nr: 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: {}rL ) r- ZphysicalrN r? r@ r' r �params�jms_retr r r �destination_present. sL
� �
� ��re 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
Nr: rb r" r$ r1 zJMS Queue set to be deletedr< Tr; zJMS Queue deletedzJMS Queue doesn't existFr[ r\ )r- r' r rd r r r �destination_absentl s
���rf �
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
Nr: zjdbc/rg 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)rm rg rk rl rh 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�passwordra r? rA r@ rB rC rD rE rF rG ZnonTransactionalConnectionsZtransactionIsolationLevelZisIsolationLevelGuaranteed�jdbc_connection_poolZ
jdbc_resourcer" r$ Tr; r! r rI rJ 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-dateFrK rL )r- r? r@ rN �vendorZsql_urlZsql_userZ sql_passwordrO rP rQ rR rS Znon_transactionalZtransaction_isolationZisolation_guaranteedr' r Zres_namerT Zpool_data_propertiesrU Z datasourcesrW rX r r r �jdbc_datasource_present� s� H
�
�
� ��
� ��rs 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``
Nr: rq rZ r" r$ r1 z!JDBC Datasource set to be deletedr< Tr; zJDBC Datasource deletedz JDBC Datasource doesn't existFr[ r\ )r- r] r' r rW r r r �jdbc_datasource_absent* s$ �
���rt 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 Nr: 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' rv r r r" r r r �system_properties_presentG sJ ��
� ���rw 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 Nr: ru 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 absentr2 )r- r' r r r" r r r �system_properties_absents s< �� �� �rx )N) r4 r Tr5 r6 r7 r8 r9 Fr FN)TN)r_ r TN)r Trg rh r r r ri rj r7 r8 r9 Fr TN)�__doc__Zsalt.utils.jsonr Zsalt.exceptionsr r) r � ImportErrorr r r r0 r3 rY r^ re rf rs rt rw rx r r r r �<module> sh �
)
�
~
�
>
�
'
,