8 from PyQt4.QtCore import *
9 from sface.config import config
10 from sface.sfiprocess import SfiProcess
12 class SfiRenewer(QObject):
13 def __init__(self, hrn, newExpiration, parent=None):
14 QObject.__init__(self, parent)
16 self.newExpiration = newExpiration
18 self.renewProcess = SfiProcess(self)
19 self.connect(self.renewProcess, SIGNAL('finished()'), self.finishedGetRecord)
20 self.renewProcess.getRecord(hrn=config.getSlice(), filename="/tmp/slicerecord")
22 def finishedGetRecord(self):
23 f = open("/tmp/slicerecord", "r")
27 # find the expiration time
28 exp = re.compile('expires="[^"]*"')
29 if exp.search(data)==None:
31 self.emitFinished("failure", "failed to find expiration in slice record")
34 # change the expiration time
35 delta = 24*60*60 # always extend the slice by one extra day to cover slop for time zone differences
36 data = exp.sub('expires="' + str(calendar.timegm(self.newExpiration.timetuple())+delta) + '"', data)
38 open("/tmp/slicerecord", "w").write(data)
40 self.disconnect(self.renewProcess, SIGNAL('finished()'), self.finishedGetRecord)
41 self.connect(self.renewProcess, SIGNAL('finished()'), self.finishedUpdateRecord)
43 self.renewProcess.updateRecord("/tmp/slicerecord")
45 def finishedUpdateRecord(self):
46 # we have to force sfi.py to download an updated slice credential
47 sliceCredName = os.path.expanduser("~/.sfi/slice_" + self.hrn.split(".")[-1] + ".cred")
48 if os.path.exists(sliceCredName):
49 os.remove(sliceCredName)
51 open("/tmp/expiration", "w").write(self.newExpiration.strftime("%Y-%m-%dT%H:%M:%SZ"))
53 # call renewSlivers on the aggregate
54 self.disconnect(self.renewProcess, SIGNAL('finished()'), self.finishedUpdateRecord)
55 self.connect(self.renewProcess, SIGNAL('finished()'), self.finishedRenewSlivers)
56 self.renewProcess.renewSlivers(self.newExpiration.strftime("%Y-%m-%dT%H:%M:%SZ"))
58 def finishedRenewSlivers(self):
59 self.emitFinished("success")
61 def emitFinished(self, status, statusMsg=None):
63 self.statusMsg = statusMsg
64 self.emit(SIGNAL("finished()"))