= fvddlZddlZddlZddlZddlZddlZddlmZddlm Z ddl ddl ddl m Z mZmZmZddlmZddldZdZdZd Zd Zd ZdZdZdZdZdZd Zd Z d Z!dZ"dZ#d Z$dZ%dZ&dZ'dZ(d Z)d Z*d Z+dZ,dZ-d Z.dZ/dZ0dZ1dZ2dZ3dZ4dZ5dZ6dZ7dZ8dZ9d Z:dZ;dZd Z?dZ@dZAdZdZd Zd Zd ZdZBdZCd ZDdZEdZFdZGdZHdZIdZJGddeKZLGddejZNGd d!eOZPy)"N)StringIO)BytesIO)*)deviceutilspmlcodes)cups J$3iceZdZdddedfdZdZdZdZeeedZ d Z d Z ee e d Z d Z d ZdZdZ ddZy) PMLFaxDeviceNFcTtj||||||d|_d|_yN) FaxDevice__init__send_fax_threadupload_log_thread)self device_uri printer_namecallbackfax_type disable_dbuss /usr/share/hplip/fax/pmlfax.pyr$zPMLFaxDevice.__init__s3 4'#X' ) $!%cyNFr's r-isAuthRequiredzPMLFaxDevice.isAuthRequiredsr.cT|jtjt|Sr")setPMLrOID_FAX_LOCAL_PHONE_NUMstr)r'nums r- setPhoneNumzPMLFaxDevice.setPhoneNums{{366CAAr.c"trUtj|jtj dj d}|jdStj|jtj dSNr zutf-8)PY3r printablegetPMLrr6encodedecoder'datas r- getPhoneNumzPMLFaxDevice.getPhoneNumse ??4;;s/J/J#KA#N#U#UV]#^_D;;w' '??4;;s/J/J#KA#NO Or.r6)doccB|jtj|Sr")r5rOID_FAX_STATION_NAME)r'names r-setStationNamezPMLFaxDevice.setStationNames{{333T::r.c"trUtj|jtj dj d}|jdStj|jtj dSr;)r<rr=r>rrFr?r@rAs r-getStationNamezPMLFaxDevice.getStationNamese ??4;;s/G/G#H#K#R#RSZ#[\D;;w' '??4;;s/G/G#H#KL Lr.rFcyr"r1r2s r-setDateAndTimezPMLFaxDevice.setDateAndTimes r.cz|js+t||_|jjyyNTF)isUloadLogActiveUploadLogThreadr&startr2s r- uploadLogzPMLFaxDevice.uploadLogs3$$&%4T%:D "  " " ( ( *r.cP|j|jjSyr0)r&is_aliver2s r-isUploadLogActivezPMLFaxDevice.isUploadLogActives&  ! ! -))224 4r.c|j6|jjr|jjyyyr")r&rTjoinr2s r-waitForUploadLogThreadz#PMLFaxDevice.waitForUploadLogThreads<  ! ! -  " " + + -  " " ' ' ) . .r.c |js?t||j||||||||| |_|jj yyrN)isSendFaxActivePMLFaxSendThreadservicer%rQ) r'phone_num_list fax_file_list cover_messagecover_re cover_funcpreserve_formattingr) update_queue event_queues r- sendFaxeszPMLFaxDevice.sendFaxessW##%#3D$,,Xe4A8Z4G4@,4? $AD  & & (r.rgNFrgNN)__name__ __module__ __qualname__ FAX_TYPE_NONEr$r3r9rCproperty phone_numrHrJ station_namerLrRrUrXrer1r.r-r r }sy"&T'# &BP k7PQI;MNN@VWL  * SUKM15r.r ceZdZdZdZy)PMLUploadLogThreadcPtjj|||_yr") threadingThreadr$dev)r'rts r-r$zPMLUploadLogThread.__init__s!!$'r.cd}d}d}d}d}d}d}d}d } d } |} | |k7r| |k(rn| |k(rn| |k(rn| |k(rR|} |jj tjtjtj nt| |k(r*|} |j} | tjk7rI|} nE| |k(rs|} |jjtjtj|jjtjtj n| |k(r| } d} |d z }|j} | tj"k(rn| tj$tj&fvrtjd t} n\|dkDrt} tjdn;t)j*d| | k(rn| | k(r|jj-| |k7ryy#t $r t} YwxYw#t $r2} tjd | jzt} Yd} ~ Td} ~ wwxYw)Nrr(2<FUnable to open device (%s).r zCfg upload aborted!z Unable to get into active state!?)rtopenr5rOID_UPLOAD_TIMEOUTDEFAULT_UPLOAD_TIMEOUTError STATE_ERRORlogerrormsggetCfgUploadStateUPDN_STATE_IDLEOID_FAX_CFG_UPLOAD_DATA_TYPE FAX_CFG_UPLOAD_DATA_TYPE_FAXLOGSOID_DEVICE_CFG_UPLOADUPDN_STATE_REQSTARTUPDN_STATE_XFERACTIVEUPDN_STATE_ERRORABORTUPDN_STATE_XFERDONEtimesleepclose)r' STATE_DONE STATE_ABORT STATE_SUCCESS STATE_BUSYSTATE_DEVICE_OPENSTATE_CHECK_IDLESTATE_REQUEST_STARTSTATE_WAIT_FOR_ACTIVESTATE_UPLOAD_DATASTATE_DEVICE_CLOSEstateeul_statetriess r-runzPMLUploadLogThread.runs.      " z! #-'*$+++ ,HHMMO , 3#9#93;U;UV**+113s222&E--- @ @#BfBfg 9 93;R;RS//)QJE#557H3#<#<<C$=$=s?V?V#WW "78 +rz + "DEJJsO#&++,, {z!$!, +, (II;aeeCD'E(s)H2HHH I$(IIN)rhrirjr$rr1r.r-rprps  K!r.rpcpeZdZ ddZdZdZdZdZdZdZ dd Z d Z d Z dd Z d ZdZdZdZy)r[Nc Dtj|||||||||| | | yr") FaxSendThreadr$) r'rtr\r]r^r_r`rarbr)rcrds r-r$zPMLFaxSendThread.__init__-s- tS'>= Hj2E < 6r.c 1d}d}d}d}d}d}d}d}d } d } d } d } d } d} d}|j}|}g|_||k7r|jr|}tj d|z||k(r1tj d|j tddf| }nx||k(r1tj d|j tddf| }nB||k(r1tj d|j tddf| }n ||k(r1tj d|j tddf| }n||k(rtj ddz|} |jj |jj|_tj d|jz|jj|_tj d|j z|jj'n||k(r+tj ddz|j)|}n||k(r+tj ddz|j+|}n||k(rrtj ddz| } t-|}tj d|d z|j t.d|d f|jdd|_n-|| k(r+tj d"dz|j5}n|| k(r+tj d#dz|j7| }n|| k(r+tj d$dz|j9| }n|| k(rtj d%dz|}d}d}d}d}d}d}d}d}d }d }d }d }d }d} d}!d&}"d'}#d(}$d)}%d*}&t:j<}'|}(|(|k7r=|jrtj d+|}(|&rN|j?})|)t:j@t:jBfvrtj d,|)z|}(|}tj d-| |(fz|(|k(rd*}&|$}(|}n|(|k(retj d.|jE}'tj d/|'t:jFjI|'d0fzd*}&|$}(|}n|(|k(rtj d1d*}&|$}(|}n|(|k(rtj d2d*}&|$}(|}ng|(|k(rWtj d3dz|}( |jj|jjJtLk(r|}(n |(|k(r*tj d4dz |jjOt:jP\}*}+|*t:jRkDr|}(tj d5ntUjVd6tUjX}+tj d7|+z |jj[t:jP|+|jjOt:jP\}*},|,|+k(r|}( ntj d8|}( n|(|k(rtj d;dz|}(|jj\t^k(r2tj d< |jja nmtj d> nV|(|k(ratj d?dz|}(|j?}-|jc}.|je}/|-t:jfk(s&|-t:jhk(s|-t:jBk(r|.t:jjk(s|.t:jlk(r|/t:jnk(s|/t:jpk(r|-t:jfk(rtj d@ nWtj dA|jj[t:jrt:jftUjtdB n|}( n|(|k(rtj dCdz|}(|j?}-|-t:jfk(rXtj dDtj dE|jj[t:jrt:jvtUjtdFtj dGdF}0|0dkrtj dH|0z |j?}-|-t:j@k(rntUjtdFtj dE|jj[t:jrt:jv|0dFz }0|0dkrtj dJ|}(dK}& nStj dL|}( n:|(|k(rtj dMdz|}( |jj[t:jxt:jz|jj[t:j|t:j~tj dN|jj ny|(|k(rtj dPdz|}(|jj\tk(r2tj d< |jja n tj d>n|(|k(rtj dRdz| }(tj dSdTztj dU|jtdKttztz|dTjdV}1tj t|1|j|1 |jn&|(| k(rtj dXdz|!}( t|jdY}2 |2jt}3|j|3\ }4}5}6}7}8}9}:};}<}=|4d[k7rtj d\|}(ntj d]|4|5|6|7|8|9|:|;fztj d^|jtdKt|j|6 |jn,|(|!k(rtj d`dz|"}(t}>t6D]}?|jr|}(|(|k(rn 2jt}3|j|3\}@}A}B}C}D}=tj da|@|A|B|C|Dfz|>j|2j|C|2j|D}E|>jd|jttb|j|@78|A|B; |>jt}FFdk(rtj dc|}(|jFt}G |>jt}FGtz }G|j?}-|-t:jhk(r|}(n|jr|}(nFddk(r$|jB |jn |j|jc}HHt:jk(r|j tddTftUjtde|jr|}(nJ|j?}-|-t:jhk(r|}(n$|jc}H|Ht:jk(r|(||fvrHt:jk(r|j tddTftUjtde|jr|}(nJ|j?}-|-t:jhk(r|}(n$|jc}H|Ht:jk(rHt:jk(r|j t@dTf|jtdb|jF|(||fvrnH|>jd|>jdn`|(|"k(r_tj dfdz|#}(tj dg|jtd*t |jd*}&n|(|#k(r8tj dhdz|#}(tUjtde|jc}H|Ht:jk(r2|j tddTftj dinrHt:jk(r2|j t@dTftj djn-Ht:jlt:jnfvr|$}(|}tj dkn|j t@dTftj dln|(|$k(r_tj dmdz|j tddf |jj[t:jPdn|%}(nZ|(|%k(rTtj dpdz|}(tj dq tj' 2j'|jj\tk(r/tj dr|jj|jj[t:jrt:jftUjtdF|jj\t^k(r/tj dr|jj|jj'|(|k7rn|| k(r}tj dsdz|jrWtj dt|jz tj|jtj du|}||k7ryy#t"$rtj d|}YLwxYw#t"$r/}tj d|j$z|}Yd}~d}~wwxYw#|jj'wxYw#t0$r|}tj d!YwxYw#t"$r/}tj d|j$z|}(Yd}~nd}~wwxYw#t"$rtj d9|}(YwxYw#t"$rtj d:|}(YwxYw#t"$r/}tj d=|j$z|}(Yd}~d}~wwxYw#t"$rtj dI|}(Y ywxYw#t"$r/}tj dO|j$z|}(Yd}~Yd}~wwxYw#t"$rtj dQ|}(YwxYw#t"$rtj dW|}(YwxYw#t$rtj dZ|}(YwxYw#t$rtj dZ|}(YwxYw#t"$rtj d_|}(Y wxYw#t$rtj dZ|}(Y >wxYw#t$rtj dZ|}(Y ewxYw#t"$rtj dW|}(YwxYw#t"$rtj dW|}(YCwxYw#t"$rtj dW|}(YwxYw#t"$rtj doYfwxYw#t$rY(wxYw#t$rY'wxYw#t$rtj dvYwxYw)wNrrrvrwryrzr{r|r}PZdnxzSTATE=(%d, 0, 0)zAborted by user.rgzSuccess.zError, aborting.zDevice busy, aborting.z%s State: Get sender infoz********************zSender name=%sz Sender fax=%szPML get failed!r~z!%s State: Pre-render non-G3 filesz%s State: Get total page countz%s State: Next recipientzProcessing for recipient %srGzLast recipient.z%s State: Render cover pagez%s State: Handle single filez%s State: Merge multiple filesz%s State: Send faxFzFax send aborted.zD/L error state=%dzSTATE=(%d, %d, 0)zFax send error.zError State=%d (%s)UnknownzFax device busy.zFax send success.z%s State: Open devicez%s State: Acquire fax tokenzSkipping token acquisition.z%d%m%Y%H:%M:%SzSetting token: %sz Unable to acquire fax token (3).z Unable to acquire fax token (2).z Unable to acquire fax token (1).z%s State: Early openzOpening fax channel.zUnable to open channel (%s).zSkipped.z%s State: Check idlezStarting in idle statezResetting to idle...rz%s State: Request startzTry: 0z)Setting to up/down state request start...r zWaiting for active state...zTry: %dzPML/SNMP errorz Could not get into active state!TzCould not get into idle state!z%s State: Set paramsz Setting date and time on device.zPML/SNMP error (%s)z%s State: Late openzUnable to open channel.z%s State: Send dial stringsz Dialing: %sfaxzSending dial strings...asciizChannel write error.z%s State: Send fax headerrbzUnable to read fax file.shplip_g3zInvalid file header. Bad magic.z>Magic=%s Ver=%d Pages=%d hDPI=%d vDPI=%d Size=%d Res=%d Enc=%dzSending fax header...zUnable to write to channel.z%s State: Send pagesz%Page=%d PPR=%d RPP=%d BPP=%d Thumb=%d) page_flagszNo data!r.g?z%s State: Send EOSzEnd of stream...z%s State: Wait for completionz Dialing ...zTransmitting ...zTransmitting done or idle ...z Pending ...z%s State: Release fax tokenzzUnable to release fax token.z%s State: Close sessionzClosing session...zClosing fax channel.z%s State: CleanupzRemoving merged file: %sRemovedz Not found)lnext_recipient_genrendered_file_listcheck_for_cancelrdebugr write_queue STATUS_IDLESTATUS_COMPLETED STATUS_ERROR STATUS_BUSYrtrrn sender_namerm sender_faxrrr pre_render count_pagesnextSTATUS_SENDING_TO_RECIPIENT StopIterationrecipient_file_list cover_page single_file merge_filesr DN_ERROR_NONEgetFaxDownloadStaterrgetFaxDownloadError DN_ERROR_STRget device_stateDEVICE_STATE_NOT_FOUNDr> OID_FAX_TOKEN ERROR_MAX_OKrstrftimegmtimer5r+FAX_TYPE_BLACK_SEND_EARLY_OPENopenFaxgetFaxJobTxStatusgetFaxJobRxStatusrrFAXJOB_TX_STATUS_IDLEFAXJOB_TX_STATUS_DONEFAXJOB_RX_STATUS_IDLEFAXJOB_RX_STATUS_DONEOID_FAX_DOWNLOADrrOID_DEV_DOWNLOAD_TIMEOUTDEFAULT_DOWNLOAD_TIMEOUTOID_FAXJOB_TX_TYPEFAXJOB_TX_TYPE_HOST_ONLYrLFAX_TYPE_BLACK_SEND_LATE_OPENcreate_mfpdtf_fixed_headerDT_DIAL_STRINGSPAGE_FLAG_NEW_DOCPAGE_FLAG_END_DOCPAGE_FLAG_END_STREAMr?reprcreate_mfpdtf_dial_strings write_streamfIOErrorreadFILE_HEADER_SIZEdecode_fax_header DT_FAX_IMAGEScreate_mfpdtf_fax_headerrrangePAGE_HEADER_SIZEdecode_page_headerwriteseekPAGE_FLAG_NEW_PAGEcreate_sop_recordRASTER_DATA_SIZEcreate_raster_data_recordcreate_eop_recordFAXJOB_TX_STATUS_DIALINGSTATUS_DIALINGFAXJOB_TX_STATUS_CONNECTINGSTATUS_CONNECTINGFAXJOB_TX_STATUS_TRANSMITTINGSTATUS_SENDINGtruncateSTATUS_CLEANUPmm NameErrorcloseFaxremove_temp_fileosremoveOSError)Ir'r STATE_ABORTEDrrSTATE_READ_SENDER_INFOSTATE_PRERENDERSTATE_COUNT_PAGESSTATE_NEXT_RECIPIENTSTATE_COVER_PAGESTATE_SINGLE_FILESTATE_MERGE_FILESSTATE_SEND_FAX STATE_CLEANUPrnext_recipientrr recipientFAX_SEND_STATE_DONEFAX_SEND_STATE_ABORTFAX_SEND_STATE_ERRORFAX_SEND_STATE_BUSYFAX_SEND_STATE_SUCCESSFAX_SEND_STATE_DEVICE_OPENFAX_SEND_STATE_SET_TOKENFAX_SEND_STATE_EARLY_OPENFAX_SEND_STATE_SET_PARAMSFAX_SEND_STATE_CHECK_IDLEFAX_SEND_STATE_START_REQUESTFAX_SEND_STATE_LATE_OPEN FAX_SEND_STATE_SEND_DIAL_STRINGSFAX_SEND_STATE_SEND_FAX_HEADERFAX_SEND_STATE_SEND_PAGES!FAX_SEND_STATE_SEND_END_OF_STREAM FAX_SEND_STATE_WAIT_FOR_COMPLETEFAX_SEND_STATE_RESET_TOKENFAX_SEND_STATE_CLOSE_SESSION monitor_state error_statefax_send_state fax_state result_codetoken check_tokendl_state tx_status rx_statusi dial_stringsffheadermagicversion total_pageshort_dpivert_dpi page_size resolutionencoding reserved1 reserved2pageppage_numpprrpp bytes_to_readthumbnail_bytes thumbnailrB total_readstatussI r-rzPMLFaxSendThread.run6s    !#!  002&"$z!$$&% II(50 1 % ,-  +q"!56%-' *%  "2Ar!:;%+% ,-  ,2!67%*$ 23  +q"!56%00 5@A'% 0  0/3xx/D/DD,II&69I9I&IJ.2hh.@.@DOIIo&GH HHNN$/) =HI(9:++ :fEF(()=>.. 4?@(  $^ 4III;i>OOP$$&A1iPVFW%XY,0+B+B1+E(** 76BC 2++ 8FCD((8++ :fEF((8.( .&9:,&'#')$')$&(#)+&-/*+-(,.),.),.)/1,+.(36014.,/)471360-0*/2, % !// !;$(;;,,. "56)=$$($<$<$> (S-F-FH_H_,``II&:Y&FG-AN$/EII1^^4TTU%)==(- )C -'+?? "34&*&>&>&@  "7;HXHXH\H\]hjsHt:u"uv(- )C +'+>> "45(- )C *'+AA "56(- )C 4'+EE "9V"DE)AF HHMMO $xx448NN1E'+CC "?6"JKN15ARAR1S.K +S-=-==1J # *G H(, 6F (V # *=*E F !N$(HHOOC4E4Eu$M @DxxsO`O`?a$+>> # *B C # *@ A $0D0DcFYFY Z $ 3-@N'+GG ";v"FG)B#'#;#;#=#s':'::IIh/II&QR HHOOC,@,@#BYBYZ JJqMII&CD !A"#b& # )a- 8!*/3/G/G/IH $,s/H/H#H$) $ 1 # *U V $0D0DcF]F] ^ !Q!#$b&&!$ *L M1D,0M II&FG-@N(+DD "8F"CD)AB HHOOC,H,H#JfJfg HHOOC,B,BCD`D`aII&HI HH335 (+CC "76"BC)I88,,0MMII&<=F $ 0 0 2  IIj1(+KK "?6"JK)G -)E2B"BC ";<77-0AADXXZ(1'7'>'>w'G  $|"4577 EB --/ (+II "="HI)B%!%dffd!3B %%'WW-=%>FJNI_I_`fIgGw Xx&)Y K/II&GH-ANII&f',g{HhXacmow&x'yz II&=> ;;M4Qbc 99+FF $ 1 1 3 (+DD "8F"CD)J&y!&{!3u)A#4461E-1EE %))+1A)B!% 7 7 ?ZHc3 PY II&M'/c=/&Z'[\!JJrww}'=>(*(@I IIaL ;;MVh;i 228XxQTVY[cd)'+yy1A'B $rz # * 51E ( ::4@)9J"&'+yy1A'B *.> > +/+C+C+E#+s/H/H#H5IN$)#'#8#8#:5IN$)#'3;$($:$:3$?%N(,(9(9(;%*%.(,(9(9(; *.)?)?)A&,0L0L&L$($4$4naSXIY5Z$[$(JJsO'+'<'<'>9M(-/3/G/G/IH'/33L3L'L9M(--1-C-C-EF'-0L0L&L$2:NPd9e#e*0C4S4S*S(,(8(8:KQPYZ_P`9a(b(, 3+/+@+@+B=QN,1373K3K3M+3s7P7P+P=QN,1151G1G1I+1C4S4S*S$*S-N-N#N$($4$4nhPYZ_P`5a$b $ ? ? Z[ ? \ $ > >t D#16JL`5a#a$)O#'R!MM!, IIaLku)p(+LL "6&"AB)I "4577 uNbcB --/ ). (+KK "AV"LM)I 3!%!7!7!9!S%A%AA $ 0 0.!YuEU1V W # - 8#s'H'HH ,,nh RWHX-YZII&89#(A(A3C\C\']]-GN$8EII&EF!,,nh RWHX-YZIIm4(+EE "?6"JK((.!R)@AF HHOOC,=,=yI*F(+GG ";v"FG)< "67!HHJ!HHJ 88,,0MMII&<= HH--/(<(Q>QR 1 88,,0NNII&<= HH--/(Y%(;;^-' -89((II8466AB/ $&&) ),#kz!Z %0II&78$/E0!, "?!%%"GH +,HHNN$0%)EII/0@ %BII&Caee&KL-ANB.(-!J$'II.P$Q5IN!J %GII&HI-FNGB$)F # *H155*P Q1EFd(-!*$'II.>$?5IN$)!*D %BII&;aee&CD-ANB$)F # *C D1EF. %BII&<=-ANB '%II&@A-AN$% '%II&@A-AN$%*$)F # *G H1EF($+) # *D E1E ()($+) # *D E1E ()>,1%N(+ 2H(I9M%N,1%.(+ 2H(I9M(-%.v %BII&<=-ANBN %FII&DEF )! ! )! !4#/ +./sa!AUA`%E<Aa L*Aa3M(AbM=Ab(S 4Ab8T AUT?AVUAUUAVU AU>U$AU9U3AVU9AU>U>AVVAVV AWWAWW AW?W$AW:W:AW?X AX&X%AX&X) AY Y AY Y AZY$AZZAZZ AZ/Z.AZ/Z2 A[*Z;$A[%[%A[*[- A\\A\\ A\8\7A\8\; A]]A]]" A^^A^^ A^-^,A^-^0 A__A__ A_;_:A_;_> A`"`!A`"`% Aa aAa a Aa0a/Aa0a3AbbAbb Ab%b$Ab%b( Ab5b4Ab5b8AccAcc|jjtj\}}|r:tj d|tj j|dfz|StjS)NzD/L State=%d (%s)r) rtr>rrrrUPDN_STATE_STRrrr'r/rs r-rz$PMLFaxSendThread.getFaxDownloadStates^!XX__S-A-AB U  II)UC4F4F4J4J5R[4\,]] ^L,, ,r.c|jjtj\}}|r|StjSr")rtr>rOID_FAX_DOWNLOAD_ERRORDN_ERROR_UNKNOWNrOs r-rz$PMLFaxSendThread.getFaxDownloadErrors3!XX__S-G-GH U L'' 'r.c|jjtj\}}|r:tj d|tj j|dfz|StjS)NzTx Status=%d (%s)r) rtr>rOID_FAXJOB_TX_STATUSrrFAXJOB_TX_STATUS_STRrrr'r/rLs r-rz"PMLFaxSendThread.getFaxJobTxStatus_"hhooc.F.FG V  II)VS5M5M5Q5QRXZc5d,ee fM,, ,r.c|jjtj\}}|r:tj d|tj j|dfz|StjS)NzRx Status=%d (%s)r) rtr>rOID_FAXJOB_RX_STATUSrrFAXJOB_RX_STATUS_STRrrrVs r-rz"PMLFaxSendThread.getFaxJobRxStatusrWr.c|jjtj\}}|r:tj d|tj j|dfz|StjS)NzCfg Upload State = %d (%s)r) rtr>rrrrrNrrrOs r-rz"PMLFaxSendThread.getCfgUploadStates_!XX__S-F-FG U  II2eS=O=O=S=STY[d=e5ff gL,, ,r.c t}|r%|tk(r |tz }n|tk(r |tz }|j j tjdd|||y)Nzrs.  &**             #$ "    T9TrQ!))Q!la }a r.