ҷhJ ddlmZmZmZmZddlmZddlmZmZm Z ddl Z ddl m Z m Z ddlmZddlmZddlmZdd lmZdd lmZdd lmZmZmZdd lmZdd lmZddlZddl Z ddlm!Z!ddl"m#Z#ddlm$Z$m%Z%ddl&Z&ddl'Z'e'jPdZ)e'jPdZ*de deede+defdZ,dede-fdZ.de/ede-fdZ0de+de+fdZ1dZ2d e3d!e3fd"Z4d-defd#Z5d$Z6de+de+fd%Z7d&e+de-fd'Z8d(e+d)e+d*e/e+de/e+fd+Z9d-defd,Z:y).)timezoneUTCAmbiguousTimeErrorNonExistentTimeError)UnknownTimeZoneError)datetimetimedateN)schema controller)get_db)get_db_session)Session)PostTypeConfig) MasterAccount) HTTPExceptionDependsstatus)func)Optional)ConnectedAccount) BeautifulSoup)CalendarPostType PostImage FB_APP_ID FB_APP_SECRET schedule_date schedule_timetz_strreturnc t|xsdj}t j ||xs t dd} |j|d}|jtS#t$rtdd|wxYw#t$r|j|d}YPt$rtddwxYw) NrizInvalid timezone: ) status_codedetailr)is_dstFz4Scheduled time does not exist due to DST transition.) rstriprrrcombiner localizerr astimezoner)rrruser_tzlocal_dtlocal_dt_with_tzs r?r@rArBrCadditional_notes) getqueryr filter_byfirstprintridaddcommit) r.r/ platform_info platform_namemaster_accountr5post_type_specpost_type_nameexisting post_specs r,save_social_config_to_dbrU5s$b9( %))*A2F -0::]:[aac 1-@VW X "&&|R8 ( N+// R@Nxx/99"0"3"3&(:eg   N#33CM?Rmno&"0"3"3&(,00%H-112BEJ)7););r?r@rArBrCrDr5)r8r6r9r:r;r<r=r>r?r@rArBrCrEappendlistvalues)rWresult platform_dictconfigr8r6post_type_datas r,format_post_type_configsr`ds2 FME??$$ = ()1 'M( # ##11$33(.(G(G$33#11$33"(";";!--(.(G(G!'!9!9$*$?$?++  h -44^D5E:}3356F; MrVhtmlct|d}d}gd}|j|D]}||j|_|jS)z0Convert HTML to styled Unicode text for Twitter.z html.parserc ittdtddzDcic]&}t|td|tdz z(c}ttdtddzDcic]&}t|td|tdz z(c}djfd |DScc}wcc}w) NAZiazir3c3BK|]}j||ywN)rF).0c bold_charss r, z=html_to_unicode_styled..style_bold..s:z~~a+:s)rangeordchrjoin)textirms @r, style_boldz*html_to_unicode_styled..style_bolds >CCHcRUhWXj>YZs1vs7a#c(l344Z >CCHcRUhWXj>YZs1vs7a#c(l344Z ww:T:::[Zs +C7+C)strongbemrtupbrh1h2h3olulli blockquote)rfind_allget_textstring)rasouprutags_to_handletags r,html_to_unicode_styledrsT } -D; N }}^,0 / 0 ==?rVz!https://ap.bestbrain.ai/x/refresh branch_idconnected_account_idc t}tjd|dt|i}ddd}t d|t j dt||}t d |jt d |jt ||jd k(r|j}|jd ijd }|s'tjd |jy|jtj!tj"|k(j%}|s*tjd| |jy||_|j)|j+|tjd|||jStjd|jd|j |jy#t,$r2} tjd| Yd} ~ jyd} ~ wwxYw#jwxYw)Nu ❌❌❌ app_idapplication/jsonzinsomnia/11.2.0) Content-Typez User-Agent REFRESH_BODYPOSTjsonheaderszStatus: z Response: tokenData access_tokenu(❌ Refresh API returned no access tokenu&❌ ConnectedAccount not found for ID u?🔄 Successfully refreshed Twitter token for ConnectedAccount u❌ Failed to refresh token:  - u%❌ Error calling token refresh API: )rlogginginfostrrJrequestsrequest REFRESH_URLr"rsrrFerrorcloserGrfilterrKrItokenrMrefresh Exception) rrr.rrrespdata new_tokenconnected_accountes r,refresh_twitter_tokenrs+$& z)-/ #i.1 .+  nl+{wW ))*+, 499+&' d   s "99;Db155nEI HI2  -)*(++/CCD  % FG[F\]^  '0  # IIK JJ( ) LLZ[oZpq r  MM9$:J:J9K3tyykZ [   =aSAB    s>C0HAH3AH/H IH<'I<IIIc>| t} |jj}|s tdt |dd}|s tdd}d|dd}t |}d|i}t j||| }|jd vrItjd |jd |jd t|j|jj} | rd| |d<t j||| } | jrtjd|j| j!j#dij#dd} | |_|j'|j)|d| dStj*d| jd| j,dd|jdS|jsAtj*d|jd|j,dd|jdStjd|j|j!j#dij#dd} d| dS#t j.j0$r@} tj*d|jd| ddt3| dcYd} ~ Sd} ~ wt4$r@} tj*d|jd| dd t3| dcYd} ~ Sd} ~ wwxYw)!Nz(Missing access token for Twitter accountcontentzNo content to post for Twitterz https://api.twitter.com/2/tweetszBearer r) Authorizationrrsriiu ⚠ Twitter  for PostType z, refreshing token...)rrru:✅ Posted to Twitter after token refresh for PostType ID rrKTsuccesspost_idu-❌ Twitter post failed after token refresh: rFz Twitter post failed with status rru❌ Twitter API error : u&✅ Posted to Twitter for PostType ID u%❌ HTTP request failed for PostType HTTP request failed: u5❌ Unexpected error posting to Twitter for PostType Unexpected error: )rrr ValueErrorgetattrrrpostr"rwarningrKrrokrrrFexternal_post_idrMrrrs exceptionsRequestExceptionrr) r6r.rrurlrtwitter_text_html_boldpayloadresponser retry_resprrs r,post_to_twitterrs z$&N  2288 GH H)Y5=> >0&|n5. "8!@12==7GD   : - OOl8+?+?*@y||n\qr s-#--%.%@%@%C%CI -4YK+@(%]]3WgN ==LL#]^g^j^j]k!lm(oo/33FB?CCD$OG18I.IIKJJy)#'#* MM$QR\RhRhQiilmwm|m|l}"~ ;H.DsAtT[[]As)rrr splitlinesr%)rarss r,html_to_facebook_textr=s3 "$ 'D 99At/@A A G G IIrV user_tokenc BKtjd4d{}td}|j|dtt |dd{}|j |jcdddd{S7f777 #1d{7swYyxYww)z Refresh a Facebook access token to get a new long-lived token. Args: user_token: The current user access token to refresh Returns: dict: Contains new access_token and expires_in )timeoutNz/oauth/access_tokenfb_exchange_token) grant_type client_id client_secretr)params)httpx AsyncClientGRAPHrFAPP_ID APP_SECRETraise_for_statusr)rclient token_urlrs r,refresh_facebook_tokenrKs  ,  g01 **Y-'!+ 0 *   vvx        sVBBB-B B#B 2 B>B?BB B BB BBpage_id page_token image_urlsc g}tj5}|D]}|jtd|d|d|dd}|jdk(r4|j j d}|sV|j|htjd |jd |j d d d |S#1swY|SxYw) z| Upload images as unpublished photos to get media IDs. Later attach them via attached_media on /{page_id}/feed. /z/photosfalse)r publishedrrrrrKu❌ FB photo upload failed: rN) rrrrr"rrFrYrrrs)rrr media_idssrrmids r,_collect_fb_media_idsras I    Yq YC'7)7+!($. A}}#ffhll4($$S) 0AB>>Cc| t} t|dd}t|ddt|dd}s td|s tdt|dd}|s tdt|t|d dgt |d rM|j rA|j D]2}t|d dxs t|d d}|s"j |4d tffd }||}|jdvr^tjd|jd|jdt|} | d} | jdd} ttjt| z} | r| |_| |_|j%|j'||| } | j(r8| j+xsijd} d| d|j-Stj.d| jd| j0dd| jd|j-Sddd|j-S|j(sQtj.d|jd |j0dd|jd|j-S|j+xsijd} d| d|j-S#t2j4j6$rP}tj.d!|jd |dd"t|dcYd}~|j-Sd}~wt8$rP}tj.d#|jd |dd$t|dcYd}~|j-Sd}~wwxYw#|j-wxYw)%z Mirrors post_to_twitter: - Formats HTML into styled Unicode text - Posts to /{page_id}/feed (text + link) or text + images via attached_media - On 401/403, refresh the Page Access Token using the stored long-lived user token Nrexternal_account_idrz,Missing Facebook page_id on ConnectedAccountz;Missing Facebook page Page Access Token on ConnectedAccountrzNo content to post for Facebooklinkimagesr image_urlcurrent_page_tokenc`di}rWt |}|stjd|r1t|D]#\}}t j d|i|d|d<%r%t d|jDs|d<tjtd d i|d |id }|S) Nmessageu8⚠ No media IDs created; falling back to text/link only media_fbidzattached_media[]c3>K|]}|jdyw)attached_mediaN) startswith)rkks r,rnz5post_to_facebook.._do_post..sW1 -= >Wsrrz/feedrrr) rrr enumeraterdumpsanykeysrrr) rrridxrrrrrrs r,_do_postz"post_to_facebook.._do_posts '*G1';MzZ  OO$^_$-i$8\S<@JJ VYGZ<[/#a 89\CW WW"& '7)5)DD1CDA HrVru⚠ FB rz; attempting token refresh...r expires_iniOrKTru"❌ FB post failed after refresh: rFzFacebook post failed: rz%Failed to refresh Facebook Page tokenu❌ Facebook API error ru(❌ HTTP request failed for FB PostType ru6❌ Unexpected error posting to Facebook for PostType r)rrrrhasattrrrYrr"rrrKrrFintr r expires_atrMrrrrrrsrrrr)r6r.car content_htmlimgryrrrefresh_resultrrr2rrrrrrs @@@@r,post_to_facebookr {s z$&m Y 3T :"3T:R$/ KL LZ[ [y)T: >? ?' 5y&$/  9h 'I,<,< '' )C-Pk41P%%a( )    6 Z  ==J & OOgamm_N9<<.Pmn o3Z@N&~6I'++L+FJTYY[)C O;J$ *   2i(55!wwyB33D9G'+@4  1MM$Fr~~FVVYZ\ZaZaYb"cd',9OPRP^P^O_7`a.  +$)3Z[*  'tt MM3AMM?"QVVHM N$1G /WX"  668>r&&t,  "$      / /M @bQRPSTU -B3q6(+KLL  J Ny||n\^_`^abc -?Ax+HII  J  siB:K9 D K9>AK9K9$A K9'K99N=5M! N= O! N=-5N8"N=#O8N==OOrj);pytzrrrrpytz.exceptionsrrr r rsrc.marketing.apps.postr r src.utils.dbr rsqlalchemy.ormrsrc.marketing.apps.post.modelr src.marketing.apps.Account.modelrfastapirrr sqlalchemyrtypingrrrrbs4rrrrosgetenvrrrr-dictrUrZr`rrrrrrrrrr rVr,rsdHH0(( 6'"8:22=E ;  RYY ' ,$,x~,s,W_,2**t*^"d>&:"t"R<2 ,S,,dQ 'Q v +JJJST,3CT#YSWX[S\4v7vrV