| | |
| |
|
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| |
|
| | |
| | |
| | |
| | |
| |
|
| |
|
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| |
|
| | import sys |
| | import re |
| | import os |
| | from stat import * |
| | import getopt |
| |
|
| | err = sys.stderr.write |
| | dbg = err |
| | rep = sys.stdout.write |
| |
|
| | new_interpreter = None |
| | preserve_timestamps = False |
| | create_backup = True |
| | keep_flags = False |
| | add_flags = b'' |
| |
|
| |
|
| | def main(): |
| | global new_interpreter |
| | global preserve_timestamps |
| | global create_backup |
| | global keep_flags |
| | global add_flags |
| |
|
| | usage = ('usage: %s -i /interpreter -p -n -k -a file-or-directory ...\n' % |
| | sys.argv[0]) |
| | try: |
| | opts, args = getopt.getopt(sys.argv[1:], 'i:a:kpn') |
| | except getopt.error as msg: |
| | err(str(msg) + '\n') |
| | err(usage) |
| | sys.exit(2) |
| | for o, a in opts: |
| | if o == '-i': |
| | new_interpreter = a.encode() |
| | if o == '-p': |
| | preserve_timestamps = True |
| | if o == '-n': |
| | create_backup = False |
| | if o == '-k': |
| | keep_flags = True |
| | if o == '-a': |
| | add_flags = a.encode() |
| | if b' ' in add_flags: |
| | err("-a option doesn't support whitespaces") |
| | sys.exit(2) |
| | if not new_interpreter or not new_interpreter.startswith(b'/') or \ |
| | not args: |
| | err('-i option or file-or-directory missing\n') |
| | err(usage) |
| | sys.exit(2) |
| | bad = 0 |
| | for arg in args: |
| | if os.path.isdir(arg): |
| | if recursedown(arg): bad = 1 |
| | elif os.path.islink(arg): |
| | err(arg + ': will not process symbolic links\n') |
| | bad = 1 |
| | else: |
| | if fix(arg): bad = 1 |
| | sys.exit(bad) |
| |
|
| |
|
| | def ispython(name): |
| | return name.endswith('.py') |
| |
|
| |
|
| | def recursedown(dirname): |
| | dbg('recursedown(%r)\n' % (dirname,)) |
| | bad = 0 |
| | try: |
| | names = os.listdir(dirname) |
| | except OSError as msg: |
| | err('%s: cannot list directory: %r\n' % (dirname, msg)) |
| | return 1 |
| | names.sort() |
| | subdirs = [] |
| | for name in names: |
| | if name in (os.curdir, os.pardir): continue |
| | fullname = os.path.join(dirname, name) |
| | if os.path.islink(fullname): pass |
| | elif os.path.isdir(fullname): |
| | subdirs.append(fullname) |
| | elif ispython(name): |
| | if fix(fullname): bad = 1 |
| | for fullname in subdirs: |
| | if recursedown(fullname): bad = 1 |
| | return bad |
| |
|
| |
|
| | def fix(filename): |
| | |
| | try: |
| | f = open(filename, 'rb') |
| | except IOError as msg: |
| | err('%s: cannot open: %r\n' % (filename, msg)) |
| | return 1 |
| | with f: |
| | line = f.readline() |
| | fixed = fixline(line) |
| | if line == fixed: |
| | rep(filename+': no change\n') |
| | return |
| | head, tail = os.path.split(filename) |
| | tempname = os.path.join(head, '@' + tail) |
| | try: |
| | g = open(tempname, 'wb') |
| | except IOError as msg: |
| | err('%s: cannot create: %r\n' % (tempname, msg)) |
| | return 1 |
| | with g: |
| | rep(filename + ': updating\n') |
| | g.write(fixed) |
| | BUFSIZE = 8*1024 |
| | while 1: |
| | buf = f.read(BUFSIZE) |
| | if not buf: break |
| | g.write(buf) |
| |
|
| | |
| |
|
| | mtime = None |
| | atime = None |
| | |
| | try: |
| | statbuf = os.stat(filename) |
| | mtime = statbuf.st_mtime |
| | atime = statbuf.st_atime |
| | os.chmod(tempname, statbuf[ST_MODE] & 0o7777) |
| | except OSError as msg: |
| | err('%s: warning: chmod failed (%r)\n' % (tempname, msg)) |
| | |
| | if create_backup: |
| | try: |
| | os.rename(filename, filename + '~') |
| | except OSError as msg: |
| | err('%s: warning: backup failed (%r)\n' % (filename, msg)) |
| | else: |
| | try: |
| | os.remove(filename) |
| | except OSError as msg: |
| | err('%s: warning: removing failed (%r)\n' % (filename, msg)) |
| | |
| | try: |
| | os.rename(tempname, filename) |
| | except OSError as msg: |
| | err('%s: rename failed (%r)\n' % (filename, msg)) |
| | return 1 |
| | if preserve_timestamps: |
| | if atime and mtime: |
| | try: |
| | os.utime(filename, (atime, mtime)) |
| | except OSError as msg: |
| | err('%s: reset of timestamp failed (%r)\n' % (filename, msg)) |
| | return 1 |
| | |
| | return 0 |
| |
|
| |
|
| | def parse_shebang(shebangline): |
| | shebangline = shebangline.rstrip(b'\n') |
| | start = shebangline.find(b' -') |
| | if start == -1: |
| | return b'' |
| | return shebangline[start:] |
| |
|
| |
|
| | def populate_flags(shebangline): |
| | old_flags = b'' |
| | if keep_flags: |
| | old_flags = parse_shebang(shebangline) |
| | if old_flags: |
| | old_flags = old_flags[2:] |
| | if not (old_flags or add_flags): |
| | return b'' |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | return b' -' + add_flags + old_flags |
| |
|
| |
|
| | def fixline(line): |
| | if not line.startswith(b'#!'): |
| | return line |
| |
|
| | if b"python" not in line: |
| | return line |
| |
|
| | flags = populate_flags(line) |
| | return b'#! ' + new_interpreter + flags + b'\n' |
| |
|
| |
|
| | if __name__ == '__main__': |
| | main() |
| |
|