#!/usr/bin/python
# -*- coding: utf-8 -*-

# (c) 2021, Simon Dodsley (simon@purestorage.com)
# GNU General Public License v3.0+ (see COPYING or https://www.gnu.org/licenses/gpl-3.0.txt)

from __future__ import absolute_import, division, print_function

__metaclass__ = type


ANSIBLE_METADATA = {
    "metadata_version": "1.1",
    "status": ["preview"],
    "supported_by": "community",
}


DOCUMENTATION = """
---
module: purefb_userquota
version_added: "1.7.0"
short_description:  Manage filesystem user quotas
description:
    - This module manages user quotas for filesystems on Pure Storage FlashBlade.
author: Pure Storage Ansible Team (@sdodsley) <pure-ansible-team@purestorage.com>
options:
  name:
    description:
      - Filesystem Name.
    required: true
    type: str
  state:
    description:
      - Create, delete or modifies a quota.
    required: false
    default: present
    type: str
    choices: [ "present", "absent" ]
  quota:
    description:
      - User quota in M, G, T or P units. This cannot be 0.
      - This value will override the file system's default user quota.
    type: str
  uid:
    description:
      - The user id on which the quota is enforced.
      - Cannot be combined with I(uname)
    type: int
  uname:
    description:
      - The user name on which the quota is enforced.
      - Cannot be combined with I(uid)
    type: str
extends_documentation_fragment:
    - purestorage.flashblade.purestorage.fb
"""

EXAMPLES = """
- name: Create new user (using UID) quota for filesystem named foo
  purestorage.flashblade.purefb_userquota:
    name: foo
    quota: 1T
    uid: 1234
    state: present
    fb_url: 10.10.10.2
    api_token: T-55a68eb5-c785-4720-a2ca-8b03903bf641

- name: Create new user (using username) quota for filesystem named foo
  purestorage.flashblade.purefb_userquota:
    name: foo
    quota: 1T
    uname: bar
    state: present
    fb_url: 10.10.10.2
    api_token: T-55a68eb5-c785-4720-a2ca-8b03903bf641

- name: Delete user quota on filesystem foo for user by UID
  purestorage.flashblade.purefb_userquota:
    name: foo
    uid: 1234
    state: absent
    fb_url: 10.10.10.2
    api_token: T-55a68eb5-c785-4720-a2ca-8b03903bf641

- name: Delete user quota on filesystem foo for user by username
  purestorage.flashblade.purefb_userquota:
    name: foo
    uname: bar
    state: absent
    fb_url: 10.10.10.2
    api_token: T-55a68eb5-c785-4720-a2ca-8b03903bf641

- name: Update user quota on filesystem foo for user by username
  purestorage.flashblade.purefb_userquota:
    name: foo
    quota: 20G
    uname: bar
    state: absent
    fb_url: 10.10.10.2
    api_token: T-55a68eb5-c785-4720-a2ca-8b03903bf641

- name: Update user quota on filesystem foo for user by UID
  purestorage.flashblade.purefb_userquota:
    name: foo
    quota: 20G
    uid: bar
    state: absent
    fb_url: 10.10.10.2
    api_token: T-55a68eb5-c785-4720-a2ca-8b03903bf641
"""

RETURN = """
"""

HAS_PURITY_FB = True
try:
    from purity_fb import QuotasUser
except ImportError:
    HAS_PURITY_FB = False

from ansible.module_utils.basic import AnsibleModule, human_to_bytes
from ansible_collections.purestorage.flashblade.plugins.module_utils.purefb import (
    get_blade,
    purefb_argument_spec,
)


MIN_REQUIRED_API_VERSION = "1.6"


def get_fs(module, blade):
    """Return Filesystem or None"""
    fsys = []
    fsys.append(module.params["name"])
    try:
        res = blade.file_systems.list_file_systems(names=fsys)
        return res.items[0]
    except Exception:
        return None


def get_quota(module, blade):
    """Return Filesystem User Quota or None"""
    fsys = []
    fsys.append(module.params["name"])
    try:
        if module.params["uid"]:
            res = blade.quotas_users.list_user_quotas(
                file_system_names=fsys, filter="user.id=" + str(module.params["uid"])
            )
        else:
            res = blade.quotas_users.list_user_quotas(
                file_system_names=fsys,
                filter="user.name='" + module.params["uname"] + "'",
            )
        return res.items[0]
    except Exception:
        return None


def create_quota(module, blade):
    """Create Filesystem User Quota"""
    changed = True
    quota = int(human_to_bytes(module.params["quota"]))
    if not module.check_mode:
        try:
            if module.params["uid"]:
                blade.quotas_users.create_user_quotas(
                    file_system_names=[module.params["name"]],
                    uids=[module.params["uid"]],
                    quota=QuotasUser(quota=quota),
                )
            else:
                blade.quotas_users.create_user_quotas(
                    file_system_names=[module.params["name"]],
                    user_names=[module.params["uname"]],
                    quota=QuotasUser(quota=quota),
                )
        except Exception:
            if module.params["uid"]:
                module.fail_json(
                    msg="Failed to create quote for UID {0} on filesystem {1}.".format(
                        module.params["uid"], module.params["name"]
                    )
                )
            else:
                module.fail_json(
                    msg="Failed to create quote for username {0} on filesystem {1}.".format(
                        module.params["uname"], module.params["name"]
                    )
                )
    module.exit_json(changed=changed)


def update_quota(module, blade):
    """Upodate Filesystem User Quota"""
    changed = False
    current_quota = get_quota(module, blade)
    quota = int(human_to_bytes(module.params["quota"]))
    if current_quota.quota != quota:
        changed = True
        if not module.check_mode:
            if module.params["uid"]:
                try:
                    blade.quotas_users.update_user_quotas(
                        file_system_names=[module.params["name"]],
                        uids=[module.params["uid"]],
                        quota=QuotasUser(quota=quota),
                    )
                except Exception:
                    module.fail_json(
                        msg="Failed to update quota for UID {0} on filesystem {1}.".format(
                            module.params["uid"], module.params["name"]
                        )
                    )
            else:
                try:
                    blade.quotas_users.update_user_quotas(
                        file_system_names=[module.params["name"]],
                        user_names=[module.params["uname"]],
                        quota=QuotasUser(quota=quota),
                    )
                except Exception:
                    module.fail_json(
                        msg="Failed to update quota for UID {0} on filesystem {1}.".format(
                            module.params["uname"], module.params["name"]
                        )
                    )
    module.exit_json(changed=changed)


def delete_quota(module, blade):
    """Delete Filesystem User Quota"""
    changed = True
    if not module.check_mode:
        try:
            if module.params["uid"]:
                blade.quotas_users.delete_user_quotas(
                    file_system_names=[module.params["name"]],
                    uids=[module.params["uid"]],
                )
            else:
                blade.quotas_users.delete_user_quotas(
                    file_system_names=[module.params["name"]],
                    user_names=[module.params["uname"]],
                )
        except Exception:
            if module.params["uid"]:
                module.fail_json(
                    msg="Failed to delete quota for UID {0} on filesystem {1}.".format(
                        module.params["uid"], module.params["name"]
                    )
                )
            else:
                module.fail_json(
                    msg="Failed to delete quota for username {0} on filesystem {1}.".format(
                        module.params["uname"], module.params["name"]
                    )
                )
    module.exit_json(changed=changed)


def main():
    argument_spec = purefb_argument_spec()
    argument_spec.update(
        dict(
            name=dict(type="str", required=True),
            uid=dict(type="int"),
            uname=dict(type="str"),
            state=dict(default="present", choices=["present", "absent"]),
            quota=dict(type="str"),
        )
    )

    mutually_exclusive = [["uid", "uname"]]
    required_if = [["state", "present", ["quota"]]]
    module = AnsibleModule(
        argument_spec,
        mutually_exclusive=mutually_exclusive,
        required_if=required_if,
        supports_check_mode=True,
    )

    if not HAS_PURITY_FB:
        module.fail_json(msg="purity_fb sdk is required for this module")

    state = module.params["state"]
    blade = get_blade(module)
    versions = blade.api_version.list_versions().versions

    if MIN_REQUIRED_API_VERSION not in versions:
        module.fail_json(
            msg="Minimum FlashBlade REST version required: {0}".format(
                MIN_REQUIRED_API_VERSION
            )
        )
    fsys = get_fs(module, blade)
    if not fsys:
        module.fail_json(
            msg="Filesystem {0} does not exist.".format(module.params["name"])
        )
    quota = get_quota(module, blade)

    if state == "present" and not quota:
        create_quota(module, blade)
    elif state == "present" and quota:
        update_quota(module, blade)
    elif state == "absent" and quota:
        delete_quota(module, blade)

    module.exit_json(changed=False)


if __name__ == "__main__":
    main()