Newer
Older
Javier Vegas-Regidor
committed
import os
from bscearth.utils.log import Log
Javier Vegas-Regidor
committed
:param path: path to CDFTOOLS binaries
:type path: str
Javier Vegas-Regidor
committed
def __init__(self, path=''):
self.path = path
def run(self, command, input, output=None, options=None, log_level=Log.INFO, input_option=None):
"""
Runs one of the CDFTools
:param command: executable to run
:param output: output file. Not all tools support this parameter
:param options: options for the tool.
:param log_level: log level at which the output of the cdftool command will be added
:param input_option: option to add before input file
:type input_option: str
Javier Vegas-Regidor
committed
line = [os.path.join(self.path, command)]
if input_option:
line.append(input_option)
Javier Vegas-Regidor
committed
if options:
Javier Vegas-Regidor
committed
for option in options:
Javier Vegas-Regidor
committed
if output:
raise ValueError('Input and output file can not be the same on CDFTools')
Javier Vegas-Regidor
committed
line.append('-o')
line.append(output)
Log.debug('Executing {0}', ' '.join(line))
shell_output = Utils.execute_shell_command(line, log_level)
self._check_output_was_created(line, output)
return shell_output
@staticmethod
def _check_output_was_created(line, output):
raise Exception('Error executing {0}\n Output file not created', ' '.join(line))
# noinspection PyShadowingBuiltins
@staticmethod
def _check_input(command, input, line):
if input:
raise ValueError('Error executing {0}\n Input file {1} file does not exist', command, input)
else:
for element in input:
line.append(element)
raise ValueError('Error executing {0}\n Input file {1} file does not exist', command, element)
# noinspection PyMethodMayBeStatic
def is_exe(self, fpath):
return os.path.isfile(fpath) and os.access(fpath, os.X_OK)
def _check_command_existence(self, command):
if self.path:
if self.is_exe(os.path.join(self.path, command)):
return
else:
for path in os.environ["PATH"].split(os.pathsep):
path = path.strip('"')
exe_file = os.path.join(path, command)
if self.is_exe(exe_file):
raise ValueError('Error executing {0}\n Command does not exist in {1}'.format(command, self.path))