from sfa.util.version import version_core
from sfa.util.cache import Cache
-from sfa.storage.model import RegRecord, RegAuthority, RegUser, RegSlice, RegNode
-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
f = open(filename, "w")
f.write("<recordlist>\n")
for record_dict in record_dicts:
- record_obj=make_record (dict=record_dict)
+ record_obj=Record(dict=record_dict)
f.write('<record hrn="' + record_obj.hrn + '" type="' + record_obj.type + '" />\n')
f.write("</recordlist>\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:
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
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
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()
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
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: