1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
|
# Copyright (c) 2015 OpenStack Foundation
# 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 networking_odl.common import constants as odl_const
from networking_odl.common import utils as odl_utils
def _filter_unmapped_null(resource_dict, unmapped_keys):
# NOTE(yamahata): bug work around
# https://bugs.eclipse.org/bugs/show_bug.cgi?id=475475
# Null-value for an unmapped element causes next mapped
# collection to contain a null value
# JSON: { "unmappedField": null, "mappedCollection": [ "a" ] }
#
# Java Object:
# class Root {
# Collection<String> mappedCollection = new ArrayList<String>;
# }
#
# Result:
# Field B contains one element; null
#
# TODO(yamahata): update along side with neutron and ODL
# add when neutron adds more extensions
# delete when ODL neutron northbound supports it
# TODO(yamahata): do same thing for other resources
keys_to_del = [key for key in unmapped_keys
if resource_dict.get(key) is None]
if keys_to_del:
odl_utils.try_del(resource_dict, keys_to_del)
_NETWORK_UNMAPPED_KEYS = ['qos_policy_id']
_PORT_UNMAPPED_KEYS = ['binding:profile', 'dns_name',
'port_security_enabled', 'qos_policy_id']
def _filter_network_create(network):
odl_utils.try_del(network, ['status', 'subnets'])
_filter_unmapped_null(network, _NETWORK_UNMAPPED_KEYS)
def _filter_network_update(network):
odl_utils.try_del(network, ['id', 'status', 'subnets', 'tenant_id'])
_filter_unmapped_null(network, _NETWORK_UNMAPPED_KEYS)
def _filter_subnet_update(subnet):
odl_utils.try_del(subnet, ['id', 'network_id', 'ip_version', 'cidr',
'allocation_pools', 'tenant_id'])
def _filter_port_create(port):
"""Filter out port attributes not required for a create."""
odl_utils.try_del(port, ['status'])
_filter_unmapped_null(port, _PORT_UNMAPPED_KEYS)
def _filter_port_update(port):
"""Filter out port attributes for an update operation."""
odl_utils.try_del(port, ['network_id', 'id', 'status', 'mac_address',
'tenant_id', 'fixed_ips'])
_filter_unmapped_null(port, _PORT_UNMAPPED_KEYS)
def _filter_router_update(router):
"""Filter out attributes for an update operation."""
odl_utils.try_del(router, ['id', 'tenant_id', 'status'])
_FILTER_MAP = {
(odl_const.ODL_NETWORK, odl_const.ODL_CREATE): _filter_network_create,
(odl_const.ODL_NETWORK, odl_const.ODL_UPDATE): _filter_network_update,
(odl_const.ODL_SUBNET, odl_const.ODL_UPDATE): _filter_subnet_update,
(odl_const.ODL_PORT, odl_const.ODL_CREATE): _filter_port_create,
(odl_const.ODL_PORT, odl_const.ODL_UPDATE): _filter_port_update,
(odl_const.ODL_ROUTER, odl_const.ODL_UPDATE): _filter_router_update,
}
def filter_for_odl(object_type, operation, data):
"""Filter out the attributed before sending the data to ODL"""
filter_key = (object_type, operation)
if filter_key in _FILTER_MAP:
_FILTER_MAP[filter_key](data)
|
