b\jW<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}|ddus[|ddusD|d|ks+|dttkrt dtr(tst dtr t jt}|ddur|d|krtrt j d krt|dttkrItt jd|d t j d d St!d d}|ddks|ddurt dd}t"rFt jt"}|d|kr|}|t%tt%tdd dddddd }t!dd|} dd|| d | d|t'jt*jd}t"t j|ddd z|d } t3d!D]B} t!d d"| z} | dd#vrn$t5jd$Ct d%| dd&ks+| d'iddur;t d(| dd)| d*t9t} | d+g}d,|D}d-|D}t;|dkot;|dko|d d.d/ko|d d.d0ko||d d1dko]|d d2dko>t j d ko| d'd3du}d||rd&nd4|| t<t%tt@t%tt@t j tt| d'| t'jt*jd5 }tt j|ddd ztt j|| |d6|dd7d8|rd ndS)9NzTranscode blocked: missing spoken_sha256verifiedTsource_canon_sha256 output_sha256z4Transcode blocked: final/canon/hash 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>rBr submitted_at) ensure_asciiindent iz"/v1/huyenan-transcode-upload/jobs/>failed cancelled completed z'Transcode poll timeout; resume same jobrX verificationzTranscode job ended z: r.streamsc<g|]}|d|S)rKget.0ss r zmain..<s->d>d>dQUVUZUZ[bUcUc>dq>d>d>dr"c<g|]}|d|S) sample_rater]r_s rrbzmain..<sclXlXlXrsCDCHCHIVCWCWlXlmlXlXlXr" codec_nameh264aacrKrL under_one_gbrV) rPr;rBr<r>endpointinputoutput output_bytesr=server_verificationindependent_probe checked_atrl)r;r>r@r$)rS)!FINAL FINAL_RECEIPT PROMOTIONexists RuntimeErrorr r5 read_textr^r+OUTPUTRECEIPTstatst_sizeprintrr SUBMISSIONr4rnowrutc isoformat write_textrangetimesleepr8lenr relative_toPROJECT)r final_receipt promotioncanonoldhealth submission candidatercreatedr>_joblocalr[videoaudior;receipts rmainr sx }Y/VV{{}}U<0Td0T0T#U#UUU*]446677M$*YM`M`MbMbBcBc jsjwjwyHkIkIdi}}Z  ,, 0A0A*0M0MUY0Y0Y]j]n]npE^F^FHM^M^MQ^QbQbcrQsQsuxy~uuQQFRSIFJFJ@J }}xw~~//xlCw6x6x0x~~v Jw((** + + 77:  $ & &3773H+I+I5+P+PU[UbUbUdUd+Pioititivivi~@MjMjMRURYRYZiRjRjlopvlwlwRwRw $*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"