o
    jEi                  
   @   s   d dl Z d dlZd dlmZ d dlmZ zd dlmZ W n e	y2 Z
 z
dZe
ZW Y dZ
[
ndZ
[
ww eeZejdddd ZdS )	    N)load_dotenv)
celery_app)get_token_statusz/keepa_deals.diag_task.run_api_connectivity_test)namec               
   C   s>  t d t d tdu rt dt  t d dS z{zNt  td} | s<t d t d W W t d dS t d	 t d
 t| }|rcd|v rc|d }t d t d| d nt d|  W n ty } zt jd| dd W Y d}~nd}~ww W t d dS W t d dS t d w )zd
    A simple diagnostic task to test basic Keepa API connectivity from within a Celery worker.
    z!--- [DIAGNOSTIC TASK STARTED] ---z,Attempting to test Keepa API connectivity...NzK[DIAGNOSTIC][CRITICAL FAILURE] Failed to import 'get_token_status'. Error: z---- [DIAGNOSTIC TASK FINISHED WITH ERROR] ---KEEPA_API_KEYzM[DIAGNOSTIC] KEEPA_API_KEY not found in environment. The task cannot proceed.z"--- [DIAGNOSTIC TASK FINISHED] ---z)[DIAGNOSTIC] API Key loaded successfully.z*[DIAGNOSTIC] Calling get_token_status()...
tokensLeftz:[DIAGNOSTIC][SUCCESS] Successfully connected to Keepa API.z[DIAGNOSTIC] API reports z tokens remaining.z>[DIAGNOSTIC][FAILURE] API call failed. The function returned: zA[DIAGNOSTIC][CRITICAL FAILURE] An unexpected exception occurred: T)exc_info)	loggerinfor   errorIMPORT_ERRORr   osgetenv	Exception)api_keystatus_datatokens_lefte r   0/var/www/agentarbitrage/keepa_deals/diag_task.pyrun_api_connectivity_test   s>   








 r   )r   loggingdotenvr   workerr   celerykeepa_deals.keepa_apir   ImportErrorr   r   	getLogger__name__r	   taskr   r   r   r   r   <module>   s   

