Merge "api_crud: migrate ensure_hm_port_mtu to opentackSDK" into stable/2023.1
This commit is contained in:
@@ -7,3 +7,4 @@
|
||||
git+https://github.com/juju/charm-tools.git
|
||||
|
||||
simplejson
|
||||
openstacksdk==1.0.1
|
||||
|
||||
@@ -33,6 +33,7 @@ from keystoneauth1 import session as keystone_session
|
||||
from keystoneauth1 import exceptions as keystone_exceptions
|
||||
from neutronclient.v2_0 import client as neutron_client
|
||||
from novaclient import client as nova_client
|
||||
from openstack import connection
|
||||
|
||||
import neutron_lib.constants
|
||||
|
||||
@@ -486,10 +487,12 @@ def ensure_hm_port_mtu(identity_service):
|
||||
reflected here as well.
|
||||
"""
|
||||
session = session_from_identity_service(identity_service)
|
||||
nc = init_neutron_client(session)
|
||||
resp = nc.list_networks(tags='charm-octavia')
|
||||
if len(resp['networks']) > 0:
|
||||
network = resp['networks'][0]
|
||||
conn = connection.Connection(session=session,
|
||||
compute_api_version='2',
|
||||
identity_interface='internal')
|
||||
net_resp = list(conn.network.networks(tags='charm-octavia'))
|
||||
if len(net_resp) > 0:
|
||||
network = net_resp[0]
|
||||
ch_core.hookenv.log('ensuring mgmt network {} mtu={}'.
|
||||
format(network['id'], network['mtu']),
|
||||
level=ch_core.hookenv.DEBUG)
|
||||
|
||||
@@ -75,3 +75,4 @@ sys.modules['neutron_lib.constants'] = neutron_lib.constants
|
||||
neutronclient = mock.MagicMock()
|
||||
sys.modules['neutronclient'] = neutronclient
|
||||
sys.modules['neutronclient.v2_0'] = neutronclient.v2_0
|
||||
sys.modules['openstack'] = mock.MagicMock()
|
||||
|
||||
@@ -21,6 +21,8 @@ import charms_openstack.test_utils as test_utils
|
||||
import charm.openstack.octavia as octavia # for constants
|
||||
import charm.openstack.api_crud as api_crud
|
||||
|
||||
from openstack import connection
|
||||
|
||||
|
||||
class FakeNeutronConflictException(Exception):
|
||||
pass
|
||||
@@ -297,12 +299,12 @@ class TestAPICrud(test_utils.PatchHelper):
|
||||
def test_setup_hm_port(self):
|
||||
self.patch_object(api_crud, 'session_from_identity_service')
|
||||
self.patch_object(api_crud, 'init_neutron_client')
|
||||
nc = mock.MagicMock()
|
||||
self.init_neutron_client.return_value = nc
|
||||
self.patch_object(connection, 'Connection')
|
||||
conn = mock.MagicMock()
|
||||
self.Connection.return_value = conn
|
||||
network_uuid = 'fake-network-uuid'
|
||||
nc.list_networks.return_value = {'networks': [{'id': network_uuid,
|
||||
'mtu': 9000}]}
|
||||
|
||||
conn.network.networks.return_value = [{'id': network_uuid,
|
||||
'mtu': 9000}]
|
||||
self.patch_object(octavia.ch_net_ip, 'get_iface_addr')
|
||||
self.get_iface_addr.return_value = [
|
||||
'fe80:db8:42%eth0', '2001:db8:42::42', '127.0.0.1'
|
||||
|
||||
Reference in New Issue
Block a user