X-Git-Url: http://git.onelab.eu/?p=sface.git;a=blobdiff_plain;f=sface%2Fsfidata.py;h=6f7b26528d5f52eb7a0bcad1596c95106090be39;hp=5de402adba292577389fc4191ef35bc2d33d5f55;hb=9e8c8ba7acb8cfaffade59e58c9f5fff762d56dc;hpb=96ec1c38a62466c4d69a57835d470fee98a39edc diff --git a/sface/sfidata.py b/sface/sfidata.py index 5de402a..6f7b265 100644 --- a/sface/sfidata.py +++ b/sface/sfidata.py @@ -1,11 +1,12 @@ +import json import os import pickle from PyQt4.QtCore import * from PyQt4.QtGui import * from lxml import etree -from sfa.util.record import SfaRecord, SliceRecord, AuthorityRecord, UserRecord -from sfa.rspecs.rspec_parser import parse_rspec +from sfa.util.xrn import hrn_to_urn, urn_to_hrn +from sfa.rspecs.rspec import RSpec from sface.config import config class SfiData: @@ -27,28 +28,35 @@ class SfiData: return names - def getSliceRecord(self): - rec_file = config.getSliceRecordFile() + def getRecord(self, rec_file): if os.path.exists(rec_file): + from sfa.storage.record import Record xml = open(rec_file).read() - rec = SliceRecord() - rec.load_from_string(xml) - return rec - return None + rec = Record(xml=xml) + return rec.todict() + return None + + def getSliceRecord(self): + rec_file = config.getSliceRecordFile() + return self.getRecord(rec_file) def getUserRecord(self): rec_file = config.getUserRecordFile() - if os.path.exists(rec_file): - xml = open(rec_file).read() - rec = UserRecord() - rec.load_from_string(xml) - return rec - return None + return self.getRecord(rec_file) def getUserSliceHrns(self): rec = self.getUserRecord() if rec: - return rec.get_field("slices") + slices = rec.get_field("slices") + if (type(slices)!=list) or (len(slices)<1): + return [] + + # get_field("slices") is returning [{"text": name}, {"text": name}, ...] + if (type(slices[0])==dict): + if "text" in slices[0]: + slices = [x["text"] for x in slices] + + return slices return [] @@ -70,9 +78,11 @@ class SfiData: rspec_file = config.getSliceRSpecFile() if os.path.exists(rspec_file): xml = open(rspec_file).read() - rspec = parse_rspec(xml) - self.purgeNonSliceResources(rspec) + if (xml.strip()==""): + return None + + rspec = RSpec(rspec=xml) return rspec return None @@ -81,19 +91,42 @@ class SfiData: rspec_file = config.getResourcesRSpecFile() if os.path.exists(rspec_file): xml = open(rspec_file).read() - return parse_rspec(xml) + + if (xml.strip()==""): + return None + + rspec = RSpec(rspec=xml) + return rspec return None def getSliverStatus(self, slice=None): if not slice: slice = config.getSlice() + if not slice: + return None + filename = config.fullpath(slice+".sliverstatus") if os.path.exists(filename): data = open(filename).read() - return pickle.loads(data) + try: + if hasattr(json, "loads"): + return json.loads(data) # python 2.6 + else: + return json.read(data) # python 2.5 + except: + print "Exception in getSliverStatus" + return None return None + def getSliceMgrVersion(self): + filename = config.fullpath("slicemgr.version") + + if os.path.exists(filename): + data = open(filename).read() + return pickle.loads(data) + + return None