551930c262
We are adding new states to the UpdateLoadBalancerNode prog to; 1. Publish cert and key files to the /vm/vmxxxxx/cert directory 2. Create a new web server to serve the files to the VM. 3. Remove the files and service in case the node is removed from the loadbalancer. We are utilizing go as the web server. The server source code lives in ubicloud/cert-server. We are also starting it on the private address [FD00:0B1C:100D:5AFE:CE::]:8080 because it is cool and looks like "oo-bic-lood-safe-ce".
92 lines
2.1 KiB
Ruby
92 lines
2.1 KiB
Ruby
# frozen_string_literal: true
|
|
|
|
require "shellwords"
|
|
|
|
class VmPath
|
|
def initialize(vm_name)
|
|
@vm_name = vm_name
|
|
end
|
|
|
|
# Read from a path, removing a trailing newline if present.
|
|
def read(path)
|
|
File.read(path).chomp
|
|
end
|
|
|
|
# Write to a path, adding a trailing newline if not already present.
|
|
def write(path, s)
|
|
s += "\n" unless s.end_with?("\n")
|
|
File.write(path, s)
|
|
end
|
|
|
|
def dnsmasq_service
|
|
"/etc/systemd/system/#{@vm_name}-dnsmasq.service"
|
|
end
|
|
|
|
def write_dnsmasq_service(s)
|
|
write(dnsmasq_service, s)
|
|
end
|
|
|
|
def systemd_service
|
|
File.join("/etc/systemd/system",
|
|
IO.popen(["systemd-escape", @vm_name + ".service"]) { _1.read.chomp })
|
|
end
|
|
|
|
def write_systemd_service(s)
|
|
write(systemd_service, s)
|
|
end
|
|
|
|
def home(n)
|
|
File.join("", "vm", @vm_name, n)
|
|
end
|
|
|
|
# Define path, q_path, read, write methods for files in
|
|
# `/vm/#{vm_name}`
|
|
%w[
|
|
guest_ephemeral
|
|
clover_ephemeral
|
|
dnsmasq.conf
|
|
meta-data
|
|
network-config
|
|
user-data
|
|
cloudinit.img
|
|
ch-api.sock
|
|
serial.log
|
|
hugepages
|
|
public_ipv4
|
|
nftables_conf
|
|
prep.json
|
|
cert
|
|
].each do |file_name|
|
|
method_name = file_name.tr(".-", "_")
|
|
fail "BUG" if method_defined?(method_name)
|
|
|
|
# Method producing a path, e.g. #user_data
|
|
define_method method_name do
|
|
home(file_name)
|
|
end
|
|
|
|
# Method producing a shell-quoted path, e.g. #q_user_data.
|
|
quoted_method_name = "q_" + method_name
|
|
fail "BUG" if method_defined?(quoted_method_name)
|
|
define_method quoted_method_name do
|
|
home(file_name).shellescape
|
|
end
|
|
|
|
# Method reading the file's contents, e.g. #read_user_data
|
|
#
|
|
# Trailing newlines are removed.
|
|
read_method_name = "read_" + method_name
|
|
fail "BUG" if method_defined?(read_method_name)
|
|
define_method read_method_name do
|
|
read(home(file_name))
|
|
end
|
|
|
|
# Method overwriting the file's contents, e.g. #write_user_data
|
|
write_method_name = "write_" + method_name
|
|
fail "BUG" if method_defined?(write_method_name)
|
|
define_method write_method_name do |s|
|
|
write(home(file_name), s)
|
|
end
|
|
end
|
|
end
|