autonomic-cooperative/djangoldp-notification
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

update: improve sender detection

Browse Source
This commit is contained in:
Matthieu Fesselier 2019-04-24 15:20:11 +07:00
parent d8ae6c1c75
commit d317cb8b5d
1 changed files with 8 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
djangoldp_notification/models.py
View File

@ -10,6 +10,7 @@ from django.db import models
from django.db.models.signals import post_save from django.db.models.signals import post_save
from django.dispatch import receiver from django.dispatch import receiver
from oidc_provider.models import Token from oidc_provider.models import Token
from django.core.urlresolvers import NoReverseMatch
from djangoldp.fields import LDPUrlField from djangoldp.fields import LDPUrlField
from djangoldp.models import Model from djangoldp.models import Model
@ -54,10 +55,14 @@ class Subscription(Model):
# --- SUBSCRIPTION SYSTEM --- # --- SUBSCRIPTION SYSTEM ---
@receiver(post_save, dispatch_uid="callback_notif") @receiver(post_save, dispatch_uid="callback_notif")
def send_notification(sender, instance, **kwargs): def send_notification(sender, instance, **kwargs):
if sender != Notification and issubclass(sender, Model): if sender != Notification:
threads = [] threads = []
try:
urlContainer = settings.BASE_URL + Model.container_id(instance) urlContainer = settings.BASE_URL + Model.container_id(instance)
urlResource = settings.BASE_URL + Model.resource_id(instance) urlResource = settings.BASE_URL + Model.resource_id(instance)
except NoReverseMatch:
return
for subscription in Subscription.objects.filter(models.Q(object=urlResource)|models.Q(object=urlContainer)): for subscription in Subscription.objects.filter(models.Q(object=urlResource)|models.Q(object=urlContainer)):
process = Thread(target=send_request, args=[subscription.inbox, urlResource]) process = Thread(target=send_request, args=[subscription.inbox, urlResource])
process.start() process.start()