X-Git-Url: http://git.onelab.eu/?a=blobdiff_plain;f=sfa%2Fclient%2Fsfi.py;h=6d7af29c83db63937e64dc03bc01d80ae29bd60b;hb=b47e82ba386c944c888970cc254b09d80ac112a7;hp=47d94c793ce6370af10ed08e421251dbe0879cf0;hpb=bda7ef032a548718aa76fe43b404895d43efb537;p=sfa.git diff --git a/sfa/client/sfi.py b/sfa/client/sfi.py index 47d94c79..6d7af29c 100644 --- a/sfa/client/sfi.py +++ b/sfa/client/sfi.py @@ -29,7 +29,7 @@ from sfa.util.config import Config from sfa.util.version import version_core from sfa.util.cache import Cache -from sfa.storage.model import make_record +from sfa.storage.record import Record from sfa.rspecs.rspec import RSpec from sfa.rspecs.rspec_converter import RSpecConverter @@ -132,14 +132,14 @@ def save_records_to_file(filename, record_dicts, format="xml"): f = open(filename, "w") f.write("\n") for record_dict in record_dicts: - record_obj=make_record (dict=record_dict) + record_obj=Record(dict=record_dict) f.write('\n') f.write("\n") f.close() elif format == "hrnlist": f = open(filename, "w") for record_dict in record_dicts: - record_obj=make_record (dict=record_dict) + record_obj=Record(dict=record_dict) f.write(record_obj.hrn + "\n") f.close() else: @@ -147,10 +147,10 @@ def save_records_to_file(filename, record_dicts, format="xml"): print "unknown output format", format def save_record_to_file(filename, record_dict): - rec_record = make_record (dict=record_dict) - str = record.save_to_string() + record = Record(dict=record_dict) + xml = record.save_as_xml() f=codecs.open(filename, encoding='utf-8',mode="w") - f.write(str) + f.write(xml) f.close() return @@ -160,7 +160,7 @@ def load_record_from_file(filename): f=codecs.open(filename, encoding="utf-8", mode="r") xml_string = f.read() f.close() - return make_record (xml=xml_string) + return Record(xml=xml_string) import uuid @@ -716,7 +716,7 @@ or version information about sfi itself record_dicts = filter_records(options.type, record_dicts) if not record_dicts: self.logger.error("No record of type %s"% options.type) - records = [ make_record (dict=record_dict) for record_dict in record_dicts ] + records = [ Record(dict=record_dict) for record_dict in record_dicts ] for record in records: if (options.format == "text"): record.dump() else: print record.save_as_xml() @@ -904,6 +904,7 @@ or with an slice hrn, shows currently provisioned resources rspec.filter({'component_manager_id': server_version['urn']}) rspec = RSpecConverter.to_pg_rspec(rspec.toxml(), content_type='request') else: + print >>sys.stderr, "\r\n \r\n \r\n WOOOOOO" users = sfa_users_arg(user_records, slice_record) # do not append users, keys, or slice tags. Anything @@ -914,7 +915,6 @@ or with an slice hrn, shows currently provisioned resources api_options = {} api_options ['append'] = False api_options ['call_id'] = unique_call_id() - result = server.CreateSliver(slice_urn, creds, rspec, users, *self.ois(server, api_options)) value = ReturnValue.get_value(result) if self.options.raw: