1
# Copyright 2011 Citrix Systems.
4
# Licensed under the Apache License, Version 2.0 (the "License"); you may
5
# not use this file except in compliance with the License. You may obtain
6
# a copy of the License at
8
# http://www.apache.org/licenses/LICENSE-2.0
10
# Unless required by applicable law or agreed to in writing, software
11
# distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
12
# WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
13
# License for the specific language governing permissions and limitations
20
from quantum.api import api_common as common
21
from quantum.api import faults
22
from quantum.api.views import ports as ports_view
23
from quantum.common import exceptions as exception
25
LOG = logging.getLogger('quantum.api.ports')
27
class Controller(common.QuantumController):
28
""" Port API controller for Quantum API """
30
_port_ops_param_list = [{
31
'param-name': 'port-state',
32
'default-value': 'DOWN',
36
_attachment_ops_param_list = [{
37
'param-name': 'attachment-id',
41
_serialization_metadata = {
44
"port": ["id","state"],
49
def __init__(self, plugin_conf_file=None):
50
self._resource_name = 'port'
51
super(Controller, self).__init__()
53
def index(self, req, tenant_id, network_id):
54
""" Returns a list of port ids for a given network """
55
return self._items(req, tenant_id, network_id, is_detail=False)
57
def _items(self, req, tenant_id, network_id, is_detail):
58
""" Returns a list of networks. """
60
ports = self.network_manager.get_all_ports(tenant_id, network_id)
61
builder = ports_view.get_view_builder(req)
62
result = [builder.build(port, is_detail)['port']
64
return dict(ports=result)
65
except exception.NetworkNotFound as e:
66
return faults.Fault(faults.NetworkNotFound(e))
68
def show(self, req, tenant_id, network_id, id):
69
""" Returns port details for given port and network """
71
port = self.network_manager.get_port_details(
72
tenant_id, network_id, id)
73
builder = ports_view.get_view_builder(req)
74
#build response with details
75
result = builder.build(port, True)
76
return dict(ports=result)
77
except exception.NetworkNotFound as e:
78
return faults.Fault(faults.NetworkNotFound(e))
79
except exception.PortNotFound as e:
80
return faults.Fault(faults.PortNotFound(e))
82
def create(self, req, tenant_id, network_id):
83
""" Creates a new port for a given network """
84
#look for port state in request
87
self._parse_request_params(req, self._port_ops_param_list)
88
except exc.HTTPError as e:
89
return faults.Fault(e)
91
port = self.network_manager.create_port(tenant_id,
93
req_params['port-state'])
94
builder = ports_view.get_view_builder(req)
95
result = builder.build(port)
96
return dict(ports=result)
97
except exception.NetworkNotFound as e:
98
return faults.Fault(faults.NetworkNotFound(e))
99
except exception.StateInvalid as e:
100
return faults.Fault(faults.RequestedStateInvalid(e))
102
def update(self, req, tenant_id, network_id, id):
103
""" Updates the state of a port for a given network """
104
#look for port state in request
107
self._parse_request_params(req, self._port_ops_param_list)
108
except exc.HTTPError as e:
109
return faults.Fault(e)
111
port = self.network_manager.update_port(tenant_id,network_id, id,
112
req_params['port-state'])
113
builder = ports_view.get_view_builder(req)
114
result = builder.build(port, True)
115
return dict(ports=result)
116
except exception.NetworkNotFound as e:
117
return faults.Fault(faults.NetworkNotFound(e))
118
except exception.PortNotFound as e:
119
return faults.Fault(faults.PortNotFound(e))
120
except exception.StateInvalid as e:
121
return faults.Fault(faults.RequestedStateInvalid(e))
124
def delete(self, req, tenant_id, network_id, id):
125
""" Destroys the port with the given id """
126
#look for port state in request
128
self.network_manager.delete_port(tenant_id, network_id, id)
129
return exc.HTTPAccepted()
130
#TODO(salvatore-orlando): Handle portInUse error
131
except exception.NetworkNotFound as e:
132
return faults.Fault(faults.NetworkNotFound(e))
133
except exception.PortNotFound as e:
134
return faults.Fault(faults.PortNotFound(e))
135
except exception.PortInUse as e:
136
return faults.Fault(faults.PortInUse(e))
139
def get_resource(self,req,tenant_id, network_id, id):
141
result = self.network_manager.get_interface_details(
142
tenant_id, network_id, id)
143
return dict(attachment=result)
144
except exception.NetworkNotFound as e:
145
return faults.Fault(faults.NetworkNotFound(e))
146
except exception.PortNotFound as e:
147
return faults.Fault(faults.PortNotFound(e))
149
#TODO - Complete implementation of these APIs
150
def attach_resource(self,req,tenant_id, network_id, id):
151
content_type = req.best_match_content_type()
152
print "Content type:%s" %content_type
155
self._parse_request_params(req,
156
self._attachment_ops_param_list)
157
except exc.HTTPError as e:
158
return faults.Fault(e)
160
self.network_manager.plug_interface(tenant_id,
162
req_params['attachment-id'])
163
return exc.HTTPAccepted()
164
except exception.NetworkNotFound as e:
165
return faults.Fault(faults.NetworkNotFound(e))
166
except exception.PortNotFound as e:
167
return faults.Fault(faults.PortNotFound(e))
168
except exception.PortInUse as e:
169
return faults.Fault(faults.PortInUse(e))
170
except exception.AlreadyAttached as e:
171
return faults.Fault(faults.AlreadyAttached(e))
174
#TODO - Complete implementation of these APIs
175
def detach_resource(self,req,tenant_id, network_id, id):
177
self.network_manager.unplug_interface(tenant_id,
179
return exc.HTTPAccepted()
180
except exception.NetworkNotFound as e:
181
return faults.Fault(faults.NetworkNotFound(e))
182
except exception.PortNotFound as e:
183
return faults.Fault(faults.PortNotFound(e))