aboutsummaryrefslogtreecommitdiffstats
path: root/yt_dlp/postprocessor/exec.py
diff options
context:
space:
mode:
authorpukkandan <pukkandan.ytdlp@gmail.com>2021-08-09 17:40:24 +0530
committerpukkandan <pukkandan.ytdlp@gmail.com>2021-08-10 01:22:55 +0530
commitad3dc496bbf2e2a574a16244ddde0740778e5daf (patch)
treef4eeaf0711946c1181ce1769c33d8ff94c3847cd /yt_dlp/postprocessor/exec.py
parent2831b4686c2436cd151260539e010ce3577911cc (diff)
downloadhypervideo-pre-ad3dc496bbf2e2a574a16244ddde0740778e5daf.tar.lz
hypervideo-pre-ad3dc496bbf2e2a574a16244ddde0740778e5daf.tar.xz
hypervideo-pre-ad3dc496bbf2e2a574a16244ddde0740778e5daf.zip
Misc fixes - See desc
* Remove unnecessary uses of _list_from_options_callback * Fix download tests - Bug from 6e84b21559f586ee4d6affb61688d5c6a0c21221 * Rename ExecAfterDownloadPP to ExecPP and refactor its tests * Ensure _write_ytdl_file closes file handle on error - Potential fix for #517
Diffstat (limited to 'yt_dlp/postprocessor/exec.py')
-rw-r--r--yt_dlp/postprocessor/exec.py42
1 files changed, 42 insertions, 0 deletions
diff --git a/yt_dlp/postprocessor/exec.py b/yt_dlp/postprocessor/exec.py
new file mode 100644
index 000000000..7a3cb4999
--- /dev/null
+++ b/yt_dlp/postprocessor/exec.py
@@ -0,0 +1,42 @@
+from __future__ import unicode_literals
+
+import subprocess
+
+from .common import PostProcessor
+from ..compat import compat_shlex_quote
+from ..utils import (
+ encodeArgument,
+ PostProcessingError,
+ variadic,
+)
+
+
+class ExecPP(PostProcessor):
+
+ def __init__(self, downloader, exec_cmd):
+ PostProcessor.__init__(self, downloader)
+ self.exec_cmd = variadic(exec_cmd)
+
+ def parse_cmd(self, cmd, info):
+ tmpl, tmpl_dict = self._downloader.prepare_outtmpl(cmd, info)
+ if tmpl_dict: # if there are no replacements, tmpl_dict = {}
+ return self._downloader.escape_outtmpl(tmpl) % tmpl_dict
+
+ # If no replacements are found, replace {} for backard compatibility
+ if '{}' not in cmd:
+ cmd += ' {}'
+ return cmd.replace('{}', compat_shlex_quote(
+ info.get('filepath') or info['_filename']))
+
+ def run(self, info):
+ for tmpl in self.exec_cmd:
+ cmd = self.parse_cmd(tmpl, info)
+ self.to_screen('Executing command: %s' % cmd)
+ retCode = subprocess.call(encodeArgument(cmd), shell=True)
+ if retCode != 0:
+ raise PostProcessingError('Command returned error code %d' % retCode)
+ return [], info
+
+
+class ExecAfterDownloadPP(ExecPP): # for backward compatibility
+ pass