MGMT-15964: Bump assisted-installer, assisted-installer-agent, assist…

…ed-service to latest versions

The dependencies in the swarm project have been too old for some time.
This PR addresses that by bumping versions to the latest.

Dockerfile.assisted-swarm-build

@@ -1,4 +1,4 @@
-FROM registry.ci.openshift.org/openshift/release:golang-1.17
+FROM registry.ci.openshift.org/openshift/release:golang-1.21
 ENV GO111MODULE=on
 ENV GOFLAGS=""
 

agent.py

@@ -60,6 +60,7 @@ class ClusterAgentConfig:
     identifier: str
     machine_hostname: str
     machine_ip: str
+    machine_ipv6: str
     cluster_identifier: str
     cluster_dir: Path
     cluster_hosts: List[dict]
@@ -260,6 +261,8 @@ def run_agent(self, next_state):
             cluster_hosts_file.write(json.dumps(self.cluster_agent_config.cluster_hosts))
             cluster_hosts_file_path = cluster_hosts_file.name
 
+        self.logging.info(f"swarm_agent_config.agent_image_path: {self.swarm_agent_config.agent_image_path}")
+
         new_agent_params = assisted_swarm.NewAgentParams(
             service_url=self.service_url,
             infra_env_id=self.infraenv_id,
@@ -275,9 +278,11 @@ def run_agent(self, next_state):
             # The installer needs to know all the hostnames in the cluster
             dry_cluster_hosts_path=cluster_hosts_file_path,
             dry_forced_host_ipv4=self.cluster_agent_config.machine_ip,
+            dry_forced_host_ipv6=self.cluster_agent_config.machine_ipv6
         )
 
         response = self.swarm_agent_config.swarm_client.create_new_agent(new_agent_params=new_agent_params)
+        self.logging.info(f"response: {response}")
         try:
             return next_state if self.wait_for_completion(response.id) else self.state
         finally:

assisted_swarm_client/assisted_swarm/models/new_agent_params.py

@@ -40,6 +40,7 @@ class NewAgentParams(object):
         'containers_storage_conf': 'str',
         'dry_forced_host_id': 'str',
         'dry_forced_host_ipv4': 'str',
+        'dry_forced_host_ipv6': 'str',
         'dry_forced_mac_address': 'str',
         'dry_forced_hostname': 'str',
         'dry_fake_reboot_marker_path': 'str',
@@ -56,13 +57,14 @@ class NewAgentParams(object):
         'containers_storage_conf': 'containers_storage_conf',
         'dry_forced_host_id': 'dry_forced_host_id',
         'dry_forced_host_ipv4': 'dry_forced_host_ipv4',
+        'dry_forced_host_ipv6': 'dry_forced_host_ipv6',
         'dry_forced_mac_address': 'dry_forced_mac_address',
         'dry_forced_hostname': 'dry_forced_hostname',
         'dry_fake_reboot_marker_path': 'dry_fake_reboot_marker_path',
         'dry_cluster_hosts_path': 'dry_cluster_hosts_path'
     }
 
-    def __init__(self, service_url=None, infra_env_id=None, agent_version=None, cacert=None, pull_secret=None, containers_conf=None, containers_storage_conf=None, dry_forced_host_id=None, dry_forced_host_ipv4=None, dry_forced_mac_address=None, dry_forced_hostname=None, dry_fake_reboot_marker_path=None, dry_cluster_hosts_path=None):  # noqa: E501
+    def __init__(self, service_url=None, infra_env_id=None, agent_version=None, cacert=None, pull_secret=None, containers_conf=None, containers_storage_conf=None, dry_forced_host_id=None, dry_forced_host_ipv4=None, dry_forced_host_ipv6=None, dry_forced_mac_address=None, dry_forced_hostname=None, dry_fake_reboot_marker_path=None, dry_cluster_hosts_path=None):  # noqa: E501
         """NewAgentParams - a model defined in Swagger"""  # noqa: E501
 
         self._service_url = None
@@ -74,6 +76,7 @@ def __init__(self, service_url=None, infra_env_id=None, agent_version=None, cace
         self._containers_storage_conf = None
         self._dry_forced_host_id = None
         self._dry_forced_host_ipv4 = None
+        self._dry_forced_host_ipv6 = None
         self._dry_forced_mac_address = None
         self._dry_forced_hostname = None
         self._dry_fake_reboot_marker_path = None
@@ -98,6 +101,8 @@ def __init__(self, service_url=None, infra_env_id=None, agent_version=None, cace
             self.dry_forced_host_id = dry_forced_host_id
         if dry_forced_host_ipv4 is not None:
             self.dry_forced_host_ipv4 = dry_forced_host_ipv4
+        if dry_forced_host_ipv6 is not None:
+            self.dry_forced_host_ipv6 = dry_forced_host_ipv6
         if dry_forced_mac_address is not None:
             self.dry_forced_mac_address = dry_forced_mac_address
         if dry_forced_hostname is not None:
@@ -296,6 +301,27 @@ def dry_forced_host_ipv4(self, dry_forced_host_ipv4):
 
         self._dry_forced_host_ipv4 = dry_forced_host_ipv4
 
+    @property
+    def dry_forced_host_ipv6(self):
+        """Gets the dry_forced_host_ipv6 of this NewAgentParams.  # noqa: E501
+
+
+        :return: The dry_forced_host_ipv6 of this NewAgentParams.  # noqa: E501
+        :rtype: str
+        """
+        return self._dry_forced_host_ipv6
+
+    @dry_forced_host_ipv6.setter
+    def dry_forced_host_ipv6(self, dry_forced_host_ipv6):
+        """Sets the dry_forced_host_ipv6 of this NewAgentParams.
+
+
+        :param dry_forced_host_ipv6: The dry_forced_host_ipv6 of this NewAgentParams.  # noqa: E501
+        :type: str
+        """
+
+        self._dry_forced_host_ipv6 = dry_forced_host_ipv6
+
     @property
     def dry_forced_mac_address(self):
         """Gets the dry_forced_mac_address of this NewAgentParams.  # noqa: E501

assisted_swarm_client/docs/NewAgentParams.md

@@ -12,6 +12,7 @@ Name | Type | Description | Notes
 **containers_storage_conf** | **str** |  | [optional] 
 **dry_forced_host_id** | **str** |  | [optional] 
 **dry_forced_host_ipv4** | **str** |  | [optional] 
+**dry_forced_host_ipv6** | **str** |  | [optional] 
 **dry_forced_mac_address** | **str** |  | [optional] 
 **dry_forced_hostname** | **str** |  | [optional] 
 **dry_fake_reboot_marker_path** | **str** |  | [optional] 

cluster.py

@@ -106,6 +106,10 @@ def agent_ip(self, agent_index):
         ip_index = agent_index + 1
         return f"10.123.{ip_index >> 8}.{ip_index & 0xff}/16"
 
+    def agent_ipv6(self, agent_index):
+        ip_index = agent_index + 1
+        return "2620:52:0:1b2:faf2:1eff:feb2:db{:02x}/64".format(ip_index)
+
     def hostname(self, agent_index):
         return f"{self.identifier}-{agent_index}"
 
@@ -118,6 +122,7 @@ def cluster_hosts(self):
             {
                 "hostname": self.hostname(agent_index),
                 "ip": self.agent_ip(agent_index),
+                "ipv6": self.agent_ipv6(agent_index),
                 "rebootMarkerPath": str(self.dry_reboot_marker(agent_index)),
             }
             for agent_index in range(self.total_agents)
@@ -228,6 +233,7 @@ def launch_agents(self, next_state):
                     index=agent_index,
                     mac_address=self.make_mac(self.cluster_config.index, agent_index),
                     machine_ip=self.agent_ip(agent_index),
+                    machine_ipv6=self.agent_ipv6(agent_index),
                     machine_hostname=self.hostname(agent_index),
                     cluster_identifier=self.identifier,
                     cluster_dir=self.cluster_dir,

cmd/main.go

@@ -16,7 +16,7 @@ const (
 )
 
 func main() {
-	util.SetLogging("combined-agent", false, true, MainDummyHostID)
+	util.SetLogging("combined-agent", false, true, false, MainDummyHostID)
 	failOnError := func(err error, msg string, args ...interface{}) {
 		if err != nil {
 			logrus.WithError(err).Fatalf(msg, args...)