add post processor
This commit is contained in:
		
							parent
							
								
									98acdc895b
								
							
						
					
					
						commit
						0c14e2fbe3
					
				
					 4 changed files with 84 additions and 0 deletions
				
			
		| 
						 | 
				
			
			@ -1,5 +1,7 @@
 | 
			
		|||
 | 
			
		||||
from .atomicparsley import AtomicParsleyPP
 | 
			
		||||
from .ffmpeg import (
 | 
			
		||||
    FFmpegMediaFixPP,
 | 
			
		||||
    FFmpegMergerPP,
 | 
			
		||||
    FFmpegMetadataPP,
 | 
			
		||||
    FFmpegVideoConvertor,
 | 
			
		||||
| 
						 | 
				
			
			@ -9,6 +11,8 @@ from .ffmpeg import (
 | 
			
		|||
from .xattrpp import XAttrMetadataPP
 | 
			
		||||
 | 
			
		||||
__all__ = [
 | 
			
		||||
    'AtomicParsleyPP',
 | 
			
		||||
    'FFmpegMediaFixPP',
 | 
			
		||||
    'FFmpegMergerPP',
 | 
			
		||||
    'FFmpegMetadataPP',
 | 
			
		||||
    'FFmpegVideoConvertor',
 | 
			
		||||
| 
						 | 
				
			
			
 | 
			
		|||
							
								
								
									
										59
									
								
								youtube_dl/postprocessor/atomicparsley.py
									
										
									
									
									
										Normal file
									
								
							
							
						
						
									
										59
									
								
								youtube_dl/postprocessor/atomicparsley.py
									
										
									
									
									
										Normal file
									
								
							| 
						 | 
				
			
			@ -0,0 +1,59 @@
 | 
			
		|||
# -*- coding: utf-8 -*-
 | 
			
		||||
from __future__ import unicode_literals
 | 
			
		||||
 | 
			
		||||
 | 
			
		||||
import os
 | 
			
		||||
import subprocess
 | 
			
		||||
 | 
			
		||||
from .common import PostProcessor
 | 
			
		||||
 | 
			
		||||
from ..utils import (
 | 
			
		||||
    check_executable,
 | 
			
		||||
    compat_urlretrieve,
 | 
			
		||||
    encodeFilename,
 | 
			
		||||
    PostProcessingError,
 | 
			
		||||
    prepend_extension,
 | 
			
		||||
    shell_quote
 | 
			
		||||
)
 | 
			
		||||
 | 
			
		||||
 | 
			
		||||
class AtomicParsleyPPError(PostProcessingError):
 | 
			
		||||
    pass
 | 
			
		||||
 | 
			
		||||
 | 
			
		||||
class AtomicParsleyPP(PostProcessor):
 | 
			
		||||
    def __init__(self, downloader=None):
 | 
			
		||||
        PostProcessor.__init__(self, downloader)
 | 
			
		||||
 | 
			
		||||
    def run(self, info):
 | 
			
		||||
        if not check_executable('AtomicParsley', ['-v']):
 | 
			
		||||
            raise AtomicParsleyPPError('AtomicParsley was not found. Please install.')
 | 
			
		||||
 | 
			
		||||
        filename = info['filepath']
 | 
			
		||||
        temp_filename = prepend_extension(filename, 'temp')
 | 
			
		||||
        temp_thumbnail = prepend_extension(filename, 'thumb')
 | 
			
		||||
 | 
			
		||||
        if not info.get('thumbnail'):
 | 
			
		||||
            raise AtomicParsleyPPError('Thumbnail was not found. Nothing to do.')
 | 
			
		||||
 | 
			
		||||
        compat_urlretrieve(info['thumbnail'], temp_thumbnail)
 | 
			
		||||
 | 
			
		||||
        cmd = ['AtomicParsley', filename, '--artwork', temp_thumbnail, '-o', temp_filename]
 | 
			
		||||
 | 
			
		||||
        self._downloader.to_screen('[atomicparsley] Adding thumbnail to "%s"' % filename)
 | 
			
		||||
 | 
			
		||||
        if self._downloader.params.get('verbose', False):
 | 
			
		||||
            self._downloader.to_screen('[debug] AtomicParsley command line: %s' % shell_quote(cmd))
 | 
			
		||||
 | 
			
		||||
        p = subprocess.Popen(cmd, stdout=subprocess.PIPE, stderr=subprocess.PIPE)
 | 
			
		||||
        stdout, stderr = p.communicate()
 | 
			
		||||
 | 
			
		||||
        if p.returncode != 0:
 | 
			
		||||
            msg = stderr.decode('utf-8', 'replace').strip()
 | 
			
		||||
            raise AtomicParsleyPPError(msg)
 | 
			
		||||
 | 
			
		||||
        os.remove(encodeFilename(filename))
 | 
			
		||||
        os.remove(encodeFilename(temp_thumbnail))
 | 
			
		||||
        os.rename(encodeFilename(temp_filename), encodeFilename(filename))
 | 
			
		||||
 | 
			
		||||
        return True, info
 | 
			
		||||
| 
						 | 
				
			
			@ -483,3 +483,17 @@ class FFmpegMergerPP(FFmpegPostProcessor):
 | 
			
		|||
        self.run_ffmpeg_multiple_files(info['__files_to_merge'], filename, args)
 | 
			
		||||
        return True, info
 | 
			
		||||
 | 
			
		||||
 | 
			
		||||
class FFmpegMediaFixPP(FFmpegPostProcessor):
 | 
			
		||||
    def run(self, info):
 | 
			
		||||
        filename = info['filepath']
 | 
			
		||||
        temp_filename = prepend_extension(filename, 'temp')
 | 
			
		||||
 | 
			
		||||
        options = ['-vcodec', 'copy', '-acodec', 'copy']
 | 
			
		||||
        self._downloader.to_screen(u'[ffmpeg] Fixing media file "%s"' % filename)
 | 
			
		||||
        self.run_ffmpeg(filename, temp_filename, options)
 | 
			
		||||
 | 
			
		||||
        os.remove(encodeFilename(filename))
 | 
			
		||||
        os.rename(encodeFilename(temp_filename), encodeFilename(filename))
 | 
			
		||||
 | 
			
		||||
        return True, info
 | 
			
		||||
| 
						 | 
				
			
			
 | 
			
		|||
		Loading…
	
	Add table
		Add a link
		
	
		Reference in a new issue