client/bindir/cloud-update-xenserver-licenses.in

#!/usr/bin/python3 -W ignore::DeprecationWarning
# -*- coding: utf-8 -*-
# Licensed to the Apache Software Foundation (ASF) under one
# or more contributor license agreements.  See the NOTICE file
# distributed with this work for additional information
# regarding copyright ownership.  The ASF licenses this file
# to you 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.


import os
import sys
import glob
from random import choice
import string
from optparse import OptionParser
import mysql.connector
import paramiko
from threading import Thread

# ---- This snippet of code adds the sources path and the waf configured PYTHONDIR to the Python path ----
# ---- We do this so cloud_utils can be looked up in the following order:
# ---- 1) Sources directory
# ---- 2) waf configured PYTHONDIR
# ---- 3) System Python path
for pythonpath in (
		"@PYTHONDIR@",
		os.path.join(os.path.dirname(__file__),os.path.pardir,os.path.pardir,"python","lib"),
	):
		if os.path.isdir(pythonpath): sys.path.insert(0,pythonpath)
# ---- End snippet of code ----
from cloud_utils import check_call, CalledProcessError, read_properties

cfg = "@MSCONF@/db.properties"

#---------------------- option parsing and command line checks ------------------------


usage = """%prog <license file> <-a | host names / IP addresses...>

This command deploys the license file specified in the command line into a specific XenServer host or all XenServer hosts known to the management server."""

parser = OptionParser(usage=usage)
parser.add_option("-a", "--all", action="store_true", dest="all", default=False,
                  help="deploy to all known hosts rather that a single host")

#------------------ functions --------------------

def e(msg): parser.error(msg)

def getknownhosts(host,username,password):
	conn = mysql.connector.connect(host=host, user=username, password=password)
	cur = conn.cursor()
	cur.execute("SELECT h.private_ip_address,d.value FROM cloud.host h inner join cloud.host_details d on (h.id = d.host_id) where d.name = 'username' and setup = 1")
	usernames = dict(cur.fetchall())
	cur.execute("SELECT h.private_ip_address,d.value FROM cloud.host h inner join cloud.host_details d on (h.id = d.host_id) where d.name = 'password' and setup = 1")
	passwords = dict(cur.fetchall())
	creds = dict( [ [x,(usernames[x],passwords[x])] for x in list(usernames.keys()) ] )
	cur.close()
	conn.close()
	return creds

def splitlast(string,splitter):
	splitted = string.split(splitter)
	first,last = splitter.join(splitted[:-1]),splitted[-1]
	return first,last

def parseuserpwfromhosts(hosts):
	creds = {}
	for host in hosts:
		user = "root"
		password = ""
		if "@" in host:
			user,host = splitlast(host,"@")
			if ":" in user:
				user,password = splitlast(user,":")
		creds[host] = (user,password)
	return creds

class XenServerConfigurator(Thread):

	def __init__(self,host,user,password,keyfiledata):
		Thread.__init__(self)
		self.host = host
		self.user = user
		self.password = password
		self.keyfiledata = keyfiledata
		self.retval = None # means all's good
		self.stdout = ""
		self.stderr = ""
		self.state = 'initialized'

	def run(self):
		try:
			self.state = 'running'
			c = paramiko.SSHClient()
			c.set_missing_host_key_policy(paramiko.AutoAddPolicy())
			c.connect(self.host,username=self.user,password=self.password)
			sftp = c.open_sftp()
			sftp.chdir("/tmp")
			f = sftp.open("xen-license","w")
			f.write(self.keyfiledata)
			f.close()
			sftp.close()
			stdin,stdout,stderr = c.exec_command("xe host-license-add license-file=/tmp/xen-license")
			c.exec_command("false")
			self.stdout = stdout.read(-1)
			self.stderr = stderr.read(-1)
			self.retval = stdin.channel.recv_exit_status()
			c.close()
			if self.retval != 0: self.state = 'failed'
			else: self.state = 'finished'

		except Exception as e:
			self.state = 'failed'
			self.retval = e
			#raise

	def __str__(self):
		if self.state == 'failed':
			return "<%s XenServerConfigurator on %s@%s: %s>"%(self.state,self.user,self.host,str(self.retval))
		else:
			return "<%s XenServerConfigurator on %s@%s>"%(self.state,self.user,self.host)

#------------- actual code --------------------

(options, args) = parser.parse_args()

try:
	licensefile,args = args[0],args[1:]
except IndexError: e("The first argument must be the license file to use")

if options.all:
	if len(args) != 0: e("IP addresses cannot be specified if -a is specified")
	config = read_properties(cfg)
	creds = getknownhosts(config["db.cloud.host"],config["db.cloud.username"],config["db.cloud.password"])
	hosts = list(creds.keys())
else:
	if not args: e("You must specify at least one IP address, or -a")
	hosts = args
	creds = parseuserpwfromhosts(hosts)

try:
	keyfiledata = file(licensefile).read(-1)
except OSError as e:
	sys.stderr.write("The file %s cannot be opened"%licensefile)
	sys.exit(1)

configurators = []
for host,(user,password) in list(creds.items()):
	configurators.append ( XenServerConfigurator(host,user,password,keyfiledata ) )


for c in configurators: c.start()

for c in configurators:
	print(c.host + "...", end=' ')
	c.join()
	if c.state == 'failed':
		if c.retval:
			msg = "failed with return code %s: %s%s"%(c.retval,c.stdout,c.stderr)
			msg = msg.strip()
			print(msg)
		else: print("failed: %s"%c.retval)
	else:
		print("done")

successes = len( [ a for a in configurators if not a.state == 'failed' ] )
failures = len( [ a for a in configurators if a.state == 'failed' ] )

print("%3s successes"%successes)
print("%3s failures"%failures)