Merge "Return node name with server API object"

api-ref/source/v1/parameters.yaml

@@ -538,9 +538,9 @@ nics:
   in: body
   required: true
   type: object
-node_uuid:
+node:
   description: |
-    The UUID of the node which our server associated with. Only visible for admin users.
+    The node which our server associated with. Only visible for admin users.
   in: body
   required: false
   type: string

api-ref/source/v1/servers.inc

@@ -62,6 +62,7 @@ Response
   - image_uuid: imageRef
   - availability_zone: availability_zone
   - addresses: addresses
+  - node: node
   - links: links
   - uuid: server_uuid
   - status: server_status
@@ -214,6 +215,7 @@ Response
   - image_uuid: imageRef
   - availability_zone: availability_zone
   - addresses: addresses
+  - node: node
   - links: links
   - uuid: server_uuid
   - status: server_status
@@ -267,7 +269,7 @@ Response
   - image_uuid: imageRef
   - availability_zone: availability_zone
   - addresses: addresses
-  - node_uuid: node_uuid
+  - node: node
   - links: links
   - uuid: server_uuid
   - status: server_status
@@ -332,6 +334,7 @@ Response
   - image_uuid: imageRef
   - availability_zone: availability_zone
   - addresses: addresses
+  - node: node
   - links: links
   - uuid: server_uuid
   - status: server_status

mogan/api/controllers/v1/servers.py

@@ -46,7 +46,7 @@ import re
 _DEFAULT_SERVER_RETURN_FIELDS = ('uuid', 'name', 'description',
                                  'status', 'power_state')
 
-_ONLY_ADMIN_VISIBLE_SEVER_FIELDS = ('node_uuid', 'affinity_zone',)
+_ONLY_ADMIN_VISIBLE_SEVER_FIELDS = ('node', 'affinity_zone',)
 
 LOG = log.getLogger(__name__)
 
@@ -450,8 +450,8 @@ class Server(base.APIBase):
     fault = {wtypes.text: types.jsontype}
     """The fault of the server"""
 
-    node_uuid = types.uuid
-    """The node UUID of the server"""
+    node = wtypes.text
+    """The backend node of the server"""
 
     affinity_zone = wtypes.text
     """The affinity zone of the server"""

mogan/baremetal/driver.py

@@ -137,6 +137,13 @@ class BaseEngineDriver(object):
         """
         raise NotImplementedError()
 
+    def get_node_name(node):
+        """Get the name of a node.
+
+        :param node: the uuid of the node.
+        """
+        raise NotImplementedError()
+
     def get_manageable_nodes(self):
         """Retrieve all manageable nodes information.
 

mogan/baremetal/ironic/driver.py

@@ -753,6 +753,19 @@ class IronicDriver(base_driver.BaseEngineDriver):
         return (not node.instance_uuid and node.provision_state ==
                 ironic_states.AVAILABLE)
 
+    def get_node_name(self, node):
+        """Get the name of a node.
+
+        :param node: the uuid of the node.
+        """
+        try:
+            node = self.ironicclient.call(
+                'node.get', node, fields=('name',))
+        except Exception:
+            return None
+
+        return node.name
+
     def get_manageable_nodes(self):
         nodes = self._get_manageable_nodes()
         manageable_nodes = []

mogan/db/sqlalchemy/alembic/versions/91941bf1ebc9_initial_migration.py

@@ -78,6 +78,7 @@ def upgrade():
         sa.Column('image_uuid', sa.String(length=36), nullable=True),
         sa.Column('launched_at', sa.DateTime(), nullable=True),
         sa.Column('availability_zone', sa.String(length=255), nullable=True),
+        sa.Column('node', sa.String(length=255), nullable=True),
         sa.Column('node_uuid', sa.String(length=36), nullable=True),
         sa.Column('extra', sa.Text(), nullable=True),
         sa.Column('partitions', sa.Text(), nullable=True),

mogan/db/sqlalchemy/models.py

@@ -85,6 +85,7 @@ class Server(Base):
     flavor_uuid = Column(String(36), nullable=True)
     availability_zone = Column(String(255), nullable=True)
     image_uuid = Column(String(36), nullable=True)
+    node = Column(String(255), nullable=True)
     node_uuid = Column(String(36), nullable=True)
     launched_at = Column(DateTime, nullable=True)
     extra = Column(db_types.JsonEncodedDict)

mogan/engine/flows/create_server.py

@@ -101,8 +101,9 @@ class OnFailureRescheduleTask(flow_utils.MoganTask):
                              filter_properties=filter_properties)
 
     def revert(self, context, result, flow_failures, server, **kwargs):
-        # Clean up associated node uuid
+        # Clean up associated node
         server.node_uuid = None
+        server.node = None
         server.save()
 
         # Check if we have a cause which can tell us not to reschedule and

mogan/engine/manager.py

@@ -345,6 +345,7 @@ class EngineManager(base_manager.BaseEngineManager):
 
         for (server, node) in six.moves.zip(servers, nodes):
             server.node_uuid = node
+            server.node = self.driver.get_node_name(node)
             server.save()
             # Add a retry entry for the selected node
             retry_nodes = retry['nodes']

mogan/objects/server.py

@@ -49,6 +49,7 @@ class Server(base.MoganObject, object_base.VersionedObjectDictCompat):
         'image_uuid': object_fields.UUIDField(nullable=True),
         'nics': object_fields.ObjectField('ServerNics', nullable=True),
         'fault': object_fields.ObjectField('ServerFault', nullable=True),
+        'node': object_fields.StringField(nullable=True),
         'node_uuid': object_fields.UUIDField(nullable=True),
         'launched_at': object_fields.DateTimeField(nullable=True),
         'metadata': object_fields.FlexibleDictField(nullable=True),

mogan/tests/unit/api/v1/test_server.py

@@ -138,7 +138,7 @@ class TestServerAuthorization(v1_test.APITestV1):
         headers = self.gen_headers(self.context, roles="no-admin")
         resp = self.get_json('/servers/%s' % self.server1.uuid,
                              headers=headers)
-        self.assertNotIn('node_uuid', resp)
+        self.assertNotIn('node', resp)
 
     def test_server_get_one_by_admin(self):
         # when the evil tenant is admin, he can do everything.
@@ -146,7 +146,7 @@ class TestServerAuthorization(v1_test.APITestV1):
         headers = self.gen_headers(self.context, roles="admin")
         resp = self.get_json('/servers/%s' % self.server1.uuid,
                              headers=headers)
-        self.assertIn('node_uuid', resp)
+        self.assertIn('node', resp)
 
     def test_server_get_one_unauthorized(self):
         # not admin and not the owner

mogan/tests/unit/db/utils.py

@@ -56,6 +56,7 @@ def get_test_server(**kw):
         'image_uuid': kw.get('image_uuid',
                              'ac3b2291-b9ef-45f6-8eeb-21ac568a64a5'),
         'nics': kw.get('nics', fake_server_nics),
+        'node': kw.get('node', 'node-0'),
         'node_uuid': kw.get('node_uuid',
                             'f978ef48-d4af-4dad-beec-e6174309bc71'),
         'launched_at': kw.get('launched_at'),

mogan/tests/unit/objects/test_objects.py

@@ -382,7 +382,7 @@ class _TestObject(object):
 # version bump. It is md5 hash of object fields and remotable methods.
 # The fingerprint values should only be changed if there is a version bump.
 expected_object_fingerprints = {
-    'Server': '1.0-2ede97617e84ef9eed6ac61e67b13167',
+    'Server': '1.0-6b13b984cd3656a977456a12d3d1c167',
     'ServerFault': '1.0-74349ff701259e4834b4e9dc2dac1b12',
     'ServerFaultList': '1.0-43e8aad0258652921f929934e9e048fd',
     'Flavor': '1.0-9f7166aa387d89ec40cd699019d0c9a9',