mygpo/pubsub/views.py

   1 # -*- coding: utf-8 -*-
   2 #
   3 # PubSubHubbub subscriber for mygpo
   4 #
   5 #
   6
   7 import logging
   8
   9 from django.http import HttpResponseNotFound, HttpResponse
  10 from django.views import View
  11 from django.views.decorators.csrf import csrf_exempt
  12
  13 from mygpo.pubsub.models import HubSubscription
  14 from mygpo.pubsub.signals import subscription_updated
  15
  16 logger = logging.getLogger(__name__)
  17
  18
  19 class SubscribeView(View):
  20     """Endpoint for Pubsubhubbub subscriptions"""
  21
  22     @csrf_exempt
  23     def dispatch(self, *args, **kwargs):
  24         return super(SubscribeView, self).dispatch(*args, **kwargs)
  25
  26     def get(self, request):
  27         """Callback used by the Hub to verify the subscription request"""
  28
  29         # received arguments: hub.mode, hub.topic, hub.challenge,
  30         # hub.lease_seconds, hub.verify_token
  31         mode = request.GET.get("hub.mode")
  32         feed_url = request.GET.get("hub.topic")
  33         challenge = request.GET.get("hub.challenge")
  34         lease_seconds = request.GET.get("hub.lease_seconds")
  35         verify_token = request.GET.get("hub.verify_token")
  36
  37         logger.debug(
  38             (
  39                 "received subscription-parameters: mode: %(mode)s, "
  40                 + "topic: %(topic)s, challenge: %(challenge)s, lease_seconds: "
  41                 + "%(lease_seconds)s, verify_token: %(verify_token)s"
  42             )
  43             % dict(
  44                 mode=mode,
  45                 topic=feed_url,
  46                 challenge=challenge,
  47                 lease_seconds=lease_seconds,
  48                 verify_token=verify_token,
  49             )
  50         )
  51
  52         try:
  53             subscription = HubSubscription.objects.get(topic_url=feed_url)
  54
  55         except HubSubscription.DoesNotExist:
  56             logger.warning("subscription does not exist")
  57             return HttpResponseNotFound()
  58
  59         if subscription.mode != mode:
  60             logger.warning("invalid mode, %s expected" % subscription.mode)
  61             return HttpResponseNotFound()
  62
  63         if subscription.verify_token != verify_token:
  64             logger.warning(
  65                 "invalid verify_token, %s expected" % subscription.verify_token
  66             )
  67             return HttpResponseNotFound()
  68
  69         subscription.verified = True
  70         subscription.save()
  71
  72         logger.info("subscription confirmed")
  73         return HttpResponse(challenge)
  74
  75     def post(self, request):
  76         """Callback to notify about a feed update"""
  77
  78         feed_url = request.GET.get("url")
  79
  80         if not feed_url:
  81             logger.info("received notification without url")
  82             return HttpResponse(status=400)
  83
  84         logger.info("received notification for %s" % feed_url)
  85
  86         try:
  87             subscription = HubSubscription.objects.get(topic_url=feed_url)
  88
  89         except HubSubscription.DoesNotExist:
  90             logger.warning("no subscription for this URL")
  91             return HttpResponse(status=400)
  92
  93         if subscription.mode != "subscribe":
  94             logger.warning("invalid subscription mode: %s" % subscription.mode)
  95             return HttpResponse(status=400)
  96
  97         if not subscription.verified:
  98             logger.warning("the subscription has not yet been verified")
  99             return HttpResponse(status=400)
 100
 101         subscription_updated.send(sender=feed_url)
 102
 103         return HttpResponse(status=200)