2014-11-27 06:01:20 +11:00
|
|
|
from __future__ import unicode_literals
|
|
|
|
|
2015-04-09 01:40:31 +10:00
|
|
|
import os
|
2015-07-01 05:22:09 +10:00
|
|
|
import shlex
|
2015-04-09 01:40:31 +10:00
|
|
|
|
|
|
|
from ..utils import (
|
|
|
|
PostProcessingError,
|
|
|
|
encodeFilename,
|
|
|
|
)
|
2014-01-07 15:59:22 +11:00
|
|
|
|
|
|
|
|
|
|
|
class PostProcessor(object):
|
|
|
|
"""Post Processor class.
|
|
|
|
|
|
|
|
PostProcessor objects can be added to downloaders with their
|
|
|
|
add_post_processor() method. When the downloader has finished a
|
|
|
|
successful download, it will take its internal chain of PostProcessors
|
|
|
|
and start calling the run() method on each one of them, first with
|
|
|
|
an initial argument and then with the returned value of the previous
|
|
|
|
PostProcessor.
|
|
|
|
|
|
|
|
The chain will be stopped if one of them ever returns None or the end
|
|
|
|
of the chain is reached.
|
|
|
|
|
|
|
|
PostProcessor objects follow a "mutual registration" process similar
|
2015-06-17 07:10:31 +10:00
|
|
|
to InfoExtractor objects. And it can receive parameters from CLI trough
|
2015-07-01 05:22:09 +10:00
|
|
|
--postprocessor-args.
|
2014-01-07 15:59:22 +11:00
|
|
|
"""
|
|
|
|
|
|
|
|
_downloader = None
|
|
|
|
|
2015-07-01 05:22:09 +10:00
|
|
|
def __init__(self, downloader=None, extra_cmd_args=None):
|
|
|
|
self._extra_cmd_args = shlex.split(extra_cmd_args or '')
|
2014-01-07 15:59:22 +11:00
|
|
|
self._downloader = downloader
|
|
|
|
|
|
|
|
def set_downloader(self, downloader):
|
|
|
|
"""Sets the downloader for this PP."""
|
|
|
|
self._downloader = downloader
|
|
|
|
|
|
|
|
def run(self, information):
|
|
|
|
"""Run the PostProcessor.
|
|
|
|
|
|
|
|
The "information" argument is a dictionary like the ones
|
|
|
|
composed by InfoExtractors. The only difference is that this
|
|
|
|
one has an extra field called "filepath" that points to the
|
|
|
|
downloaded file.
|
|
|
|
|
2015-04-18 19:36:42 +10:00
|
|
|
This method returns a tuple, the first element is a list of the files
|
|
|
|
that can be deleted, and the second of which is the updated
|
|
|
|
information.
|
2014-01-07 15:59:22 +11:00
|
|
|
|
|
|
|
In addition, this method may raise a PostProcessingError
|
|
|
|
exception if post processing fails.
|
|
|
|
"""
|
2015-04-18 19:36:42 +10:00
|
|
|
return [], information # by default, keep file and do nothing
|
2014-01-07 15:59:22 +11:00
|
|
|
|
2015-04-09 01:40:31 +10:00
|
|
|
def try_utime(self, path, atime, mtime, errnote='Cannot update utime of file'):
|
|
|
|
try:
|
|
|
|
os.utime(encodeFilename(path), (atime, mtime))
|
|
|
|
except Exception:
|
|
|
|
self._downloader.report_warning(errnote)
|
|
|
|
|
2014-01-07 15:59:22 +11:00
|
|
|
|
|
|
|
class AudioConversionError(PostProcessingError):
|
|
|
|
pass
|