From 18b03936c208e3c89d7f20eee6063722174bb0b9 Mon Sep 17 00:00:00 2001 From: "Brian C. Lane" Date: Thu, 26 Jul 2018 18:10:57 -0700 Subject: [PATCH] Add composer-cli function tests These depend on there being a freshly installed lorax-composer API server running, if there is no /run/weldr/api.socket they will be skipped. (cherry picked from commit 7700ae3135655b6dcae69f02cb803e52ef1cde14) --- tests/composer/test_blueprints.py | 136 +++++++++++++++++++++++++++++- 1 file changed, 135 insertions(+), 1 deletion(-) diff --git a/tests/composer/test_blueprints.py b/tests/composer/test_blueprints.py index 3da9c7db..4e2abd21 100644 --- a/tests/composer/test_blueprints.py +++ b/tests/composer/test_blueprints.py @@ -14,9 +14,14 @@ # You should have received a copy of the GNU General Public License # along with this program. If not, see . # +import os import unittest -from composer.cli.blueprints import prettyDiffEntry +from ..lib import captured_output + +from composer.cli.blueprints import prettyDiffEntry, blueprints_list, blueprints_show, blueprints_changes +from composer.cli.blueprints import blueprints_diff, blueprints_save, blueprints_delete, blueprints_depsolve +from composer.cli.blueprints import blueprints_push, blueprints_freeze, blueprints_undo, blueprints_tag diff_entries = [{'new': {'Description': 'Shiny new description'}, 'old': {'Description': 'Old reliable description'}}, {'new': {'Version': '0.3.1'}, 'old': {'Version': '0.1.1'}}, @@ -38,3 +43,132 @@ class BlueprintsTest(unittest.TestCase): def test_prettyDiffEntry(self): """Return a nice representation of a diff entry""" self.assertEqual([prettyDiffEntry(entry) for entry in diff_entries], diff_result) + + @unittest.skipUnless(os.path.exists("/run/weldr/api.socket"), "Test requires a running API server") + def test_list(self): + """blueprints list""" + with captured_output() as (out, _): + rc = blueprints_list("/run/weldr/api.socket", 0, [], show_json=False) + output = out.getvalue().strip() + self.assertTrue(rc == 0) + self.assertTrue("http-server" in output) + + @unittest.skipUnless(os.path.exists("/run/weldr/api.socket"), "Test requires a running API server") + def test_show(self): + """blueprints show""" + with captured_output() as (out, _): + blueprints_show("/run/weldr/api.socket", 0, ["http-server"], show_json=False) + output = out.getvalue().strip() + self.assertTrue("http-server" in output) + self.assertTrue("[[packages]]" in output) + self.assertTrue("[[modules]]" in output) + + @unittest.skipUnless(os.path.exists("/run/weldr/api.socket"), "Test requires a running API server") + def test_changes(self): + """blueprints changes""" + with captured_output() as (out, _): + rc = blueprints_changes("/run/weldr/api.socket", 0, ["http-server"], show_json=False) + output = out.getvalue().strip() + self.assertTrue(rc == 0) + self.assertTrue("http-server" in output) + self.assertTrue("Recipe http-server, version 0.0.1 saved." in output) + + @unittest.skipUnless(os.path.exists("/run/weldr/api.socket"), "Test requires a running API server") + def test_diff(self): + """blueprints diff""" + # Get the oldest commit, it should be 2nd to last line + with captured_output() as (out, _): + rc = blueprints_changes("/run/weldr/api.socket", 0, ["http-server"], show_json=False) + output = out.getvalue().strip().splitlines() + first_commit = output[-2].split()[1] + + with captured_output() as (out, _): + rc = blueprints_diff("/run/weldr/api.socket", 0, ["http-server", first_commit, "HEAD"], show_json=False) + output = out.getvalue().strip() + self.assertTrue(rc == 0) + self.assertTrue("Changed Version" in output) + + @unittest.skipUnless(os.path.exists("/run/weldr/api.socket"), "Test requires a running API server") + def test_save_0(self): + """blueprints save""" + blueprints_save("/run/weldr/api.socket", 0, ["http-server"], show_json=False) + self.assertTrue(os.path.exists("http-server.toml")) + + @unittest.skipUnless(os.path.exists("/run/weldr/api.socket"), "Test requires a running API server") + def test_save_1(self): + """blueprints push""" + rc = blueprints_push("/run/weldr/api.socket", 0, ["http-server.toml"], show_json=False) + self.assertTrue(rc == 0) + + @unittest.skipUnless(os.path.exists("/run/weldr/api.socket"), "Test requires a running API server") + def test_delete(self): + """blueprints delete""" + rc = blueprints_delete("/run/weldr/api.socket", 0, ["development"], show_json=False) + self.assertTrue(rc == 0) + + @unittest.skipUnless(os.path.exists("/run/weldr/api.socket"), "Test requires a running API server") + def test_depsolve(self): + """blueprints depsolve""" + with captured_output() as (out, _): + rc = blueprints_depsolve("/run/weldr/api.socket", 0, ["http-server"], show_json=False) + output = out.getvalue().strip() + self.assertTrue(rc == 0) + self.assertTrue("blueprint: http-server v" in output) + self.assertTrue("httpd" in output) + + @unittest.skipUnless(os.path.exists("/run/weldr/api.socket"), "Test requires a running API server") + def test_freeze_show(self): + """blueprints freeze show""" + with captured_output() as (out, _): + rc = blueprints_freeze("/run/weldr/api.socket", 0, ["show", "http-server"], show_json=False) + output = out.getvalue().strip() + self.assertTrue(rc == 0) + self.assertTrue("version" in output) + self.assertTrue("http-server" in output) + self.assertTrue("x86_64" in output) + self.assertTrue("[[packages]]" in output) + self.assertTrue("[[modules]]" in output) + + @unittest.skipUnless(os.path.exists("/run/weldr/api.socket"), "Test requires a running API server") + def test_freeze_save(self): + """blueprints freeze save""" + rc = blueprints_freeze("/run/weldr/api.socket", 0, ["save", "http-server"], show_json=False) + self.assertTrue(rc == 0) + self.assertTrue(os.path.exists("http-server.frozen.toml")) + + @unittest.skipUnless(os.path.exists("/run/weldr/api.socket"), "Test requires a running API server") + def test_freeze(self): + """blueprints freeze""" + with captured_output() as (out, _): + rc = blueprints_freeze("/run/weldr/api.socket", 0, ["http-server"], show_json=False) + output = out.getvalue().strip() + self.assertTrue(rc == 0) + self.assertTrue("blueprint: http-server v" in output) + self.assertTrue("httpd" in output) + self.assertTrue("x86_64" in output) + + @unittest.skipUnless(os.path.exists("/run/weldr/api.socket"), "Test requires a running API server") + def test_tag(self): + """blueprints tag""" + rc = blueprints_tag("/run/weldr/api.socket", 0, ["glusterfs"], show_json=False) + self.assertTrue(rc == 0) + + @unittest.skipUnless(os.path.exists("/run/weldr/api.socket"), "Test requires a running API server") + def test_undo(self): + """blueprints undo""" + # Get the oldest commit, it should be 2nd to last line + with captured_output() as (out, _): + rc = blueprints_changes("/run/weldr/api.socket", 0, ["http-server"], show_json=False) + output = out.getvalue().strip().splitlines() + first_commit = output[-2].split()[1] + + with captured_output() as (out, _): + rc = blueprints_undo("/run/weldr/api.socket", 0, ["http-server", first_commit, "HEAD"], show_json=False) + output = out.getvalue().strip() + self.assertTrue(rc == 0) + + @unittest.skipUnless(os.path.exists("/run/weldr/api.socket"), "Test requires a running API server") + def test_workspace(self): + """blueprints workspace""" + rc = blueprints_push("/run/weldr/api.socket", 0, ["http-server.toml"], show_json=False) + self.assertTrue(rc == 0)