Restore RPC after tenant_id -> project_id DB column rename

Closes-Bug: #1649762
Change-Id: Iaf99814082d122512e5ee17dd2dc6f6682c3d196
This commit is contained in:
YAMAMOTO Takashi 2016-12-14 13:14:31 +09:00
parent 55b0e6618f
commit b942ead930
3 changed files with 10 additions and 1 deletions

View File

@ -169,6 +169,8 @@ class BaseIPsecVPNDriver(service_drivers.VpnDriver):
also converting parameter name for vpn agent driver
"""
vpnservice_dict = dict(vpnservice)
# Populate tenant_id for RPC compat
vpnservice_dict['tenant_id'] = vpnservice_dict['project_id']
vpnservice_dict['ipsec_site_connections'] = []
if vpnservice.subnet:
vpnservice_dict['subnet'] = dict(vpnservice.subnet)

View File

@ -196,6 +196,8 @@ class CiscoCsrIPsecVPNDriver(base_ipsec.BaseIPsecVPNDriver):
def make_vpnservice_dict(self, context, vpnservice, router_info):
"""Collect all service info, including Cisco info for IPSec conn."""
vpnservice_dict = dict(vpnservice)
# Populate tenant_id for RPC compat
vpnservice_dict['tenant_id'] = vpnservice_dict['project_id']
vpnservice_dict['ipsec_conns'] = []
vpnservice_dict['subnet'] = dict(vpnservice.subnet)
vpnservice_dict['router_info'] = self._get_router_info(router_info)

View File

@ -166,7 +166,8 @@ class TestIPsecDriver(base.BaseTestCase):
external_v4_ip=external_ip,
external_v6_ip=None,
subnet_id=subnet_id,
router_id='foo-router-id')
router_id='foo-router-id',
project_id='foo-project-id')
if local_endpoints:
fake_vpnservice.subnet = None
else:
@ -207,6 +208,8 @@ class TestIPsecDriver(base.BaseTestCase):
'network_id': 'foo-net-id'},
'subnet_id': 'foo-subnet-id',
'external_ip': external_ip,
'project_id': 'foo-project-id',
'tenant_id': 'foo-project-id',
'ipsec_site_connections': [
{'id': 'conn-id',
'peer_id': peer_id,
@ -246,6 +249,8 @@ class TestIPsecDriver(base.BaseTestCase):
'subnet': None,
'subnet_id': None,
'external_ip': external_ip,
'project_id': 'foo-project-id',
'tenant_id': 'foo-project-id',
'ipsec_site_connections': [
{'id': 'conn-id',
'peer_id': peer_id,