a
    .iv                     @   s   d dl Z d dlZd dlZd dlmZ ejd eee	 j
j
j
j
j
 d dlmZ d dlmZ d dlmZ dddZdd	d
ZdddZdddZdS )    N)Path)Satbot)app)CONFIGc                 C   sX   t  < tjtjjj| jk } | j	|||d W d    n1 sJ0    Y  d S )N)statelogprogress)
r   Zapp_contextr   queryfilterZ	__table__cidoneupdate)satbotr   r   r    r   r/var/www/staging/api/virtual_environments/venv/lib/python3.9/site-packages/main/services/satbots/scripts/shared.pyupdate_satbot   s    
r   Fc                 C   sL   |r| dng }| r0t| |s"|nd ||d n|D ]}td|  q4d S )N
)r   r   r   )splitr   print)r   stdoutr   r   Zsuppress_logr   messager   r   r   output   s
    r   c                 C   sx   |dkrt | d|p| d tj|dtjtjdd}|sTt | |j pP|j  |jdkrttd| d|j |S )N z
==========
T)shellr   stderrcheckr   zExiting after z returned value )	r   
subprocessrunPIPEr   decoder   
returncode
ValueError)r   commandZmaskedZsuppress_outputresultr   r   r   run_command   s    
r%   get   c              	   C   sr   |s|dd}d|d< t d |  } z$tt|| |||d}|j|jfW S  tjjtjjfyl   i df Y S 0 d S )Nzapplication/json)AuthorizationzContent-TypeZAPIz
User-Agentbase_url)timeoutheadersdatai  )r   getattrrequestscontentstatus_code
exceptionsConnectionErrorReadTimeout)urlmethodr+   r,   r*   Zapi_keyr   r   r   internal_api_request$   s    
r6   )NNN)NNF)NF)r&   NNr'   N)r   sysr.   pathlibr   pathinsertstr__file__resolveparentZmain.models.users.satbotr   r   setupr   r   r   r%   r6   r   r   r   r   <module>   s   $

	
