from datetime import timedelta from django.core.urlresolvers import reverse from django.shortcuts import redirect from django.template import RequestContext from django.utils import timezone from django.utils.translation import ugettext as _ from misago.acl.exceptions import ACLError403, ACLError404 from misago.apps.errors import error403, error404 from misago.forms import FormLayout from misago.markdown import post_markdown from misago.messages import Message from misago.models import Forum, Thread, Post, WatchedThread from misago.utils.datesformats import date from misago.utils.strings import slugify from misago.utils.pagination import make_pagination from misago.utils.translation import ugettext_lazy from misago.apps.threads.forms import PostForm from misago.apps.threads.views.base import BaseView class PostingBaseView(BaseView): def __call__(self, request, **kwargs): self.request = request # Empty context attributes self.forum = None self.thread = None self.quote = None self.post = None # Let inheriting class set context self.set_context() # And set forum parents for render self.parents = Forum.objects.forum_parents(self.forum.pk, True) # Create form instance def set_context(self): raise NotImplementedError(u"\"set_context\" method should be implemented in inheriting objects.") class PostingNewThreadView(PostingBaseView): pass class PostingEditThreadView(PostingBaseView): pass class PostingNewReplyView(PostingBaseView): pass class PostingEditReplyView(PostingBaseView): pass class PostingView(BaseView): def fetch_target(self, kwargs): if self.mode == 'new_thread': self.fetch_forum(kwargs) else: self.fetch_thread(kwargs) if self.mode == 'edit_thread': self.fetch_post(self.thread.start_post_id) if self.mode == 'edit_post': self.fetch_post(kwargs['post']) def fetch_forum(self, kwargs): self.forum = Forum.objects.get(pk=kwargs['forum'], type='forum') self.proxy = Forum.objects.parents_aware_forum(self.forum) self.request.acl.forums.allow_forum_view(self.forum) self.request.acl.threads.allow_new_threads(self.proxy) self.parents = Forum.objects.forum_parents(self.forum.pk, True) def fetch_thread(self, kwargs): self.thread = Thread.objects.get(pk=kwargs['thread']) self.forum = self.thread.forum self.proxy = Forum.objects.parents_aware_forum(self.forum) self.request.acl.forums.allow_forum_view(self.forum) self.request.acl.threads.allow_thread_view(self.request.user, self.thread) self.request.acl.threads.allow_reply(self.proxy, self.thread) self.parents = Forum.objects.forum_parents(self.forum.pk, True) if kwargs.get('quote'): self.quote = Post.objects.select_related('user').get(pk=kwargs['quote'], thread=self.thread.pk) self.request.acl.threads.allow_post_view(self.request.user, self.thread, self.quote) def fetch_post(self, post): self.post = self.thread.post_set.get(pk=post) self.request.acl.threads.allow_post_view(self.request.user, self.thread, self.post) if self.mode == 'edit_thread': self.request.acl.threads.allow_thread_edit(self.request.user, self.proxy, self.thread, self.post) if self.mode == 'edit_post': self.request.acl.threads.allow_reply_edit(self.request.user, self.proxy, self.thread, self.post) def get_form(self, bound=False): initial = {} if self.mode == 'edit_thread': initial['thread_name'] = self.thread.name if self.mode in ['edit_thread', 'edit_post']: initial['post'] = self.post.post if self.quote: quote_post = [] if self.quote.user: quote_post.append('@%s' % self.quote.user.username) else: quote_post.append('@%s' % self.quote.user_name) for line in self.quote.post.splitlines(): quote_post.append('> %s' % line) quote_post.append('\n') initial['post'] = '\n'.join(quote_post) if bound: return PostForm(self.request.POST, request=self.request, mode=self.mode, initial=initial) return PostForm(request=self.request, mode=self.mode, initial=initial) def __call__(self, request, **kwargs): self.request = request self.forum = None self.thread = None self.quote = None self.post = None self.parents = None self.mode = kwargs.get('mode') if self.request.POST.get('quick_reply') and self.mode == 'new_post': self.mode = 'new_post_quick' try: self.fetch_target(kwargs) if not request.user.is_authenticated(): raise ACLError403(_("Guest, you have to sign-in in order to post replies.")) except (Forum.DoesNotExist, Thread.DoesNotExist, Post.DoesNotExist): return error404(self.request) except ACLError403 as e: return error403(request, e.message) except ACLError404 as e: return error404(request, e.message) message = request.messages.get_message('threads') if request.method == 'POST': form = self.get_form(True) # Show message preview if 'preview' in request.POST: if form['post'].value(): md, preparsed = post_markdown(request, form['post'].value()) else: md, preparsed = None, None form.empty_errors() return request.theme.render_to_response('threads/posting.html', { 'mode': self.mode, 'forum': self.forum, 'thread': self.thread, 'post': self.post, 'quote': self.quote, 'parents': self.parents, 'message': message, 'preview': preparsed, 'form': FormLayout(form), }, context_instance=RequestContext(request)); # Commit form to database if form.is_valid(): # Record original vars if user is editing if self.mode in ['edit_thread', 'edit_post']: old_name = self.thread.name old_post = self.post.post # If there is no change, throw user back changed_name = (old_name != form.cleaned_data['thread_name']) if self.mode == 'edit_thread' else False changed_post = old_post != form.cleaned_data['post'] changed_anything = changed_name or changed_post # Some extra initialisation now = timezone.now() md = None moderation = False if not request.acl.threads.acl[self.forum.pk]['can_approve']: if self.mode == 'new_thread' and request.acl.threads.acl[self.forum.pk]['can_start_threads'] == 1: moderation = True if self.mode in ['new_post', 'new_post_quick'] and request.acl.threads.acl[self.forum.pk]['can_write_posts'] == 1: moderation = True # Get or create new thread if self.mode == 'new_thread': thread = Thread.objects.create( forum=self.forum, name=form.cleaned_data['thread_name'], slug=slugify(form.cleaned_data['thread_name']), start=now, last=now, moderated=moderation, score=request.settings['thread_ranking_initial_score'], ) if moderation: thread.replies_moderated += 1 else: thread = self.thread if self.mode == 'edit_thread': thread.name = form.cleaned_data['thread_name'] thread.slug = slugify(form.cleaned_data['thread_name']) thread.previous_last = thread.last # Create new message if self.mode in ['new_thread', 'new_post', 'new_post_quick']: # Use last post instead? if self.mode in ['new_post', 'new_post_quick']: merge_diff = (now - self.thread.last) merge_diff = (merge_diff.days * 86400) + merge_diff.seconds if (self.mode in ['new_post', 'new_post_quick'] and request.settings.post_merge_time and merge_diff < (request.settings.post_merge_time * 60) and self.thread.last_poster_id == request.user.id): # Overtake posting post = self.thread.last_post post.appended = True post.moderated = moderation post.date = now post.post = '%s\n\n- - -\n**%s**\n%s' % (post.post, _("Added on %(date)s:") % {'date': date(now, 'SHORT_DATETIME_FORMAT')}, form.cleaned_data['post']) md, post.post_preparsed = post_markdown(request, post.post) post.save(force_update=True) thread.last = now thread.save(force_update=True) self.forum.last = now self.forum.save(force_update=True) # Ignore rest of posting action request.messages.set_flash(Message(_("Your reply has been added to previous one.")), 'success', 'threads_%s' % post.pk) return self.redirect_to_post(post) else: md, post_preparsed = post_markdown(request, form.cleaned_data['post']) post = Post.objects.create( forum=self.forum, thread=thread, merge=thread.merges, user=request.user, user_name=request.user.username, ip=request.session.get_ip(request), agent=request.META.get('HTTP_USER_AGENT'), post=form.cleaned_data['post'], post_preparsed=post_preparsed, date=now, moderated=moderation, ) post.appended = False elif changed_post: # Change message post = self.post post.post = form.cleaned_data['post'] md, post.post_preparsed = post_markdown(request, form.cleaned_data['post']) post.edits += 1 post.edit_date = now post.edit_user = request.user post.edit_user_name = request.user.username post.edit_user_slug = request.user.username_slug post.save(force_update=True) # Record this edit in changelog? if self.mode in ['edit_thread', 'edit_post'] and changed_anything: self.post.change_set.create( forum=self.forum, thread=self.thread, post=self.post, user=request.user, user_name=request.user.username, user_slug=request.user.username_slug, date=now, ip=request.session.get_ip(request), agent=request.META.get('HTTP_USER_AGENT'), reason=form.cleaned_data['edit_reason'], size=len(self.post.post), change=len(self.post.post) - len(old_post), thread_name_old=old_name if self.mode == 'edit_thread' and form.cleaned_data['thread_name'] != old_name else None, thread_name_new=self.thread.name if self.mode == 'edit_thread' and form.cleaned_data['thread_name'] != old_name else None, post_content=old_post, ) # Set thread start post and author data if self.mode == 'new_thread': thread.start_post = post thread.start_poster = request.user thread.start_poster_name = request.user.username thread.start_poster_slug = request.user.username_slug if request.user.rank and request.user.rank.style: thread.start_poster_style = request.user.rank.style # Reward user for posting new thread? if not request.user.last_post or request.user.last_post < timezone.now() - timedelta(seconds=request.settings['score_reward_new_post_cooldown']): request.user.score += request.settings['score_reward_new_thread'] # New post - increase post counters, thread score # Notify quoted post author and close thread if it has hit limit if self.mode in ['new_post', 'new_post_quick']: if moderation: thread.replies_moderated += 1 else: thread.replies += 1 if thread.last_poster_id != request.user.pk: thread.score += request.settings['thread_ranking_reply_score'] # Notify quoted poster of reply? if self.quote and self.quote.user_id and self.quote.user_id != request.user.pk and not self.quote.user.is_ignoring(request.user): alert = self.quote.user.alert(ugettext_lazy("%(username)s has replied to your post in thread %(thread)s").message) alert.profile('username', request.user) alert.post('thread', self.thread, post) alert.save_all() if (self.request.settings.thread_length > 0 and not thread.closed and thread.replies >= self.request.settings.thread_length): thread.closed = True post.set_checkpoint(self.request, 'limit') # Reward user for posting new post? if not post.appended and (not request.user.last_post or request.user.last_post < timezone.now() - timedelta(seconds=request.settings['score_reward_new_post_cooldown'])): request.user.score += request.settings['score_reward_new_post'] # Update last poster data if not moderation and self.mode not in ['edit_thread', 'edit_post']: thread.last = now thread.last_post = post thread.last_poster = request.user thread.last_poster_name = request.user.username thread.last_poster_slug = request.user.username_slug thread.last_poster_style = request.user.rank.style # Final update of thread entry if self.mode != 'edit_post': thread.save(force_update=True) # Update forum and monitor if not moderation: if self.mode == 'new_thread': self.request.monitor['threads'] = int(self.request.monitor['threads']) + 1 self.forum.threads += 1 if self.mode in ['new_thread', 'new_post', 'new_post_quick']: self.request.monitor['posts'] = int(self.request.monitor['posts']) + 1 self.forum.posts += 1 if self.mode in ['new_thread', 'new_post', 'new_post_quick'] or ( self.mode == 'edit_thread' and self.forum.last_thread_id == thread.pk and self.forum.last_thread_name != thread.name): self.forum.last_thread = thread self.forum.last_thread_name = thread.name self.forum.last_thread_slug = thread.slug self.forum.last_thread_date = thread.last if self.mode in ['new_thread', 'new_post', 'new_post_quick']: self.forum.last_poster = thread.last_poster self.forum.last_poster_name = thread.last_poster_name self.forum.last_poster_slug = thread.last_poster_slug self.forum.last_poster_style = thread.last_poster_style if self.mode != 'edit_post': self.forum.save(force_update=True) # Update user if not moderation: if self.mode == 'new_thread': request.user.threads += 1 request.user.posts += 1 if self.mode in ['new_thread', 'new_post', 'new_post_quick']: request.user.last_post = thread.last request.user.save(force_update=True) # Notify users about post if md: try: if self.quote and self.quote.user_id: del md.mentions[self.quote.user.username_slug] except KeyError: pass if md.mentions: post.notify_mentioned(request, md.mentions) post.save(force_update=True) # Set thread watch status if self.mode == 'new_thread' and request.user.subscribe_start: WatchedThread.objects.create( user=request.user, forum=self.forum, thread=thread, last_read=now, email=(request.user.subscribe_start == 2), ) if self.mode in ['new_post', 'new_post_quick'] and request.user.subscribe_reply: try: watcher = WatchedThread.objects.get(user=request.user, thread=self.thread) except WatchedThread.DoesNotExist: WatchedThread.objects.create( user=request.user, forum=self.forum, thread=thread, last_read=now, email=(request.user.subscribe_reply == 2), ) # Set flash and redirect user to his post if self.mode == 'new_thread': if moderation: request.messages.set_flash(Message(_("New thread has been posted. It will be hidden from other members until moderator reviews it.")), 'success', 'threads') else: request.messages.set_flash(Message(_("New thread has been posted.")), 'success', 'threads') return redirect(reverse('thread', kwargs={'thread': thread.pk, 'slug': thread.slug}) + ('#post-%s' % post.pk)) if self.mode in ['new_post', 'new_post_quick']: thread.email_watchers(request, post) if moderation: request.messages.set_flash(Message(_("Your reply has been posted. It will be hidden from other members until moderator reviews it.")), 'success', 'threads_%s' % post.pk) else: request.messages.set_flash(Message(_("Your reply has been posted.")), 'success', 'threads_%s' % post.pk) return self.redirect_to_post(post) if self.mode == 'edit_thread': request.messages.set_flash(Message(_("Your thread has been edited.")), 'success', 'threads_%s' % self.post.pk) if self.mode == 'edit_post': request.messages.set_flash(Message(_("Your reply has been edited.")), 'success', 'threads_%s' % self.post.pk) return self.redirect_to_post(self.post) return redirect(reverse('thread', kwargs={'thread': self.thread.pk, 'slug': self.thread.slug}) + ('#post-%s' % self.post.pk)) message = Message(form.non_field_errors()[0], 'error') else: form = self.get_form() # Merge proxy into forum self.forum.closed = self.proxy.closed return request.theme.render_to_response('threads/posting.html', { 'mode': self.mode, 'forum': self.forum, 'thread': self.thread, 'post': self.post, 'quote': self.quote, 'parents': self.parents, 'message': message, 'form': FormLayout(form), }, context_instance=RequestContext(request));