\j<ddlZddlZddlZddlZddlZddlZddlmZmZddl m Z e e  j dZedz Zedz Zedz Zedz Zed z Zed z Zd Zdd ZdZdZdZedkrejedSdS)N)datetimetimezone)Pathzoutput/final.mp4zlog/final-render.jsonzstory/promotion-report.jsonzoutput/final-upload.mp4z$log/upload-transcode-submission.jsonzlog/upload-transcode.jsonzhttp://192.168.1.104:8024cV|&tj|nd}tjt |z||rddini|}tj||5}tj|cdddS#1swxYwYdS)Nz Content-Typezapplication/json)dataheadersmethod)timeout) jsondumpsencodeurllibrequestRequestBASEurlopenload)r pathpayloadr bodyreqresponses script/transcode-upload.pyrrs)0)<G   # # % % %$DtDydbf;nNK];^;^lnv|}}C   G  4 4[ RZH[H[[[[[[[[[[[[[[[[[[[s=BB"%B"ctj}|d5tfddD]}|| dddn #1swxYwY|S)Nrbc.dS)Ni)read)fsrzsha..s !4!4r")hashlibsha256openiterupdate hexdigest)rhblockr s @rshar+s nA 4JA4444S99IIE!((5////IJJJJJJJJJJJJJJJ ;;==s,A##A'*A'ctjdddddddddt|g d d d }tj|jS) Nffprobez-verrorz -show_entrieszformat=duration,sizezMstream=index,codec_name,width,height,sample_rate,channels:stream_tags=encoderz-ofr T)capture_outputtextcheck) subprocessrunstrr loadsstdout)routs rprober8s $w?UVegvw|}CDGHLDMDMN^bhlsw x x xC :cj ! !!r"c tttfD](}|st d|)t jt}t jt}|d}|ddus0|ddus|d|krt dtr(tst dtrt jt}|ddur|d|krtrkt j dkrItt jd|d t j d d Std d }|ddks|ddurt dd}t rFt jt }|d|kr|}|t#tt#tdddddddd }tdd|} dd|| d | d|t%jt(jd}t t j|dddz|d } t1d D]B} td d!| z} | dd"vrn$t3jd#Ct d$| dd%ks+| d&iddur;t d'| dd(| d)t7t} | d*g}d+|D}d,|D}t9|dkot9|dko|d d-d.ko|d d-d/ko||d d0dko]|d d1dko>t j dko| d&d2du}d||rd%nd3|| t:t#tt>t#tt>t j tAt| d&| t%jt(jd4 }tt j|dddztt j|| |d5|d6d7d8|rd ndS)9NzTranscode blocked: missing spoken_sha256verifiedTsource_canon_sha256z/Transcode blocked: final/canon receipt mismatchz2Unreceipted upload output exists; do not overwriteiʚ;job_id)reused_verifiedr=bytesrGETz/healthstatusok h264_nvenczTranscode endpoint unhealthyi/`ii8rF) input_video_pathoutput_video_pathtarget_output_bytesmax_output_bytesaudio_bitrate_kbpswidthheightfps overwritePOSTz!/v1/huyenan-transcode-upload/jobsr)versionr;r<r=rAr submitted_at) ensure_asciiindent iz"/v1/huyenan-transcode-upload/jobs/>failed cancelled completed z'Transcode poll timeout; resume same jobrW verificationzTranscode job ended z: r.streamsc<g|]}|d|S)rJget.0ss r zmain..<s->d>d>dQUVUZUZ[bUcUc>dq>d>d>dr"c<g|]}|d|S) sample_rater\r^s rrazmain..<sclXlXlXrsCDCHCHIVCWCWlXlmlXlXlXr" codec_nameh264aacrJrK under_one_gbrU) rOr;rAr<r=endpointinputoutput output_bytes output_sha256server_verificationindependent_probe checked_atrkrl)r;r=r?r$)rR)!FINAL FINAL_RECEIPT PROMOTIONexists RuntimeErrorr r5 read_textr]OUTPUTRECEIPTstatst_sizeprintrr SUBMISSIONr4rnowrutc isoformat write_textrangetimesleepr8lenr relative_toPROJECTr+)r final_receipt promotioncanonoldhealth submission candidatercreatedr=_joblocalrZvideoaudior;receipts rmainr s}Y/VV{{}}U<0Td0T0T#U#UUU*]446677M$*YM`M`MbMbBcBc jsjwjwyHkIkIdi}}Z  ,, 0A0A*0M0MUY0Y0Y]j]n]npE^F^FHM^M^MT`aRTSTSNS }}xw~~//xlCw6x6x0x~~v Jw((** + + 77:  $ & &3773H+I+I5+P+PU[UbUbUdUd+Pioititivivi~@MjMjM $*c(mTZT_T_TaTaTijjkk l l ltutu 5 # #F zz(T!!VZZ %=%=T%I%IP\]{P|P|J|JL*Z113344 ==. / / 6 6)z$'JJ3v;;epERhjswAELN[`aaB7KK5uV]^fVgqxzBrCNUemeqrzr~eeeIeIeKeKLL djaPPPQUUVVV h F 3ZZGG E>vE F F 778   B B B55 2EFF F wwx+%%)C)C)G)G )S)S[_)_)_frtrKNKRKRS[K\K\trtr`c`g`gho`p`ptrtrgsgsas --E )B 7 7>d>d'>d>d>dlXlXw~lXlXlXej%jj!mXE A X%(,,|2L2Lf2TXY^_`YaYeYefrYsYsuzYzX@EFG@H@L@LMT@U@UW[@[X`efg`h`l`lmu`v`vx|`|XAGALALANANAVWdAdXilm{i|i@i@AOiPiPTXiXHHX6[kkS[rwBHTXadejevevw~eea@a@JMNTN`N`ahNiNiJjJjz@zEzEzGzGzO`cdj`k`kBEFTBUjo}E}IJRJV}W}W}a}a}c}c d dG tz'uAFFFtKLLL $*6'.BYcjkzc{||KP Q Q QRRR_gZnZ[Z[mnSnr"__main__)Nr)r#r r2sysrurllib.requestrrrpathlibr__file__resolveparentsrrprqrrrvr{rwrrr+r8r__name__exitr"rrsL  '''''''' X  (+   -- / / (( 9 9 ++ \\\\ """ n n nB Z(((((r"