o

ckF[�
�@sDdd
lZddl
mZ
ddlmZ
dd
lZdd
lZGdd�de�Zd
S)�N)
�Service)
�ServiceMessagecs:eZ
dZd
�f
dd�	Zdd�Zdd�Z�f
dd	�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__c
Csltj
�d
|jj�

|jD]&}
tj
�d|
j�

t�}|jr%d|jji
}nd}|�|
|�
|j�	|�

q
dS)NzQueueing files from %szQueueing %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||jfg
SgS)Nzrunning:
%sr
)rr�splitextrrrrrr)r*�runr)r!�in_file_name�msg�base�ext�
out_file_namer�statusr&r&r'�process_file@s



�




zSonOfMMM.process_filec
s@tj
�|j�
r|jr|j�|j�
}
|
�|j�

tt	|��
�
dS�
N)rr�isfilerr�new_keyr�set_contents_from_filenamerr�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'�<module>
s