from ansible.errors import AnsibleError
from ansible.plugins.action import ActionBase

_engine_to_module = {
   'docker': 'community.docker.docker_image',
   'podman': 'containers.podman.podman_image'
}

class ActionModule(ActionBase):
    def run(self, tmp=None, task_vars=None):
        super(ActionModule, self).run(tmp, task_vars)
        module_args = self._task.args.copy()
        engine = task_vars.get("container_engine", "docker")
        if engine == "podman":
            # Translate from docker args
            source = module_args["source"]
            if source == "build":
                module_args["state"] = "build"
            elif source == "pull":
                module_args["pull"] = True
            else:
                raise AnsibleError(f'Unsupported source parameter: {source}')
            del module_args["source"]
        module = _engine_to_module.get(engine)
        module_return = self._execute_module(module_name=module,
                                             module_args=module_args,
                                             task_vars=task_vars, tmp=tmp)
        return module_return