# Copyright 2013: Mirantis Inc.
# All Rights Reserved.
#
#    Licensed under the Apache License, Version 2.0 (the "License"); you may
#    not use this file except in compliance with the License. You may obtain
#    a copy of the License at
#
#         http://www.apache.org/licenses/LICENSE-2.0
#
#    Unless required by applicable law or agreed to in writing, software
#    distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
#    WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
#    License for the specific language governing permissions and limitations
#    under the License.

from rally.benchmark.context import base
from rally.openstack.common import log as logging
from rally import osclients


LOG = logging.getLogger(__name__)

SSH_GROUP_NAME = "rally_ssh_open"


def _prepare_open_secgroup(endpoint):
    """Generate secgroup allowing all tcp/udp/icmp access.

    In order to run tests on instances it is necessary to have SSH access.
    This function generates a secgroup which allows all tcp/udp/icmp access
    """
    nova = osclients.Clients(endpoint).nova()

    if SSH_GROUP_NAME not in [sg.name for sg in nova.security_groups.list()]:
        descr = "Allow ssh access to VMs created by Rally for benchmarking"
        rally_open = nova.security_groups.create(SSH_GROUP_NAME, descr)

    rally_open = nova.security_groups.find(name=SSH_GROUP_NAME)

    rules_to_add = [
        {
            "ip_protocol": "tcp",
            "to_port": 65535,
            "from_port": 1,
            "ip_range": {"cidr": "0.0.0.0/0"}
        },
        {
            "ip_protocol": "udp",
            "to_port": 65535,
            "from_port": 1,
            "ip_range": {"cidr": "0.0.0.0/0"}
        },
        {
            "ip_protocol": "icmp",
            "to_port": 1,
            "from_port": -1,
            "ip_range": {"cidr": "0.0.0.0/0"}
        }
    ]

    def rule_match(criteria, existing_rule):
        return all(existing_rule[key] == value
                   for key, value in criteria.iteritems())

    for new_rule in rules_to_add:
        if not any(rule_match(new_rule, existing_rule) for existing_rule
                   in rally_open.rules):
            nova.security_group_rules.create(
                        rally_open.id,
                        from_port=new_rule['from_port'],
                        to_port=new_rule['to_port'],
                        ip_protocol=new_rule['ip_protocol'],
                        cidr=new_rule['ip_range']['cidr'])

    return rally_open


class AllowSSH(base.Context):
    __ctx_name__ = "allow_ssh"

    def __init__(self, context):
        super(AllowSSH, self).__init__(context)
        self.secgroup = []

    def setup(self):
        used_tenants = []
        for user in self.context['users']:
            endpoint = user['endpoint']
            tenant = endpoint.tenant_name
            if tenant not in used_tenants:
                secgroup = _prepare_open_secgroup(endpoint)
                self.secgroup.append(secgroup)
                used_tenants.append(tenant)

    def cleanup(self):
        for secgroup in self.secgroup:
            try:
                secgroup.delete()
            except Exception as ex:
                LOG.warning("Unable to delete secgroup: %(group_id)s. "
                            "Exception: %(ex)s" %
                            {"group_id": secgroup.id, "ex": ex})
