3 NZ7@sddlZddlZddlZddlZddlZddlZddlmZddlm Z ddl Tddl Tddl m Z mZmZmZddlmZddlTdZdZdZd 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 ZDdZEdZFdZGdZHdZIdZJGdddeKZLGdddejMZNGd d!d!eOZPdS)"N)StringIO)BytesIO)*)deviceutilspmlcodes)cups J$3ic@seZdZdddedfddZddZddZeeed d Zd d Z d dZ ee e dd Z ddZ ddZ ddZddZdddZdS) PMLFaxDeviceNFcCs$tj||||||d|_d|_dS)N) FaxDevice__init__send_fax_threadupload_log_thread)selfZ device_uri printer_namecallbackfax_typeZ disable_dbusr'/usr/share/hplip/fax/pmlfax.pyr s zPMLFaxDevice.__init__cCs|jtjt|S)N)setPMLrOID_FAX_LOCAL_PHONE_NUMstr)r#Znumr'r'r( setPhoneNumszPMLFaxDevice.setPhoneNumcCsDtr*tj|jtjdjd}|jdStj|jtjdSdS)Nr zutf-8)PY3r printablegetPMLrr*encodedecode)r#datar'r'r( getPhoneNums zPMLFaxDevice.getPhoneNumr*)doccCs|jtj|S)N)r)rOID_FAX_STATION_NAME)r#namer'r'r(setStationNameszPMLFaxDevice.setStationNamecCsDtr*tj|jtjdjd}|jdStj|jtjdSdS)Nr zutf-8)r-rr.r/rr5r0r1)r#r2r'r'r(getStationNames zPMLFaxDevice.getStationNamer5cCsdS)Nr')r#r'r'r(setDateAndTimeszPMLFaxDevice.setDateAndTimecCs(|js t||_|jjdSdSdS)NTF)ZisUloadLogActiveZUploadLogThreadr"start)r#r'r'r( uploadLogs   zPMLFaxDevice.uploadLogcCs|jdk r|jjSdSdS)NF)r"isAlive)r#r'r'r(isUploadLogActives  zPMLFaxDevice.isUploadLogActivecCs"|jdk r|jjr|jjdS)N)r"r<join)r#r'r'r(waitForUploadLogThreads  z#PMLFaxDevice.waitForUploadLogThreadc Cs>|js6t||j||||||||| |_|jjdSdSdS)NTF)ZisSendFaxActivePMLFaxSendThreadservicer!r:) r#phone_num_list fax_file_list cover_messagecover_re cover_funcpreserve_formattingr$ update_queue event_queuer'r'r( sendFaxess  zPMLFaxDevice.sendFaxes)r@r@NFr@NN)__name__ __module__ __qualname__Z FAX_TYPE_NONEr r,r3property phone_numr7r8 station_namer9r;r=r?rKr'r'r'r(r}s" rc@seZdZddZddZdS)PMLUploadLogThreadcCstjj|||_dS)N) threadingThreadr dev)r#rUr'r'r(r s zPMLUploadLogThread.__init__cCsd}d}d}d}d}d}d}d}d } d } |} x| |kr| |krDq0| |krNq0| |krXq0| |kr|} y|jjWn6tk r} ztjd | jt} WYdd} ~ Xn0Xytjtj tj Wntk rt} YnXq0| |kr|} |j } | tj kr|} q0| |kr6|} |jjtj tj|jjtjtjq0| |kr| } d}x|d 7}|j } | tjkrhP| tjtjfkrtjd t} P|dkrt} tjdPtjdqJWq0| | krq0| | kr0|jjq0WdS)Nrr(2<FzUnable to open device (%s).r zCfg upload aborted!z Unable to get into active state!g?)rUopenErrorlogerrormsg STATE_ERRORr)rZOID_UPLOAD_TIMEOUTZDEFAULT_UPLOAD_TIMEOUTgetCfgUploadStateUPDN_STATE_IDLEZOID_FAX_CFG_UPLOAD_DATA_TYPEZ FAX_CFG_UPLOAD_DATA_TYPE_FAXLOGSOID_DEVICE_CFG_UPLOADUPDN_STATE_REQSTARTUPDN_STATE_XFERACTIVEUPDN_STATE_ERRORABORTUPDN_STATE_XFERDONEtimesleepclose)r# STATE_DONEZ STATE_ABORT STATE_SUCCESS STATE_BUSYZSTATE_DEVICE_OPENZSTATE_CHECK_IDLEZSTATE_REQUEST_STARTZSTATE_WAIT_FOR_ACTIVEZSTATE_UPLOAD_DATAZSTATE_DEVICE_CLOSEstateeZul_stateZtriesr'r'r(runsv          zPMLUploadLogThread.runN)rLrMrNr rsr'r'r'r(rRsrRc@seZdZd$ddZddZdd Zd d Zd d ZddZddZ d%ddZ ddZ ddZ d&ddZ ddZddZd d!Zd"d#ZdS)'rAr@NFc Cs$tj|||||||||| | | dS)N) FaxSendThreadr ) r#rUrBrCrDrErFrGrHr$rIrJr'r'r(r +szPMLFaxSendThread.__init__cICsd}d}d}d}d}d}d}d}d } d } d } d } d } d} d}|j}|}g|_x||kr|jrh|}tjd|||krtjd|jtddf| }qR||krtjd|jtddf| }qR||krtjd|jt ddf| }qR||krtjd|jt ddf| }qR||krtjddx|}zy|j j Wn8t k r|}ztjd|j|}WYdd}~Xn`Xy8|j j|_tjd|j|j j|_tjd|jWn$t k rtjd|}YnXWd|j jXqR||krtjddy|j|}qR||kr6tjddz|j|}qR||krtjdd{| }y2t|}tjd|d |jtd|d fWn&tk r|}tjd!wRYnX|jdd|_qR|| krtjd"d||j|}qR|| krtjd#d}|j| }qR|| kr*tjd$d~|j| }qR|| krtjd%d|}d}d}d}d}d}d}d}d}d }d }d }d }d }d} d}!d&}"d'}#d(}$d)}%d*}&tj}'|}(xP|(|kr|jrtjd+|}(|&r|j})|)tj tj!fkrtjd,|)|}(|}tjd-| |(f|(|kr(d*}&|$}(|}q|(|krptjd.|j"}'tjd/|'tj#j$|'d0fd*}&|$}(|}q|(|krtjd1d*}&|$}(|}q|(|krtjd2d*}&|$}(|}q|(|kr2tjd3d|}(y|j j Wn8t k r}ztjd|j|}(WYdd}~XnX|j j%t&kr~|}(q|(|kr.tjd4dy|j j'tj(\}*}+Wn$t k rtjd5|}(YnX|*tj)kr|}(tjd6nt*j+d7t*j,}+tjd8|+y|j j-tj(|+Wn$t k rtjd9|}(Yn2X|j j'tj(\}*},|,|+kr|}(ntjd:|}(q|(|krtjd;d|}(|j j.t/krtjd<y|j j0Wn8t k r}ztjd=|j|}(WYdd}~XnXn tjd>q|(|krtjd?d|}(|j}-|j1}.|j2}/|-tj3ks|-tj4ks|-tj!kr|.tj5ks*|.tj6kr|/tj7ksB|/tj8kr|-tj3krZtjd@n&tjdA|j j-tj9tj3t*j:dBn|}(q|(|krtjdCd|}(|j}-|-tj3krtjdDtjdE|j j-tj9tj;t*j:dFtjdGdF}0x|0dkrtjdH|0y |j}-Wn&t k rDtjdI|}(PYnX|-tj krTPt*j:dFtjdE|j j-tj9tj;|0dF7}0qWtjdJ|}(dK}&ntjdL|}(q|(|k rDtjdMd|}(y<|j j-tjtj?tjdN|j j@Wn8t k r>}ztjdO|j|}(WYdd}~XnXq|(|k rtjdPd|}(|j j.tAk rtjd<y|j j0Wn$t k rtjdQ|}(YnXn tjd>q|(|k rftjdRd| }(tjdS|dTtjdU|jBtCdKtDtEBtFB|dTjGdV}1tjtH|1|jI|1y |jJWn$t k r`tjdW|}(YnXq|(| k rtjdXd|!}(yt |jKdY}2Wn(tLk rtjdZ|}(wYnXy|2jMtN}3Wn(tLk rtjdZ|}(wYnX|jO|3\ }4}5}6}7}8}9}:};}<}=|4d[k r,tjd\|}(nrtjd]|4|5|6|7|8|9|:|;ftjd^|jBtPdKtD|jQ|6y |jJWn$t k rtjd_|}(YnXq|(|!krtjd`d|"}(tR}>xtS|6D],}?|j r|}(|(|k rPy|2jMtT}3Wn(tLk r&tjdZ|}( wYnX|jU|3\}@}A}B}C}D}=tjda|@|A|B|C|Df|>jV|2jM|C|2jM|D}E|>jWd|jBtPtXdb|jY|@|7|8|A|B|;y|>jMtZ}FWn(tLk rtjdZ|}( wYnX|Fdk rtjdc|}( q|j[|FtZ}Gx|>jMtZ}F|GtZ7}G|j}-|-tj4k r.|}(P|j r>|}(P|Fddk r|j\|By |jJWn$t k rtjdW|}(YnXPn4y |jJWn&t k rtjdW|}(PYnX|j1}Hxb|Htj]kr&|jt^d|dTft*j:de|jr|}(P|j}-|-tj4kr|}(P|j1}H qW|(||fkrxb|Htj_kr|jt`d|dTft*j:de|jrr|}(P|j}-|-tj4kr|}(P|j1}Hq8W|Htjakr|jtb|@|dTf|jBtPddb|j[|F|(||fk rP qW|>jcd|>jWd qWq|(|"krttjdfd|#}(tjdg|jBtPd*tFy |jJWn$t k rjtjdW|}(YnXd*}&q|(|#krBtjdhd|#}(t*j:de|j1}H|Htj]kr|jt^d|dTftjdinp|Htjakr|jtb|@|dTftjdjnD|Htj6tj7fkr |$}(|}tjdkn|jtb|@|dTftjdlq|(|$krtjdmd|jtdddfy|j j-tj(dWn t k rtjdpYnX|%}(n|(|%krtjdqd|}(tjdry tejWntfk rYnXy |2jWntfk rYnX|j j.tAkr6tjds|j jg|j j-tj9tj3t*j:dF|j j.t/krttjds|j jg|j jqWqR|| krRtjdtd|jhrtjdu|jKytijj|jKtjdvWn tkk rtjdwYnX|}qRWdS)NrrrVrWrYrZr[r\r]PZdnxzSTATE=(%d, 0, 0)zAborted by user.r@zSuccess.zError, aborting.zDevice busy, aborting.z%s State: Get sender inforzUnable to open device (%s).zSender name=%sz Sender fax=%szPML get failed!z!%s State: Pre-render non-G3 filesz%s State: Get total page countz%s State: Next recipientzProcessing for recipient %sr6zLast 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 tokenz Unable to acquire fax token (1).zSkipping token acquisition.z%d%m%Y%H:%M:%SzSetting token: %sz Unable to acquire fax token (2).z Unable to acquire fax token (3).z%s State: Early openzOpening fax channel.zUnable to open channel (%s).zSkipped.z%s State: Check idlezStarting in idle statezResetting to idle...g?z%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!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 tokenrzUnable to release fax token.z%s State: Close sessionzClosing session...zClosing fax channel.z%s State: CleanupzRemoving merged file: %sZRemovedz Not foundz********************z********************z********************z********************z********************z********************z********************z********************z********************z********************z********************z********************z********************z********************z********************z********************z********************z********************z********************z********************z********************zz********************z********************)lZnext_recipient_genZrendered_file_listZcheck_for_cancelr`debugraZ write_queueZ STATUS_IDLEZSTATUS_COMPLETEDZ STATUS_ERRORZ STATUS_BUSYrUr^r_rbrQZ sender_namerPZ sender_faxrmZ pre_renderZ count_pagesnextZSTATUS_SENDING_TO_RECIPIENT StopIterationZrecipient_file_listZ cover_pageZ single_fileZ merge_filesrZ DN_ERROR_NONEgetFaxDownloadStaterhrjgetFaxDownloadErrorZ DN_ERROR_STRgetZ device_stateZDEVICE_STATE_NOT_FOUNDr/Z OID_FAX_TOKENZ ERROR_MAX_OKrkZstrftimeZgmtimer)r&ZFAX_TYPE_BLACK_SEND_EARLY_OPENZopenFaxgetFaxJobTxStatusgetFaxJobRxStatusreriFAXJOB_TX_STATUS_IDLEZFAXJOB_TX_STATUS_DONEFAXJOB_RX_STATUS_IDLEZFAXJOB_RX_STATUS_DONEOID_FAX_DOWNLOADrlrgZOID_DEV_DOWNLOAD_TIMEOUTZDEFAULT_DOWNLOAD_TIMEOUTZOID_FAXJOB_TX_TYPEZFAXJOB_TX_TYPE_HOST_ONLYr9ZFAX_TYPE_BLACK_SEND_LATE_OPENcreate_mfpdtf_fixed_headerDT_DIAL_STRINGSPAGE_FLAG_NEW_DOCPAGE_FLAG_END_DOCPAGE_FLAG_END_STREAMr0reprcreate_mfpdtf_dial_strings write_streamfIOErrorreadZFILE_HEADER_SIZEZdecode_fax_header DT_FAX_IMAGEScreate_mfpdtf_fax_headerrrangeZPAGE_HEADER_SIZEZdecode_page_headerwriteseekPAGE_FLAG_NEW_PAGEcreate_sop_recordRASTER_DATA_SIZEcreate_raster_data_recordcreate_eop_recordZFAXJOB_TX_STATUS_DIALINGZSTATUS_DIALINGZFAXJOB_TX_STATUS_CONNECTINGZSTATUS_CONNECTINGZFAXJOB_TX_STATUS_TRANSMITTINGZSTATUS_SENDINGtruncateZSTATUS_CLEANUPZmm NameErrorZcloseFaxZremove_temp_fileosremoveOSError)Ir#rnZ STATE_ABORTEDrorpZSTATE_READ_SENDER_INFOZSTATE_PRERENDERZSTATE_COUNT_PAGESZSTATE_NEXT_RECIPIENTZSTATE_COVER_PAGEZSTATE_SINGLE_FILEZSTATE_MERGE_FILESZSTATE_SEND_FAXZ STATE_CLEANUPrcZnext_recipientrqrrZ recipientZFAX_SEND_STATE_DONEZFAX_SEND_STATE_ABORTZFAX_SEND_STATE_ERRORZFAX_SEND_STATE_BUSYZFAX_SEND_STATE_SUCCESSZFAX_SEND_STATE_DEVICE_OPENZFAX_SEND_STATE_SET_TOKENZFAX_SEND_STATE_EARLY_OPENZFAX_SEND_STATE_SET_PARAMSZFAX_SEND_STATE_CHECK_IDLEZFAX_SEND_STATE_START_REQUESTZFAX_SEND_STATE_LATE_OPENZ FAX_SEND_STATE_SEND_DIAL_STRINGSZFAX_SEND_STATE_SEND_FAX_HEADERZFAX_SEND_STATE_SEND_PAGESZ!FAX_SEND_STATE_SEND_END_OF_STREAMZ FAX_SEND_STATE_WAIT_FOR_COMPLETEZFAX_SEND_STATE_RESET_TOKENZFAX_SEND_STATE_CLOSE_SESSIONZ monitor_stateZ error_stateZfax_send_stateZ fax_state result_codetokenZ check_tokenZdl_stateZ tx_statusZ rx_statusiZ dial_stringsZffheadermagicversion total_pageshort_dpivert_dpiZ page_sizeZ resolutionencodingZ reserved1Z reserved2Zpageppage_numpprrppZ bytes_to_readZthumbnail_bytesZ thumbnailr2Z total_readstatusr'r'r(rs4s                                                                                                                                             zPMLFaxSendThread.runcCs@|jjtj\}}|r6tjd|tjj|df|StjSdS)NzD/L State=%d (%s)r) rUr/rrr`rUPDN_STATE_STRrri)r#rrqr'r'r(rs z$PMLFaxSendThread.getFaxDownloadStatecCs$|jjtj\}}|r|StjSdS)N)rUr/rZOID_FAX_DOWNLOAD_ERRORZDN_ERROR_UNKNOWN)r#rrqr'r'r(rsz$PMLFaxSendThread.getFaxDownloadErrorcCs@|jjtj\}}|r6tjd|tjj|df|StjSdS)NzTx Status=%d (%s)r) rUr/rZOID_FAXJOB_TX_STATUSr`rZFAXJOB_TX_STATUS_STRrr)r#rrr'r'r(rs z"PMLFaxSendThread.getFaxJobTxStatuscCs@|jjtj\}}|r6tjd|tjj|df|StjSdS)NzRx Status=%d (%s)r) rUr/rZOID_FAXJOB_RX_STATUSr`rZFAXJOB_RX_STATUS_STRrr)r#rrr'r'r(rs z"PMLFaxSendThread.getFaxJobRxStatuscCs@|jjtj\}}|r6tjd|tjj|df|StjSdS)NzCfg Upload State = %d (%s)r) rUr/rrfr`rrrri)r#rrqr'r'r(rds z"PMLFaxSendThread.getCfgUploadStatercCsHt}|r*|tkr|t7}n|tkr*|t7}|jjtjdd|||dS)Nzs   WV