|
@@ -0,0 +1,230 @@
|
|
|
|
+from django.forms import ValidationError
|
|
|
|
+from django.template import RequestContext
|
|
|
|
+from django.utils.translation import ugettext as _
|
|
|
|
+from misago.forms import FormLayout
|
|
|
|
+from misago.messages import Message
|
|
|
|
+from misago.models import Forum, Thread, Post
|
|
|
|
+from misago.apps.forumbase.list.forms import MoveThreadsForm, MergeThreadsForm
|
|
|
|
+
|
|
|
|
+class ThreadsListModeration(object):
|
|
|
|
+ def action_accept(self, ids):
|
|
|
|
+ accepted = 0
|
|
|
|
+ last_posts = []
|
|
|
|
+ users = []
|
|
|
|
+ for thread in self.threads:
|
|
|
|
+ if thread.pk in ids and thread.moderated:
|
|
|
|
+ accepted += 1
|
|
|
|
+ # Sync thread and post
|
|
|
|
+ thread.moderated = False
|
|
|
|
+ thread.replies_moderated -= 1
|
|
|
|
+ thread.save(force_update=True)
|
|
|
|
+ thread.start_post.moderated = False
|
|
|
|
+ thread.start_post.save(force_update=True)
|
|
|
|
+ thread.last_post.set_checkpoint(self.request, 'accepted')
|
|
|
|
+ last_posts.append(thread.last_post.pk)
|
|
|
|
+ # Sync user
|
|
|
|
+ if thread.last_post.user:
|
|
|
|
+ thread.start_post.user.threads += 1
|
|
|
|
+ thread.start_post.user.posts += 1
|
|
|
|
+ users.append(thread.start_post.user)
|
|
|
|
+ if accepted:
|
|
|
|
+ Post.objects.filter(id__in=last_posts).update(checkpoints=True)
|
|
|
|
+ self.request.monitor['threads'] = int(self.request.monitor['threads']) + accepted
|
|
|
|
+ self.request.monitor['posts'] = int(self.request.monitor['posts']) + accepted
|
|
|
|
+ self.forum.sync()
|
|
|
|
+ self.forum.save(force_update=True)
|
|
|
|
+ for user in users:
|
|
|
|
+ user.save(force_update=True)
|
|
|
|
+ self.request.messages.set_flash(Message(_('Selected threads have been marked as reviewed and made visible to other members.')), 'success', 'threads')
|
|
|
|
+
|
|
|
|
+ def action_annouce(self, ids):
|
|
|
|
+ acl = self.request.acl.threads.get_role(self.forum)
|
|
|
|
+ annouced = []
|
|
|
|
+ for thread in self.threads:
|
|
|
|
+ if thread.pk in ids and thread.weight < 2:
|
|
|
|
+ annouced.append(thread.pk)
|
|
|
|
+ if annouced:
|
|
|
|
+ Thread.objects.filter(id__in=annouced).update(weight=2)
|
|
|
|
+ self.request.messages.set_flash(Message(_('Selected threads have been turned into announcements.')), 'success', 'threads')
|
|
|
|
+
|
|
|
|
+ def action_sticky(self, ids):
|
|
|
|
+ acl = self.request.acl.threads.get_role(self.forum)
|
|
|
|
+ sticky = []
|
|
|
|
+ for thread in self.threads:
|
|
|
|
+ if thread.pk in ids and thread.weight != 1 and (acl['can_pin_threads'] == 2 or thread.weight < 2):
|
|
|
|
+ sticky.append(thread.pk)
|
|
|
|
+ if sticky:
|
|
|
|
+ Thread.objects.filter(id__in=sticky).update(weight=1)
|
|
|
|
+ self.request.messages.set_flash(Message(_('Selected threads have been sticked to the top of list.')), 'success', 'threads')
|
|
|
|
+
|
|
|
|
+ def action_normal(self, ids):
|
|
|
|
+ normalised = []
|
|
|
|
+ for thread in self.threads:
|
|
|
|
+ if thread.pk in ids and thread.weight > 0:
|
|
|
|
+ normalised.append(thread.pk)
|
|
|
|
+ if normalised:
|
|
|
|
+ Thread.objects.filter(id__in=normalised).update(weight=0)
|
|
|
|
+ self.request.messages.set_flash(Message(_('Selected threads weight has been removed.')), 'success', 'threads')
|
|
|
|
+
|
|
|
|
+ def action_move(self, ids):
|
|
|
|
+ threads = []
|
|
|
|
+ for thread in self.threads:
|
|
|
|
+ if thread.pk in ids:
|
|
|
|
+ threads.append(thread)
|
|
|
|
+ if self.request.POST.get('origin') == 'move_form':
|
|
|
|
+ form = MoveThreadsForm(self.request.POST, request=self.request, forum=self.forum)
|
|
|
|
+ if form.is_valid():
|
|
|
|
+ new_forum = form.cleaned_data['new_forum']
|
|
|
|
+ for thread in threads:
|
|
|
|
+ thread.move_to(new_forum)
|
|
|
|
+ thread.save(force_update=True)
|
|
|
|
+ new_forum.sync()
|
|
|
|
+ new_forum.save(force_update=True)
|
|
|
|
+ self.forum.sync()
|
|
|
|
+ self.forum.save(force_update=True)
|
|
|
|
+ self.request.messages.set_flash(Message(_('Selected threads have been moved to "%(forum)s".') % {'forum': new_forum.name}), 'success', 'threads')
|
|
|
|
+ return None
|
|
|
|
+ self.message = Message(form.non_field_errors()[0], 'error')
|
|
|
|
+ else:
|
|
|
|
+ form = MoveThreadsForm(request=self.request, forum=self.forum)
|
|
|
|
+ return self.request.theme.render_to_response(('%s/move_threads.html' % self.templates_prefix),
|
|
|
|
+ {
|
|
|
|
+ 'message': self.message,
|
|
|
|
+ 'forum': self.forum,
|
|
|
|
+ 'parents': self.parents,
|
|
|
|
+ 'threads': threads,
|
|
|
|
+ 'form': FormLayout(form),
|
|
|
|
+ },
|
|
|
|
+ context_instance=RequestContext(self.request));
|
|
|
|
+
|
|
|
|
+ def action_merge(self, ids):
|
|
|
|
+ if len(ids) < 2:
|
|
|
|
+ raise ValidationError(_("You have to pick two or more threads to merge."))
|
|
|
|
+ threads = []
|
|
|
|
+ for thread in self.threads:
|
|
|
|
+ if thread.pk in ids:
|
|
|
|
+ threads.append(thread)
|
|
|
|
+ if self.request.POST.get('origin') == 'merge_form':
|
|
|
|
+ form = MergeThreadsForm(self.request.POST, request=self.request, threads=threads)
|
|
|
|
+ if form.is_valid():
|
|
|
|
+ new_thread = Thread.objects.create(
|
|
|
|
+ forum=form.cleaned_data['new_forum'],
|
|
|
|
+ name=form.cleaned_data['thread_name'],
|
|
|
|
+ slug=slugify(form.cleaned_data['thread_name']),
|
|
|
|
+ start=timezone.now(),
|
|
|
|
+ last=timezone.now()
|
|
|
|
+ )
|
|
|
|
+ last_merge = 0
|
|
|
|
+ last_thread = None
|
|
|
|
+ merged = []
|
|
|
|
+ for i in range(0, len(threads)):
|
|
|
|
+ thread = form.merge_order[i]
|
|
|
|
+ merged.append(thread.pk)
|
|
|
|
+ if last_thread and last_thread.last > thread.start:
|
|
|
|
+ last_merge += thread.merges + 1
|
|
|
|
+ thread.merge_with(new_thread, last_merge=last_merge)
|
|
|
|
+ last_thread = thread
|
|
|
|
+ Thread.objects.filter(id__in=merged).delete()
|
|
|
|
+ new_thread.sync()
|
|
|
|
+ new_thread.save(force_update=True)
|
|
|
|
+ self.forum.sync()
|
|
|
|
+ self.forum.save(force_update=True)
|
|
|
|
+ if form.cleaned_data['new_forum'].pk != self.forum.pk:
|
|
|
|
+ form.cleaned_data['new_forum'].sync()
|
|
|
|
+ form.cleaned_data['new_forum'].save(force_update=True)
|
|
|
|
+ self.request.messages.set_flash(Message(_('Selected threads have been merged into new one.')), 'success', 'threads')
|
|
|
|
+ return None
|
|
|
|
+ self.message = Message(form.non_field_errors()[0], 'error')
|
|
|
|
+ else:
|
|
|
|
+ form = MergeThreadsForm(request=self.request, threads=threads)
|
|
|
|
+ return self.request.theme.render_to_response(('%s/merge.html' % self.templates_prefix),
|
|
|
|
+ {
|
|
|
|
+ 'message': self.message,
|
|
|
|
+ 'forum': self.forum,
|
|
|
|
+ 'parents': self.parents,
|
|
|
|
+ 'threads': threads,
|
|
|
|
+ 'form': FormLayout(form),
|
|
|
|
+ },
|
|
|
|
+ context_instance=RequestContext(self.request));
|
|
|
|
+
|
|
|
|
+ def action_open(self, ids):
|
|
|
|
+ opened = []
|
|
|
|
+ last_posts = []
|
|
|
|
+ for thread in self.threads:
|
|
|
|
+ if thread.pk in ids and thread.closed:
|
|
|
|
+ opened.append(thread.pk)
|
|
|
|
+ thread.last_post.set_checkpoint(self.request, 'opened')
|
|
|
|
+ last_posts.append(thread.last_post.pk)
|
|
|
|
+ if opened:
|
|
|
|
+ Post.objects.filter(id__in=last_posts).update(checkpoints=True)
|
|
|
|
+ Thread.objects.filter(id__in=opened).update(closed=False)
|
|
|
|
+ self.request.messages.set_flash(Message(_('Selected threads have been opened.')), 'success', 'threads')
|
|
|
|
+
|
|
|
|
+ def action_close(self, ids):
|
|
|
|
+ closed = []
|
|
|
|
+ last_posts = []
|
|
|
|
+ for thread in self.threads:
|
|
|
|
+ if thread.pk in ids and not thread.closed:
|
|
|
|
+ closed.append(thread.pk)
|
|
|
|
+ thread.last_post.set_checkpoint(self.request, 'closed')
|
|
|
|
+ last_posts.append(thread.last_post.pk)
|
|
|
|
+ if closed:
|
|
|
|
+ Post.objects.filter(id__in=last_posts).update(checkpoints=True)
|
|
|
|
+ Thread.objects.filter(id__in=closed).update(closed=True)
|
|
|
|
+ self.request.messages.set_flash(Message(_('Selected threads have been closed.')), 'success', 'threads')
|
|
|
|
+
|
|
|
|
+ def action_undelete(self, ids):
|
|
|
|
+ undeleted = []
|
|
|
|
+ last_posts = []
|
|
|
|
+ posts = 0
|
|
|
|
+ for thread in self.threads:
|
|
|
|
+ if thread.pk in ids and thread.deleted:
|
|
|
|
+ undeleted.append(thread.pk)
|
|
|
|
+ posts += thread.replies + 1
|
|
|
|
+ thread.start_post.deleted = False
|
|
|
|
+ thread.start_post.save(force_update=True)
|
|
|
|
+ thread.last_post.set_checkpoint(self.request, 'undeleted')
|
|
|
|
+ if undeleted:
|
|
|
|
+ self.request.monitor['threads'] = int(self.request.monitor['threads']) + len(undeleted)
|
|
|
|
+ self.request.monitor['posts'] = int(self.request.monitor['posts']) + posts
|
|
|
|
+ self.forum.sync()
|
|
|
|
+ self.forum.save(force_update=True)
|
|
|
|
+ Post.objects.filter(id__in=last_posts).update(checkpoints=True)
|
|
|
|
+ Thread.objects.filter(id__in=undeleted).update(deleted=False)
|
|
|
|
+ self.request.messages.set_flash(Message(_('Selected threads have been undeleted.')), 'success', 'threads')
|
|
|
|
+
|
|
|
|
+ def action_soft(self, ids):
|
|
|
|
+ deleted = []
|
|
|
|
+ last_posts = []
|
|
|
|
+ posts = 0
|
|
|
|
+ for thread in self.threads:
|
|
|
|
+ if thread.pk in ids and not thread.deleted:
|
|
|
|
+ deleted.append(thread.pk)
|
|
|
|
+ posts += thread.replies + 1
|
|
|
|
+ thread.start_post.deleted = True
|
|
|
|
+ thread.start_post.save(force_update=True)
|
|
|
|
+ thread.last_post.set_checkpoint(self.request, 'deleted')
|
|
|
|
+ last_posts.append(thread.last_post.pk)
|
|
|
|
+ if deleted:
|
|
|
|
+ self.request.monitor['threads'] = int(self.request.monitor['threads']) - len(deleted)
|
|
|
|
+ self.request.monitor['posts'] = int(self.request.monitor['posts']) - posts
|
|
|
|
+ self.forum.sync()
|
|
|
|
+ self.forum.save(force_update=True)
|
|
|
|
+ Post.objects.filter(id__in=last_posts).update(checkpoints=True)
|
|
|
|
+ Thread.objects.filter(id__in=deleted).update(deleted=True)
|
|
|
|
+ self.request.messages.set_flash(Message(_('Selected threads have been softly deleted.')), 'success', 'threads')
|
|
|
|
+
|
|
|
|
+ def action_hard(self, ids):
|
|
|
|
+ deleted = []
|
|
|
|
+ posts = 0
|
|
|
|
+ for thread in self.threads:
|
|
|
|
+ if thread.pk in ids:
|
|
|
|
+ deleted.append(thread.pk)
|
|
|
|
+ posts += thread.replies + 1
|
|
|
|
+ thread.delete()
|
|
|
|
+ if deleted:
|
|
|
|
+ self.request.monitor['threads'] = int(self.request.monitor['threads']) - len(deleted)
|
|
|
|
+ self.request.monitor['posts'] = int(self.request.monitor['posts']) - posts
|
|
|
|
+ self.forum.sync()
|
|
|
|
+ self.forum.save(force_update=True)
|
|
|
|
+ self.request.messages.set_flash(Message(_('Selected threads have been deleted.')), 'success', 'threads')
|