#!/usr/bin/python2 # Copyright (c) 2003 Intel Corporation # All rights reserved. # # Copyright (c) 2004-2006 The Trustees of Princeton University # All rights reserved. import xmlrpclib import xml.parsers.expat import hmac import string import sha from Exceptions import * def create_auth_structure( vars, call_params ): """ create and return an authentication structure for a Boot API call. Vars contains the boot manager runtime variables, and call_params is a tuple of the parameters that will be passed to the API call. Return None if unable to (typically due to missing keys in vars, such as node_id or node_key) """ auth= {} auth['AuthMethod']= 'hmac' try: network= vars['NETWORK_SETTINGS'] auth['node_id']= vars['NODE_ID'] auth['node_ip']= network['ip'] node_key= vars['NODE_KEY'] except KeyError, e: return None params= serialize_params(call_params) params.sort() msg= "[" + "".join(params) + "]" node_hmac= hmac.new(node_key,msg.encode('utf-8'),sha).hexdigest() auth['value']= node_hmac return auth def serialize_params( call_params ): """ convert a list of parameters into a format that will be used in the hmac generation. both the boot manager and plc must have a common format. full documentation is in the boot manager technical document, but essentially we are going to take all the values (and keys for dictionary objects), and put them into a list. sort them, and combine them into one long string encased in a set of braces. """ values= [] for param in call_params: if isinstance(param,list) or isinstance(param,tuple): values += serialize_params(param) elif isinstance(param,dict): values += serialize_params(param.values()) elif isinstance(param,xmlrpclib.Boolean): # bool was not a real type in Python <2.3 and had to be # marshalled as a custom type in xmlrpclib. Make sure that # bools serialize consistently. if param: values.append("True") else: values.append("False") else: values.append(unicode(param)) return values def call_api_function( vars, function, user_params ): """ call the named api function with params, and return the value to the caller. the authentication structure is handled automatically, and doesn't need to be passed in with params. If the call fails, a BootManagerException is raised. """ try: api_server= vars['API_SERVER_INST'] except KeyError, e: raise BootManagerException, "No connection to the API server exists." auth= create_auth_structure(vars,user_params) if auth is None: raise BootManagerException, \ "Could not create auth structure, missing values." params= (auth,) params= params + user_params try: exec( "rc= api_server.%s(*params)" % function ) return rc except xmlrpclib.Fault, fault: raise BootManagerException, "API Fault: %s" % fault except xmlrpclib.ProtocolError, err: raise BootManagerException,"XML RPC protocol error: %s" % err except xml.parsers.expat.ExpatError, err: raise BootManagerException,"XML parsing error: %s" % err