phantasmobile/app/item/tasks.py

import os
import tempfile

import requests

from celery.schedules import crontab
from django.conf import settings
from django.utils import timezone

from ..signalbot import rpc
from ..celery import app
from . import models


@app.task(queue="default")
def announce_items():
    if not getattr(settings, 'SIGNAL_ANNOUNCE_GROUP'):
        return
    now = timezone.now()
    qs = models.Item.objects.exclude(published=None).filter(announced=None).filter(published__lte=now).order_by('published')
    for item in qs:
        item.announced = now
        link = settings.BASE_URL + item.get_absolute_url()
        message = link
        image = item.data.get('thumbnail')
        description = ""
        if image:
            f = tempfile.NamedTemporaryFile(suffix=".jpg", delete=False)
            r = requests.get(image)
            f.write(r.content)
            f.close()
            image = f.name
        r = rpc.send(
            message, group=settings.SIGNAL_ANNOUNCE_GROUP,
            preview_url=link,
            preview_title=item.title,
            preview_image=image,
            preview_description=description,
        )
        item.save()
        if image:
            os.unlink(f.name)


@app.task(queue="default")
def notify_moderators(id, link):
    comment = models.Comment.objects.filter(id=id).first()
    if comment:
        message = "%s commnented on %s\n\n%s" % (comment.name, link, comment.text)
        r = rpc.send(message, group=settings.SIGNAL_MODERATORS_GROUP)
        if r and "timestamp" in r:
            comment.data["moderator_ts"] = r["timestamp"]
            comment.save()
        else:
            print("failed to notify", r)

@app.on_after_finalize.connect
def setup_periodic_tasks(sender, **kwargs):
    sender.add_periodic_task(crontab(minute="*/2"), announce_items.s())