Newer
Older
Javier Vegas-Regidor
committed
import os
from bscearth.utils.log import Log
from earthdiagnostics.utils import Utils
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_file, output_file=None, options=None, log_level=Log.INFO, input_option=None):
:param command: executable to run
:param input_file: input file
:type input_file: str
:param output_file: output file. Not all tools support this parameter
:param options: options for the tool.
:type options: str | [str] | Tuple[str] | None
: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)
self._check_input(command, input_file, line)
Javier Vegas-Regidor
committed
if options:
Javier Vegas-Regidor
committed
for option in options:
if output_file:
if input_file == output_file:
raise ValueError('Input and output file can not be the same on CDFTools')
Javier Vegas-Regidor
committed
line.append('-o')
Log.debug('Executing {0}', ' '.join(line))
shell_output = Utils.execute_shell_command(line, log_level)
self._check_output_was_created(line, output_file)
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
def _check_input(command, input_file, line):
if input_file:
if isinstance(input_file, six.string_types):
line.append(input_file)
if not os.path.isfile(input_file):
raise ValueError('Error executing {0}\n Input file {1} file does not exist', command, input_file)
raise ValueError('Error executing {0}\n Input file {1} file does not exist', command, element)
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)
raise ValueError('Error executing {0}\n Command does not exist in {1}'.format(command, self.path))