U i@sddlZddlZddlZddlZddlZddlZddlmZddlmZm Z m Z m Z m Z m Z mZmZmZmZddlmZddlmZddlmZmZddlmZmZmZddlmZmZdd l m!Z!m"Z"dd l#m$Z$m%Z%m&Z&ed e'Z(d Z)d ddhZ*e+dddZ,e-ddddZ.ej/e-dddZ0ej/e1ddddZ2e+dddZ3ddZ4e-d d!d"Z5e-e+d#d$d%Z6e-dd&d'Z7e-dd(d)Z8e-e-d*d+d,Z9ej:d-d.d/Z;d0d1Ze(j?d6d7d8d9d7Z@e(j?d:d;d8dd8d?d>ZBe(j?d@dAd8dBdAZCe(j?dCdDd8dEdDZDe(j?dFdGdHgdIdJdKdIZEe(j?dLdHgdMdJdNdMZFe(jGdOdPd8dQdPZHe(jIdRdSd8e-dTdUdSZJe(jIdVdWd8e-dTdXdWZKe(jIdYdZd8d[dZZLe(j?d\dHgd]dJd^d]ZMe(j?d_dGgd`dJe-dadbd`ZNe(j?dcdGgdddJe-dadeddZOe(j?dfdHgdgdJe-dadhdgZPe(j?didHgdjdJe-dadkdjZQe(j?dldGgdmdJe-dadndmZRe(j?dodGgdpdJe-dadqdpZSe(jGdrdsd8e-dadtdsZTe(jGdudvd8e-dTdwdvZUe(jGdxdyd8e-dTdzdyZVdS){N)datetime) Blueprint current_apprender_templaterequestredirecturl_forflash send_filejsonifysession)bulk_db)require_login_access_token) save_draft load_draft) safe_filenamevideo_duration_seconds_ffprobebuild_public_media_url)creator_can_post_nowparse_publish_at_iso_to_ts) load_token save_token)query_creator_infoupload_video_direct_postfetch_post_statusZuiZadmin_authenticatedcompletefailed cancelled)returncCstddk S)N tiktok_token)r getr!r!//var/www/html/luxverbi-app/app/blueprints/ui.py _is_connected%sr#)aliasrcCsR|pd}|sdSz$t|s6td}|r6t||Wntk rLYnXdS)u Defensa extra para el caso en que ya existan sesiones antiguas donde oauth_alias estaba seteado pero token_store no lo tenía aún. Nr)striprr r r Exception)r$atokr!r!r"_ensure_alias_token_persisted)s  r*)conn table_namec Csf|}|d|dg}|D]:}z||dWq&tk r^||dYq&Xq&|S)NzPRAGMA table_info()name)cursorexecutefetchallappendr')r+r,curcolsrowr!r!r"_table_columns;s r7)r+jobrcsht|dfdd|D}d|}ddgt|}|d|d|dt|dS) N bulk_jobscs"i|]\}}|tkr||qSr!)set.0kvr5r!r" Is z$_insert_bulk_job.., ?INSERT INTO bulk_jobs ( ) VALUES (r-)r7itemsjoinkeyslenr1tuplevalues)r+r8Zfilteredcolnames placeholdersr!r?r"_insert_bulk_jobGs  rMcCsttdkS)NT)r r ADMIN_SESSION_KEYr!r!r!r"_is_admin_authenticatedOsrOcCs,tr dStjrtjntj}ttd|dS)Nui.admin_login)next)rOr query_string full_pathpathrrnext_urlr!r!r" _admin_guardSsrW)stored_filenamecCs@|pd}|r(d|ks(d|ks(d|kr,dStjtjd|S)Nr%/\z.. UPLOAD_DIR)r&osrTrFrconfig)rXfilenamer!r!r"_job_file_pathZs r_)rXrcCst|}t|otj|S)N)r_boolr\rTisfile)rXrTr!r!r" _job_has_fileasrbcCsD|dkr dSztt|dWStk r>t|YSXdS)NNr%-z%Y-%m-%d %H:%M:%S)r fromtimestampintstrftimer'str)tsr!r!r" _format_tsfs rjcCs||dkr dSddddg}t|}|d}|D]$}|dksD||d krHqR|d }q,|dkrj|d d |St|d |S) NrcrdBZKBMBGBrig@z.1f )floatrf)sizeunitsvalueunitr!r!r" _format_bytesos  ru)statusrcCsD|pd}|dkrdS|dkr(dS|dkr4dS|dkr@dSd S) Nr%rokrerrrwarn submitting submittedinfo)r&lower)rvstr!r!r" _status_tone|sr)r6cCst|}|dpd}|tk|d<t||d<t|dpDd|d<t|d|d<t|d |d <t|d |d <t|d |d<|drt|dpd}zt j ||d<Wqt k rd|d<YqXnd|d<t |d|d<|S)Nrvr% is_terminalZ status_tonerXhas_file created_at_tsZcreated_at_label publish_at_tsZpublish_at_labelnext_attempt_tsZnext_attempt_label updated_at_tsZupdated_at_labelZfile_size_bytesZfile_size_label)dictr r&r~TERMINAL_JOB_STATUSESrrbrjr_r\rTgetsizeOSErrorru)r6r8rv file_pathr!r!r"_job_for_admins$  rcCsnttjd}tj|_|}|d|}| g}|D](}t |}|dr^|ds^q@| |q@|S)N BULK_DB_PATHz SELECT * FROM bulk_jobs ORDER BY CASE WHEN status IN ('scheduled', 'submitting', 'submitted') THEN 0 ELSE 1 END, publish_at_ts ASC, updated_at_ts DESC rr) r rr]sqlite3Row row_factoryr0r1r2closerr3)r+r4rowsjobsr6r8r!r!r"_load_admin_jobss  rc Cstjd}i}|D].}|dp"d}|s.q||g|qg}t|D]r}|s^qP| }||j g}||j |j t |j t t|jt|tdd|Dtdd|DdqP|jdd d |S) Nr[rXr%css|]}|drdndVqdS)rrr/Nr!r<jr!r!r" sz)_load_upload_inventory..css|]}|drdndVqdS)rr/rNr!rr!r!r"rs)rXZ size_bytesZ size_labelZmodified_at_labellinked_jobs_countactive_jobs_countZterminal_jobs_countcSs |ddk|d |dfS)NrrrrX)r~)itemr!r!r"s  z(_load_upload_inventory..)key)rr]r r& setdefaultr3r\scandiris_filestatr.st_sizerurjrfst_mtimerHsumsort) r upload_dirZ job_linksr8rXfilesentryrZ linked_jobsr!r!r"_load_upload_inventorys6   rcCsttjd}tj|_|}|d|f|}| d}d}|D]>}t |dpXd}|dpfd t kr~||7}qH||7}qH||fS)Nrz SELECT status, COUNT(*) AS total FROM bulk_jobs WHERE stored_filename=? GROUP BY status rtotalrvr%)r rr]rrrr0r1r2rrfr&r~r)rXr+r4rZactiveZterminalr6rr!r!r"_count_jobs_for_files"   rrYlanding)endpointcCstdtdS)Nz landing.htmlZ is_connectedrr#r!r!r!r"rs/appapp_homecCstdtdS)Nz index.htmlrrr!r!r!r"rsz/contactcontactcCstdtdS)Nz contact.htmlrrr!r!r!r"r sz/tostoscCstdS)Nztos.htmlrr!r!r!r"rsz/privacyprivacycCstdS)Nz privacy.htmlrr!r!r!r"rsz /admin/loginGETPOST admin_login)methodsrcCstrttdStjdp,tjdp,d}tjdkrtjdpJd}t t j dp\d}|rt ||rdtt<dt_tdd |d rt|SttdStd d td |dS)N ui.admin_jobsrQr%rpasswordADMIN_PASSWORDTzAcceso admin concedido.successrYuContraseña admin incorrecta.errorzadmin_login.htmlrU)rOrrrargsr formr&methodrhrr]secretscompare_digestr rNmodifiedr startswithr)rVprovidedexpectedr!r!r"rs       z /admin/logout admin_logoutcCs(ttddt_tddttdS)NTuSesión admin cerrada.rrP)r poprNrr rrr!r!r!r"r5s  z/admin admin_jobscCsNt}|r|St}dd|D}dd|D}t|}td|||t|dS)NcSsg|]}|ds|qSrr!r<r8r!r!r" Dszadmin_jobs..cSsg|]}|dr|qSrr!rr!r!r"rEszadmin_jobs.html)in_progress_jobs finished_jobs upload_filesZ total_jobs)rWrrrrH)guardrrrrr!r!r"r=sz/admin/jobs//canceladmin_cancel_jobjob_idcCst}|r|Sttjd}tj|_|}|d|f| }|sd| t ddt t dS|dpnd}|tkr| t dd t t dStt}|d |||f|| |jd krt d d t t dS|d krt dd n t ddt t dS)Nr"SELECT * FROM bulk_jobs WHERE id=?El trabajo indicado no existe.rrrvr%z!Ese trabajo ya estaba finalizado.warningz UPDATE bulk_jobs SET status='cancelled', next_attempt_ts=?, last_status='CANCELLED_BY_ADMIN', updated_at_ts=? WHERE id=? AND status NOT IN ('complete', 'failed', 'cancelled') r/uGNo se pudo cancelar el trabajo porque su estado cambió mientras tanto.rzulTrabajo cancelado localmente. Si TikTok ya había aceptado el envío, esta acción no puede retirarlo allí.z Trabajo cancelado correctamente.r)rWr rr]rrrr0r1fetchonerr rrr&r~rrftimecommitrowcount)rrr+r4r6rvnow_tsr!r!r"rQsD           z/admin/jobs//relaunchadmin_relaunch_jobcCst}|r|Sttjd}tj|_|}|d|f| }|sd| t ddt t dS|dpnd}|tkr| t ddt t dS|d pd}t|}|rtj|s| t d dt t dSt|d pdp|}tj} | d |} t| } zt|| WnLtk rt} z,| t d | dt t dWYSd} ~ XYnXtt} | | | | ddd|d|d|d|d|d|d|d|d|d|d|d| |dddd| d}zt|||Wnrt k rn} zR| zt!| Wntk r<YnXt d| dt t dWYSd} ~ XYnX| t d| dt t dS)Nrrrrrrvr%z-Solo se pueden relanzar trabajos finalizados.rXz=No se puede relanzar porque el archivo original ya no existe.original_filename_z6No se pudo duplicar el archivo para el relanzamiento: scheduledr access_token account_aliastitle privacy_level allow_comment allow_duet allow_stitchcommercial_togglebrand_organic_togglebrand_content_toggleis_aigcidrrrrvattemptsZ last_errorrrrrrrrrrrrrXr video_url publish_idZ last_statusZlast_fail_reasonrz#No se pudo crear el nuevo trabajo: zTrabajo relanzado. Nuevo job: r)"rWr rr]rrrr0r1rrr rrr&r~rr_r\rTraruuiduuid4hexshutilcopy2rrfrrMrr'remove)rrr+r4r6rvZsource_filename source_pathrZ new_job_idZnew_stored_filenameZ new_file_pathexcrr8r!r!r"rs        "   "z/admin/files/deleteadmin_delete_filec Cs t}|r|Stjdpd}t|}|sDtddttdSt |\}}t j |srtddttdSzt |WnBtk r}z$td|dttdWYSd}~XYnX|d krtd |d dn|d krtd d n tdd ttdS)NrXr%uNombre de archivo inválido.rrz&El archivo ya no existe en el sistema.rzNo se pudo borrar el archivo: ruArchivo borrado. Ojo: había uE trabajo(s) en curso usando ese vídeo y ahora quedarán sin fichero.uVArchivo borrado. Los trabajos finalizados asociados dejarán de mostrarse en el panel.rzArchivo borrado del sistema.)rWrrr r&r_r rrrr\rTrarr)rrXrZ active_jobsZ terminal_jobsrr!r!r"rs4      "   z /upload_local upload_localc Cst}|stddtdSdtjkr8tddtdStjd}|jsZtddtdStjd}t|j}t j }|d|}t j ||}||t||||dddd ddd ttd |d S) N!Please connect with TikTok first.rrZvideozNo video file provided.zNo file selected.r[rZlocal_uploaded) rrXrrlast_init_responseposting_summaryrvr bulk_job_idui.post_to_tiktokdraft_id)rr rrrr^rr]rrrrr\rTrFsaverr)rfilerZ original_fnrrXZ save_pathr!r!r"rs>         z/static_preview/static_previewrcCsJt}|sdSt|}|sdS|d}|r8tj|spost_to_tiktokc Cs2t}|stddtdSt|}|s:tddtdSz t|}Wn>tk r}z td|dtdWYSd}~XYnXt|\}}|d}t|d}d} d} t |t r|d kr|d kr||krd } d ||f} d} |d } | rt | t j d t j dt j dd} td|||| | | ||d S)NrrrDraft not found.8Cannot post right now. Please try again later. Details: max_video_post_duration_secrTrFz7Video is %.1fs but max allowed is %ss for this creator.rXPUBLIC_BASE_URLMEDIA_SIGNING_SECRETMEDIA_TOKEN_TTL_SECONDSrXZpublic_base_urlZsigning_secretZ ttl_secondszpost_to_tiktok.html)rr  creator_info duration_ok duration_msgpull_url can_post_nowcannot_post_reason)rr rrrr'rr r isinstancerfrrr]r) rrr rerrmax_durdurrrrrXr!r!r"r AsR      "  z/post//publishpublishcCsVt}|stddtdSt|}|s:tddtdSz t|}WnFtk r}z(td|dttd|dWYSd}~XYnXtj dd krtd dttj ptd St |\}}|st|pd dttd|dStj d pd }|s tddttj ptd Stj dp0d }tj ddk} tj ddk} tj ddk} | r|dkrtddttd|dS| dpg} || krtddttd|dStj ddk} tj ddk}tj ddk}| ddkrd} | ddkrd}| d dkr0d}| }| }| }d}d}| r| sv| svtd!dttd|dS| }| }|r|dkrtddttd|dS| d"}t |d#}t|tr |d$kr |d$kr ||kr td%||fdttd|dS| d&}|s4td'dttd|dStjd(}tj||}tj|sttd)dttd|dSt|tjd*tjd+tjd,d-}zrt||||||||dd.|d/ }| d0pi d1}t||||||| ||| | | d2d3|d4ttd5|dWStk rP}z(td6|dttd|dWYSd}~XYnXdS)7Nrrrr r rr music_confirm1uEYou must agree to TikTok’s Music Usage Confirmation before posting.z ui.app_homezJThis TikTok account cannot publish at this moment. Please try again later.rr%z1Please select a Privacy status before publishing.rron your_brandbranded_content SELF_ONLYzIBranded content cannot be posted with privacy set to Only me (SELF_ONLY).privacy_level_options'You must select a valid privacy option.rrrcomment_disabledTF duet_disabledstitch_disabled]If commercial content disclosure is on, you must select Your brand, Branded content, or both.r rr1Video duration %.1fs exceeds allowed maximum %ss.rX2Internal error: missing stored_filename for draft.r[Video file not found on server.rrrrZ PULL_FROM_URL) rZcaptionrdisable_comment disable_duetdisable_stitchrrrmoderdatar)rrrrrrr r!Zposted)rrrrvrzui.status_pagezError posting to TikTok: )rr rrrr'rrrr referrerrr&rrrfrr]r\rTrFrrrr)rrr rrrrrrrr r!optionsrrrr,r-r.rrrrrXr local_pathrZ init_resprr!r!r"rxs   &          *     z/post//schedule schedule_postc"st}|stddtdSt|}|s:tddtdStdpFd}|sbd}|td<dt_t|t j d pxd}|std dtt d |d Sz t |}WnFt k r}z(td |dtt d |d WYSd}~XYnXt j ddkrtddtt d |d St j dp,d}|sRtddtt d |d St j dpbd}t j ddk} t j ddk} t j ddk} | r| s| stddtt d |d St| o| } t| o| } | r |dkr tddtt d |d St j ddk}t j ddk}t j ddk}|d}|rXtj|srtddtt d |d S|d }|d!pdptj|}|std"dtt d |d Sz t|}|d#pg}|r||krtd$dtt d |d WS|d%dkrd&}|d'dkr.d&}|d(dkrBd&}|d)}t|}t|tr|d*kr|d*kr||krtd+||fdtt d |d WSt|\}}|st|pd,d-d.Wn4t k r}ztd/|d.W5d}~XYnXtt}tj}||||d0d*d|||||r6d1nd*|rBd1nd*|rNd1nd*| rZd1nd*| rfd1nd*| rrd1nd*d1||dddd|d2}ttjd3}tj |_!|"}|#d4d5d6|$D}t%|fd7d8|&D}d9'|(} d9'd:gt)|}!|#d;| d<|!d=t*|+|,|-t.||d0||||||| | | ||d> d?td@|dAtt dB|dCS)DNrrrr Z oauth_aliasr%defaultT publish_atz#Please select a schedule date/time.rrz.csi|]\}}|kr||qSr!r!r;Zcolsetr!r"r@sz!schedule_post..rArBrCrDr-) rrrrrrr r!r6r)rvrrzScheduled job created: rzui.bulk_job_pager)/rr rrr r r&rr*rrrrr'r`r\rTrbasenamerrrrfrrrrrr rr]rrrr0r1r2r:rErFrGrHrIrJrrr)"rrr rr6rrrrrr r!rrrrrrrXrrr2rrrrrrr8r+r4r5rKrLr!r8r"r4s    &       "   * "         "z/status/ status_pagecCsHt}|stddtdSt|}|s:tddtdStd||dS)Nrrrr z status.html)rr )rr rrr)rrr r!r!r"r:s  z/api/status/ api_statusc Cst}|stddddfSt|}|s:tddddfS|d}|sZtdd d d fSzt||}td|d d fWStk r}ztdt|dd fWYSd}~XYnXdS) NFnot_authenticatedrwrrdraft_not_foundrrTZno_publish_id_yet)rwstate)rwr0)rr rr rr'rh)rrr rr0rr!r!r"r;s  z/api/media_url/ api_media_urlcCst}|stddddfSt|}|s:tddddfS|d}|sZtdddd fStjd }tj||}tj |stdd ddfSt |tjd tjd tjdd}td|dS)NFr<r=rr>rrXZmissing_stored_filenameir[Zfile_not_foundrrrrT)rwurl) rr rr rr]r\rTrFrr)rrr rXrr3rBr!r!r"rAs(   z/bulk/job/ bulk_job_pagecCs(t}|stddtdStd|dS)Nrrrz bulk_job.htmlr)rr rr)rrr!r!r"rCs  z/api/bulk/job/ api_bulk_jobcCst}|stddddfSttjd}tj|_|}| d|f| }| |sntddddfStd t |d d fS) NFr<r=rrrZ not_foundrT)rwr8r@) rr r rr]rrrr0r1rrr)rrr+r4r6r!r!r"rDs)Wr\rrrrrrflaskrrrrrrr r r r db.bulkr Z services.authrZservices.draftsrrZservices.mediarrrZservices.creatorrr token_storerrZ tiktok_clientrrr__name__bprNrr`r#rhr* Connectionr7rrMrOrWr_rbrjrurrrrrrrouterrrrrrrr rpostrrrrrr rr4r:r;rArCrDr!r!r!r"s 0        &               4 W  ' )6: