#! /usr/bin/python
-import sys
-from subprocess import Popen, PIPE
+import os, sys
+import subprocess
+import tempfile
+from errno import EEXIST
from flac_archive.tags import Tags
Exception.__init__(self, msg % (abs(status), command_msg))
self.status = status
self.command = command
- self.stderr = stderr
+ self.stderr = ''.join(stderr)
def get_tags(fn):
tags = Tags()
command = ['metaflac', '--no-utf8-convert', '--export-tags-to=-', fn]
- p = Popen(command, stdout=PIPE)
+ p = subprocess.Popen(command, stdout=subprocess.PIPE,
+ stderr=subprocess.STDOUT)
tags.load(p.stdout)
status = p.wait()
if status != 0:
- raise SubprocessError(status, command=command, stderr=p.stderr)
+ raise SubprocessError(status, command=command, stderr=p.stdout)
return tags
+def rewrite_track_tags(track, tags, fn, tmp):
+ tmp.write('\n'.join(tags.track(track)) + '\n')
+ tmp.close()
+ command = ['metaflac', '--no-utf8-convert', '--dont-use-padding',
+ '--remove-all-tags', '--import-tags-from', tmp.name, fn]
+ p = subprocess.Popen(command, stdout=subprocess.PIPE,
+ stderr=subprocess.STDOUT)
+ status = p.wait()
+ if status != 0:
+ raise SubprocessError(status, command=command, stderr=p.stdout)
+
def do_read(filenames):
# Use this mapping of tag names to sets of tag values to detect global tags.
all_tags = {}
# this check belongs in Tags
if len(track_tags) != 1:
sys.stderr.write('bogus TRACKNUMBER %s: %s\n' % (track_tags, fn))
- return 3
+ return 4
track = int(track_tags[0])
for tag, values in tags._global.iteritems():
# Makes no sense to save TRACKNUMBER in coll_tags.
if len(args) != len(tags):
sys.stderr.write('expected %d flac files, got %d\n'
% (len(tags), len(args)))
- return 4
+ return 2
artist = tags.get_path_safe('ARTIST')
- album = tags.get_path_safe('ALBUM'),
+ album = tags.get_path_safe('ALBUM')
try:
os.mkdir(artist)
except OSError, e:
track = i + 1
fn = '%s/%s/%s.flac' % (artist, album, tags.make_filename(track))
if fn != old_fn:
- #os.rename(old_fn, fn)
- pass
+ os.rename(old_fn, fn)
+ tmp = tempfile.NamedTemporaryFile(delete=False)
+ try:
+ rewrite_track_tags(track, tags, fn, tmp)
+ finally:
+ try:
+ os.unlink(tmp.name)
+ except:
+ pass
+ return 0
def main(args):
if len(args) < 3:
return usage()
- if args[1] == 'read':
- return do_read(args[2:])
- if args[1] == 'write':
- return do_write(args[2:])
+ try:
+ if args[1] == 'read':
+ return do_read(args[2:])
+ if args[1] == 'write':
+ return do_write(args[2:])
+ except SubprocessError, e:
+ sys.stderr.write('%s\n%s\n' % (e.stderr, e))
+ return 3
return usage()
def usage():