From 5688d2243ccbcd7bbef4e672e27f098e0eebd463 Mon Sep 17 00:00:00 2001
From: Matt Clay <matt@mystile.com>
Date: Fri, 9 Mar 2018 14:30:04 -0800
Subject: [PATCH] Update support for Tower testing.

This is required for compatibility with the latest
version of ansible-core-ci, which now handles more
of the Tower instance setup.
---
 test/runner/lib/cloud/tower.py | 90 ++++++----------------------------
 1 file changed, 15 insertions(+), 75 deletions(-)

diff --git a/test/runner/lib/cloud/tower.py b/test/runner/lib/cloud/tower.py
index 964ee0707f1..29e147f9e90 100644
--- a/test/runner/lib/cloud/tower.py
+++ b/test/runner/lib/cloud/tower.py
@@ -121,10 +121,6 @@ class TowerCloudProvider(CloudProvider):
 
         connection = aci.get()
 
-        self._set_cloud_config('ssh_hostname', connection.hostname)
-        self._set_cloud_config('ssh_username', connection.username)
-        self._set_cloud_config('ssh_port', connection.port)
-
         config = self._read_config_template()
 
         if not self.args.explain:
@@ -133,8 +129,8 @@ class TowerCloudProvider(CloudProvider):
             values = dict(
                 VERSION=self.version,
                 HOST=connection.hostname,
-                USERNAME='admin',
-                PASSWORD=generate_password(),
+                USERNAME=connection.username,
+                PASSWORD=connection.password,
             )
 
             config = self._populate_config_template(config, values)
@@ -147,51 +143,8 @@ class TowerCloudEnvironment(CloudEnvironment):
     def setup(self):
         """Setup which should be done once per environment instead of once per test target."""
         self.setup_cli()
-
-        if self.managed:
-            self.setup_dynamic()
-
-        self.ping_tower_api()
         self.disable_pendo()
 
-    def setup_dynamic(self):
-        """Dynamic setup which should be done once per environment instead of once per test target."""
-        display.info('Waiting for Tower instance to become reachable over SSH')
-
-        ssh_hostname = self._get_cloud_config('ssh_hostname')
-        ssh_username = self._get_cloud_config('ssh_username')
-        ssh_port = self._get_cloud_config('ssh_port')
-
-        config = TowerConfig.parse(self.config_path)
-
-        aci = get_tower_aci(self.args)
-        aci.connection = InstanceConnection(True, ssh_hostname, ssh_port, ssh_username, None)
-
-        mci = ManagePosixCI(aci)
-        mci.wait()
-
-        display.info('Waiting for Tower to be reconfigured')
-
-        attempts = 60
-
-        while attempts:
-            attempts -= 1
-
-            try:
-                # Tower is supposed to drop a /etc/tower/reset/.reconfigured file when it is reconfigured.
-                # However, the playbook sometimes fails, so we'll look for the completion of the playbook in the log instead.
-                mci.ssh(['grep', '--quiet', '--no-messages', 'PLAY RECAP', '/etc/tower/reset/reset.log'])
-                break
-            except SubprocessError:
-                time.sleep(5)
-        else:
-            raise ApplicationError('Timed out waiting for Tower to be reconfigured.')
-
-        display.info('Updating the Tower %s password' % config.username)
-
-        cmd = ['awx-manage', 'update_password', '--username', config.username, '--password', config.password]
-        mci.ssh(cmd)
-
     def setup_cli(self):
         """Install the correct Tower CLI for the version of Tower being tested."""
         tower_cli_version = self._get_cloud_config('tower_cli_version')
@@ -203,31 +156,6 @@ class TowerCloudEnvironment(CloudEnvironment):
 
         run_command(self.args, cmd)
 
-    def ping_tower_api(self):
-        """Wait for Tower API to become available."""
-        display.info('Waiting for the Tower API to become reachable')
-
-        config = TowerConfig.parse(self.config_path)
-
-        http = HttpClient(self.args, insecure=True)
-        http.username = config.username
-        http.password = config.password
-
-        uri = 'https://%s/api/v1/ping/' % config.host
-
-        attempts = 60
-
-        while attempts:
-            attempts -= 1
-            response = http.get(uri)
-
-            if response.status_code == 200:
-                return
-
-            time.sleep(5)
-
-        raise ApplicationError('Timed out waiting for Tower API to become reachable.')
-
     def disable_pendo(self):
         """Disable Pendo tracking."""
         display.info('Disable Pendo tracking')
@@ -238,7 +166,19 @@ class TowerCloudEnvironment(CloudEnvironment):
         cmd = ['tower-cli', 'setting', 'modify', 'PENDO_TRACKING_STATE', 'off',
                '-h', config.host, '-u', config.username, '-p', config.password]
 
-        run_command(self.args, cmd)
+        attempts = 60
+
+        while True:
+            attempts -= 1
+
+            try:
+                run_command(self.args, cmd, capture=True)
+                return
+            except SubprocessError as ex:
+                if not attempts:
+                    raise ApplicationError('Timed out trying to disable Pendo tracking:\n%s' % ex)
+
+            time.sleep(5)
 
     def configure_environment(self, env, cmd):
         """Configuration which should be done once for each test target.