X-Git-Url: http://git.onelab.eu/?a=blobdiff_plain;f=sfa%2Futil%2Fconfig.py;h=2ad7f7b5e4fbadb2ecaa77b96f4c0b165b27f516;hb=11156a540daa4b6ac2f6348f31f5f0d850161b2b;hp=cef2fdd8b0d68e538ba6a0baba519477dc429bdf;hpb=f13173726f8382eef380f1e754f24dd2b126a77b;p=sfa.git diff --git a/sfa/util/config.py b/sfa/util/config.py index cef2fdd8..2ad7f7b5 100644 --- a/sfa/util/config.py +++ b/sfa/util/config.py @@ -1,101 +1,144 @@ ## -# Geniwrapper Configuration Info +# SFA Configuration Info # -# This module holds configuration parameters for geniwrapper. There are two +# This module holds configuration parameters for SFA. There are two # main pieces of information that are used: the database connection and # the PLCAPI connection ## ## -# Geniwrapper uses a MYSQL database to store records. This database may be +# SFA uses a MYSQL database to store records. This database may be # co-located with the PLC database, or it may be a separate database. The # following parameters define the connection to the database. # -# Note that Geniwrapper does not access any of the PLC databases directly via +# Note that SFA does not access any of the PLC databases directly via # a mysql connection; All PLC databases are accessed via PLCAPI. -### $Id$ -### $URL$ - import os.path import traceback -from sfa.util.debug import log - -# xxx the path-search part could use a cleanup; -# why would anyone want to store the config in /usr/share/geniwrapper at all ? -# also, if users want to use this, it might help to store stuff in ~/.sfirc or something - -# this would denote "/usr/share/geniwrapper/geni" -# geni = join(os.path.dirname(os.path.dirname(os.path.dirname(os.path.abspath(__file__)))), "geni") - class Config: """ Parse the bash/Python/PHP version of the configuration file. Very fast but no type conversions. """ - def __init__(self, filepath = "/etc/sfa/sfa_config"): - # Load plc_config - - loaded = False - # path to config.py source - this would be '/usr/share/geniwrapper/geni/util' - path = os.path.dirname(os.path.abspath(__file__)) - # parent directory of config.py source - self.basepath = os.path.dirname(path) - # path to actual config file - filename = os.path.basename(filepath) - alt_file = os.path.join(path, 'util', filename) - files = [filepath, alt_file] - - for config_file in files: - try: - execfile(config_file, self.__dict__) - loaded = True - self.config_file = config_file - self.config_path = os.path.dirname(config_file) - break - except: - pass - - if not loaded: - raise Exception, "Could not find config in " + ", ".join(files) - - # set up some useful variables - - def load(self, filepath): - try: - execfile(filepath, self.__dict__) - except: - raise Exception, "Could not find config in " + filepath - -plcConfig = Config("/etc/planetlab/plc_config") + def __init__(self, config_file = "/etc/sfa/sfa_config.py"): + self.config_file = None + self.config_path = None + self.data_path = None + self.load(config_file) -def get_default_dbinfo(): - dbinfo={ 'dbname' : plcConfig.PLC_DB_NAME, - 'address' : plcConfig.PLC_DB_HOST, - 'port' : plcConfig.PLC_DB_PORT, - 'user' : plcConfig.PLC_DB_USER, - 'password' : plcConfig.PLC_DB_PASSWORD - } - - return dbinfo - -## -# Geniwrapper uses a PLCAPI connection to perform operations on the registry, -# such as creating and deleting slices. This connection requires an account -# on the PLC server with full administrator access. -# -# The Url parameter controls whether the connection uses PLCAPI directly (i.e. -# Geniwrapper is located on the same machine as PLC), or uses a XMLRPC connection -# to the PLC machine. If you wish to use the API directly, then remove the Url -# field from the dictionary. - -def get_pl_auth(): - pl_auth = {'Username': plcConfig.PLC_API_MAINTENANCE_USER, - 'AuthMethod': 'capability', - 'AuthString': plcConfig.PLC_API_MAINTENANCE_PASSWORD, - "Url": 'https://%s:%s%s' %(plcConfig.PLC_API_HOST, plcConfig.PLC_API_PORT, plcConfig.PLC_API_PATH) - } - - return pl_auth + def load(self, config_file): + try: + execfile(config_file, self.__dict__) + self.config_file = config_file + # path to configuration data + self.config_path = os.path.dirname(config_file) + + # path to server data + if not hasattr(self, 'SFA_DATA_DIR'): + # default to /var/lib/sfa not specified in config + self.SFA_DATA_DIR="/var/lib/sfa" + self.data_path = self.SFA_DATA_DIR + else: + self.data_path = self.SFA_DATA_DIR + + # path to config data + if not hasattr(self, 'SFA_CONFIG_DIR'): + # default to /var/lib/sfa not specified in config + self.SFA_CONFIG_DIR="/etc/sfa" + + if not hasattr(self, 'SFA_REGISTRY_LEVEL1_AUTH'): + self.SFA_REGISTRY_LEVEL1_AUTH=None + + # define interface types + # this will determine which manager to use + if not hasattr(self, 'SFA_REGISTRY_TYPE'): + self.SFA_REGISTRY_TYPE='pl' + + if not hasattr(self, 'SFA_AGGREGATE_TYPE'): + self.SFA_AGGREGATE_TYPE='pl' + + if not hasattr(self, 'SFA_SM_TYPE'): + self.SFA_SM_TYPE='pl' + + if not hasattr(self, 'SFA_CM_TYPE'): + self.SFA_COMPONENT_TYPE='pl' + + if not hasattr(self, 'SFA_MAX_SLICE_RENEW'): + self.SFA_MAX_SLICE_RENEW=60 + + # create the data directory if it doesnt exist + if not os.path.isdir(self.SFA_DATA_DIR): + try: + os.mkdir(self.SFA_DATA_DIR) + except: pass + + except IOError, e: + raise IOError, "Could not find or load the configuration file: %s" % config_file + + def get_trustedroots_dir(self): + return self.config_path + os.sep + 'trusted_roots' + + def get_openflow_aggrMgr_info(self): + aggr_mgr_ip = 'localhost' + if (hasattr(self,'OPENFLOW_AGGREGATE_MANAGER_IP')): + aggr_mgr_ip = self.OPENFLOW_AGGREGATE_MANAGER_IP + + aggr_mgr_port = 2603 + if (hasattr(self,'OPENFLOW_AGGREGATE_MANAGER_PORT')): + aggr_mgr_port = self.OPENFLOW_AGGREGATE_MANAGER_PORT + + return (aggr_mgr_ip,aggr_mgr_port) + + def get_aggregate_type(self): + if (hasattr(self,'SFA_AGGREGATE_TYPE')): + return self.SFA_AGGREGATE_TYPE + else: + return "pl" + + def get_interface_hrn(self): + if (hasattr(self,'SFA_INTERFACE_HRN')): + return self.SFA_INTERFACE_HRN + else: + return "plc" + + def get_plc_dbinfo(self): + return { + 'dbname' : self.SFA_DB_NAME, + 'address' : self.SFA_DB_HOST, + 'port' : self.SFA_DB_PORT, + 'user' : self.SFA_DB_USER, + 'password' : self.SFA_DB_PASSWORD + } + + # TODO: find a better place to put this method + def get_max_aggrMgr_info(self): + am_apiclient_path = '/usr/local/MAXGENI_AM_APIClient' + if (hasattr(self,'MAXGENI_AM_APICLIENT_PATH')): + am_client_path = self.MAXGENI_AM_APICLIENT_PATH + + am_url = 'https://geni.dragon.maxgigapop.net:8443/axis2/services/AggregateGENI' + if (hasattr(self,'MAXGENI_AM_URL')): + am_url = self.MAXGENI_AM_URL + + return (am_apiclient_path,am_url) + + ## + # SFA uses a PLCAPI connection to perform operations on the registry, + # such as creating and deleting slices. This connection requires an account + # on the PLC server with full administrator access. + # + # The Url parameter controls whether the connection uses PLCAPI directly (i.e. + # SFA is located on the same machine as PLC), or uses a XMLRPC connection + # to the PLC machine. If you wish to use the API directly, then remove the Url + # field from the dictionary. + + def get_plc_auth(self): + return { + 'AuthMethod': 'capability', + 'Username': self.SFA_PLC_USER, + 'AuthString': self.SFA_PLC_PASSWORD, + "Url": self.SFA_PLC_URL + }