o
    _gU                     @   s^   d dl mZ d dlZedZedZeeeZ dedefddZdefd	d
Z	dd Z
dS )    )create_clientNSUPABASE_URLSUPABASE_KEY
article_idreturnc              
   C   sb   zt ddd|  }t|jdkW S  ty0 } ztd|  W Y d}~dS d}~ww )u+   id 컬럼 기준으로 중복 여부 확인motie_ididr   u   [❌] 중복 확인 실패: NF)	supabasetableselecteqexecutelendata	Exceptionprint)r   resulte r   +/var/www/html/bot/services/motie_service.pyis_article_processed
   s   r   c              
   C   sb   zt dd| i  td|   W dS  ty0 } ztd|  W Y d}~dS d}~ww )u   id 컬럼에 article_id 저장r   r   u$   [✅] Supabase에 id 저장 완료: u   [❌] Supabase 저장 실패: N)r	   r
   insertr   r   r   )r   r   r   r   r   mark_article_as_processed   s   r   c               
   C   sT   zt dd } | jW S  ty) } ztd|  g W  Y d }~S d }~ww )Nmotie_subscriberschat_idu   [❌] 구독자 조회 실패: )r	   r
   r   r   r   r   r   )r   r   r   r   r   get_motie_subscribers   s   r   )r	   r   osgetenvr   r   strboolr   r   r   r   r   r   r   <module>   s   


	