ó
č?F[c           @   s^   d  d l  Z  d  d l m Z d  d l m Z d  d l Z d  d l Z d e f d     YZ d S(   i’’’’N(   t   Service(   t   ServiceMessaget   SonOfMMMc           B   s/   e  Z d d   Z d   Z d   Z d   Z RS(   c         C   s8  t  t |   j |  d |  j |  _ t j j |  j |  j  |  _	 t
 j |  j |  j	  |  j j d  r d |  j j d  |  _ n	 d |  _ |  j j d  |  _ |  j j d  rŠ |  j j d  |  _ n t j |  j  |  _ |  j j d  |  _ |  j j d  |  _ |  j j d	  } | s4|  j   n  d  S(
   Ns   %s.logt   ffmpeg_argss   /usr/local/bin/ffmpeg s!   /usr/local/bin/ffmpeg -y -i %s %st   output_mimetypet
   output_extt   output_buckett   input_bucketi   (   t   superR   t   __init__t   instance_idt   log_filet   ost   patht   joint   working_dirt   log_patht   botot   set_file_loggert   namet   sdt
   has_optiont   gett   commandR   R   t	   mimetypest   guess_extensiont   get_objR   R   t   input_queuet   readt   queue_files(   t   selft   config_filet   m(    (    s5   lib/python2.7/site-packages/boto/services/sonofmmm.pyR	      s     	c         C   s   t  j j d |  j j  xv |  j D]k } t  j j d | j  t   } |  j ri i |  j j d 6} n d  } | j | |  |  j	 j
 |  q$ Wd  S(   Ns   Queueing files from %ss   Queueing %st   OutputBucket(   R   t   logt   infoR   R   R   R   t   Nonet   for_keyR   t   write(   R   t   keyR    t   d(    (    s5   lib/python2.7/site-packages/boto/services/sonofmmm.pyR   4   s    		c         C   s   t  j j |  \ } } t  j j |  j | |  j  } |  j | | f } t j j	 d |  |  j
 |  } | d k r | |  j f g Sg  Sd  S(   Ns   running:
%si    (   R   R   t   splitextR   R   R   R   R   R"   R#   t   runR   (   R   t   in_file_namet   msgt   baset   extt   out_file_nameR   t   status(    (    s5   lib/python2.7/site-packages/boto/services/sonofmmm.pyt   process_file@   s    c         C   s`   t  j j |  j  rI |  j rI |  j j |  j  } | j |  j  qI n  t t	 |   j
   d  S(   N(   R   R   t   isfileR   R   t   new_keyR   t   set_contents_from_filenameR   R   t   shutdown(   R   R'   (    (    s5   lib/python2.7/site-packages/boto/services/sonofmmm.pyR5   L   s
    	N(   t   __name__t
   __module__R$   R	   R   R1   R5   (    (    (    s5   lib/python2.7/site-packages/boto/services/sonofmmm.pyR      s   		(   R   t   boto.services.serviceR    t   boto.services.messageR   R   R   R   (    (    (    s5   lib/python2.7/site-packages/boto/services/sonofmmm.pyt   <module>   s
   