# vim: tabstop=4 shiftwidth=4 softtabstop=4

# Copyright (c) 2014, 2015, Oracle and/or its affiliates. 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.

#

# @author: Girish Moodalbail, Oracle, Inc.

import rad.client as radcli

import rad.connect as radcon

import rad.bindings.com.oracle.solaris.rad.evscntl_1 as evsbind

from oslo.config import cfg

from neutron.api.rpc.agentnotifiers import dhcp_rpc_agent_api

from neutron.api.rpc.agentnotifiers import l3_rpc_agent_api

from neutron.api.v2 import attributes

from neutron.common import exceptions

from neutron.common import topics

from neutron.db import db_base_plugin_v2

from neutron.db import external_net_db

from neutron.extensions import external_net

from neutron.extensions import providernet

from neutron.openstack.common import lockutils

from neutron.openstack.common import log as logging

from neutron.plugins.common import constants as svc_constants

LOG = logging.getLogger(__name__)

evs_controller_opts = [

    cfg.StrOpt('evs_controller', default='ssh://evsuser@localhost',

               help=_("An URI that specifies an EVS controller"))

]

cfg.CONF.register_opts(evs_controller_opts, "EVS")

class EVSControllerError(exceptions.NeutronException):

    message = _("EVS controller: %(errmsg)s")

    def __init__(self, evs_errmsg):

        super(EVSControllerError, self).__init__(errmsg=evs_errmsg)

class EVSOpNotSupported(exceptions.NeutronException):

    message = _("Operation not supported by EVS plugin: %(opname)s")

    def __init__(self, evs_errmsg):

        super(EVSOpNotSupported, self).__init__(opname=evs_errmsg)

class EVSNeutronPluginV2(db_base_plugin_v2.NeutronDbPluginV2,

                         external_net_db.External_net_db_mixin,

    """Implements v2 Neutron Plug-in API specification.

    All the neutron API calls to create/delete/retrieve Network/Subnet/Port

    are forwarded to EVS controller through Solaris RAD. The RAD connection

    to EVS Controller is over SSH. In order that this plugin can communicate

    with EVS Controller non-interactively and securely, one should setup SSH

    authentication with pre-shared keys between the host running neutron-server

    and the host running EVS controller.

    The following table maps OpenStack Neutron resources and attributes to

    Solaris Elastic Virtual Switch resources and attributes

    |---------------------+------------------+------------------------------|

    | OpenStack Neutron   | Solaris EVS      | Comments                     |

    |---------------------+------------------+------------------------------|

    | Network             | EVS              | Represents an isolated L2    |

    | -- name             | -- name          | segment; implemented either  |

    | -- id               | -- uuid          | through VLANs or VXLANs      |

    | -- tenant_id        | -- tenant        |                              |

    | -- shared           | Always False     |                              |

    | -- admin_state_up   | Always True      |                              |

    | -- status           | Always ACTIVE    |                              |

    | -- provider:        |                  |                              |

    |    network_type     |  -- l2-type      | (either VLAN or VXLAN)       |

    | -- provider:        |                  |                              |

    |    segmentation_id  |  -- vlanid/vni   |                              |

    |                     |                  |                              |

    |                     |                  |                              |

    | Subnet              | IPnet            | An IP network represents     |

    | -- name             | -- name          | a block of either IPv4       |

    | -- id               | -- uuid          | or IPv6 addresses (subnet)   |

    | -- network_id       | -- evs           | along with a default router  |

    | -- tenant_id        | -- tenant        | for the block                |

    | -- cidr             | -- subnet        |                              |

    | -- gateway_ip       | -- defrouter     |                              |

    | -- allocation_pools | -- start/stop    |                              |

    | -- dns_nameservers  | -- OpenStack:\   |                              |

    |                     | dns_nameservers  |                              |

    | -- host_routes      | -- OpenStack:\   |                              |

    |                     | host_routes      |                              |

    | -- enable_dhcp      | -- OpenStack:\   |                              |

    |                     | enable_dhcp      |                              |

    | -- shared           | Always False     |                              |

    |                     |                  |                              |

    | Port                | VPort            | A VPort represents the point |

    | -- name             | -- name          | of attachment between the    |

    | -- id               | -- uuid          | VNIC and an EVS. It          |

    | -- network_id       | -- evs           | encapsulates various network |

    | -- tenant_id        | -- tenant        | configuration parameters (   |

    | -- status           | -- status        | MAC addresses, IP addresses, |

    | -- mac_address      | -- macaddr       | and SLAs)                    |

    | -- fixed_ips        | -- ipaddr        |                              |

    | -- device_id        | -- OpenStack:\   |                              |

    |                     |    device_id     |                              |

    | -- device_owner     | -- OpenStack:\   |                              |

    |                     |    device_owner  |                              |

    | -- security_groups  | -- Not Supported |                              |

    | -- admin_state_up   | Always UP        |                              |

    |---------------------+------------------+------------------------------|

    """

    _supported_extension_aliases = ["provider", "external-net", "router",

    def __init__(self):

        suh = cfg.CONF.EVS.evs_controller.split('://')

        if len(suh) != 2 or suh[0] != 'ssh' or not suh[1].strip():

            raise SystemExit(_("Specified evs_controller is invalid"))

        uh = suh[1].split('@')

        if len(uh) != 2 or not uh[0].strip() or not uh[1].strip():

            raise SystemExit(_("'user' and 'hostname' need to be specified "

                               "for evs_controller"))

    def _setup_rpc(self):

        # RPC support

        self.service_topics = {svc_constants.CORE: topics.PLUGIN,

                               svc_constants.L3_ROUTER_NAT: topics.L3PLUGIN}

        for svc_topic in self.service_topics.values():

        # Consume from all consumers in a thread

        self.dhcp_agent_notifier = dhcp_rpc_agent_api.DhcpAgentNotifyAPI()

    @property

    def supported_extension_aliases(self):

        return self._supported_extension_aliases

        try:

            ipnet = evs.addIPnet(propstr, ipnetname)

        except radcli.ObjectError as oe:

            raise EVSControllerError(oe.get_payload().errmsg)

        return ipnet

    def create_subnet(self, context, subnet):

        """Creates a subnet(IPnet) for a given network(EVS).

         An IP network represents a block of either IPv4 or IPv6 addresses

         (i.e., subnet) along with a default router for the block. Only one

         IPnet can be associated with an EVS. All the zones/VNICs that

         connect to the EVS, through a VPort, will get an IP address from the

         IPnet associated with the EVS.

        """

        # notify dhcp agent of subnet creation

                                        'subnet.create.end')

    def update_subnet(self, context, id, subnet):

        evs_rpccall_sync = subnet.pop('evs_rpccall_sync', False)

        # notify dhcp agent of subnet update

        methodname = 'subnet.update.end'

        payload = {'subnet': retval}

        if not evs_rpccall_sync:

            self.dhcp_agent_notifier.notify(context, payload, methodname)

        else:

            msg = self.dhcp_agent_notifier.make_msg(

                methodname.replace(".", "_"), payload=payload)

            self.dhcp_agent_notifier.call(context, msg,

                                          topic=topics.DHCP_AGENT)

        return retval

    def get_subnet(self, context, id, fields=None):

    def get_subnets(self, context, filters=None, fields=None,

                    sorts=None, limit=None, marker=None, page_reverse=False):

    def _release_subnet_dhcp_port(self, context, subnet, delete_network):

        """Release any dhcp port associated with the subnet"""

        portlist = self.get_ports(context, filters)

        if delete_network:

            # One can delete a network if there is only one port that has a

            # VNIC attached to it and that port happens to be a DHCP port.

            ports_with_deviceid = [port for port in portlist

                                   if port['device_id'] != '']

            update_subnet = len(ports_with_deviceid) == 1

        else:

            # One can delete a subnet if there is only one port and that

            # port happens to be a DHCP port.

            update_subnet = len(portlist) == 1

        if update_subnet:

            # the lone port is a dhcp port created by dhcp agent

            # it must be released before we can delete the subnet

            subnet_update = {'subnet': {'enable_dhcp': False},

                             'evs_rpccall_sync': True}

            self.update_subnet(context, subnet['id'], subnet_update)

    @lockutils.synchronized('evs-plugin', 'neutron-')

        pat = radcli.ADRGlobPattern({'name': evsname, 'tenant': tenantname})

        try:

            evs.removeIPnet(ipnetuuid)

        except radcli.ObjectError as oe:

            raise EVSControllerError(oe.get_payload().errmsg)

    def delete_subnet(self, context, id):

        subnet = self.get_subnet(context, id)

        if not subnet:

            return

        # If the subnet is dhcp_enabled, then the dhcp agent would have

        # created a port connected to this subnet. We need to remove

        # that port before we can proceed with subnet delete operation.

        # Since, there is no subnet.delete.start event, we use an another

        # approach of updating the subnet's enable_dhcp attribute to

        # False that in turn sends a subnet.udpate notification. This

        # results in DHCP agent releasing the port.

        if subnet['enable_dhcp']:

                self._release_subnet_dhcp_port(context, subnet, False)

        # notify dhcp agent

        payload = {

            'subnet': {

                'network_id': subnet['network_id'],

                'id': id,

            }

        }

        self.dhcp_agent_notifier.notify(context, payload, 'subnet.delete.end')

    @lockutils.synchronized('evs-plugin', 'neutron-')

        try:

        except radcli.ObjectError as oe:

            raise EVSControllerError(oe.get_payload().errmsg)

        return evs

    def create_network(self, context, network):

        """Creates a network(EVS) for a given tenant.

        An Elastic Virtual Switch (EVS) is a virtual switch that spans

        one or more servers (physical machines). It represents an isolated L2

        segment, and the isolation is implemented either through VLANs or

        VXLANs. An EVS provides network connectivity between the Virtual

        Machines connected to it. There are two main resources associated with

        an EVS: IPnet and VPort.

        """

        evsname = network['network']['name']

        if not evsname:

            evsname = None

        tenantname = self._get_tenant_id_for_create(context,

                                                    network['network'])

        proplist = []

        network_type = network['network'][providernet.NETWORK_TYPE]

        if attributes.is_attr_set(network_type):

            proplist.append('l2-type=%s' % network_type)

        segment_id = network['network'][providernet.SEGMENTATION_ID]

        if attributes.is_attr_set(segment_id):

            if (not attributes.is_attr_set(network_type) or

                    len(network_type) == 0):

                raise EVSControllerError(_("provider:network_type must be "

                                           "specified when provider:"

                                           "segmentation_id is provided"))

            if network_type == 'vxlan':

                proplist.append('vni=%d' % segment_id)

            elif network_type == 'vlan':

                proplist.append('vlanid=%d' % segment_id)

            else:

                raise EVSControllerError(_("specified "

                                           "provider:network_type '%s' not "

                                           "supported") % network_type)

        propstr = None

        if proplist:

            propstr = ",".join(proplist)