UI for node allocation from Intel Rackscale systems

  - Lists available systems from Rackscale Simulator
  - Allows selection of specific systems for allocation
  - Creates a node object and allocates the same as a crowbar node
  - Also refined the controller to obtain system-specific info
  - UI contains only a list of check-boxes and one Allocate button

Author: mmnelemane

crowbar_framework/app/controllers/intelrsd_controller.rb

@@ -31,12 +31,32 @@
 #   where the data model is employed.
 # 
 
-class IntelRSDController < ApplicationController
-  attr_reader :logger, :insecure
+class RsdController < ApplicationController
+  attr_reader :redfish_client, :logger
+
+  # Client setup for the class
+  host = ENV["CROWBAR_REDFISH_HOST"] || "localhost"
+  port = ENV["CROWBAR_REDFISH_PORT"] || "8443"
+  @redfish_client = RedfishHelper::RedfishClient.new(host, port)
+
+  def show
+    @title = "Welcome to RackScale Design"
+    sys_list = get_all_systems
+    @rsd_systems = "Systems not Available"
+    unless sys_list.empty?
+      @rsd_systems = sys_list
+    end
+  end
 
-  def initialize()
-    @redfish_client = RedfishHelper::RedfishClient.new('localhost', '8443')
-    @node_object_list = []
+  def allocate
+    all_sys_list = get_systems
+    all_sys_list.each do |sys_id|
+      next unless params[sys_id.to_s] == "1"
+      node = get_crowbar_node_object(sys_id)
+      node.allocate
+      node.set_state("ready")
+    end
+    redirect_to rsd_show_path, notice: "Selected nodes allocated as compute nodes"
   end
 
   def get_system_resource_list(sys_id, resource)
@@ -61,7 +81,37 @@ def make_node_object_for_system(sys_id)
     return nodeobject
   end
 
-  def get_systems()
+  def get_processors(sys_id)
+    proc_list = get_system_resource_list(sys_id, "Processors")
+    processors = []
+    proc_list.each do |proc|
+      proc_object = Hash.new
+      proc_object["Model"] = proc["Model"]
+      proc_object["Manufacturer"] = proc["Manufacturer"]
+      proc_object["Architecture"] = proc["Architecture"]
+      proc_object["TotalCores"] = proc["TotalCores"]
+      proc_object["TotalThreads"] = proc["TotalThreads"]
+      processors.push(proc_object)
+    end
+    processors
+  end
+
+  def get_memory(sys_id)
+    mem_list = get_system_resource_list(sys_id, "Memory")
+    memories = []
+    mem_list.each do |mem|
+      mem_object = Hash.new
+      mem_object["MemoryType"] = mem["MemoryType"]
+      mem_object["CapacityMB"] = mem["CapacityMiB"]
+      mem_object["Speed"] = mem["OperatingSpeedMHz"]
+      mem_object["Size"] = mem["SizeMiB"]
+      mem_object["Health"] = mem["Health"]
+      memories.push(mem_object)
+    end
+    memories
+  end
+
+  def get_systems
     @systems = @redfish_client.get_resource("Systems")
     sys_list = []
 
@@ -83,39 +133,46 @@ def get_system_data(sys_id)
     return system_data
   end
 
-  def get_rsd_nodes()
-    system_list = get_systems()
-    system_list.each do |system|
-      node_object = make_node_object_for_system(system)
-      @node_object_list.push(node_object)
+  def get_all_systems
+    sys_list = get_systems
+    all_systems = []
+    sys_list.each do |sys_id|
+      sys_object = Hash.new
+      sys_object["SystemId"] = sys_id
+      sys_object["Processors"] = get_processors(sys_id)
+      sys_object["Memory"] = get_memory(sys_id)
+      all_systems.push(sys_object)
     end
-    return @node_object_list
-  end
-
-  def reset_system(sys_id)
-    post_action("Systems/#{sys_id}", action: "ComputerSystem.Reset")
+    all_systems
   end
 
   def get_crowbar_node_object(sys_id)
     system_object = get_system_data(sys_id)
     node_name_prefix = "d"
-    node_name_prefix = "IRSD" if system_object["Oem"].has_key?("Intel_RackScale")
+    node_name_prefix = "IRSD-" if system_object["Oem"].key?("Intel_RackScale")
 
+    # Pickin up the first IP address. This may not be always the correct address.
+    # It must be revisited when testing with Rackscale hardware.
     eth_interface = system_object["EthernetInterfaces"].first
-    node_name = node_name_prefix + eth_interface["MACAddress"].gsub(":", "-")
-
-    node = NodeObject.create_new node_name
-    NodeObject.initialize(node)
-    node.set['name'] = node_name 
-    node.set['target_cpu'] = ""
-    node.set['target_vendor'] = "suse"
-    node.set['host_cpu'] = ""
-    node.set['host_vendor'] = "suse"
-    node.set['kernel'] = ""   # Kernel modules and configurations
-    node.set['counters'] = "" # various network interfaces and other counters
-    node.set['hostname'] = node_name 
-    node.set['fqdn'] = node_name + "." + ChefObject.cloud_domain
-    node.set['domain'] = ChefObject.cloud_domain
+    node_name = node_name_prefix + eth_interface["MACAddress"].tr(":", "-") + "-#{sys_id}"
+
+    node = NodeObject.create_new "#{node_name}.#{Crowbar::Settings.domain}".downcase
+
+    node.set["name"] = node_name
+    # set a flag to identify this node as a rackscale one
+    node.set["rackscale"] = true
+    # track the rackscale id for this node
+    node.set["rackscale_id"] = sys_id
+    node.set["target_cpu"] = "x86_64"
+    node.set["target_vendor"] = "suse"
+    node.set["host_cpu"] = system_object["ProcessorSummary"]["Model"]
+    node.set["host_vendor"] = "suse"
+    node.set["kernel"] = ""   # Kernel modules and configurations
+    node.set["counters"] = "" # various network interfaces and other counters
+    node.set["hostname"] = node_name
+    node.set["fqdn"] = "#{node_name}.#{Crowbar::Settings.domain}"
+    node.set["domain"] = Crowbar::Settings.domain
+
     ipaddress_data = eth_interface["IPv4Addresses"].first
     node.set['ipaddress'] = ipaddress_data["Address"]
     node.set['macaddress'] = eth_interface["MACAddress"]
@@ -125,66 +182,53 @@ def get_crowbar_node_object(sys_id)
     node.set['recipes'] = ""
 
     # Add other roles as seen fit
-    node.set['roles'] = []
-    ["deployer-config-default", "network-config-default", "dns-config-default", 
-     "logging-config-default", "ntp-config-default", "nova-compute-kvm",
-     "provisioner-base", "provisioner-config-default", "crowbar-#{node['fqdn']}"].each do |role_name|
-      role = RoleObject.find_role_by_name "#{role_name}"
-      node['roles'] += role
-    end 
-
-    node.set['run_list'] = ["role[#{node['roles']}]"]
-    node.set['keys']['host']['host_dsa_public'] = ""
-    node.set['keys']['host']['host_rsa_public'] = ""
-    node.set['keys']['host']['host_ecdsa_public'] = ""
-    node.set['virtualization']['system'] = "kvm"
-    node.set['virtualization']['role'] = "guest"
-    node.set['platform'] = "suse"
-    node.set['platform_version'] = "12.1"
-    node.set['dmi']['bios']['all_records'] = ""
-    node.set['dmi']['bios']['vendor'] = ""
-    node.set['dmi']['bios']['version'] = system_object["BiosVersion"]
-    node.set['dmi']['bios']['release_date'] = ""
-    node.set['dmi']['bios']['address'] = ""
-    node.set['dmi']['bios']['runtime_size'] = ""
-    node.set['dmi']['bios']['rom_size'] = ""
-    node.set['dmi']['bios']['bios_revision'] = ""
-    node.set['dmi']['system']['product_name'] = ""
-    node.set['dmi']['system']['manufacturer'] = ""
-    node.set['dmi']['system']['serial_number'] = "Not Specified"
-    node.set['dmi']['system']['uuid'] = ""
-    node.set['dmi']['system']['wake_up_type'] = "Power Switch"
-    node.set['dmi']['system']['sku_number'] = "Not Specified"
-    node.set['dmi']['system']['family'] = "Not Specified"
-    node.set['dmi']['chassis']['serial_number'] = system_object['Chassis']['SerialNumber']
-    node.set['dmi']['chassis']['all_records'] = ""
-    node.set['dmi']['chassis']['manufacturer'] = ""
-    node.set['dmi']['chassis']['all_records'] = ""
-    node.set['dmi']['chassis']['boot_up_state'] = "Safe"
-    node.set['dmi']['chassis']['power_supply_state'] = "Safe"
-    node.set['block_device']['sda'] = ""
-    node.set['memory']['swap'] = ""
-    node.set['memory']['buffers'] = ""
-
-    system_object["Processors"].each do | processor |
-      id = processor["Id"]
-      node.set["cpu"]["#{id}"]['manufacturer'] = processor["Manufacturer"]
-      node.set["cpu"]["#{id}"]["model"] = processor["Model"]
-      node.set["cpu"]["#{id}"]["family"] = processor["ProcessorArchitecture"]
-      node.set["cpu"]["#{id}"]["family"] = "x86_64" if processor["InstructionSet"] == "x86-64"
-      node.set["cpu"]["#{id}"]["flags"] = processor["Capabilities"]
+    node.set["roles"] = []
+    ["deployer-config-default", "network-config-default", "dns-config-default",
+     "logging-config-default", "ntp-config-default",
+     "provisioner-base", "provisioner-config-default", "nova-compute"].each do |role_name|
+      node["roles"] << role_name
+    end
+
+    node.set["run_list"] = ["role[crowbar-#{node_name}.#{Crowbar::Settings.domain.tr(".", "_")}]"]
+    node.set["keys"]["host"]["host_dsa_public"] = ""
+    node.set["keys"]["host"]["host_rsa_public"] = ""
+    node.set["keys"]["host"]["host_ecdsa_public"] = ""
+    node.set["virtualization"]["system"] = "kvm"
+    node.set["virtualization"]["role"] = "guest"
+    node.set["platform"] = "suse"
+    node.set["platform_version"] = "12.1"
+    node.set["dmi"]["bios"]["version"] = system_object["BiosVersion"]
+    node.set["dmi"]["system"]["product_name"] = system_object["Model"]
+    node.set["dmi"]["system"]["manufacturer"] = system_object["Manufacturer"]
+    node.set["dmi"]["system"]["serial_number"] = system_object["SerialNumber"]
+    node.set["dmi"]["system"]["uuid"] = system_object["UUID"]
+    node.set["dmi"]["system"]["wake_up_type"] = "Power Switch"
+    node.set["dmi"]["system"]["sku_number"] = "Not Specified"
+    node.set["dmi"]["system"]["family"] = "Not Specified"
+    node.set["dmi"]["chassis"]["serial_number"] = system_object["SerialNumber"]
+    node.set["dmi"]["chassis"]["boot_up_state"] = "Safe"
+    node.set["dmi"]["chassis"]["power_supply_state"] = "Safe"
+    # this is needed so its counted properly for the UI
+    node.set["block_device"]["sda"] = { removable: "0" }
+    node.set["memory"]["swap"] = ""
+    node.set["memory"]["buffers"] = ""
+    total_mem = 0
+    system_object["Memory"].each do |m|
+      total_mem += m["CapacityMiB"].to_i
+    end
+    node.set["memory"]["total"] = "#{total_mem * 1024}kB"
+
+    system_object["Processors"].each do |processor|
+      id = processor["Id"].to_i - 1 # API starts at 1, we start at 0
+      node.set["cpu"][id.to_s]["manufacturer"] = processor["Manufacturer"]
+      node.set["cpu"][id.to_s]["model"] = processor["Model"]
+      node.set["cpu"][id.to_s]["family"] = processor["ProcessorArchitecture"]
+      node.set["cpu"][id.to_s]["family"] = "x86_64" if processor["InstructionSet"] == "x86-64"
+      node.set["cpu"][id.to_s]["flags"] = processor["Capabilities"]
     end
 
-    node.set['filesystem']['sysfs'] = ""
+    node.set["filesystem"]["sysfs"] = ""
     node.save
+    node
   end
 end
-
-# usage of the controller APIs
-rsd_controller = IntelRSDController.new
-node_list = rsd_controller.get_rsd_nodes()
-first_node = node_list.first
-p "FIRST NODE: #{first_node}"
-# node_object = rsd_controller.get_crowbar_node_object(first_node["System_Id"])
-# p node_object
-

crowbar_framework/app/views/rsd/show.html.haml

@@ -0,0 +1,32 @@
+.row
+  .col-xs-12
+    %h1.page-header
+      = t(".title")
+
+.row
+  .col-xs-12
+    .panel.panel-default
+      .panel-body
+        .alert.alert-info
+          = t(".rsd_header")
+
+= form_for :node, :url => rsd_allocate_path, :html => { :role => "form" } do |f|
+  = hidden_field_tag "return", @allocated
+  .panel.panel-default#accordion
+    %h2
+      = t(".sys_header")
+      .panel-panel-body
+        %table.table.table-hover.table-middle{ :style => "border: 1px; width: 100%" }
+          %thead
+            %tr
+              %th
+                = t(".rsd_selection")
+              %th
+                = t(".system_id")
+          %tbody
+          - @rsd_systems.each do |rsd_system|
+            %tr
+              %td= check_box_tag "#{rsd_system['SystemId']}"
+              %td= link_to("System-#{rsd_system['SystemId']}")
+          .btn-group.pull-right
+            %input.btn.btn-default{ :type => "submit", :name => "allocate", :value => t(".allocate_switch") }

crowbar_framework/config/locales/intel_rsd/en.yml

@@ -0,0 +1,36 @@
+#
+# Copyright 2016, SUSE LINUX GmbH
+#
+# Licensed under the Apache License, Version 2.0 (the "License");
+# you may not use this file except in compliance with the License.
+# You may obtain a copy of the License at
+#
+#   http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+#
+
+en:
+  nav:
+    utils:
+      rsd: 'Intel RackScale'
+  rsd:
+    show:
+      title: 'Intel Rackscale'
+      rsd_header: 'Lists Systems available from Intel RackScale server by talking to the Redfish APIs'
+      man_header: 'Managers'
+      sys_header: 'Systems'
+      sw_header:  'Switches'
+      ch_header:  'Chassis'
+      allocate_switch: 'Allocate'
+      rsd_selection: 'Selection'
+      system_id:  'System ID'
+  barclamp:
+    rsd:
+      login:
+        provide_creds: 'Please provide Rackscale login credentials.'
+        please_login: 'No active Rackscale session; please login.'

crowbar_framework/config/navigation.rb

@@ -39,6 +39,7 @@
       level2.item :repositories, t("nav.utils.repositories"), repositories_path
       level2.item :backup, t("nav.utils.backup"), backups_path
       level2.item :logs, t("nav.utils.logs"), utils_path
+      level2.item :rsd, t("nav.utils.rsd"), rsd_show_path
     end
   end
 end

crowbar_framework/config/routes.d/intel-rsd.routes

@@ -0,0 +1,18 @@
+#
+# Copyright 2016, SUSE LINUX GmbH
+#
+# Licensed under the Apache License, Version 2.0 (the "License");
+# you may not use this file except in compliance with the License.
+# You may obtain a copy of the License at
+#
+#   http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+#
+
+get 'rsd/show' => 'rsd#show', as: 'rsd_show'
+post 'rsd/allocate' => 'rsd#allocate', as: 'rsd_allocate'

intelrsd.yml

@@ -29,3 +29,9 @@ crowbar:
   run_order: 112
   chef_order: 112
   proposal_schema_version: 3
+
+nav:
+  utils:
+    rsd:
+      order: 91
+      route: 'rsd_edit_path'