post.py
421 lines
| 11.8 KiB
| text/x-python
|
PythonLexer
neko259
|
r407 | from datetime import datetime, timedelta | ||
from datetime import time as dtime | ||||
neko259
|
r384 | import os | ||
from random import random | ||||
import time | ||||
import math | ||||
neko259
|
r386 | import re | ||
neko259
|
r527 | import hashlib | ||
neko259
|
r410 | from django.core.cache import cache | ||
neko259
|
r493 | from django.core.paginator import Paginator | ||
neko259
|
r384 | |||
neko259
|
r566 | from django.db import models, transaction | ||
neko259
|
r384 | from django.http import Http404 | ||
from django.utils import timezone | ||||
from markupfield.fields import MarkupField | ||||
from neboard import settings | ||||
from boards import thumbs | ||||
neko259
|
r484 | MAX_TITLE_LENGTH = 50 | ||
neko259
|
r410 | APP_LABEL_BOARDS = 'boards' | ||
CACHE_KEY_PPD = 'ppd' | ||||
neko259
|
r408 | POSTS_PER_DAY_RANGE = range(7) | ||
neko259
|
r384 | BAN_REASON_AUTO = 'Auto' | ||
IMAGE_THUMB_SIZE = (200, 150) | ||||
TITLE_MAX_LENGTH = 50 | ||||
DEFAULT_MARKUP_TYPE = 'markdown' | ||||
NO_PARENT = -1 | ||||
NO_IP = '0.0.0.0' | ||||
UNKNOWN_UA = '' | ||||
ALL_PAGES = -1 | ||||
IMAGES_DIRECTORY = 'images/' | ||||
FILE_EXTENSION_DELIMITER = '.' | ||||
SETTING_MODERATE = "moderate" | ||||
REGEX_REPLY = re.compile('>>(\d+)') | ||||
class PostManager(models.Manager): | ||||
def create_post(self, title, text, image=None, thread=None, | ||||
ip=NO_IP, tags=None, user=None): | ||||
neko259
|
r418 | """ | ||
Create new post | ||||
""" | ||||
neko259
|
r384 | posting_time = timezone.now() | ||
neko259
|
r398 | if not thread: | ||
thread = Thread.objects.create(bump_time=posting_time, | ||||
last_edit_time=posting_time) | ||||
else: | ||||
thread.bump() | ||||
thread.last_edit_time = posting_time | ||||
thread.save() | ||||
neko259
|
r384 | |||
post = self.create(title=title, | ||||
text=text, | ||||
pub_time=posting_time, | ||||
neko259
|
r398 | thread_new=thread, | ||
neko259
|
r384 | image=image, | ||
poster_ip=ip, | ||||
neko259
|
r484 | poster_user_agent=UNKNOWN_UA, # TODO Get UA at | ||
# last! | ||||
neko259
|
r384 | last_edit_time=posting_time, | ||
user=user) | ||||
neko259
|
r398 | thread.replies.add(post) | ||
neko259
|
r384 | if tags: | ||
linked_tags = [] | ||||
for tag in tags: | ||||
tag_linked_tags = tag.get_linked_tags() | ||||
if len(tag_linked_tags) > 0: | ||||
linked_tags.extend(tag_linked_tags) | ||||
tags.extend(linked_tags) | ||||
neko259
|
r398 | map(thread.add_tag, tags) | ||
neko259
|
r384 | |||
neko259
|
r398 | self._delete_old_threads() | ||
neko259
|
r384 | self.connect_replies(post) | ||
return post | ||||
def delete_post(self, post): | ||||
neko259
|
r418 | """ | ||
neko259
|
r456 | Delete post and update or delete its thread | ||
neko259
|
r418 | """ | ||
neko259
|
r552 | |||
neko259
|
r456 | thread = post.thread_new | ||
neko259
|
r418 | |||
neko259
|
r552 | if post.is_opening(): | ||
thread.delete_with_posts() | ||||
neko259
|
r456 | else: | ||
thread.last_edit_time = timezone.now() | ||||
thread.save() | ||||
neko259
|
r384 | |||
neko259
|
r470 | post.delete() | ||
neko259
|
r384 | |||
def delete_posts_by_ip(self, ip): | ||||
neko259
|
r418 | """ | ||
Delete all posts of the author with same IP | ||||
""" | ||||
neko259
|
r384 | posts = self.filter(poster_ip=ip) | ||
map(self.delete_post, posts) | ||||
neko259
|
r548 | # TODO This method may not be needed any more, because django's paginator | ||
# is used | ||||
neko259
|
r384 | def get_threads(self, tag=None, page=ALL_PAGES, | ||
neko259
|
r484 | order_by='-bump_time', archived=False): | ||
neko259
|
r384 | if tag: | ||
threads = tag.threads | ||||
neko259
|
r398 | if not threads.exists(): | ||
neko259
|
r384 | raise Http404 | ||
else: | ||||
neko259
|
r398 | threads = Thread.objects.all() | ||
neko259
|
r384 | |||
neko259
|
r484 | threads = threads.filter(archived=archived).order_by(order_by) | ||
neko259
|
r384 | |||
if page != ALL_PAGES: | ||||
neko259
|
r493 | threads = Paginator(threads, settings.THREADS_PER_PAGE).page( | ||
page).object_list | ||||
neko259
|
r384 | |||
return threads | ||||
neko259
|
r398 | # TODO Move this method to thread manager | ||
neko259
|
r384 | def _delete_old_threads(self): | ||
""" | ||||
Preserves maximum thread count. If there are too many threads, | ||||
neko259
|
r484 | archive the old ones. | ||
neko259
|
r384 | """ | ||
neko259
|
r470 | threads = self.get_threads() | ||
neko259
|
r384 | thread_count = threads.count() | ||
if thread_count > settings.MAX_THREAD_COUNT: | ||||
num_threads_to_delete = thread_count - settings.MAX_THREAD_COUNT | ||||
old_threads = threads[thread_count - num_threads_to_delete:] | ||||
neko259
|
r484 | for thread in old_threads: | ||
thread.archived = True | ||||
neko259
|
r492 | thread.last_edit_time = timezone.now() | ||
neko259
|
r484 | thread.save() | ||
neko259
|
r384 | |||
def connect_replies(self, post): | ||||
neko259
|
r418 | """ | ||
Connect replies to a post to show them as a reflink map | ||||
""" | ||||
neko259
|
r384 | |||
for reply_number in re.finditer(REGEX_REPLY, post.text.raw): | ||||
post_id = reply_number.group(1) | ||||
ref_post = self.filter(id=post_id) | ||||
if ref_post.count() > 0: | ||||
referenced_post = ref_post[0] | ||||
referenced_post.referenced_posts.add(post) | ||||
referenced_post.last_edit_time = post.pub_time | ||||
referenced_post.save() | ||||
neko259
|
r535 | referenced_thread = referenced_post.thread_new | ||
referenced_thread.last_edit_time = post.pub_time | ||||
referenced_thread.save() | ||||
neko259
|
r407 | def get_posts_per_day(self): | ||
neko259
|
r418 | """ | ||
Get average count of posts per day for the last 7 days | ||||
""" | ||||
neko259
|
r407 | |||
neko259
|
r424 | today = datetime.now().date() | ||
ppd = cache.get(CACHE_KEY_PPD + str(today)) | ||||
neko259
|
r410 | if ppd: | ||
return ppd | ||||
neko259
|
r408 | posts_per_days = [] | ||
for i in POSTS_PER_DAY_RANGE: | ||||
neko259
|
r413 | day_end = today - timedelta(i + 1) | ||
day_start = today - timedelta(i + 2) | ||||
neko259
|
r412 | day_time_start = timezone.make_aware(datetime.combine(day_start, | ||
dtime()), timezone.get_current_timezone()) | ||||
day_time_end = timezone.make_aware(datetime.combine(day_end, | ||||
dtime()), timezone.get_current_timezone()) | ||||
neko259
|
r408 | |||
neko259
|
r410 | posts_per_days.append(float(self.filter( | ||
pub_time__lte=day_time_end, | ||||
pub_time__gte=day_time_start).count())) | ||||
neko259
|
r408 | |||
neko259
|
r410 | ppd = (sum(posts_per_day for posts_per_day in posts_per_days) / | ||
len(posts_per_days)) | ||||
neko259
|
r569 | cache.set(CACHE_KEY_PPD + str(today), ppd) | ||
neko259
|
r410 | return ppd | ||
neko259
|
r407 | |||
neko259
|
r384 | |||
class Post(models.Model): | ||||
"""A post is a message.""" | ||||
objects = PostManager() | ||||
class Meta: | ||||
neko259
|
r410 | app_label = APP_LABEL_BOARDS | ||
neko259
|
r384 | |||
neko259
|
r418 | # TODO Save original file name to some field | ||
neko259
|
r384 | def _update_image_filename(self, filename): | ||
"""Get unique image filename""" | ||||
path = IMAGES_DIRECTORY | ||||
new_name = str(int(time.mktime(time.gmtime()))) | ||||
new_name += str(int(random() * 1000)) | ||||
new_name += FILE_EXTENSION_DELIMITER | ||||
new_name += filename.split(FILE_EXTENSION_DELIMITER)[-1:][0] | ||||
return os.path.join(path, new_name) | ||||
title = models.CharField(max_length=TITLE_MAX_LENGTH) | ||||
pub_time = models.DateTimeField() | ||||
text = MarkupField(default_markup_type=DEFAULT_MARKUP_TYPE, | ||||
escape_html=False) | ||||
image_width = models.IntegerField(default=0) | ||||
image_height = models.IntegerField(default=0) | ||||
neko259
|
r452 | image_pre_width = models.IntegerField(default=0) | ||
image_pre_height = models.IntegerField(default=0) | ||||
neko259
|
r384 | image = thumbs.ImageWithThumbsField(upload_to=_update_image_filename, | ||
blank=True, sizes=(IMAGE_THUMB_SIZE,), | ||||
width_field='image_width', | ||||
neko259
|
r452 | height_field='image_height', | ||
preview_width_field='image_pre_width', | ||||
preview_height_field='image_pre_height') | ||||
neko259
|
r527 | image_hash = models.CharField(max_length=36) | ||
neko259
|
r384 | |||
poster_ip = models.GenericIPAddressField() | ||||
poster_user_agent = models.TextField() | ||||
thread = models.ForeignKey('Post', null=True, default=None) | ||||
neko259
|
r398 | thread_new = models.ForeignKey('Thread', null=True, default=None) | ||
neko259
|
r384 | last_edit_time = models.DateTimeField() | ||
user = models.ForeignKey('User', null=True, default=None) | ||||
referenced_posts = models.ManyToManyField('Post', symmetrical=False, | ||||
null=True, | ||||
blank=True, related_name='rfp+') | ||||
def __unicode__(self): | ||||
return '#' + str(self.id) + ' ' + self.title + ' (' + \ | ||||
self.text.raw[:50] + ')' | ||||
def get_title(self): | ||||
title = self.title | ||||
if len(title) == 0: | ||||
neko259
|
r521 | title = self.text.rendered | ||
neko259
|
r384 | |||
return title | ||||
neko259
|
r398 | def get_sorted_referenced_posts(self): | ||
return self.referenced_posts.order_by('id') | ||||
def is_referenced(self): | ||||
return self.referenced_posts.all().exists() | ||||
neko259
|
r400 | def is_opening(self): | ||
return self.thread_new.get_replies()[0] == self | ||||
neko259
|
r527 | def save(self, *args, **kwargs): | ||
""" | ||||
Save the model and compute the image hash | ||||
""" | ||||
if not self.pk and self.image: | ||||
md5 = hashlib.md5() | ||||
for chunk in self.image.chunks(): | ||||
md5.update(chunk) | ||||
self.image_hash = md5.hexdigest() | ||||
super(Post, self).save(*args, **kwargs) | ||||
neko259
|
r566 | @transaction.atomic | ||
def add_tag(self, tag): | ||||
edit_time = timezone.now() | ||||
thread = self.thread_new | ||||
thread.add_tag(tag) | ||||
self.last_edit_time = edit_time | ||||
self.save() | ||||
thread.last_edit_time = edit_time | ||||
thread.save() | ||||
@transaction.atomic | ||||
def remove_tag(self, tag): | ||||
edit_time = timezone.now() | ||||
thread = self.thread_new | ||||
neko259
|
r576 | thread.remove_tag(tag) | ||
neko259
|
r566 | self.last_edit_time = edit_time | ||
self.save() | ||||
thread.last_edit_time = edit_time | ||||
thread.save() | ||||
neko259
|
r398 | |||
class Thread(models.Model): | ||||
class Meta: | ||||
neko259
|
r410 | app_label = APP_LABEL_BOARDS | ||
neko259
|
r398 | |||
tags = models.ManyToManyField('Tag') | ||||
bump_time = models.DateTimeField() | ||||
last_edit_time = models.DateTimeField() | ||||
replies = models.ManyToManyField('Post', symmetrical=False, null=True, | ||||
blank=True, related_name='tre+') | ||||
neko259
|
r484 | archived = models.BooleanField(default=False) | ||
neko259
|
r398 | |||
def get_tags(self): | ||||
neko259
|
r418 | """ | ||
Get a sorted tag list | ||||
""" | ||||
neko259
|
r398 | |||
return self.tags.order_by('name') | ||||
def bump(self): | ||||
neko259
|
r418 | """ | ||
Bump (move to up) thread | ||||
""" | ||||
neko259
|
r398 | |||
if self.can_bump(): | ||||
self.bump_time = timezone.now() | ||||
neko259
|
r384 | def get_reply_count(self): | ||
return self.replies.count() | ||||
def get_images_count(self): | ||||
neko259
|
r398 | return self.replies.filter(image_width__gt=0).count() | ||
neko259
|
r384 | |||
def can_bump(self): | ||||
neko259
|
r418 | """ | ||
Check if the thread can be bumped by replying | ||||
""" | ||||
neko259
|
r384 | |||
neko259
|
r484 | if self.archived: | ||
return False | ||||
neko259
|
r384 | post_count = self.get_reply_count() | ||
neko259
|
r428 | return post_count < settings.MAX_POSTS_PER_THREAD | ||
neko259
|
r384 | |||
neko259
|
r398 | def delete_with_posts(self): | ||
neko259
|
r418 | """ | ||
Completely delete thread and all its posts | ||||
""" | ||||
neko259
|
r384 | |||
neko259
|
r398 | if self.replies.count() > 0: | ||
neko259
|
r470 | self.replies.all().delete() | ||
neko259
|
r398 | |||
self.delete() | ||||
neko259
|
r384 | |||
def get_last_replies(self): | ||||
neko259
|
r418 | """ | ||
Get last replies, not including opening post | ||||
""" | ||||
neko259
|
r398 | |||
neko259
|
r384 | if settings.LAST_REPLIES_COUNT > 0: | ||
reply_count = self.get_reply_count() | ||||
if reply_count > 0: | ||||
reply_count_to_show = min(settings.LAST_REPLIES_COUNT, | ||||
neko259
|
r398 | reply_count - 1) | ||
neko259
|
r384 | last_replies = self.replies.all().order_by('pub_time')[ | ||
reply_count - reply_count_to_show:] | ||||
return last_replies | ||||
neko259
|
r542 | def get_skipped_replies_count(self): | ||
last_replies = self.get_last_replies() | ||||
return self.get_reply_count() - len(last_replies) - 1 | ||||
neko259
|
r398 | def get_replies(self): | ||
neko259
|
r418 | """ | ||
Get sorted thread posts | ||||
""" | ||||
neko259
|
r384 | |||
neko259
|
r398 | return self.replies.all().order_by('pub_time') | ||
neko259
|
r384 | |||
neko259
|
r398 | def add_tag(self, tag): | ||
neko259
|
r418 | """ | ||
Connect thread to a tag and tag to a thread | ||||
""" | ||||
neko259
|
r384 | |||
neko259
|
r398 | self.tags.add(tag) | ||
tag.threads.add(self) | ||||
neko259
|
r576 | def remove_tag(self, tag): | ||
self.tags.remove(tag) | ||||
tag.threads.remove(self) | ||||
neko259
|
r400 | def get_opening_post(self): | ||
neko259
|
r418 | """ | ||
Get first post of the thread | ||||
""" | ||||
neko259
|
r400 | return self.get_replies()[0] | ||
neko259
|
r398 | def __unicode__(self): | ||
neko259
|
r552 | return str(self.id) | ||
neko259
|
r402 | |||
def get_pub_time(self): | ||||
neko259
|
r418 | """ | ||
Thread does not have its own pub time, so we need to get it from | ||||
the opening post | ||||
""" | ||||
neko259
|
r411 | return self.get_opening_post().pub_time | ||