update mainloop from deprecation, remove spaces
This commit is contained in:
Jakobus Schürz
parent
d73ec91cf2
commit
899deb1c7a
1 changed files with 123 additions and 118 deletions
|
|
@ -32,8 +32,13 @@ except:
|
|||
|
||||
import dbus
|
||||
import dbus.service
|
||||
import dbus.glib
|
||||
from mkbackup.system_notification_emitter import Emitter
|
||||
# deprecated
|
||||
#import dbus.glib
|
||||
# replaces by this 2 lines
|
||||
from dbus.mainloop.glib import DBusGMainLoop
|
||||
DBusGMainLoop(set_as_default=True)
|
||||
|
||||
from mkbackup.system_notification_emitter import Emitter
|
||||
from mkbackup.mkbackup_emitter import Emitter as EM
|
||||
|
||||
#from mksnapshotconfig import Config
|
||||
|
|
@ -79,7 +84,7 @@ class progress_timer:
|
|||
|
||||
def initialize(self):
|
||||
#initialize timer
|
||||
widgets = [self.description, pb.Percentage(), ' ',
|
||||
widgets = [self.description, pb.Percentage(), ' ',
|
||||
pb.Bar(marker=pb.RotatingMarker()), ' ', pb.ETA()]
|
||||
self.timer = pb.ProgressBar(widgets=widgets, maxval=self.n_iter).start()
|
||||
|
||||
|
|
@ -109,7 +114,7 @@ else:
|
|||
def DEBUG(*msg,level=0,verbose=0):
|
||||
if verbose < level :
|
||||
return
|
||||
else:
|
||||
else:
|
||||
#print(' '.join(msg))
|
||||
for i in msg: print(i)
|
||||
return
|
||||
|
|
@ -235,7 +240,7 @@ class BtrfsListing:
|
|||
#argmts = line.split(' ')
|
||||
argmts = line.split()
|
||||
#ID 2412 gen 8547 cgen 8547 top level 2393 parent_uuid 7991115b-8a6b-6d4d-b664-03db01e902d0 received_uuid - uuid 368490e7-5aca-0d4d-9b7a-becff0487ebd path aldebaran/__ALWAYSCURRENT__.2016-10-15_22:40:25.hourly.part/var-spool-dovecot
|
||||
self.svols[argmts[1]] = dict()
|
||||
self.svols[argmts[1]] = dict()
|
||||
self.svols[argmts[1]]['id'] = argmts[1]
|
||||
self.svols[argmts[1]]['gen'] = argmts[3]
|
||||
self.svols[argmts[1]]['cgen'] = argmts[5]
|
||||
|
|
@ -263,7 +268,7 @@ class BtrfsListing:
|
|||
for sub in sorted(self.svols.keys(),key=int):
|
||||
if self.svols[sub]['path'] == snap: stroot = self.svols[sub]['uuid']
|
||||
ext = " (gen: "+str(self.svols[sub]['gen'])+" cgen: "+str(self.svols[sub]['gen'])+")"
|
||||
try:
|
||||
try:
|
||||
vars()[str(self.svols[sub]['uuid'])] = Node(str(self.svols[sub]['path'])+ext,parent=vars()[self.svols[sub]['puuid']])
|
||||
except:
|
||||
vars()[str(self.svols[sub]['uuid'])] = Node(str(self.svols[sub]['path'])+ext,parent=wood)
|
||||
|
|
@ -271,10 +276,10 @@ class BtrfsListing:
|
|||
for pre, fill, node in RenderTree(wood if snap == None else vars()[stroot]):
|
||||
print("%s%s" % (pre, node.name))
|
||||
else:
|
||||
print("""anytree is not available. Please ask your sysadmin to install anytree with
|
||||
print("""anytree is not available. Please ask your sysadmin to install anytree with
|
||||
pip3 install anytree""")
|
||||
|
||||
|
||||
|
||||
def list_sisters(self,ID,rev=False,older=None,younger=None,names=True):
|
||||
result = []
|
||||
if older == None: older = self.args.older
|
||||
|
|
@ -333,7 +338,7 @@ class BtrfsListing:
|
|||
|
||||
def list_subvolumes(self,id,rev=False,names=True,incl_self=True):
|
||||
result= []
|
||||
first = '' if names else id
|
||||
first = '' if names else id
|
||||
if incl_self: result.append(first)
|
||||
for sub in self._lssub(id):
|
||||
result.append(self.svols[sub]['path'].partition(self.svols[id]['path']+'/')[2]) if names else result.append(sub)
|
||||
|
|
@ -359,7 +364,7 @@ class BtrfsListing:
|
|||
result.append(self.svols[sub]['path']) if names else result.append(sub)
|
||||
return(self._ret(result,reverse=rev))
|
||||
|
||||
|
||||
|
||||
def _isbtrfs(self,path,store='SRC',tag='DEFAULT'):
|
||||
mi = MountInfo(conn=self.args.config.getssh(tag,store))
|
||||
logger.info("Filesysem for »%s« is %s" % (path,mi.fstype(path)))
|
||||
|
|
@ -420,14 +425,14 @@ class SubVolumeInfo(BtrfsListing):
|
|||
for line in output.splitlines():
|
||||
#argmnts = [arg.strip() for arg in str(line, encoding='utf8').split(': ')]
|
||||
argmnts = [arg.strip() for arg in line.replace('\t',' ').split(': ')]
|
||||
|
||||
|
||||
if len(argmnts) > 1:
|
||||
#setattr(self, self.tr_att(argmnts[0].strip()), argmnts[1].strip())
|
||||
setattr(self, self.tr_att(argmnts[0]), argmnts[1])
|
||||
elif sv:
|
||||
snaps.append(argmnts[0].strip())
|
||||
else:
|
||||
if argmnts[0].strip() == 'Snapshot(s):':
|
||||
if argmnts[0].strip() == 'Snapshot(s):':
|
||||
sv = True
|
||||
else:
|
||||
self.path=argmnts[0].strip()
|
||||
|
|
@ -449,7 +454,7 @@ class SubVolume(SubVolumeInfo):
|
|||
self.exist = True
|
||||
|
||||
self.args = args
|
||||
self.timestamp = args.timestamp
|
||||
self.timestamp = args.timestamp
|
||||
self.verbose = args.verbose
|
||||
self.tag = args.tag
|
||||
self.config = args.config #Config()
|
||||
|
|
@ -462,7 +467,7 @@ class SubVolume(SubVolumeInfo):
|
|||
self.trans_ts = name.split('.')[1]
|
||||
self.trans_tag = name.split('.')[2]
|
||||
|
||||
regexpart = re.compile('\.part')
|
||||
regexpart = re.compile('\.part')
|
||||
|
||||
self.OrigName = re.sub('\.part$','',self.SourceName)
|
||||
self.OrigLock = self.OrigName+'.part'
|
||||
|
|
@ -493,16 +498,16 @@ class SubVolume(SubVolumeInfo):
|
|||
self.subvolumes = []
|
||||
self.stderr = args.stderr
|
||||
self.DEBUG('[II] <%s> is %s: ' % (self.store, self.config.getStorePath(self.store,self.args.tag,original=True)),level=2)
|
||||
#self.partstep = (100 / (self.args.mdbpart * self.args.mdbsteps)) / len(self.list_subvolumes(self.id))
|
||||
self.partstep = mdbslice / len(self.list_subvolumes(self.id))
|
||||
#self.partstep = (100 / (self.args.mdbpart * self.args.mdbsteps)) / len(self.list_subvolumes(self.id))
|
||||
self.partstep = mdbslice / len(self.list_subvolumes(self.id))
|
||||
logger.debug("""Steps
|
||||
mdpart: %i
|
||||
count subvolumes: %i
|
||||
len list_subvolumes: %i
|
||||
mdparts (mdbpart * mdbsteps): %i
|
||||
pparts: %i
|
||||
partstep: %f""" % (self.args.mdbpart,
|
||||
self.count_subvolumes(self.id),
|
||||
partstep: %f""" % (self.args.mdbpart,
|
||||
self.count_subvolumes(self.id),
|
||||
len(self.list_subvolumes(self.id)),
|
||||
self.args.mdbpart * self.args.mdbsteps,
|
||||
100,
|
||||
|
|
@ -534,8 +539,8 @@ class SubVolume(SubVolumeInfo):
|
|||
Myos(dry=self.args.dry_run).remove(path+lf,args.config.getssh(self.tag,self.store))
|
||||
except OSError as e:
|
||||
if e.errno == errno.EEXIST or errno.ENOENT:
|
||||
pass
|
||||
# if lockfile doesn't exist, continue
|
||||
pass
|
||||
# if lockfile doesn't exist, continue
|
||||
#self.DEBUG('INFO - lockfile is not existing: <%s - %s>/%s' % (self.store,self.StorePath,path+lf),level=2)
|
||||
else:
|
||||
raise e
|
||||
|
|
@ -563,7 +568,7 @@ class SubVolume(SubVolumeInfo):
|
|||
st = self.store if store == None else store
|
||||
|
||||
StorePath = self.config.getStorePath(st,self.args.tag)
|
||||
if not issubvol(self.args,StorePath,store,self.args.tag):
|
||||
if not issubvol(self.args,StorePath,store,self.args.tag):
|
||||
self.DEBUG("Failed to rename »<%s>%s«, is no btrfs-subvolume, or not existing" % (st,From),level=3)
|
||||
return
|
||||
|
||||
|
|
@ -581,8 +586,8 @@ class SubVolume(SubVolumeInfo):
|
|||
return
|
||||
else:
|
||||
if issubvol(self.args,StorePath+'/'+From,store,self.args.tag):
|
||||
self.DEBUG(' =%s-rename> »<%s>/%s« --> %s' % (Action,st,From,To), level=1)
|
||||
else:
|
||||
self.DEBUG(' =%s-rename> »<%s>/%s« --> %s' % (Action,st,From,To), level=1)
|
||||
else:
|
||||
return
|
||||
try:
|
||||
#print('DRY',self.args.dry_run)
|
||||
|
|
@ -593,7 +598,7 @@ class SubVolume(SubVolumeInfo):
|
|||
print(e)
|
||||
except:
|
||||
raise
|
||||
|
||||
|
||||
return
|
||||
|
||||
def lock(self,store=None):
|
||||
|
|
@ -631,7 +636,7 @@ class SubVolume(SubVolumeInfo):
|
|||
raise
|
||||
self.scanfs()
|
||||
return
|
||||
|
||||
|
||||
def unlock(self,checked=False,store=None):
|
||||
store = self.store
|
||||
self.DEBUG('try to unlock on action %s' % (self.args.action),level=4)
|
||||
|
|
@ -698,7 +703,7 @@ class SubVolume(SubVolumeInfo):
|
|||
def setprop(self,ro=True):
|
||||
if self.args.action == 'create':
|
||||
sname = self.SnapLock
|
||||
elif self.args.action == 'setprop':
|
||||
elif self.args.action == 'setprop':
|
||||
sname = self.OrigName
|
||||
else:
|
||||
sname = self.OrigLock
|
||||
|
|
@ -718,10 +723,10 @@ class SubVolume(SubVolumeInfo):
|
|||
self.args.config.remotecommand(tag=self.args.tag, store=self.store, cmd=cmd)
|
||||
except:
|
||||
self.DEBUG('setprop error',level=1)
|
||||
|
||||
|
||||
else:
|
||||
pass
|
||||
|
||||
|
||||
def create(self):
|
||||
self.DEBUG(' =create-snapshot=> from »<%s>/%s«' % (self.store, self.SourceName),level=1)
|
||||
#compile regular expression for ignoring subvolume-names
|
||||
|
|
@ -784,7 +789,7 @@ class SubVolume(SubVolumeInfo):
|
|||
self.SnapID = self.svols[i]['id']
|
||||
BtrfsListing.CreatedSubvolumes.push((self.store,self.SnapName))
|
||||
return(list([self.svols[i]['id'],self.svols[i]['path']]))
|
||||
|
||||
|
||||
raise CreateError('FAILURE - create new snapshot failed %s' % (self.SnapLock), 0)
|
||||
except:
|
||||
raise CreateError
|
||||
|
|
@ -805,7 +810,7 @@ class SubVolume(SubVolumeInfo):
|
|||
sname = self.OrigLock
|
||||
sid = self.id
|
||||
|
||||
|
||||
|
||||
#get uuids of SNP/SRC and BKP and compare. If they are the same, no transfer, if they are different, make transfer to external media
|
||||
#print(self.config.getDevice(store='BKP'))
|
||||
try:
|
||||
|
|
@ -833,7 +838,7 @@ class SubVolume(SubVolumeInfo):
|
|||
logger.critical(" |no-transfer: Filesystem for »%s« not mounted: »%s«" % ('BKP',self.config.getMountPath(store='BKP',tag=args.tag)))
|
||||
return
|
||||
|
||||
if uuidS == uuidB:
|
||||
if uuidS == uuidB:
|
||||
# Same Filesystem on SRC/SNP and BKP. No transfer
|
||||
logger.critical(" |no-transfer: external backupmedia obviously not mounted")
|
||||
return
|
||||
|
|
@ -853,7 +858,7 @@ class SubVolume(SubVolumeInfo):
|
|||
# try:
|
||||
# print("%s exists; is directory" % (self.BkpPath))
|
||||
# print("%s -> change to subvolume, this may take a while" % (self.BkpPath))
|
||||
# # rename original BKPStore
|
||||
# # rename original BKPStore
|
||||
# print('A ren')
|
||||
# cmd = ['mv',self.BkpPath,self.BkpPath+'.orig']
|
||||
# sp_call(self.args,cmd)
|
||||
|
|
@ -909,7 +914,7 @@ class SubVolume(SubVolumeInfo):
|
|||
if BKP.svols[bsub]['ruuid'] == self.svols[sis]['uuid']:
|
||||
plist[self.svols[sis]['id']] = self.svols[sis]['id']
|
||||
|
||||
|
||||
|
||||
transfers[self.svols[sub]['path']] = dict()
|
||||
if len(plist) > 0:
|
||||
v=[int(i) for i in plist.values()]
|
||||
|
|
@ -1016,7 +1021,7 @@ class SubVolume(SubVolumeInfo):
|
|||
|
||||
|
||||
#output = args.config.remotecommand(tag=args.tag, store=store, cmd=cmd)
|
||||
|
||||
|
||||
if not self.args.transferinfo:
|
||||
# print("S->R",first,second)
|
||||
# stdin_send,stdout_send,stderr_send = cmdsh(self.tag,self.store,first)
|
||||
|
|
@ -1053,7 +1058,7 @@ class SubVolume(SubVolumeInfo):
|
|||
# self.DEBUG("[II] TARGET => LINKNAME: %s => %s" % (target.strip(),link_name.strip()),level=3)
|
||||
# else:
|
||||
# raise e
|
||||
|
||||
|
||||
def symlink(self):
|
||||
for st in list(self.args.sourcepath.keys())[0], list(self.args.destpath.keys())[0]:
|
||||
StorePath = self.config.getStorePath(st,self.args.tag)
|
||||
|
|
@ -1061,7 +1066,7 @@ class SubVolume(SubVolumeInfo):
|
|||
linkName = self.basename+'.'+args.config.getSymLink(args.tag)
|
||||
self.DEBUG('%-12s =>»<%s>/%s«' % (' =symlink>',st,linkName),level=0)
|
||||
self.symlink_force('./'+self.SnapName, StorePath+'/'+linkName,st)
|
||||
if args.config.getSymLink(args.tag) != args.config.getSymLink():
|
||||
if args.config.getSymLink(args.tag) != args.config.getSymLink():
|
||||
self.DEBUG('%-12s =>»<%s>/%s«' % (' =symlink>',st,self.basename+'.LAST'),level=0)
|
||||
self.symlink_force('./'+self.SnapName, StorePath+'/'+self.basename+'.LAST',st)
|
||||
|
||||
|
|
@ -1073,7 +1078,7 @@ class SubVolume(SubVolumeInfo):
|
|||
linkName = self.basename
|
||||
self.DEBUG('%-12s =>»<%s>/%s«' % (' =symlink>',st,linkName),level=0)
|
||||
self.symlink_force('./'+self.SnapName, StorePath+'/'+linkName,st)
|
||||
# if args.config.getSymLink(args.tag) != args.config.getSymLink():
|
||||
# if args.config.getSymLink(args.tag) != args.config.getSymLink():
|
||||
# self.DEBUG('%-12s =>»<%s>/%s«' % (' =symlink>',st,self.basename+'.LAST'),level=0)
|
||||
# self.symlink_force('./'+self.SnapName, StorePath+'/'+self.basename+'.LAST',st)
|
||||
|
||||
|
|
@ -1087,7 +1092,7 @@ class SubVolume(SubVolumeInfo):
|
|||
sname = self.OrigLock
|
||||
slock = self.OLockFile
|
||||
sid = self.id
|
||||
|
||||
|
||||
|
||||
#print('delete %s - %s with %s and action %s' % (sname,sid,slock,self.args.action))
|
||||
|
||||
|
|
@ -1140,10 +1145,10 @@ class SubVolume(SubVolumeInfo):
|
|||
if self.args.npb: pt.update()
|
||||
|
||||
if self.args.npb: pt.finish()
|
||||
|
||||
|
||||
|
||||
|
||||
def main(self):
|
||||
#print(self.svols)
|
||||
#print(self.svols)
|
||||
#print(self.list_sisters(self.ID))
|
||||
#try:
|
||||
self.parse_btrfs_show()
|
||||
|
|
@ -1163,7 +1168,7 @@ def main(args):
|
|||
#L.main()
|
||||
#L.list_sisters()
|
||||
#X=SubVolume(BtrfsListing)
|
||||
|
||||
|
||||
def issubvol(args,path,store='SRC',tag=None):
|
||||
#print("issubvol-store",store,tag,path)
|
||||
if not path == None:
|
||||
|
|
@ -1173,17 +1178,17 @@ def issubvol(args,path,store='SRC',tag=None):
|
|||
except:
|
||||
return False
|
||||
return True if int(output) == 256 else False
|
||||
|
||||
|
||||
|
||||
|
||||
def cleanup(args):
|
||||
args.mdbsteps = 4 #create, setprop, transfer, cleanup
|
||||
args.mdbslice = 100 / 4
|
||||
DEBUG(' --== cleanup ==-->',verbose=args.verbose,level=1)
|
||||
#self.partstep = (100 / (args.mdbpart * args.mdbsteps)) / len(self.list_subvolumes(self.id))
|
||||
#self.partstep = (100 / (args.mdbpart * args.mdbsteps)) / len(self.list_subvolumes(self.id))
|
||||
if args.npb: pt = progress_timer(description= ' --== cleanup ==-->', n_iter=6)
|
||||
args.action = 'cleanup'
|
||||
#DEL = dict()
|
||||
#DEL = dict()
|
||||
DEL = Stack()
|
||||
ST = dict()
|
||||
explock = re.compile('.*.~lock$')
|
||||
|
|
@ -1226,7 +1231,7 @@ def cleanup(args):
|
|||
DEBUG(args,' --cleanup *.part$-Snapshots',level=3)
|
||||
for i in ST[st].svols:
|
||||
subvol = ST[st].svols[i]['path']
|
||||
if exppart.search(subvol):
|
||||
if exppart.search(subvol):
|
||||
DEL.push([st,subvol])
|
||||
|
||||
# Delete them
|
||||
|
|
@ -1272,7 +1277,7 @@ def create(args):
|
|||
SRC[snap].unlock()
|
||||
SRC[snap].symlink()
|
||||
except RuntimeError as e:
|
||||
if e.args[1] == 0:
|
||||
if e.args[1] == 0:
|
||||
print('nicht so schlimm')
|
||||
else:
|
||||
raise e
|
||||
|
|
@ -1299,7 +1304,7 @@ def rollback(args):
|
|||
SRC[snap].symlink_sysvol()
|
||||
#SRC[snap].rename()
|
||||
except RuntimeError as e:
|
||||
if e.args[1] == 0:
|
||||
if e.args[1] == 0:
|
||||
print('nicht so schlimm')
|
||||
else:
|
||||
raise e
|
||||
|
|
@ -1323,7 +1328,7 @@ def delete(args):
|
|||
SRC[snap].setprop(ro=False)
|
||||
SRC[snap].delete()
|
||||
except RuntimeError as e:
|
||||
if e.args[1] == 0:
|
||||
if e.args[1] == 0:
|
||||
print("delete error - nicht so schlimm")
|
||||
else:
|
||||
raise e
|
||||
|
|
@ -1333,7 +1338,7 @@ def delete(args):
|
|||
except:
|
||||
raise
|
||||
return
|
||||
|
||||
|
||||
def setprop(args):
|
||||
args.mdbsteps = 4 #create, setprop, transfer, cleanup
|
||||
args.mdbslice = 100 / 4
|
||||
|
|
@ -1347,7 +1352,7 @@ def setprop(args):
|
|||
SRC[snap].unlock()
|
||||
except RuntimeError as e:
|
||||
print(e.args,e.args[1])
|
||||
if e.args[1] == 0:
|
||||
if e.args[1] == 0:
|
||||
print("setprop error - nicht so schlimm")
|
||||
else:
|
||||
raise e
|
||||
|
|
@ -1357,7 +1362,7 @@ def setprop(args):
|
|||
except:
|
||||
raise
|
||||
return
|
||||
|
||||
|
||||
def lists(args):
|
||||
args.mdbsteps = 4 #create, setprop, transfer, cleanup
|
||||
args.mdbslice = 100 / 4
|
||||
|
|
@ -1382,7 +1387,7 @@ def lists(args):
|
|||
|
||||
if args.print_config:
|
||||
args.config.PrintConfig(tag = None if args.tagset else args.tag, of=args.of)
|
||||
|
||||
|
||||
if args.showyoungest:
|
||||
ST=dict()
|
||||
for st in args.store:
|
||||
|
|
@ -1397,7 +1402,7 @@ def lists(args):
|
|||
dirlist = dict()
|
||||
for snps in glob.glob(args.config.getStorePath(st,args.tag)+'/'+vol+'.*'):
|
||||
#print("snps",snps)
|
||||
if len(os.path.basename(snps).split('.')) == 3:
|
||||
if len(os.path.basename(snps).split('.')) == 3:
|
||||
if not os.path.basename(snps).split('.')[1] in dirlist:
|
||||
dirlist[os.path.basename(snps).split('.')[1]] = list()
|
||||
dirlist[os.path.basename(snps).split('.')[1]].append(os.path.basename(snps))
|
||||
|
|
@ -1405,7 +1410,7 @@ def lists(args):
|
|||
for snp in dirlist[t]:
|
||||
#print("T",dirlist[t],snp)
|
||||
for intv in ST[st][vol].keys():
|
||||
R = re.compile(intv +'$')
|
||||
R = re.compile(intv +'$')
|
||||
#print("I",intv)
|
||||
if R.search(snp):
|
||||
#print("snp",st,vol,intv,snp)
|
||||
|
|
@ -1447,14 +1452,14 @@ def lists(args):
|
|||
s['dirlist'] = ST[st][vol]['dirlist'][sorted(dirlist.keys()).pop()]
|
||||
else:
|
||||
#print("C",i)
|
||||
#if i.split('.')[2] == args.tag:
|
||||
#if i.split('.')[2] == args.tag:
|
||||
#print("D",i)
|
||||
#s[i.split('.')[1]] = i
|
||||
if intv == args.tag:
|
||||
s[k] = i
|
||||
else:
|
||||
missing.append(intv)
|
||||
|
||||
|
||||
lo = 0
|
||||
for i in reversed(sorted(s.keys())):
|
||||
#for j in s[i] if i == 'dirlist' else [s[i]]:
|
||||
|
|
@ -1480,18 +1485,18 @@ def lists(args):
|
|||
res = subprocess.Popen(cmd,stdout=subprocess.PIPE, stderr=args.stderr)
|
||||
output,error = res.communicate()
|
||||
if res.returncode > 0:
|
||||
raise
|
||||
raise
|
||||
except:
|
||||
raise
|
||||
#if output[0] == 0:
|
||||
cut = 120
|
||||
for line in output.splitlines():
|
||||
l = line.decode()
|
||||
if "ACTIVATES" in l:
|
||||
if "ACTIVATES" in l:
|
||||
cut = l.find("ACTIVATES")
|
||||
i = l.find("UNIT")
|
||||
print(l[:cut])
|
||||
elif reintv.search(l):
|
||||
elif reintv.search(l):
|
||||
l = l[:cut]
|
||||
o = l.replace("timer-","").replace(".timer","").rstrip()
|
||||
x = o[i:].rstrip(),
|
||||
|
|
@ -1552,7 +1557,7 @@ def lists(args):
|
|||
for i in SRC[snap].list_subvolumes(SRC[snap].id,rev=args.reverse): print(fp+i)
|
||||
except RuntimeError as e:
|
||||
print(e.args,e.args[1])
|
||||
if e.args[1] == 0:
|
||||
if e.args[1] == 0:
|
||||
print("list error - nicht so schlimm")
|
||||
else:
|
||||
raise e
|
||||
|
|
@ -1595,7 +1600,7 @@ def restore(args):
|
|||
#print('RESTORE FILES', args)
|
||||
# if User running "mkbackup restore" is root, set uroot=True
|
||||
if os.getuid() == 0:
|
||||
uroot = True
|
||||
uroot = True
|
||||
else:
|
||||
uroot = False
|
||||
|
||||
|
|
@ -1662,7 +1667,7 @@ def restore(args):
|
|||
else: raise
|
||||
#shutil.copy(src,dest)
|
||||
mounts.close()
|
||||
|
||||
|
||||
#class desktop_notification:
|
||||
# def __init__(self, args, urgency=1):
|
||||
# self.args = args
|
||||
|
|
@ -1686,10 +1691,10 @@ def restore(args):
|
|||
# msg = dict()
|
||||
# msg['sender'] = "mkbackup"
|
||||
# msg['msgheader'] = "%s-backup" % (self.args.tag)
|
||||
# msg['msgbody'] = """am %s
|
||||
# msg['msgbody'] = """am %s
|
||||
#um %s Uhr abgeschlossen.
|
||||
#
|
||||
#%s
|
||||
#%s
|
||||
#(Ugency: %s)
|
||||
#""" % (self.date, self.time, '\n'.join(args), self.signal_name)
|
||||
# msg['expiration_timeout'] = '-1'
|
||||
|
|
@ -1713,21 +1718,21 @@ parser.add_argument('-L', '--logfile', default=None, help='''Write output also t
|
|||
parser.add_argument('-i', '--ignore', action='append', help='''Regular expression pattern for ignoring several subvolumes to be not backed up (and subvolumes unter them)
|
||||
Use it more than once''')
|
||||
parser.add_argument('-n', '--no-progressbar', dest='npb', action='store_false', default=True, help='''Dont show progressbar (for use in systemctl-unit for example)''')
|
||||
parser.add_argument('-B', '--backup-mount-path',
|
||||
dest='bkpmount',
|
||||
default=config.getMountPath('BKP'),
|
||||
parser.add_argument('-B', '--backup-mount-path',
|
||||
dest='bkpmount',
|
||||
default=config.getMountPath('BKP'),
|
||||
help='''set path to destination mountpoint of backup-mountpoint. (default=%s) overrides 'BKP-Path':''' % (config.getMountPath('BKP')))
|
||||
parser.add_argument('-b', '--backup-store',
|
||||
dest='bkpstore',
|
||||
default=config.getStoreName('BKP'),
|
||||
parser.add_argument('-b', '--backup-store',
|
||||
dest='bkpstore',
|
||||
default=config.getStoreName('BKP'),
|
||||
help='''set storename in backup-mount. (default=%s) overrides 'BKP-Store':''' % (config.getStoreName('BKP')))
|
||||
parser.add_argument('-S', '--snapshot-mount-path',
|
||||
dest='snpmount',
|
||||
default=config.getMountPath('SNP'),
|
||||
parser.add_argument('-S', '--snapshot-mount-path',
|
||||
dest='snpmount',
|
||||
default=config.getMountPath('SNP'),
|
||||
help='''set path to destination mountpoint of snapshot-mountpoint. (default=%s) overrides 'SNP-Path':''' % (config.getMountPath('SNP')))
|
||||
parser.add_argument('-s', '--snapshot-store',
|
||||
dest='snpstore',
|
||||
default=config.getStoreName('SNP'),
|
||||
parser.add_argument('-s', '--snapshot-store',
|
||||
dest='snpstore',
|
||||
default=config.getStoreName('SNP'),
|
||||
help='''set storename in snapshot-mount. (default=%s) overrides 'BKP-Store':''' % (config.getStoreName('SNP')))
|
||||
parser.add_argument('-N', '--notification', default=None, help='''Send notification. Possible values are "desktop" ''')
|
||||
parser.add_argument('-U', '--notification_urgency', default=None, help='''Send notification. Possible values are 0=low, 1=normal, 2=critical ''')
|
||||
|
|
@ -1736,8 +1741,8 @@ parser.add_argument('-U', '--notification_urgency', default=None, help='''Send n
|
|||
subparsers = parser.add_subparsers()
|
||||
|
||||
list_parser=subparsers.add_parser('list')
|
||||
list_parser.add_argument("store",
|
||||
default='SRC',
|
||||
list_parser.add_argument("store",
|
||||
default='SRC',
|
||||
metavar='stores and snapshots',
|
||||
nargs='*',
|
||||
help="""one of SRC, BKP or SNP - where is the snapshot
|
||||
|
|
@ -1766,8 +1771,8 @@ list_parser.set_defaults(func=lists)
|
|||
list_parser.set_defaults(action='list')
|
||||
|
||||
create_parser=subparsers.add_parser('create')
|
||||
create_parser.add_argument("store",
|
||||
default='SRC',
|
||||
create_parser.add_argument("store",
|
||||
default='SRC',
|
||||
metavar='stores and snapshots',
|
||||
nargs='*',
|
||||
help="""one of SRC or SNP - where is the snapshot located and one ore more snapshots
|
||||
|
|
@ -1778,8 +1783,8 @@ create_parser.set_defaults(func=create)
|
|||
create_parser.set_defaults(action='create')
|
||||
|
||||
rollback_parser=subparsers.add_parser('rollback')
|
||||
rollback_parser.add_argument("store",
|
||||
default='SRC',
|
||||
rollback_parser.add_argument("store",
|
||||
default='SRC',
|
||||
metavar='stores and snapshots',
|
||||
nargs='*',
|
||||
help="""one of SRC, BKP or SNP - where is the snapshot
|
||||
|
|
@ -1789,8 +1794,8 @@ rollback_parser.set_defaults(func=rollback)
|
|||
rollback_parser.set_defaults(action='rollback')
|
||||
|
||||
delete_parser=subparsers.add_parser('delete')
|
||||
delete_parser.add_argument("store",
|
||||
default='SRC',
|
||||
delete_parser.add_argument("store",
|
||||
default='SRC',
|
||||
metavar='stores and snapshots',
|
||||
nargs='*',
|
||||
help="""one of SRC, BKP or SNP - where is the snapshot
|
||||
|
|
@ -1799,23 +1804,23 @@ delete_parser.set_defaults(func=delete)
|
|||
delete_parser.set_defaults(action='delete')
|
||||
|
||||
transfer_parser=subparsers.add_parser('transfer')
|
||||
transfer_parser.add_argument("snapshots",
|
||||
default='SRC',
|
||||
transfer_parser.add_argument("snapshots",
|
||||
default='SRC',
|
||||
nargs='*',
|
||||
help="""one of SRC or SNP - where is the snapshot located and one ore more snapshots
|
||||
which to be transfered to the external backup-device.
|
||||
BKP is ignored!!!""")
|
||||
transfer_parser.add_argument('--no-clones', action='store_true', default=False, help="""do not use clones for transfer, only parent (if present)""")
|
||||
transfer_parser.add_argument('-i', '--info',
|
||||
dest='transferinfo',
|
||||
action='store_true',
|
||||
default=False,
|
||||
transfer_parser.add_argument('-i', '--info',
|
||||
dest='transferinfo',
|
||||
action='store_true',
|
||||
default=False,
|
||||
help="""show only if initial or incremental transfer is done and the parents""")
|
||||
transfer_parser.set_defaults(func=transfer)
|
||||
transfer_parser.set_defaults(action='transfer')
|
||||
|
||||
cleanup_parser=subparsers.add_parser('cleanup')
|
||||
cleanup_parser.add_argument("snapshots",
|
||||
cleanup_parser.add_argument("snapshots",
|
||||
nargs='*',
|
||||
help='''cleanup all snapshots, which are older and more
|
||||
than allowed in config''')
|
||||
|
|
@ -1823,13 +1828,13 @@ cleanup_parser.set_defaults(func=cleanup)
|
|||
cleanup_parser.set_defaults(action='cleanup')
|
||||
|
||||
setprop_parser=subparsers.add_parser('setprop')
|
||||
setprop_parser.add_argument("store",
|
||||
default='SRC',
|
||||
setprop_parser.add_argument("store",
|
||||
default='SRC',
|
||||
metavar='stores and snapshots',
|
||||
nargs='*',
|
||||
help='''one of SRC, BKP or SNP - where is the snapshot
|
||||
located and one ore more snapshots''')
|
||||
setprop_parser.add_argument("-r", "--ro",
|
||||
setprop_parser.add_argument("-r", "--ro",
|
||||
default=False,
|
||||
action='store_true',
|
||||
help='''setproperty to readonly. If -r is not given,
|
||||
|
|
@ -1838,10 +1843,10 @@ setprop_parser.set_defaults(func=setprop)
|
|||
setprop_parser.set_defaults(action='setprop')
|
||||
|
||||
restore_parser=subparsers.add_parser('restore')
|
||||
restore_parser.add_argument("file",
|
||||
restore_parser.add_argument("file",
|
||||
nargs='*',
|
||||
help="""restore all given files""")
|
||||
restore_parser.add_argument("-n", "--no-preserve",
|
||||
restore_parser.add_argument("-n", "--no-preserve",
|
||||
default=False,
|
||||
action='store_true',
|
||||
help="""if set, the original file will be overwritten. If not set,
|
||||
|
|
@ -1861,7 +1866,7 @@ if __name__ == '__main__':
|
|||
# args.notification['bool']=False
|
||||
# args.notification['type']=None
|
||||
|
||||
# --- Logger ---
|
||||
# --- Logger ---
|
||||
levels = (logging.CRITICAL, logging.ERROR, logging.WARNING, logging.INFO, logging.DEBUG, logging.NOTSET)
|
||||
#print(logging.CRITICAL, logging.ERROR, logging.WARNING, logging.INFO, logging.DEBUG, logging.NOTSET)
|
||||
print('verbose', args.verbose, levels[args.verbose])
|
||||
|
|
@ -1894,12 +1899,12 @@ if __name__ == '__main__':
|
|||
if not 'dry_run' in args:
|
||||
args.dry_run=False
|
||||
|
||||
if 'store' in args:
|
||||
if 'store' in args:
|
||||
if isstring(args.store): args.store = args.store.split(' ')
|
||||
else:
|
||||
args.store = []
|
||||
|
||||
if 'snapshots' in args:
|
||||
if 'snapshots' in args:
|
||||
if isstring(args.snapshots): args.snapshots = args.snapshots.split()
|
||||
else:
|
||||
args.snapshots = []
|
||||
|
|
@ -1930,7 +1935,7 @@ if __name__ == '__main__':
|
|||
|
||||
# tag = None is not allowed. Set it to misc, if not set
|
||||
args.tagset = False
|
||||
if args.tag == None:
|
||||
if args.tag == None:
|
||||
args.tag = 'misc'
|
||||
args.tagset = True # if no tag was given, and tag is set here, this value is true - it indicates, tag was set automatically to 'misc'
|
||||
|
||||
|
|
@ -1993,8 +1998,8 @@ Author: %s""" % (confversion,__version__,__author__))
|
|||
args.stderr=None
|
||||
|
||||
if args.verbose > 0:
|
||||
args.npb = False
|
||||
|
||||
args.npb = False
|
||||
|
||||
|
||||
#DEBUG("Arguments",args,verbose=args.verbose)
|
||||
if args.verbose > 3:
|
||||
|
|
@ -2052,9 +2057,9 @@ Author: %s""" % (confversion,__version__,__author__))
|
|||
# for s in args.config.ssh[t].keys():
|
||||
# if not args.config.ssh[t][s]['ssh'] == None:
|
||||
# print("CLOSE",t,s)
|
||||
# args.config.ssh[t][s]['ssh'].close()
|
||||
# args.config.ssh[t][s]['ssh'].close()
|
||||
|
||||
# print summary over all actions
|
||||
# print summary over all actions
|
||||
volumes = list()
|
||||
|
||||
if not args.action == 'list' and not args.action == 'restore':
|
||||
|
|
@ -2064,7 +2069,7 @@ snapshots: %s
|
|||
""" % (args.store,args.snapshots))
|
||||
DEBUG("Created Subvolumes:",level=0,verbose=args.verbose)
|
||||
volumes.append('<b>Volumes created:</b>')
|
||||
if BtrfsListing.CreatedSubvolumes.is_empty():
|
||||
if BtrfsListing.CreatedSubvolumes.is_empty():
|
||||
volumes.append('---')
|
||||
print('''---
|
||||
''')
|
||||
|
|
@ -2076,7 +2081,7 @@ snapshots: %s
|
|||
|
||||
DEBUG("Transfered Subvolumes:",level=0,verbose=args.verbose)
|
||||
volumes.append('<b>Volumes transfered:</b>')
|
||||
if BtrfsListing.TransferedSubvolumes.is_empty():
|
||||
if BtrfsListing.TransferedSubvolumes.is_empty():
|
||||
volumes.append('---')
|
||||
print('''---
|
||||
''')
|
||||
|
|
@ -2085,10 +2090,10 @@ snapshots: %s
|
|||
volumes.append(i[1])
|
||||
print(i)
|
||||
volumes.append('')
|
||||
|
||||
|
||||
DEBUG("Deleted Subvolumes:",level=0,verbose=args.verbose)
|
||||
volumes.append('<b>Volumes deleted:</b>')
|
||||
if BtrfsListing.DeletedSubvolumes.is_empty():
|
||||
if BtrfsListing.DeletedSubvolumes.is_empty():
|
||||
volumes.append('---')
|
||||
print(''' ---
|
||||
''')
|
||||
|
|
@ -2100,25 +2105,25 @@ snapshots: %s
|
|||
|
||||
|
||||
print(args.notification, config.getNotification(intv=args.tag), args.notification_urgency, config.getUrgency(intv=args.tag))
|
||||
if args.notification == None:
|
||||
if args.notification == None:
|
||||
args.notification = config.getNotification(intv=args.tag)
|
||||
if args.notification_urgency == None:
|
||||
if args.notification_urgency == None:
|
||||
args.notification_urgency = config.getUrgency(intv=args.tag)
|
||||
print(args.notification, args.notification_urgency)
|
||||
|
||||
if args.notification == 'desktop':
|
||||
# notify = desktop_notification(args, urgency=args.notification_urgency)
|
||||
# notify.send_signal(args, *volumes)
|
||||
# notify.send_signal(args, *volumes)
|
||||
# print(volumes)
|
||||
# print(*volumes)
|
||||
|
||||
msg = dict()
|
||||
msg['sender'] = "mkbackup"
|
||||
msg['header'] = "%s-backup" % (args.tag)
|
||||
msg['body'] = """am %s
|
||||
msg['body'] = """am %s
|
||||
um %s Uhr abgeschlossen.
|
||||
|
||||
%s
|
||||
%s
|
||||
http://www.google.com
|
||||
<a href="file:///home/jakob/backup">TEST</a>
|
||||
(Ugency: normal)
|
||||
|
|
@ -2127,7 +2132,7 @@ http://www.google.com
|
|||
# msg['action']['action1'] = dict()
|
||||
# msg['action']['action1']['title'] = 'Open Backup'
|
||||
# msg['action']['action1']['loc'] = 'file:~/backup'
|
||||
|
||||
|
||||
|
||||
advnotify = Notification()
|
||||
advnotify.normal(msg)
|
||||
|
|
@ -2136,13 +2141,13 @@ http://www.google.com
|
|||
else:
|
||||
logger.critical("No notification at all")
|
||||
|
||||
|
||||
|
||||
logger.critical("---== (%s) finnished %s %s at %s ==---" % (os.getpid(),args.func.__name__, args.tag, args.timestamp))
|
||||
|
||||
args.mdb.finished(args.tag)
|
||||
|
||||
|
||||
#import ntfy
|
||||
|
||||
|
||||
# import smtplib
|
||||
# server = smtplib.SMTP('localhost', 587)
|
||||
#
|
||||
|
|
|
|||
Loading…
Reference in a new issue