Revision 25d08a62 flowspec/tasks.py
| b/flowspec/tasks.py | ||
|---|---|---|
| 2 | 2 |
from celery.task import task |
| 3 | 3 |
from celery.task.sets import subtask |
| 4 | 4 |
import logging |
| 5 |
import json |
|
| 6 |
|
|
| 5 | 7 |
from celery.task.http import * |
| 6 | 8 |
from flowspy.utils import beanstalkc |
| 7 | 9 |
from django.conf import settings |
| ... | ... | |
| 24 | 26 |
route.is_online = is_online |
| 25 | 27 |
route.is_active = is_active |
| 26 | 28 |
route.response = response |
| 27 |
subtask(announce).delay("Route add: %s - Result: %s" %(route.name, response))
|
|
| 29 |
subtask(announce).delay("Route add: %s - Result: %s" %(route.name, response), route.applier)
|
|
| 28 | 30 |
route.save() |
| 29 | 31 |
|
| 30 | 32 |
@task |
| ... | ... | |
| 39 | 41 |
route.is_online = is_online |
| 40 | 42 |
route.response = response |
| 41 | 43 |
route.save() |
| 42 |
subtask(announce).delay("Route edit: %s - Result: %s" %(route.name, response))
|
|
| 44 |
subtask(announce).delay("Route edit: %s - Result: %s" %(route.name, response), route.applier)
|
|
| 43 | 45 |
|
| 44 | 46 |
|
| 45 | 47 |
|
| ... | ... | |
| 57 | 59 |
route.is_active = is_active |
| 58 | 60 |
route.response = response |
| 59 | 61 |
route.save() |
| 60 |
subtask(announce).delay("Route delete: %s - Result %s" %(route.name, response))
|
|
| 62 |
subtask(announce).delay("Route delete: %s - Result %s" %(route.name, response), route.applier)
|
|
| 61 | 63 |
|
| 62 | 64 |
|
| 63 | 65 |
|
| 64 | 66 |
@task |
| 65 |
def announce(messg): |
|
| 67 |
def announce(messg, user):
|
|
| 66 | 68 |
messg = str(messg) |
| 69 |
username = user.username |
|
| 67 | 70 |
b = beanstalkc.Connection() |
| 68 | 71 |
b.use(settings.POLLS_TUBE) |
| 69 |
b.put(messg) |
|
| 72 |
tube_message = json.dumps({'message': messg, 'username':username})
|
|
| 73 |
b.put(tube_message) |
|
| 70 | 74 |
b.close() |
| 71 | 75 |
|
| 72 | 76 |
|
Also available in: Unified diff