|
|
from datetime import datetime
|
|
|
import json
|
|
|
from django.db import transaction
|
|
|
from django.http import HttpResponse
|
|
|
from django.shortcuts import get_object_or_404, render
|
|
|
from django.template import RequestContext
|
|
|
from django.utils import timezone
|
|
|
from boards.forms import ThreadForm, PlainErrorList
|
|
|
from boards.models import Post
|
|
|
from boards.views import _datetime_to_epoch, _new_post, \
|
|
|
_ban_current_user
|
|
|
|
|
|
__author__ = 'neko259'
|
|
|
|
|
|
|
|
|
@transaction.atomic
|
|
|
def api_get_threaddiff(request, thread_id, last_update_time):
|
|
|
"""Get posts that were changed or added since time"""
|
|
|
|
|
|
thread = get_object_or_404(Post, id=thread_id).thread_new
|
|
|
|
|
|
filter_time = datetime.fromtimestamp(float(last_update_time) / 1000000,
|
|
|
timezone.get_current_timezone())
|
|
|
|
|
|
json_data = {
|
|
|
'added': [],
|
|
|
'updated': [],
|
|
|
'last_update': None,
|
|
|
}
|
|
|
added_posts = Post.objects.filter(thread_new=thread,
|
|
|
pub_time__gt=filter_time) \
|
|
|
.order_by('pub_time')
|
|
|
updated_posts = Post.objects.filter(thread_new=thread,
|
|
|
pub_time__lte=filter_time,
|
|
|
last_edit_time__gt=filter_time)
|
|
|
for post in added_posts:
|
|
|
json_data['added'].append(get_post(request, post.id).content.strip())
|
|
|
for post in updated_posts:
|
|
|
json_data['updated'].append(get_post(request, post.id).content.strip())
|
|
|
json_data['last_update'] = _datetime_to_epoch(thread.last_edit_time)
|
|
|
|
|
|
return HttpResponse(content=json.dumps(json_data))
|
|
|
|
|
|
|
|
|
# TODO This method needs to be implemented properly
|
|
|
# def api_add_post(request, form):
|
|
|
# """
|
|
|
# Add a post and return the JSON response for it
|
|
|
# """
|
|
|
#
|
|
|
# status = 'ok'
|
|
|
# errors = []
|
|
|
#
|
|
|
# if request.method == 'POST':
|
|
|
# form = ThreadForm(request.POST, request.FILES,
|
|
|
# error_class=PlainErrorList)
|
|
|
# form.session = request.session
|
|
|
#
|
|
|
# if form.is_valid():
|
|
|
# # TODO Don't form a response here cause we'll not need it
|
|
|
# _new_post(request, form)
|
|
|
# if form.need_to_ban:
|
|
|
# # Ban user because he is suspected to be a bot
|
|
|
# _ban_current_user(request)
|
|
|
# else:
|
|
|
# status = 'error'
|
|
|
# for field in form.fields:
|
|
|
# if field.errors:
|
|
|
# errors.append(field.errors)
|
|
|
#
|
|
|
# response = {
|
|
|
# 'status': status,
|
|
|
# 'errors': errors,
|
|
|
# }
|
|
|
#
|
|
|
# return HttpResponse(content=json.dumps(response))
|
|
|
def get_post(request, post_id):
|
|
|
"""Get the html of a post. Used for popups."""
|
|
|
|
|
|
post = get_object_or_404(Post, id=post_id)
|
|
|
thread = post.thread_new
|
|
|
|
|
|
context = RequestContext(request)
|
|
|
context["post"] = post
|
|
|
context["can_bump"] = thread.can_bump()
|
|
|
if "truncated" in request.GET:
|
|
|
context["truncated"] = True
|
|
|
|
|
|
return render(request, 'boards/post.html', context)
|
