o ckF[ª ã@sDddlZddlmZddlmZddlZddlZGdd„deƒZdS)éN)ÚService)ÚServiceMessagecs:eZdZd ‡fdd„ Zdd„Zdd„Z‡fdd „Z‡ZS) ÚSonOfMMMNcsÚtt|ƒ |¡d|j|_tj |j|j¡|_ t   |j |j ¡|j  d¡r0d|j  d¡|_nd|_|j  d¡|_|j  d¡rH|j  d¡|_nt |j¡|_|j  d¡|_|j  d¡|_|j d ¡}|sk| ¡dSdS) Nz%s.logÚ ffmpeg_argsz/usr/local/bin/ffmpeg z!/usr/local/bin/ffmpeg -y -i %s %sÚoutput_mimetypeÚ output_extÚ output_bucketÚ input_bucketé)ÚsuperrÚ__init__Ú instance_idÚlog_fileÚosÚpathÚjoinÚ working_dirÚlog_pathÚbotoÚset_file_loggerÚnameÚsdÚ has_optionÚgetÚcommandrrÚ mimetypesÚguess_extensionÚget_objrr Ú input_queueÚreadÚ queue_files)ÚselfÚ config_fileÚm©Ú __class__©ú8/usr/lib/python3/dist-packages/boto/services/sonofmmm.pyr s"     ÿzSonOfMMM.__init__cCsltj d|jj¡|jD]&}tj d|j¡tƒ}|jr%d|jji}nd}| ||¡|j  |¡q dS)NzQueueing files from %sz Queueing %sÚ OutputBucket) rÚlogÚinfor rrrÚfor_keyrÚwrite)r!Úkeyr#Údr&r&r'r 4s  øzSonOfMMM.queue_filescCsftj |¡\}}tj |j||j¡}|j||f}tj  d|¡|  |¡}|dkr1||j fgSgS)Nz running: %sr) rrÚsplitextrrrrrr)r*Úrunr)r!Ú in_file_nameÚmsgÚbaseÚextÚ out_file_namerÚstatusr&r&r'Ú process_file@s ÿ  zSonOfMMM.process_filecs@tj |j¡r|jr|j |j¡}| |j¡tt |ƒ  ¡dS©N) rrÚisfilerrÚnew_keyrÚset_contents_from_filenamer rÚshutdown)r!r-r$r&r'r<Ls  zSonOfMMM.shutdownr8)Ú__name__Ú __module__Ú __qualname__r r r7r<Ú __classcell__r&r&r$r'rs   r)rÚboto.services.servicerÚboto.services.messagerrrrr&r&r&r'Ús