##// END OF EJS Templates
Removed invalid requirements item
Removed invalid requirements item

File last commit:

r1501:c4d18abb merge decentral
r1510:04249065 decentral
Show More
manager.py
154 lines | 4.7 KiB | text/x-python | PythonLexer
neko259
Moved post manager in a separate module
r1359 import logging
from datetime import datetime, timedelta, date
from datetime import time as dtime
from django.db import models, transaction
from django.utils import timezone
import boards
from boards.models.user import Ban
from boards.mdx_neboard import Parser
from boards.models import PostImage, Attachment
from boards import utils
__author__ = 'neko259'
IMAGE_TYPES = (
'jpeg',
'jpg',
'png',
'bmp',
'gif',
)
POSTS_PER_DAY_RANGE = 7
NO_IP = '0.0.0.0'
class PostManager(models.Manager):
@transaction.atomic
def create_post(self, title: str, text: str, file=None, thread=None,
neko259
Allow to edit tag and post in the admin site
r1367 ip=NO_IP, tags: list=None, opening_posts: list=None,
neko259
Added image aliases to upload the same images (like "fake" or "gtfo")
r1500 tripcode='', monochrome=False, images=[]):
neko259
Moved post manager in a separate module
r1359 """
Creates new post
"""
neko259
Prevent posting into an archived thread
r1449 if thread is not None and thread.is_archived():
raise Exception('Cannot post into an archived thread')
neko259
Added anonymous mode in which the board does not save poster IP addresses
r1362 if not utils.is_anonymous_mode():
is_banned = Ban.objects.filter(ip=ip).exists()
neko259
Added ability to create monochrome threads
r1434 else:
is_banned = False
neko259
Moved post manager in a separate module
r1359
# TODO Raise specific exception and catch it in the views
if is_banned:
raise Exception("This user is banned")
if not tags:
tags = []
if not opening_posts:
opening_posts = []
posting_time = timezone.now()
new_thread = False
if not thread:
thread = boards.models.thread.Thread.objects.create(
neko259
Added ability to create monochrome threads
r1434 bump_time=posting_time, last_edit_time=posting_time,
monochrome=monochrome)
neko259
Moved post manager in a separate module
r1359 list(map(thread.tags.add, tags))
boards.models.thread.Thread.objects.process_oldest_threads()
new_thread = True
pre_text = Parser().preparse(text)
post = self.create(title=title,
text=pre_text,
pub_time=posting_time,
poster_ip=ip,
thread=thread,
last_edit_time=posting_time,
tripcode=tripcode,
opening=new_thread)
post.threads.add(thread)
logger = logging.getLogger('boards.post.create')
neko259
Cosmetic changes to post creation log
r1380 logger.info('Created post [{}] with text [{}] by {}'.format(post,
neko259
Deduplicated upload_to method for images and file attachments
r1368 post.get_text(),post.poster_ip))
neko259
Moved post manager in a separate module
r1359
# TODO Move this to other place
if file:
file_type = file.name.split('.')[-1].lower()
if file_type in IMAGE_TYPES:
post.images.add(PostImage.objects.create_with_hash(file))
else:
post.attachments.add(Attachment.objects.create_with_hash(file))
neko259
Added image aliases to upload the same images (like "fake" or "gtfo")
r1500 for image in images:
post.images.add(image)
neko259
Moved post manager in a separate module
r1359
post.connect_threads(opening_posts)
neko259
Merged with default
r1320 post.set_global_id()
neko259
Moved post manager in a separate module
r1359
# Thread needs to be bumped only when the post is already created
if not new_thread:
thread.last_edit_time = posting_time
thread.bump()
thread.save()
return post
def delete_posts_by_ip(self, ip):
"""
Deletes all posts of the author with same IP
"""
posts = self.filter(poster_ip=ip)
for post in posts:
post.delete()
@utils.cached_result()
def get_posts_per_day(self) -> float:
"""
Gets average count of posts per day for the last 7 days
"""
day_end = date.today()
day_start = day_end - timedelta(POSTS_PER_DAY_RANGE)
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())
posts_per_period = float(self.filter(
pub_time__lte=day_time_end,
pub_time__gte=day_time_start).count())
ppd = posts_per_period / POSTS_PER_DAY_RANGE
return ppd
neko259
Merged with default
r1320 @transaction.atomic
def import_post(self, title: str, text: str, pub_time: str, global_id,
opening_post=None, tags=list()):
neko259
Merged with default branch
r1360 is_opening = opening_post is None
if is_opening:
neko259
Merged with default
r1320 thread = boards.models.thread.Thread.objects.create(
bump_time=pub_time, last_edit_time=pub_time)
list(map(thread.tags.add, tags))
else:
thread = opening_post.get_thread()
post = self.create(title=title, text=text,
pub_time=pub_time,
poster_ip=NO_IP,
last_edit_time=pub_time,
neko259
Merged with default branch
r1360 global_id=global_id,
neko259
Sync fixes
r1386 opening=is_opening,
thread=thread)
neko259
Merged with default
r1320
neko259
Sync fixes
r1386 post.threads.add(thread)