import os
import os.path
import pipes
+import stat
import subprocess
from tempfile import NamedTemporaryFile
from time import sleep
@classmethod
def set_tags(cls, audiobook, file_name):
+ tags = getattr(audiobook, "%s_tags" % cls.ext)['tags']
+ if not tags.get('flac_sha1'):
+ tags['flac_sha1'] = audiobook.get_source_sha1()
audio = File(file_name)
- for k, v in getattr(audiobook, "%s_tags" % cls.ext)['tags'].items():
+ for k, v in tags.items():
audio[k] = v
audio.save()
ExistingFile(file_name),
save=False
)
+ os.chmod(getattr(audiobook, field).path, stat.S_IREAD|stat.S_IWRITE|stat.S_IRGRP|stat.S_IROTH)
Audiobook.objects.filter(pk=audiobook.pk).update(
**{field: getattr(audiobook, field)})
except SystemExit, e:
raise cls.RemoteOperationError
- def run(self, aid):
+ def run(self, aid, publish=True):
aid = int(aid)
audiobook = Audiobook.objects.get(id=aid)
self.set_status(aid, status.ENCODING)
self.set_tags(audiobook, out_file.name)
self.set_status(aid, status.SENDING)
- self.put(audiobook, out_file.name)
+ if publish:
+ self.put(audiobook, out_file.name)
+ self.published(aid)
+ else:
+ self.set_status(aid, None)
self.save(audiobook, out_file.name)
- self.published(aid)
def on_failure(self, exc, task_id, args, kwargs, einfo):
aid = (args[0], kwargs.get('aid'))[0]
@classmethod
def set_tags(cls, audiobook, file_name):
+ mp3_tags = audiobook.mp3_tags['tags']
+ if not mp3_tags.get('flac_sha1'):
+ mp3_tags['flac_sha1'] = audiobook.get_source_sha1()
audio = id3.ID3(file_name)
- for k, v in audiobook.mp3_tags['tags'].items():
+ for k, v in mp3_tags.items():
factory_tuple = cls.TAG_MAP[k]
factory, tagtype = factory_tuple[:2]
audio.add(factory(tagtype, v, *factory_tuple[2:]))