ソースを参照

Handle Swarm-style prefixed names in Service.containers()

Signed-off-by: Aanand Prasad <[email protected]>
Aanand Prasad 10 年 前
コミット
edb6b24b8f
2 ファイル変更14 行追加3 行削除
  1. 2 3
      fig/service.py
  2. 12 0
      tests/unit/service_test.py

+ 2 - 3
fig/service.py

@@ -545,9 +545,8 @@ def get_container_name(container):
     if 'Name' in container:
         return container['Name']
     # ps
-    for name in container['Names']:
-        if len(name.split('/')) == 2:
-            return name[1:]
+    shortest_name = min(container['Names'], key=lambda n: len(n.split('/')))
+    return shortest_name.split('/')[-1]
 
 
 def parse_restart_spec(restart_config):

+ 12 - 0
tests/unit/service_test.py

@@ -54,6 +54,7 @@ class ServiceTest(unittest.TestCase):
         self.assertIsNone(get_container_name({}))
         self.assertEqual(get_container_name({'Name': 'myproject_db_1'}), 'myproject_db_1')
         self.assertEqual(get_container_name({'Names': ['/myproject_db_1', '/myproject_web_1/db']}), 'myproject_db_1')
+        self.assertEqual(get_container_name({'Names': ['/swarm-host-1/myproject_db_1', '/swarm-host-1/myproject_web_1/db']}), 'myproject_db_1')
 
     def test_containers(self):
         service = Service('db', client=self.mock_client, project='myproject')
@@ -69,6 +70,17 @@ class ServiceTest(unittest.TestCase):
         ]
         self.assertEqual([c.id for c in service.containers()], ['IN_1'])
 
+    def test_containers_prefixed(self):
+        service = Service('db', client=self.mock_client, project='myproject')
+
+        self.mock_client.containers.return_value = [
+            {'Image': 'busybox', 'Id': 'OUT_1', 'Names': ['/swarm-host-1/myproject', '/swarm-host-1/foo/bar']},
+            {'Image': 'busybox', 'Id': 'OUT_2', 'Names': ['/swarm-host-1/myproject_db']},
+            {'Image': 'busybox', 'Id': 'OUT_3', 'Names': ['/swarm-host-1/db_1']},
+            {'Image': 'busybox', 'Id': 'IN_1', 'Names': ['/swarm-host-1/myproject_db_1', '/swarm-host-1/myproject_web_1/db']},
+        ]
+        self.assertEqual([c.id for c in service.containers()], ['IN_1'])
+
     def test_get_volumes_from_container(self):
         container_id = 'aabbccddee'
         service = Service(