from typing import NamedTuple


# Job mock and helpers=======================================
class Job:
    def __init__(self):
        self.input_datasets = []
        self.input_library_datasets = []
        self.param_values = {}
        self.parameters = []

    def set_arg_value(self, key, value):
        self.param_values[key] = value

    def add_input_dataset(self, dataset):
        self.input_datasets.append(dataset)

    def get_parameters(self):
        return self.parameters


class InputDataset:
    def __init__(self, name, dataset):
        self.name = name
        self.dataset = dataset


class NotAFile:
    pass


class Dataset:
    def __init__(self, file_name, file_ext, value):
        self.file_name_ = file_name
        self.datatype = Datatype(file_ext)
        self.ext = file_ext
        self.metadata = {}
        self.metadata["sequences"] = value

    def get_metadata(self):
        return self.metadata

    def get_file_name(self, sync_cache=True):
        return self.file_name_


class Datatype:
    def __init__(self, file_ext):
        self.file_ext = file_ext


# Tool mock and helpers=========================================
class Tool:
    def __init__(self, id):
        self.old_id = id
        self.installed_tool_dependencies = []

    def add_tool_dependency(self, dependency):
        self.installed_tool_dependencies.append(dependency)

    def get_param_values(self, job: Job, ignore_errors=False):
        return job.param_values


class ToolDependency:
    def __init__(self, name, dir_name):
        self.name = name
        self.dir_name = dir_name

    def installation_directory(self, app):
        return self.dir_name


# App mock=======================================================
class App:
    def __init__(self, tool_id: str, params: str):
        self.job_config = JobConfig(tool_id, params)


class Info(NamedTuple):
    id: str
    nativeSpec: str
    runner: str


class JobConfig:
    def __init__(self, tool_id, params):
        self.tool_id = tool_id
        self.nativeSpec = params
        self.default_id = "cluster_default"
        self.defNativeSpec = "-q test.q"
        self.defRunner = "drmaa"
        self.keys = {
            tool_id: Info(self.tool_id, self.nativeSpec, self.defRunner),
            "cluster_default": Info(self.default_id, self.defNativeSpec, self.defRunner),
        }

    def get_destination(self, tool_id):
        invalid_destinations = [
            "cluster-kow",
            "destinationf",
            "thig",
            "not_true_destination",
            "cluster_kow",
            "Destination_3_med",
            "fake_destination",
            "cluster_defaut",
            "even_lamerr_cluster",
            "no_such_dest",
        ]
        if tool_id in invalid_destinations:
            return None
        else:
            return tool_id


# JobMappingException mock=======================================
class JobMappingException(Exception):
    pass


class JobDestination:
    def __init__(self, params=None, **kwd):
        params = params or {}
        self.id = kwd.get("id")
        self.nativeSpec = params["nativeSpecification"]
        self.runner = kwd.get("runner")