#!/usr/bin/python

import re

from ansible.errors import AnsibleActionFail
from ansible.plugins.action import ActionBase
from ansible_collections.tensin.infra.plugins.module_utils import git


class ActionModule(ActionBase):
    def run(self, tmp=None, task_vars=None):
        result = super().run(tmp, task_vars)

        msg = self._task.args["msg"]
        allowlist = self._task.args.get("allowlist", [])
        allowlist = [re.compile(pattern) for pattern in allowlist]
        skip_no_changes = self._task.args.get("skip_no_changes", False)

        dirty_files = git.get_dirty_file_list(self, "/etc", task_vars)
        if not dirty_files:
            if skip_no_changes:
                return result
            raise AnsibleActionFail("Nothing to commit")

        if allowlist:
            unexpected = [
                path
                for path in dirty_files
                if not any([pattern.fullmatch(path) for pattern in allowlist])
            ]
            if unexpected:
                raise AnsibleActionFail(
                    f"Unexpected modifications in repository:\n{'\n'.join(unexpected)}"
                )

        return self._commit(msg, task_vars)

    def _commit(self, msg, task_vars):
        cmd_result = self._execute_module(
            module_name="ansible.builtin.command",
            module_args=dict(
                argv=["etckeeper", "commit", msg],
            ),
            task_vars=task_vars,
        )
        if cmd_result.get("failed"):
            raise AnsibleActionFail("etckeeper commit failed", result=cmd_result)
        return cmd_result