--- a/src/ldt/ldt/ldt_utils/views/content.py Wed Oct 10 16:19:10 2012 +0200
+++ b/src/ldt/ldt/ldt_utils/views/content.py Wed Oct 10 18:00:00 2012 +0200
@@ -4,6 +4,7 @@
from django.core.urlresolvers import reverse
from django.forms.models import model_to_dict
from django.core.files import File
+from django.db import transaction
#from django.core.files.temp import NamedTemporaryFile
from django.forms.util import ErrorList
from django.http import HttpResponse, HttpResponseRedirect
@@ -29,8 +30,9 @@
import requests
import django.utils.simplejson as simplejson
import urlparse
-import tempfile
+import tempfile
+@transaction.commit_manually
def write_content_base(request, iri_id=None):
if iri_id:
instance_content = Content.safe_objects.get(iri_id=iri_id) #@UndefinedVariable
@@ -44,282 +46,309 @@
if instance_content:
current_front_project = instance_content.front_project
form_status = 'none'
- if request.method == "POST":
-
- if instance_content is not None:
- content_instance_val = model_to_dict(instance_content, exclude=ContentForm.Meta.exclude)
- else:
- content_instance_val = {}
-
- if instance_media is not None:
- media_instance_val = model_to_dict(instance_media, exclude=MediaForm.Meta.exclude)
- else:
- media_instance_val = {}
- #add prefix
-
- def add_prefix(_dict, prefix):
- return dict([('%s-%s' % (prefix, key), value) for key,value in _dict.items()])
-
- content_instance_val = add_prefix(content_instance_val, "content")
- media_instance_val= add_prefix(media_instance_val, "media")
-
- for k in request.POST.keys():
- value = request.POST.get(k)
- content_instance_val[k] = value
- media_instance_val[k] = value
+ errors_transaction = []
+
+ # catch error from creating content, project, media
+ try:
+ if request.method == "POST":
+
+ if instance_content is not None:
+ content_instance_val = model_to_dict(instance_content, exclude=ContentForm.Meta.exclude)
+ else:
+ content_instance_val = {}
- content_instance_val['read_list'] = request.POST.getlist('read_list')
- content_instance_val['write_list'] = request.POST.getlist('write_list')
- content_instance_val['share'] = request.POST.get('share', True)
-
- content_form = ContentForm(content_instance_val, prefix="content", instance=instance_content)
- media_form = MediaForm(media_instance_val, request.FILES, prefix="media", instance=instance_media)
- picture_form = PictureForm(None, request.POST, request.FILES)
-
- if request.user.is_staff:
- content_form.fields['front_project'].queryset = Project.objects.filter(contents__in=[instance_content])
-
-
- media_valid = media_form.is_valid()
- content_valid = content_form.is_valid()
- picture_valid = picture_form.is_valid()
- if 'image' in request.POST.keys():
- image_link = request.POST.get('url_image')
- if picture_valid and image_link!='' :
- try :
- r = requests.get(image_link)
- img_temp = tempfile.NamedTemporaryFile(suffix='.png')
- if img_temp:
- img_temp.write(r.content)
- img_temp.flush()
- picture_form.cleaned_data["image"]=File(img_temp)
- except Exception as inst:
- logging.debug("couldn't download video thumbnail from image_link : "+str(image_link))
- logging.debug("write_content_base : valid form: for instance : " + repr(instance_media) + " -> media " + str(media_valid) + " content : for instance : " + repr(instance_content) + " : " + str(content_valid) + "picture : valid :" +str(picture_valid)+" loulou") #@UndefinedVariable
-
- if media_valid and content_valid and picture_valid:
-
- # see if media must be created
- cleaned_data = {}
- cleaned_data.update(media_form.cleaned_data)
- cleaned_data.pop("media_public")
+ if instance_media is not None:
+ media_instance_val = model_to_dict(instance_media, exclude=MediaForm.Meta.exclude)
+ else:
+ media_instance_val = {}
+ #add prefix
+
+ def add_prefix(_dict, prefix):
+ return dict([('%s-%s' % (prefix, key), value) for key,value in _dict.items()])
- media_input_type = content_form.cleaned_data["media_input_type"]
+ content_instance_val = add_prefix(content_instance_val, "content")
+ media_instance_val= add_prefix(media_instance_val, "media")
+
+ for k in request.POST.keys():
+ value = request.POST.get(k)
+ content_instance_val[k] = value
+ media_instance_val[k] = value
+
+ content_instance_val['read_list'] = request.POST.getlist('read_list')
+ content_instance_val['write_list'] = request.POST.getlist('write_list')
+ content_instance_val['share'] = request.POST.get('share', True)
- if media_input_type == "none":
- media = None
- elif media_input_type == "link":
- media = content_form.cleaned_data["media_obj"]
- created = False
- elif media_input_type == "create":
- del cleaned_data["media_file"]
- if not cleaned_data['videopath']:
- cleaned_data['videopath'] = settings.STREAM_URL
- # if the source is already http:// or rtmp:// we don't have to add STREAM_URL
- if cleaned_data['src'].startswith("rtmp://") or cleaned_data['src'].startswith("http://"):
- cleaned_data['videopath'] = ''
- media, created = Media.objects.get_or_create(src=cleaned_data['src'], defaults=cleaned_data) #@UndefinedVariable
- elif media_input_type == "url" or media_input_type == "upload" :
- # copy file
- #complet src
- destination_file = None
- source_file = None
- try:
- if media_input_type == "url":
- url = cleaned_data["external_src_url"]
- source_file = urllib2.urlopen(url)
- source_filename = source_file.info().get('Content-Disposition', None)
- if not source_filename:
- source_filename = urlparse.urlparse(url).path.rstrip("/").split('/')[-1]
- elif media_input_type == "upload":
- #source_file = request.FILES['media-media_file']
- # At this point the file has already be uploaded thanks to the upload view, and original file name is sent through a post var
- source_filename = request.POST["media-local_file_name"]
-
- source_filename = ldt_utils_path.sanitize_filename(source_filename)
- destination_filepath = os.path.join(settings.STREAM_PATH, source_filename)
- base_source_filename = source_filename
- extension = base_source_filename.split(".")[-1]
- if extension == base_source_filename:
- extension = ""
- base_basename_filename = base_source_filename
- else:
- base_basename_filename = base_source_filename[:-1 * (len(extension) + 1)]
- i = 0
-
- while os.path.exists(destination_filepath):
- base_source_filename = "%s.%d.%s" % (base_basename_filename, i, extension)
- destination_filepath = os.path.join(settings.STREAM_PATH, base_source_filename)
- i += 1
-
- if media_input_type == "url":
- # we upload the file if we are in url case
- destination_file = open(destination_filepath, "wb")
- chunck = source_file.read(2048)
- while chunck:
- destination_file.write(chunck)
- chunck = source_file.read(2048)
-
- elif media_input_type == "upload":
- # The media file has been uploaded in the session temp folder
- # so we just have to move to the regular folder and rename it.
- if os.path.exists(os.path.join(settings.STREAM_PATH, "tmp/" + request.COOKIES[settings.SESSION_COOKIE_NAME] + "/", source_filename)):
- os.rename(os.path.join(settings.STREAM_PATH, "tmp/" + request.COOKIES[settings.SESSION_COOKIE_NAME] + "/", source_filename), os.path.join(settings.STREAM_PATH, base_source_filename))
-
-
- src_prefix = settings.STREAM_SRC_PREFIX.rstrip("/")
- if len(src_prefix) > 0:
- cleaned_data["src"] = src_prefix + "/" + base_source_filename
- else:
- cleaned_data["src"] = base_source_filename
-
-
- except Exception as inst:
- logging.debug("write_content_base : POST error when processing file:" + str(inst)) #@UndefinedVariable
- form_status = "error"
- #set error for form
- if media_input_type == "url":
- errors = media_form._errors.setdefault("external_src_url", ErrorList())
- errors.append(_("Problem when downloading file from url : ") + url)
- elif media_input_type == "upload":
- errors = media_form._errors.setdefault("media_file", ErrorList())
- errors.append(_("Problem when uploading file : ") + str(inst))
- finally:
- if media_input_type == "url":
- if destination_file:
- destination_file.close()
- if source_file:
- source_file.close()
+ content_form = ContentForm(content_instance_val, prefix="content", instance=instance_content)
+ media_form = MediaForm(media_instance_val, request.FILES, prefix="media", instance=instance_media)
+ picture_form = PictureForm(None, request.POST, request.FILES)
+
+ if request.user.is_staff:
+ content_form.fields['front_project'].queryset = Project.objects.filter(contents__in=[instance_content])
+
+
+ media_valid = media_form.is_valid()
+ content_valid = content_form.is_valid()
+ picture_valid = picture_form.is_valid()
+ if 'image' in request.POST.keys():
+ image_link = request.POST.get('url_image')
+ if picture_valid and image_link!='' :
+ try :
+ r = requests.get(image_link)
+ img_temp = tempfile.NamedTemporaryFile(suffix='.png')
+ if img_temp:
+ img_temp.write(r.content)
+ img_temp.flush()
+ picture_form.cleaned_data["image"]=File(img_temp)
+ except Exception as inst:
+ logging.debug("couldn't download video thumbnail from image_link : "+str(image_link))
+ logging.debug("write_content_base : valid form: for instance : " + repr(instance_media) + " -> media " + str(media_valid) + " content : for instance : " + repr(instance_content) + " : " + str(content_valid) + "picture : valid :" +str(picture_valid)+" loulou") #@UndefinedVariable
+
+ if media_valid and content_valid and picture_valid:
+
+ # see if media must be created
+ cleaned_data = {}
+ cleaned_data.update(media_form.cleaned_data)
+ cleaned_data.pop("media_public")
+ media_input_type = content_form.cleaned_data["media_input_type"]
- if form_status != "error":
- #try:
+ if media_input_type == "none":
+ media = None
+ elif media_input_type == "link":
+ media = content_form.cleaned_data["media_obj"]
+ created = False
+ elif media_input_type == "create":
del cleaned_data["media_file"]
if not cleaned_data['videopath']:
cleaned_data['videopath'] = settings.STREAM_URL
+ # if the source is already http:// or rtmp:// we don't have to add STREAM_URL
+ if cleaned_data['src'].startswith("rtmp://") or cleaned_data['src'].startswith("http://"):
+ cleaned_data['videopath'] = ''
+ media, created = Media.objects.get_or_create(src=cleaned_data['src'], defaults=cleaned_data) #@UndefinedVariable
+ elif media_input_type == "url" or media_input_type == "upload" :
+ # copy file
+ #complet src
+ destination_file = None
+ source_file = None
+ try:
+ if media_input_type == "url":
+ url = cleaned_data["external_src_url"]
+ source_file = urllib2.urlopen(url)
+ source_filename = source_file.info().get('Content-Disposition', None)
+ if not source_filename:
+ source_filename = urlparse.urlparse(url).path.rstrip("/").split('/')[-1]
+ elif media_input_type == "upload":
+ #source_file = request.FILES['media-media_file']
+ # At this point the file has already be uploaded thanks to the upload view, and original file name is sent through a post var
+ source_filename = request.POST["media-local_file_name"]
+
+ source_filename = ldt_utils_path.sanitize_filename(source_filename)
+ destination_filepath = os.path.join(settings.STREAM_PATH, source_filename)
+ base_source_filename = source_filename
+ extension = base_source_filename.split(".")[-1]
+ if extension == base_source_filename:
+ extension = ""
+ base_basename_filename = base_source_filename
+ else:
+ base_basename_filename = base_source_filename[:-1 * (len(extension) + 1)]
+ i = 0
+
+ while os.path.exists(destination_filepath):
+ base_source_filename = "%s.%d.%s" % (base_basename_filename, i, extension)
+ destination_filepath = os.path.join(settings.STREAM_PATH, base_source_filename)
+ i += 1
+
+ if media_input_type == "url":
+ # we upload the file if we are in url case
+ destination_file = open(destination_filepath, "wb")
+ chunck = source_file.read(2048)
+ while chunck:
+ destination_file.write(chunck)
+ chunck = source_file.read(2048)
+
+ elif media_input_type == "upload":
+ # The media file has been uploaded in the session temp folder
+ # so we just have to move to the regular folder and rename it.
+ if os.path.exists(os.path.join(settings.STREAM_PATH, "tmp/" + request.COOKIES[settings.SESSION_COOKIE_NAME] + "/", source_filename)):
+ os.rename(os.path.join(settings.STREAM_PATH, "tmp/" + request.COOKIES[settings.SESSION_COOKIE_NAME] + "/", source_filename), os.path.join(settings.STREAM_PATH, base_source_filename))
+
+
+ src_prefix = settings.STREAM_SRC_PREFIX.rstrip("/")
+ if len(src_prefix) > 0:
+ cleaned_data["src"] = src_prefix + "/" + base_source_filename
+ else:
+ cleaned_data["src"] = base_source_filename
+
+
+ except Exception as inst:
+ logging.debug("write_content_base : POST error when processing file:" + str(inst)) #@UndefinedVariable
+ form_status = "error"
+ #set error for form
+ if media_input_type == "url":
+ errors = media_form._errors.setdefault("external_src_url", ErrorList())
+ errors.append(_("Problem when downloading file from url : ") + url)
+ elif media_input_type == "upload":
+ errors = media_form._errors.setdefault("media_file", ErrorList())
+ errors.append(_("Problem when uploading file : ") + str(inst))
+ finally:
+ if media_input_type == "url":
+ if destination_file:
+ destination_file.close()
+ if source_file:
+ source_file.close()
+
+
+ if form_status != "error":
+ #try:
+ del cleaned_data["media_file"]
+ if not cleaned_data['videopath']:
+ cleaned_data['videopath'] = settings.STREAM_URL
+ mimetype = cleaned_data.get('mimetype_field', None)
+ if not mimetype:
+ mimetype = mimetypes.guess_type(cleaned_data['src'])
+ cleaned_data['mimetype_field'] = mimetype
+ media, created = Media.safe_objects.get_or_create(src=cleaned_data['src'], defaults=cleaned_data) #@UndefinedVariable
+ cached_assign('view_media', request.user, media)
+ else:
+ media = None
+
+
+ if media and not created:
+ for attribute in ('external_id', 'external_permalink', 'external_publication_url', 'external_src_url', 'media_creation_date', 'videopath', 'duration', 'description', 'title', 'front_project'):
+ setattr(media, attribute, cleaned_data.get(attribute))
mimetype = cleaned_data.get('mimetype_field', None)
if not mimetype:
- mimetype = mimetypes.guess_type(cleaned_data['src'])
- cleaned_data['mimetype_field'] = mimetype
- media, created = Media.safe_objects.get_or_create(src=cleaned_data['src'], defaults=cleaned_data) #@UndefinedVariable
+ mimetype = mimetypes.guess_type(media.src)
+ media.mimetype_field = mimetype
cached_assign('view_media', request.user, media)
- else:
- media = None
-
-
- if media and not created:
- for attribute in ('external_id', 'external_permalink', 'external_publication_url', 'external_src_url', 'media_creation_date', 'videopath', 'duration', 'description', 'title', 'front_project'):
- setattr(media, attribute, cleaned_data.get(attribute))
- mimetype = cleaned_data.get('mimetype_field', None)
- if not mimetype:
- mimetype = mimetypes.guess_type(media.src)
- media.mimetype_field = mimetype
- cached_assign('view_media', request.user, media)
- cached_assign('change_media', request.user, media)
- media.save()
-
- if form_status != "error":
- content_defaults = {}
- content_defaults.update(content_form.cleaned_data)
- content_defaults['media_obj'] = media
-
- for key in ["media_input_type", "groups", "is_public", "read_list", "write_list", "share" ]:
- del content_defaults[key]
-
- content, created = Content.safe_objects.get_or_create(iri_id=content_form.cleaned_data['iri_id'], defaults=content_defaults) #@UndefinedVariable
-
- if not created and not request.user.has_perm('ldt_utils.change_content', content):
- raise AttributeError("%s is not allowed to change content %s" % (request.user, content))
-
- cached_assign('change_content', request.user, content)
- cached_assign('view_content', request.user, content)
- everyone = Group.objects.get(name=settings.PUBLIC_GROUP_NAME)
+ cached_assign('change_media', request.user, media)
+ media.save()
- if media_form.cleaned_data['media_public']:
- cached_assign('view_content', everyone, content)
- if media:
- cached_assign('view_media', everyone, media)
- else:
- remove_perm('ldt_utils.view_media', everyone, media)
- if media:
- assign_perm_to_obj(media, content_form.cleaned_data['read_list'], content_form.cleaned_data['write_list'], request.user)
- assign_perm_to_obj(content, content_form.cleaned_data['read_list'], content_form.cleaned_data['write_list'], request.user)
- if content_form.cleaned_data['is_public']:
+ if form_status != "error":
+ content_defaults = {}
+ content_defaults.update(content_form.cleaned_data)
+ content_defaults['media_obj'] = media
+
+ for key in ["media_input_type", "groups", "is_public", "read_list", "write_list", "share" ]:
+ del content_defaults[key]
+
+ content, created = Content.safe_objects.get_or_create(iri_id=content_form.cleaned_data['iri_id'], defaults=content_defaults) #@UndefinedVariable
+
+ if not created and not request.user.has_perm('ldt_utils.change_content', content):
+ raise AttributeError("%s is not allowed to change content %s" % (request.user, content))
+
+ cached_assign('change_content', request.user, content)
+ cached_assign('view_content', request.user, content)
+ everyone = Group.objects.get(name=settings.PUBLIC_GROUP_NAME)
+
+ if media_form.cleaned_data['media_public']:
cached_assign('view_content', everyone, content)
+ if media:
+ cached_assign('view_media', everyone, media)
else:
- remove_perm('ldt_utils.view_content', everyone, content)
-
- if not created:
- for attribute in ('iriurl', 'title', 'description', 'duration', 'content_creation_date', 'tags', 'media_obj'):
- setattr(content, attribute, content_defaults[attribute])
-
- if request.user.is_staff and content_defaults.has_key('front_project'):
- content.front_project = content_defaults['front_project']
+ remove_perm('ldt_utils.view_media', everyone, media)
+ if media:
+ assign_perm_to_obj(media, content_form.cleaned_data['read_list'], content_form.cleaned_data['write_list'], request.user)
+ assign_perm_to_obj(content, content_form.cleaned_data['read_list'], content_form.cleaned_data['write_list'], request.user)
+ if content_form.cleaned_data['is_public']:
+ cached_assign('view_content', everyone, content)
+ else:
+ remove_perm('ldt_utils.view_content', everyone, content)
- content.save()
- picture_form.model = content
- picture_form.save()
- form_status = 'saved'
- media_form = MediaForm(instance=media, prefix="media")
- content_form = ContentForm(instance=content, prefix="content")
- picture_form = PictureForm()
- else:
- form_status = 'error'
- else:
- form_status = 'empty'
- initial_c = { 'media_input_type':"link"}
- initial_m = {}
- if instance_media:
- initial_m['media_public'] = instance_media.is_public
+ if not created:
+ for attribute in ('iriurl', 'title', 'description', 'duration', 'content_creation_date', 'tags', 'media_obj'):
+ setattr(content, attribute, content_defaults[attribute])
+
+ if request.user.is_staff and content_defaults.has_key('front_project'):
+ content.front_project = content_defaults['front_project']
+
+ content.save()
+ picture_form.model = content
+ picture_form.save()
+ form_status = 'saved'
+ media_form = MediaForm(instance=media, prefix="media")
+ content_form = ContentForm(instance=content, prefix="content")
+ picture_form = PictureForm()
+ else:
+ form_status = 'error'
else:
- initial_m['media_public'] = True
- if instance_content:
- initial_c['is_public'] = instance_content.is_public
- else:
- initial_c['is_public'] = True
- content_form = ContentForm(prefix="content", instance=instance_content, initial=initial_c)
- media_form = MediaForm(prefix="media", instance=instance_media, initial=initial_m)
- picture_form = PictureForm()
-
- if instance_content is not None:
- content_form.media_input_type = "link"
-
- if request.user.is_staff:
- content_form.fields['front_project'].queryset = Project.objects.filter(contents__in=[instance_content])
-
- return content_form, media_form, picture_form, form_status, current_front_project
+ form_status = 'empty'
+ initial_c = { 'media_input_type':"link"}
+ initial_m = {}
+ if instance_media:
+ initial_m['media_public'] = instance_media.is_public
+ else:
+ initial_m['media_public'] = True
+ if instance_content:
+ initial_c['is_public'] = instance_content.is_public
+ else:
+ initial_c['is_public'] = True
+ content_form = ContentForm(prefix="content", instance=instance_content, initial=initial_c)
+ media_form = MediaForm(prefix="media", instance=instance_media, initial=initial_m)
+ picture_form = PictureForm()
+
+ if instance_content is not None:
+ content_form.media_input_type = "link"
+
+ if request.user.is_staff:
+ content_form.fields['front_project'].queryset = Project.objects.filter(contents__in=[instance_content])
+ except:
+ transaction.rollback()
+ errors_transaction.append(_("Content creation failure"))
+ return False, False, False, False, False, errors_transaction
+ else:
+ #Try to make sure the commit succeeded or not.
+ try:
+ transaction.commit()
+ except:
+ transaction.rollback()
+ errors_transaction.append(_("Commit of the content creation failed"))
+ return False, False, False, False, False, errors_transaction
+ return content_form, media_form, picture_form, form_status, current_front_project, errors_transaction
@login_required
def write_content(request, iri_id=None):
submit_action = request.REQUEST.get("submit_button", False)
member_list = admin_list = []
current_front_project = None
+ deleted = None
- if submit_action == "prepare_delete":
- errors, titles = prepare_delete_content(request, iri_id)
- if errors and len(errors) > 0:
- message = ungettext("There is %(count)d error when deleting content", "There are %(count)d errors when deleting content", len(errors)) % { 'count': len(errors)}
- title_msg = _('title error deleting content')
+ if submit_action == "prepare_delete":
+ errors, titles, delete, message_temp = prepare_delete_content(request, iri_id)
+ #if there is only front_project, with no annotations, delete without confirmation
+ if delete:
+ deleted, errors_transaction = delete_content(request, iri_id)
+ content_form = ContentForm()
+ form_status="deleted"
else:
- message = _("Confirm delete content %(titles)s") % { 'titles' : ",".join(titles) }
- title_msg = _("confirm delete content")
- return render_to_response('ldt/ldt_utils/error_confirm.html', {'errors':errors, 'message':message, 'title': title_msg}, context_instance=RequestContext(request))
+ if errors and len(errors) > 0:
+ message = ungettext("There is %(count)d error when deleting content", "There are %(count)d errors when deleting content", len(errors)) % { 'count': len(errors)}
+ title_msg = _('title error deleting content')
+ else:
+ if len(message_temp)>0:
+ message = message_temp
+ else:
+ message = _("Confirm delete content %(titles)s") % { 'titles' : ",".join(titles) }
+ title_msg = _("confirm delete content")
+ return render_to_response('ldt/ldt_utils/error_confirm.html', {'errors':errors, 'message':message, 'title': title_msg}, context_instance=RequestContext(request))
elif submit_action == "delete":
- delete_content(request, iri_id)
+ deleted, errors_transaction = delete_content(request, iri_id)
+ content_form = contentForm()
form_status = "deleted"
- content_form = ContentForm()
- media_form = MediaForm()
- picture_form = PictureForm()
elif submit_action == "prepare_reset":
errors=[]
content_temp = Content.objects.get(iri_id=iri_id)
- if content_temp.front_project.state==2:
- errors.append(_("Please unpublish the front project %(title)s") % {'title':content_temp.front_project.title})
- message=_("The front project is published")
- title = _("confirm reset")
+ if content_temp.front_project is not None:
+ if content_temp.front_project.state==2:
+ errors.append(_("Please unpublish the front project %(title)s") % {'title':content_temp.front_project.title})
+ message=_("The front project is published")
+ title = _("confirm reset")
+ else:
+ message = _("please confirm reseting project %(title)s") % {'title':content_temp.front_project.title}
+ title = _("confirm reset")
else:
- message = _("please confirm reseting project %(title)s") % {'title':content_temp.front_project.title}
- title = _("confirm reset")
+ content_temp.create_front_project()
+ return redirect("root-view")
return render_to_response('ldt/ldt_utils/reset_confirm.html', {'errors':errors, 'message':message, 'title': title}, context_instance=RequestContext(request))
elif submit_action == "reset":
#TODO : verifier index de la recherche maj
@@ -328,12 +357,11 @@
content.create_front_project()
content.save()
project_temp.delete()
- form_status= 'saved'
return HttpResponseRedirect(reverse('ldt.ldt_utils.views.content.write_content', kwargs={'iri_id':iri_id}))
elif submit_action=="close":
return redirect("root-view")
else:
- content_form, media_form, picture_form, form_status, current_front_project = write_content_base(request, iri_id)
+ content_form, media_form, picture_form, form_status, current_front_project, errors_transaction = write_content_base(request, iri_id)
if iri_id:
content_temp = Content.objects.get(iri_id=iri_id)
media_temp = content_temp.media_obj
@@ -341,6 +369,13 @@
member_list, admin_list = get_userlist_model(media_temp, request.user)
else:
member_list, admin_list = get_userlist_model(content_temp, request.user)
+
+ # Deleted is False if an error occurred during deletion
+ if (deleted == False) or (content_form == False and media_form == False and picture_form == False and form_status == False and current_front_project == False):
+ message=_("An error occurred - Please try again or contact webmaster")
+ title = _("Error")
+ return render_to_response('ldt/ldt_utils/error_confirm.html', {'errors':errors_transaction, 'message':message, 'title': title}, context_instance=RequestContext(request))
+
if iri_id:
create_content_action = reverse('ldt.ldt_utils.views.content.write_content', kwargs={'iri_id':iri_id})
img_container = content_form.instance
@@ -369,6 +404,8 @@
def prepare_delete_content(request, iri_id=None):
errors = []
titles = []
+ delete = False
+ message={}
if not iri_id:
iri_id = request.REQUEST.get("iri_id", None)
@@ -377,21 +414,53 @@
titles.append(unicode(content.title))
projects = content.project_set.all()
projects_nb = len(projects)
- if projects_nb > 0:
+ if projects_nb > 1:
project_titles = map(lambda p: unicode(p.title), projects)
errors.append(ungettext("Content '%(title)s' is referenced by this project : %(project_titles)s. Please delete it beforehand.", "Content '%(title)s' is referenced by %(count)d projects: %(project_titles)s. Please delete them beforehand.", projects_nb) % {'title':unicode(content.title), 'count':projects_nb, 'project_titles': ",".join(project_titles)})
-
- return errors, titles
+ elif projects_nb == 1:
+ if not projects[0].has_annotations():
+ delete = True
+ else:
+ message = _("The project '%(project_title)s' pointing on the content '%(title)s' has several annotations. Do you want to delete the content and the project anyway ?")% {'project_title':unicode(projects[0].title), 'title':unicode(content.title)}
+ elif project_nb == 0:
+ delete = True
+ return errors, titles, delete, message
@login_required
+@transaction.commit_manually
def delete_content(request, iri_id=None):
+ #Delete the project, the media if exists, and the content
+ errors_transaction=[]
if not iri_id:
- iri_id = request.REQUEST.get("iri_id", None)
-
+ iri_id = request.REQUEST.get("iri_id", None)
if iri_id:
- Content.safe_objects.get(iri_id=iri_id).delete()
-
+ content = Content.safe_objects.get(iri_id=iri_id)
+ try:
+ if content.media_obj is not None:
+ contents_media = Content.safe_objects.filter(media_obj = content.media_obj)
+ #check if the media is ref by severals content
+ if len(contents_media) < 2:
+ Media.safe_objects.get(id=content.media_obj.id).delete()
+ project = content.front_project
+ content.delete()
+ if project is not None:
+ Project.safe_objects.get(ldt_id= project.ldt_id).delete()
+ except:
+ content.rollback()
+ transaction.rollback()
+ errors_transaction.append(_("Content deletion failure"))
+ return False, errors_transaction
+ else:
+ try:
+ transaction.commit()
+ content.commit()
+ return True, errors_transaction
+ except:
+ transaction.rollback()
+ content.rollback()
+ errors_transaction.append(_("Commit of the content deletion failed"))
+ return False, errors_transaction
def upload(request):
if request.method == 'POST':