123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398 |
- import datetime
- import os
- import django.utils.copycompat as copy
- from django.conf import settings
- from django.db.models.fields import Field
- from django.core.files.base import File, ContentFile
- from django.core.files.storage import default_storage
- from django.core.files.images import ImageFile, get_image_dimensions
- from django.core.files.uploadedfile import UploadedFile
- from django.utils.functional import curry
- from django.db.models import signals
- from django.utils.encoding import force_unicode, smart_str
- from django.utils.translation import ugettext_lazy, ugettext as _
- from django import forms
- from django.db.models.loading import cache
- class FieldFile(File):
- def __init__(self, instance, field, name):
- super(FieldFile, self).__init__(None, name)
- self.instance = instance
- self.field = field
- self.storage = field.storage
- self._committed = True
- def __eq__(self, other):
-
-
- if hasattr(other, 'name'):
- return self.name == other.name
- return self.name == other
- def __ne__(self, other):
- return not self.__eq__(other)
- def __hash__(self):
-
- return hash(self.name)
-
-
-
- def _require_file(self):
- if not self:
- raise ValueError("The '%s' attribute has no file associated with it." % self.field.name)
- def _get_file(self):
- self._require_file()
- if not hasattr(self, '_file') or self._file is None:
- self._file = self.storage.open(self.name, 'rb')
- return self._file
- def _set_file(self, file):
- self._file = file
- def _del_file(self):
- del self._file
- file = property(_get_file, _set_file, _del_file)
- def _get_path(self):
- self._require_file()
- return self.storage.path(self.name)
- path = property(_get_path)
- def _get_url(self):
- self._require_file()
- return self.storage.url(self.name)
- url = property(_get_url)
- def _get_size(self):
- self._require_file()
- if not self._committed:
- return self.file.size
- return self.storage.size(self.name)
- size = property(_get_size)
- def open(self, mode='rb'):
- self._require_file()
- self.file.open(mode)
-
- open.alters_data = True
-
-
-
- def save(self, name, content, save=True):
- name = self.field.generate_filename(self.instance, name)
- self.name = self.storage.save(name, content)
- setattr(self.instance, self.field.name, self.name)
-
- self._size = content.size
- self._committed = True
-
- if save:
- self.instance.save()
- save.alters_data = True
- def delete(self, save=True):
-
-
- if hasattr(self, '_file'):
- self.close()
- del self.file
- self.storage.delete(self.name)
- self.name = None
- setattr(self.instance, self.field.name, self.name)
-
- if hasattr(self, '_size'):
- del self._size
- self._committed = False
- if save:
- self.instance.save()
- delete.alters_data = True
- def _get_closed(self):
- file = getattr(self, '_file', None)
- return file is None or file.closed
- closed = property(_get_closed)
- def close(self):
- file = getattr(self, '_file', None)
- if file is not None:
- file.close()
- def __getstate__(self):
-
-
-
-
- return {'name': self.name, 'closed': False, '_committed': True, '_file': None}
- class FileDescriptor(object):
- """
- The descriptor for the file attribute on the model instance. Returns a
- FieldFile when accessed so you can do stuff like::
- >>> instance.file.size
- Assigns a file object on assignment so you can do::
- >>> instance.file = File(...)
- """
- def __init__(self, field):
- self.field = field
- def __get__(self, instance=None, owner=None):
- if instance is None:
- raise AttributeError(
- "The '%s' attribute can only be accessed from %s instances."
- % (self.field.name, owner.__name__))
-
-
-
-
-
-
-
-
-
-
-
- file = instance.__dict__[self.field.name]
-
-
-
-
-
-
-
- if isinstance(file, basestring) or file is None:
- attr = self.field.attr_class(instance, self.field, file)
- instance.__dict__[self.field.name] = attr
-
-
-
-
- elif isinstance(file, File) and not isinstance(file, FieldFile):
- file_copy = self.field.attr_class(instance, self.field, file.name)
- file_copy.file = file
- file_copy._committed = False
- instance.__dict__[self.field.name] = file_copy
-
-
-
- elif isinstance(file, FieldFile) and not hasattr(file, 'field'):
- file.instance = instance
- file.field = self.field
- file.storage = self.field.storage
-
- return instance.__dict__[self.field.name]
- def __set__(self, instance, value):
- instance.__dict__[self.field.name] = value
- class FileField(Field):
-
-
- attr_class = FieldFile
-
- descriptor_class = FileDescriptor
- description = ugettext_lazy("File path")
- def __init__(self, verbose_name=None, name=None, upload_to='', storage=None, **kwargs):
- for arg in ('primary_key', 'unique'):
- if arg in kwargs:
- raise TypeError("'%s' is not a valid argument for %s." % (arg, self.__class__))
- self.storage = storage or default_storage
- self.upload_to = upload_to
- if callable(upload_to):
- self.generate_filename = upload_to
- kwargs['max_length'] = kwargs.get('max_length', 100)
- super(FileField, self).__init__(verbose_name, name, **kwargs)
- def get_internal_type(self):
- return "FileField"
- def get_prep_lookup(self, lookup_type, value):
- if hasattr(value, 'name'):
- value = value.name
- return super(FileField, self).get_prep_lookup(lookup_type, value)
- def get_prep_value(self, value):
- "Returns field's value prepared for saving into a database."
-
- if value is None:
- return None
- return unicode(value)
- def pre_save(self, model_instance, add):
- "Returns field's value just before saving."
- file = super(FileField, self).pre_save(model_instance, add)
- if file and not file._committed:
-
- file.save(file.name, file, save=False)
- return file
- def contribute_to_class(self, cls, name):
- super(FileField, self).contribute_to_class(cls, name)
- setattr(cls, self.name, self.descriptor_class(self))
- def get_directory_name(self):
- return os.path.normpath(force_unicode(datetime.datetime.now().strftime(smart_str(self.upload_to))))
- def get_filename(self, filename):
- return os.path.normpath(self.storage.get_valid_name(os.path.basename(filename)))
- def generate_filename(self, instance, filename):
- return os.path.join(self.get_directory_name(), self.get_filename(filename))
- def save_form_data(self, instance, data):
-
-
-
-
- if data is not None:
-
-
- if not data:
- data = ''
- setattr(instance, self.name, data)
- def formfield(self, **kwargs):
- defaults = {'form_class': forms.FileField, 'max_length': self.max_length}
-
-
-
-
-
- if 'initial' in kwargs:
- defaults['required'] = False
- defaults.update(kwargs)
- return super(FileField, self).formfield(**defaults)
- class ImageFileDescriptor(FileDescriptor):
- """
- Just like the FileDescriptor, but for ImageFields. The only difference is
- assigning the width/height to the width_field/height_field, if appropriate.
- """
- def __set__(self, instance, value):
- previous_file = instance.__dict__.get(self.field.name)
- super(ImageFileDescriptor, self).__set__(instance, value)
-
-
-
-
-
-
-
-
-
- if previous_file is not None:
- self.field.update_dimension_fields(instance, force=True)
- class ImageFieldFile(ImageFile, FieldFile):
- def delete(self, save=True):
-
- if hasattr(self, '_dimensions_cache'):
- del self._dimensions_cache
- super(ImageFieldFile, self).delete(save)
- class ImageField(FileField):
- attr_class = ImageFieldFile
- descriptor_class = ImageFileDescriptor
- description = ugettext_lazy("File path")
- def __init__(self, verbose_name=None, name=None, width_field=None, height_field=None, **kwargs):
- self.width_field, self.height_field = width_field, height_field
- FileField.__init__(self, verbose_name, name, **kwargs)
- def contribute_to_class(self, cls, name):
- super(ImageField, self).contribute_to_class(cls, name)
-
-
-
- signals.post_init.connect(self.update_dimension_fields, sender=cls)
- def update_dimension_fields(self, instance, force=False, *args, **kwargs):
- """
- Updates field's width and height fields, if defined.
- This method is hooked up to model's post_init signal to update
- dimensions after instantiating a model instance. However, dimensions
- won't be updated if the dimensions fields are already populated. This
- avoids unnecessary recalculation when loading an object from the
- database.
- Dimensions can be forced to update with force=True, which is how
- ImageFileDescriptor.__set__ calls this method.
- """
-
- has_dimension_fields = self.width_field or self.height_field
- if not has_dimension_fields:
- return
-
-
-
- file = getattr(instance, self.attname)
-
- if not file and not force:
- return
- dimension_fields_filled = not(
- (self.width_field and not getattr(instance, self.width_field))
- or (self.height_field and not getattr(instance, self.height_field))
- )
-
-
-
-
-
-
-
- if dimension_fields_filled and not force:
- return
-
- if file:
- width = file.width
- height = file.height
- else:
-
- width = None
- height = None
-
- if self.width_field:
- setattr(instance, self.width_field, width)
- if self.height_field:
- setattr(instance, self.height_field, height)
- def formfield(self, **kwargs):
- defaults = {'form_class': forms.ImageField}
- defaults.update(kwargs)
- return super(ImageField, self).formfield(**defaults)
|