forked from 0x2620/pandora
new file/path logic
This commit is contained in:
parent
ccf4889c7e
commit
6916792f95
2 changed files with 68 additions and 67 deletions
|
@ -18,16 +18,16 @@ import ox
|
||||||
import chardet
|
import chardet
|
||||||
|
|
||||||
from item import utils
|
from item import utils
|
||||||
|
from person.models import get_name_sort
|
||||||
|
|
||||||
import extract
|
import extract
|
||||||
|
|
||||||
|
|
||||||
class File(models.Model):
|
class File(models.Model):
|
||||||
|
|
||||||
created = models.DateTimeField(auto_now_add=True)
|
created = models.DateTimeField(auto_now_add=True)
|
||||||
modified = models.DateTimeField(auto_now=True)
|
modified = models.DateTimeField(auto_now=True)
|
||||||
|
|
||||||
auto = models.BooleanField(default=True)
|
|
||||||
|
|
||||||
oshash = models.CharField(max_length=16, unique=True)
|
oshash = models.CharField(max_length=16, unique=True)
|
||||||
item = models.ForeignKey("item.Item", related_name='files')
|
item = models.ForeignKey("item.Item", related_name='files')
|
||||||
|
|
||||||
|
@ -35,12 +35,13 @@ class File(models.Model):
|
||||||
sort_path = models.CharField(max_length=2048, default="") # sort name
|
sort_path = models.CharField(max_length=2048, default="") # sort name
|
||||||
|
|
||||||
type = models.CharField(default="", max_length=255)
|
type = models.CharField(default="", max_length=255)
|
||||||
part = models.IntegerField(null=True)
|
|
||||||
version = models.CharField(default="", max_length=255)
|
|
||||||
language = models.CharField(default="", max_length=8)
|
|
||||||
|
|
||||||
season = models.IntegerField(default=-1)
|
#editable
|
||||||
episode = models.IntegerField(default=-1)
|
extension = models.CharField(default="", max_length=255, null=True)
|
||||||
|
language = models.CharField(default="", max_length=8, null=True)
|
||||||
|
part = models.IntegerField(null=True)
|
||||||
|
part_title = models.CharField(default="", max_length=255, null=True)
|
||||||
|
version = models.CharField(default="", max_length=255, null=True)
|
||||||
|
|
||||||
size = models.BigIntegerField(default=0)
|
size = models.BigIntegerField(default=0)
|
||||||
duration = models.FloatField(null=True)
|
duration = models.FloatField(null=True)
|
||||||
|
@ -71,15 +72,15 @@ class File(models.Model):
|
||||||
is_video = models.BooleanField(default=False)
|
is_video = models.BooleanField(default=False)
|
||||||
is_subtitle = models.BooleanField(default=False)
|
is_subtitle = models.BooleanField(default=False)
|
||||||
|
|
||||||
|
#upload and data handling
|
||||||
|
data = models.FileField(null=True, blank=True,
|
||||||
|
upload_to=lambda f, x: f.get_path('data.bin'))
|
||||||
|
|
||||||
def __unicode__(self):
|
def __unicode__(self):
|
||||||
return self.path
|
return self.path
|
||||||
|
|
||||||
def set_state(self):
|
def parse_info(self):
|
||||||
self.path = self.create_path()
|
if self.info:
|
||||||
|
|
||||||
if not self.path.split('.')[-1] in (
|
|
||||||
'srt', 'rar', 'sub', 'idx', 'txt', 'jpg', 'png', 'nfo'
|
|
||||||
) and self.info:
|
|
||||||
for key in ('duration', 'size'):
|
for key in ('duration', 'size'):
|
||||||
setattr(self, key, self.info.get(key, 0))
|
setattr(self, key, self.info.get(key, 0))
|
||||||
|
|
||||||
|
@ -125,44 +126,64 @@ class File(models.Model):
|
||||||
if self.framerate:
|
if self.framerate:
|
||||||
self.pixels = int(self.width * self.height * float(utils.parse_decimal(self.framerate)) * self.duration)
|
self.pixels = int(self.width * self.height * float(utils.parse_decimal(self.framerate)) * self.duration)
|
||||||
|
|
||||||
else:
|
def parse_instance_path(self):
|
||||||
self.is_video = self.path.split('.')[-1].lower() in ox.movie.EXTENSIONS['video']
|
if self.instances.count():
|
||||||
self.is_audio = self.path.split('.')[-1].lower() in ox.movie.EXTENSIONS['audio']
|
path = self.instances.all()[0].path
|
||||||
self.is_audio = self.path.split('.')[-1].lower() == 'srt'
|
data = ox.movie.parse_path(path)
|
||||||
|
self.extension = data['extension']
|
||||||
|
self.language = data['language']
|
||||||
|
self.part = data['part']
|
||||||
|
self.part_title = data['partTitle']
|
||||||
|
self.type = data['type'] or 'unknown'
|
||||||
|
self.version = data['version']
|
||||||
|
|
||||||
if self.path.endswith('.srt'):
|
def path_data(self):
|
||||||
self.is_subtitle = True
|
data = {
|
||||||
self.is_audio = False
|
'part': self.part,
|
||||||
self.is_video = False
|
'partTitle': self.part_title,
|
||||||
else:
|
'language': self.language,
|
||||||
self.is_subtitle = False
|
'version': self.version,
|
||||||
|
'extension': self.extension,
|
||||||
|
'type': self.type,
|
||||||
|
'directory': None
|
||||||
|
}
|
||||||
|
for key in (
|
||||||
|
'title', 'director', 'year',
|
||||||
|
'episode', 'episodeTitle', 'seriesTitle', 'seriesYear'
|
||||||
|
):
|
||||||
|
data[key] = self.item.get(key)
|
||||||
|
data['directorSort'] = [get_name_sort(n) for n in self.item.get('director', [])]
|
||||||
|
return data
|
||||||
|
|
||||||
self.type = self.get_type()
|
def normalize_path(self):
|
||||||
if self.instances.count()>0:
|
return u'/'.join(ox.movie.format_path(self.path_data()).split('/')[1:])
|
||||||
info = ox.movie.parse_path(self.path)
|
|
||||||
self.language = info['language'] or ''
|
def save(self, *args, **kwargs):
|
||||||
self.part = self.get_part()
|
if self.id and not self.path and self.instances.count():
|
||||||
|
self.parse_info()
|
||||||
|
self.parse_instance_path()
|
||||||
|
self.path = self.normalize_path()
|
||||||
|
|
||||||
|
if self.path:
|
||||||
|
self.path = self.normalize_path()
|
||||||
|
self.sort_path = utils.sort_string(self.path)
|
||||||
|
self.is_audio = self.type == 'audio'
|
||||||
|
self.is_video = self.type == 'video'
|
||||||
|
self.is_subtitle = self.path.endswith('.srt')
|
||||||
|
|
||||||
if self.type not in ('audio', 'video'):
|
if self.type not in ('audio', 'video'):
|
||||||
self.duration = None
|
self.duration = None
|
||||||
|
elif self.duration <= 0:
|
||||||
|
self.duration = sum([s.info.get('duration',0)
|
||||||
|
for s in self.streams.filter(source=None)])
|
||||||
|
|
||||||
def save(self, *args, **kwargs):
|
|
||||||
if self.auto:
|
|
||||||
self.set_state()
|
|
||||||
if self.duration <= 0:
|
|
||||||
self.duration = sum([s.info.get('duration',0) for s in self.streams.filter(source=None)])
|
|
||||||
self.sort_path = utils.sort_string(self.path)
|
|
||||||
if self.is_subtitle:
|
if self.is_subtitle:
|
||||||
self.available = self.data and True or False
|
self.available = self.data and True or False
|
||||||
else:
|
else:
|
||||||
self.available = not self.uploading and \
|
self.available = not self.uploading and \
|
||||||
self.streams.filter(source=None, available=True).count() > 0
|
self.streams.filter(source=None, available=True).count() > 0
|
||||||
super(File, self).save(*args, **kwargs)
|
super(File, self).save(*args, **kwargs)
|
||||||
|
|
||||||
#upload and data handling
|
|
||||||
data = models.FileField(null=True, blank=True,
|
|
||||||
upload_to=lambda f, x: f.get_path('data.bin'))
|
|
||||||
|
|
||||||
def get_path(self, name):
|
def get_path(self, name):
|
||||||
h = self.oshash
|
h = self.oshash
|
||||||
return os.path.join('files', h[:2], h[2:4], h[4:6], h[6:], name)
|
return os.path.join('files', h[:2], h[2:4], h[4:6], h[6:], name)
|
||||||
|
@ -242,7 +263,7 @@ class File(models.Model):
|
||||||
return data
|
return data
|
||||||
|
|
||||||
def get_part(self):
|
def get_part(self):
|
||||||
if os.path.splitext(self.path)[-1] in ('.sub', '.idx', '.srt'):
|
if self.type not in ('audio', 'video'):
|
||||||
name = os.path.splitext(self.path)[0]
|
name = os.path.splitext(self.path)[0]
|
||||||
if self.language:
|
if self.language:
|
||||||
name = name[-(len(self.language)+1)]
|
name = name[-(len(self.language)+1)]
|
||||||
|
@ -257,27 +278,6 @@ class File(models.Model):
|
||||||
return files.index(self) + 1
|
return files.index(self) + 1
|
||||||
return None
|
return None
|
||||||
|
|
||||||
def get_type(self):
|
|
||||||
if self.is_video:
|
|
||||||
return 'video'
|
|
||||||
if self.is_audio:
|
|
||||||
return 'audio'
|
|
||||||
if self.is_subtitle or os.path.splitext(self.path)[-1] in ('.sub', '.idx'):
|
|
||||||
return 'subtitle'
|
|
||||||
return 'unknown'
|
|
||||||
|
|
||||||
def get_instance(self):
|
|
||||||
#FIXME: what about other instances?
|
|
||||||
if self.instances.all().count() > 0:
|
|
||||||
return self.instances.all()[0]
|
|
||||||
return None
|
|
||||||
|
|
||||||
def create_path(self):
|
|
||||||
instance = self.get_instance()
|
|
||||||
if instance:
|
|
||||||
return ox.movie.parse_path(instance.path)['normalizedPath']
|
|
||||||
return self.path
|
|
||||||
|
|
||||||
def all_paths(self):
|
def all_paths(self):
|
||||||
return [self.path] + [i.path for i in self.instances.all()]
|
return [self.path] + [i.path for i in self.instances.all()]
|
||||||
|
|
||||||
|
|
|
@ -435,22 +435,23 @@ def getPath(request):
|
||||||
'''
|
'''
|
||||||
change file / item link
|
change file / item link
|
||||||
param data {
|
param data {
|
||||||
ids: [hash of file]
|
id: [hash of file]
|
||||||
}
|
}
|
||||||
|
|
||||||
return {
|
return {
|
||||||
status: {'code': int, 'text': string},
|
status: {'code': int, 'text': string},
|
||||||
data: {
|
data: {
|
||||||
path: {
|
id: path
|
||||||
id: path
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
'''
|
'''
|
||||||
data = json.loads(request.POST['data'])
|
data = json.loads(request.POST['data'])
|
||||||
response = json_response({'path': {}})
|
response = json_response({'path': {}})
|
||||||
for f in models.File.objects.filter(oshash__in=data['ids']):
|
ids = data['id']
|
||||||
response['data']['path'][f.oshash] = f.path
|
if isinstance(ids, basestring):
|
||||||
|
ids = [ids]
|
||||||
|
for f in models.File.objects.filter(oshash__in=ids).values('path', 'oshash'):
|
||||||
|
response['data'][f['oshash']] = f['path']
|
||||||
return render_to_json_response(response)
|
return render_to_json_response(response)
|
||||||
actions.register(getPath, cache=True)
|
actions.register(getPath, cache=True)
|
||||||
|
|
||||||
|
|
Loading…
Reference in a new issue