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   app_contextr   queryfilter	__table__cidoneupdate)satbotr   r   r    r   E/var/www/staging/api/app_home/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   command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-TypeAPIz
User-Agentbase_url)timeoutheadersdatai  )r   getattrrequestscontentstatus_code
exceptionsConnectionErrorReadTimeout)urlmethodr/   r0   r.   api_keyr   r   r   internal_api_request$   s    
r;   )NNN)NNF)NF)r)   NNr*   N)r   sysr2   pathlibr   pathinsertstr__file__resolveparentmain.models.users.satbotr   r   setupr   r   r   r(   r;   r   r   r   r   <module>   s   $

	
