bashclub/piler
1
0
Fork 0
mirror of https://bitbucket.org/jsuto/piler.git synced 2024-11-08 04:01:58 +01:00
Code Issues Packages Projects Releases Wiki Activity

refactored util/pilerpurge.py

Browse Source 
Signed-off-by: Janos SUTO <sj@acts.hu>
This commit is contained in:
Janos SUTO 2018-11-03 16:03:01 +01:00
parent e776eead0c
commit a4dc3deb36
1 changed files with 7 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
util/pilerpurge.py
View File

@ -113,7 +113,7 @@ def remove_attachment_files(rows=(), opts={}):
unlink(get_attachment_file_path(piler_id, attachment_id, unlink(get_attachment_file_path(piler_id, attachment_id,
opts), opts) opts), opts)
else: else:
print get_attachment_file_path(piler_id, attachment_id, opts) print(get_attachment_file_path(piler_id, attachment_id, opts))
else: else:
referenced_ids.append(id) referenced_ids.append(id)
@ -125,7 +125,7 @@ def remove_attachment_files(rows=(), opts={}):
(format), remove_ids) (format), remove_ids)
opts['db'].commit() opts['db'].commit()
else: else:
print remove_ids print(remove_ids)
opts['referenced_attachments'] = referenced_ids opts['referenced_attachments'] = referenced_ids
@ -136,12 +136,12 @@ def remove_m_files(ids=[], opts={}):
unlink(get_m_file_path(ids[i], opts), opts) unlink(get_m_file_path(ids[i], opts), opts)
opts['messages'] = opts['messages'] + 1 opts['messages'] = opts['messages'] + 1
else: else:
print get_m_file_path(ids[i], opts) print(get_m_file_path(ids[i], opts))
def unlink(filename="", opts={}): def unlink(filename="", opts={}):
if opts['verbose']: if opts['verbose']:
print "removing", filename print("removing", filename)
try: try:
st = os.stat(filename) st = os.stat(filename)
@ -179,7 +179,7 @@ def main():
args = parser.parse_args() args = parser.parse_args()
if getpass.getuser() not in ['root', 'piler']: if getpass.getuser() not in ['root', 'piler']:
print "Please run me as user 'piler'" print("Please run me as user 'piler'")
sys.exit(1) sys.exit(1)
opts['dry_run'] = args.dry_run opts['dry_run'] = args.dry_run
@ -234,7 +234,7 @@ def main():
opts['db'].commit() opts['db'].commit()
except dbapi.DatabaseError, e: except dbapi.DatabaseError, e:
print "Error %s" % e print("Error %s" % e)
if opts['db']: if opts['db']:
opts['db'].close() opts['db'].close()
@ -245,7 +245,7 @@ def main():
str(opts['purged_stored_size']) + " bytes" str(opts['purged_stored_size']) + " bytes"
if opts['verbose']: if opts['verbose']:
print summary print(summary)
syslog.syslog(summary) syslog.syslog(summary)