Dynamic update of Kubespray and K8s [#10]

bin/k8sinfra

@@ -153,6 +153,10 @@ class K8sInfra < Thor
       if options['dry-run'] then
         puts "Dry-run successfully completed"
       else
+        if @cluster_hash['k8s_infra']["release_type"]=="kubespray" then
+	  latest = ks.latest_kubespray_release
+	  ks.update_kubespray(latest)
+        end
         cluster = ks.start_kubespray 
         if cluster[:exit_code] == 0 then
           puts "KUBECONFIG path: #{full_kubeconfig_path}"
@@ -233,8 +237,17 @@ class K8sInfra < Thor
       puts "All required options not handled"
     end
 
-    kubernetes_release = K8sUtils.kubernetes_release("#{options['release-type']}/#{options['arch']}")
-    stable_k8s_release = K8sUtils.kubernetes_release('stable')
+    unless options['release-type'] == "kubespray"
+      kubernetes_release = K8sUtils.kubernetes_release("#{options['release-type']}/#{options['arch']}")
+      stable_k8s_release = K8sUtils.kubernetes_release('stable')
+    else
+      ks = Kubespray.new(@cluster_hash)
+      ks_version = ks.latest_kubespray_release
+      k8s_version = ks.latest_supported_kubernetes(ks_version)
+      kubernetes_release = k8s_version + "\n"
+      stable_k8s_release = k8s_version + "\n"
+    end
+
     config = ERB.new(cluster_config_template("#{options['arch']}", "#{options['provision-type']}", "#{kubernetes_release}", "#{stable_k8s_release}", "#{options['release-type']}"), nil, '-')
     if options['output'] then
       if File.exist?(options['output']) then

bin/kubespray-integration.rb

@@ -1,6 +1,8 @@
 require 'open3'
 require 'fileutils'
 require 'logger'
+require 'json'
+require 'yaml'
 require_relative './k8sutils'
 
 class Kubespray
@@ -57,7 +59,51 @@ def set_urls(cluster_hash)
     cluster_hash
   end
 
+  def latest_kubespray_release
+    release_url = "https://api.github.com/repos/kubernetes-sigs/kubespray/releases/latest"
+    response = Faraday.get release_url
+    if response.status != 200
+      @logger.error "Failed to get Kubespray release info"
+      exit 1
+    end
+    results = JSON.parse(response.body)
+    latest = results['tag_name']
+    return "#{latest}"
+  end
+
+  def latest_supported_kubernetes(tag)
+    version_url = "https://raw.githubusercontent.com/kubernetes-sigs/kubespray/#{tag}/roles/download/defaults/main.yml"
+    response = Faraday.get version_url
+    if response.status != 200
+      @logger.error "Failed to Kubespray raw file"
+      exit 1
+    end
+    parsed = YAML.load(response.body)
+    return parsed['kube_version']
+  end
 
+  def update_kubespray(tag)
+    if ENV["RUBY_ENV"]=="test" then
+      kubedir=File.expand_path '../../lib/provisioner/kubespray/kubespray'
+    else
+      kubedir=File.expand_path 'lib/provisioner/kubespray/kubespray'
+    end
+
+    commands = [ ]
+    commands.push("git -C #{kubedir} checkout master -q")
+    commands.push("git -C #{kubedir} pull --all -q")
+    commands.push("git -C #{kubedir} checkout tags/#{tag} -q")
+
+    commands.each do |command|
+      Open3.popen3(command) do |stdin, stdout, stderr, wait_thr|
+        unless stderr.read.to_s.strip.empty?
+          @logger.error "#{stderr.read}"
+          exit 1
+        end
+      end
+    end
+    puts "Kubespray updated to #{tag}"
+  end
 
   def start_kubespray
     @logger.debug "pwd: #{FileUtils.pwd()}"
@@ -142,6 +188,10 @@ def provision_template
     container_manager: containerd
     download_container: False
     kubeconfig_localhost: true
+    <%- if @cluster_hash['k8s_infra']['release_type']=='kubespray' -%>
+    kube_network_plugin: calico
+    kube_network_plugin_multus: true
+    <%- end -%>
     kubectl_localhost: false
     kubelet_download_url: <%= @cluster_hash['k8s_infra']['kubelet_download_url'] %> 
     kubelet_binary_checksum: <%= @cluster_hash['k8s_infra']['kubelet_binary_checksum'] %>