
    该j                     \    d dl Z d dlZd dlmZmZ d dlmZmZ d dlmZ dZ	d Z
d Zd Zd	 Zy)
    N)datetimetimezone)BufferErrorchannels)create_postBUFFER_AS_API_KEYc                     t        j                  |       }|j                  d      D ch c]  }|d   	 }}dD ]  }||vs|j                  d| d        |j                          |j	                          y c c}w )Nz pragma table_info(content_items)   )buffer_post_idbuffer_channel_idbuffer_synced_atbuffer_errorbuffer_modebuffer_due_atz%alter table content_items add column z TEXT)sqlite3connectexecutecommitclose)db_pathcrcolsnames        ,/opt/struktur/asol-runtime/buffer_support.pyensure_schemar   	   sy    oogA		"DE	F1!A$	FD	Fv KtII=dV5IJK HHJ		 
Gs   A9c                      t         j                  j                  t              xs dj	                         } | st        d      | S )N zASO Buffer API-Key fehlt)osenvironget	TOKEN_ENVstripr   )tokens    r   _tokenr%      s6    ::>>)$*
1
1
3E455L    c                  x    	 dt        t                     dS # t        $ r} dt        |       dcY d } ~ S d } ~ ww xY w)NT)okr   Fr(   error)r   r%   r   str)es    r   buffer_statusr-      s8    +Xfh%788 +3q6**+s    	9499c                 n   |j                  d      xs dj                         }|j                  d      xs dj                         j                         }t        |j                  d      xs d      }|dk(  rddd	S t	        j
                  |       }t        j                  |_        |j                  d
||f      j                         }|s|j                          ddd	S t        |      }|j                  d      xs dj                         }|j                  d      xs( |j                  d      xs |j                  d      xs dj                         xs d }	|	rF|	j                  d      r5t        j                  j                  d      xs dj                  d      |	z   }	|j                  d      xs dj                         }
|j                  d      xs d }d }|j                  d      xs dj                         xs d }|j                  d      xs dj                         }	 t!        t#               |||||	|
|||
      }t%        j&                  t(        j*                        j-                         }|j                  d|||d   |d   |||j                  d      xs |||f	       |j/                          |j                          d||d|S # t0        $ rY}|j                  d t        |      d d! ||f       |j/                          |j                          dt        |      d	cY d }~S d }~ww xY w)"N	signal_idr   platformfacebookbodyreelsFz9Reels werden nicht als normaler Instagram-Post uebergebenr)   z<select * from content_items where signal_id=? and platform=?zEntwurf nicht gefundenactiondraft	media_urlpost_media_url	image_url/ASOL_PUBLIC_URLz,https://sma-asol.agentsolutions-mallorca.com
media_kindimagedue_atlink_url	post_typepost)r4   r=   r6   r;   first_commentr>   r?   zupdate content_items set body=?,updated_at=?,buffer_post_id=?,buffer_channel_id=?,buffer_synced_at=?,buffer_error=NULL,buffer_mode=?,buffer_due_at=? where signal_id=? and platform=?post_id
channel_idT)r(   r4   r0   zHupdate content_items set buffer_error=? where signal_id=? and platform=?i  )r!   r#   lowerr+   r   r   Rowrow_factoryr   fetchoner   dict
startswithr   r    rstripr   r%   r   nowr   utc	isoformatr   r   )r   datasidr0   r2   r   rowdr4   r6   r;   r=   rA   r>   r?   resrK   r,   s                     r   handoffrS      s   	+		$"++-Chhz"0j779??AH	TXXf#	$D7#^__oogAgkk			PRUV^Q_`iikC		.FGG
3iAHHX)'002Fxx$[.>(?[155CU[Y[bbdlhlIY))#.::>>"34f8fnnorsv	&1'88:J88H%FMhhz"(b//19THxx$.557I+$fF"+z&3X"+- LL&002			  JC	N3|+<SPXHYHc]cdghpq	s	
AGGI6XDDD +			\^abc^deifi^jknow]xy	
AGGI3q6**+s    (B)K 	L4AL/)L4/L4)r   r   r   r   buffer_bridger   r   buffer_publishr   r"   r   r%   r-   rS    r&   r   <module>rW      s*     ' / &	+!+r&   