|
1 | 1 | # -*- coding: utf-8 -*- |
2 | 2 | from __future__ import absolute_import, unicode_literals |
| 3 | + |
3 | 4 | try: |
4 | 5 | from celery.task import task |
5 | 6 | except ImportError: |
|
15 | 16 | from django.db.models.fields.files import FieldFile |
16 | 17 |
|
17 | 18 |
|
18 | | -FILE_COMPRESS_DELETE_OLD_FILE = getattr(settings, |
19 | | - 'FILE_COMPRESS_DELETE_OLD_FILE', True) |
| 19 | +FILE_COMPRESS_DELETE_OLD_FILE = getattr(settings, "FILE_COMPRESS_DELETE_OLD_FILE", True) |
20 | 20 |
|
21 | 21 |
|
22 | 22 | class CompressFieldFile(FieldFile): |
23 | 23 | compress_ext = None |
24 | 24 |
|
25 | 25 | def _is_compressed(self): |
26 | 26 | basename, ext = os.path.splitext(self.name) |
27 | | - compress_ext = '.' + self.compress_ext |
| 27 | + compress_ext = "." + self.compress_ext |
28 | 28 | return compress_ext == ext |
| 29 | + |
29 | 30 | is_compressed = property(_is_compressed) |
30 | 31 |
|
31 | 32 | def _base_name(self): |
32 | 33 | return os.path.basename(self.file.name) |
| 34 | + |
33 | 35 | base_name = property(_base_name) |
34 | 36 |
|
35 | 37 | def _compress_name(self): |
36 | | - if not hasattr(self, '_avaliable_compress_name'): |
| 38 | + if not hasattr(self, "_avaliable_compress_name"): |
37 | 39 | basename, ext = os.path.splitext(self.name) |
38 | | - compress_name = basename + ('.' + self.compress_ext) |
| 40 | + compress_name = basename + ("." + self.compress_ext) |
39 | 41 | self._avaliable_compress_name = self.storage.get_available_name( |
40 | 42 | compress_name |
41 | 43 | ) |
@@ -75,12 +77,14 @@ def compress_wrapper(self, delete_old_file): |
75 | 77 |
|
76 | 78 | def compress(self, async_task=True, delete_old_file=FILE_COMPRESS_DELETE_OLD_FILE): |
77 | 79 | if self.is_compressed: |
78 | | - return 'This file is alredy compress' |
| 80 | + return "This file is alredy compress" |
79 | 81 |
|
80 | 82 | if async_task and task: |
81 | 83 | from .tasks import task_compress_wrapper |
| 84 | + |
82 | 85 | wrapper = task_compress_wrapper.delay( |
83 | | - self.instance, self.field.name, delete_old_file) |
| 86 | + self.instance, self.field.name, delete_old_file |
| 87 | + ) |
84 | 88 | else: |
85 | 89 | wrapper = CompressFieldFile.compress_wrapper(self, delete_old_file) |
86 | 90 |
|
|
0 commit comments