mygpo/api/legacy.py

   1 #
   2 # This file is part of my.gpodder.org.
   3 #
   4 # my.gpodder.org is free software: you can redistribute it and/or modify it
   5 # under the terms of the GNU Affero General Public License as published by
   6 # the Free Software Foundation, either version 3 of the License, or (at your
   7 # option) any later version.
   8 #
   9 # my.gpodder.org is distributed in the hope that it will be useful, but
  10 # WITHOUT ANY WARRANTY; without even the implied warranty of MERCHANTABILITY
  11 # or FITNESS FOR A PARTICULAR PURPOSE. See the GNU Affero General Public
  12 # License for more details.
  13 #
  14 # You should have received a copy of the GNU Affero General Public License
  15 # along with my.gpodder.org. If not, see <http://www.gnu.org/licenses/>.
  16 #
  17
  18 from django.http import HttpResponse
  19 from django.contrib.auth.models import User
  20 from mygpo.api.opml import Importer, Exporter
  21 from mygpo.api.models import Subscription, Podcast, SubscriptionAction, Device, SUBSCRIBE_ACTION, UNSUBSCRIBE_ACTION
  22 from datetime import datetime
  23 from django.utils.datastructures import MultiValueDictKeyError
  24 from django.db import IntegrityError
  25 from mygpo.log import log
  26 from mygpo.api.sanitizing import sanitize_url
  27 from django.views.decorators.csrf import csrf_exempt
  28
  29 LEGACY_DEVICE_NAME = 'Legacy Device'
  30 LEGACY_DEVICE_UID  = 'legacy'
  31
  32 @csrf_exempt
  33 def upload(request):
  34     try:
  35         emailaddr = request.POST['username']
  36         password  = request.POST['password']
  37         action    = request.POST['action']
  38         protocol  = request.POST['protocol']
  39         opml      = request.FILES['opml'].read()
  40     except MultiValueDictKeyError:
  41         return HttpResponse("@PROTOERROR", mimetype='text/plain')
  42
  43     user = auth(emailaddr, password)
  44     if (not user):
  45         return HttpResponse('@AUTHFAIL', mimetype='text/plain')
  46
  47     d, created = Device.objects.get_or_create(user=user, uid=LEGACY_DEVICE_UID,
  48         defaults = {'type': 'unknown', 'name': LEGACY_DEVICE_NAME})
  49
  50     # undelete a previously deleted device
  51     if d.deleted:
  52         d.deleted = False
  53         d.save()
  54
  55     existing = Subscription.objects.filter(user=user, device=d)
  56
  57     existing_urls = [e.podcast.url for e in existing]
  58
  59     i = Importer(opml)
  60     podcast_urls = []
  61     for p in i.items:
  62         u = sanitize_url(p['url'])
  63         if u != '': podcast_urls.append(u)
  64
  65     new = [u for u in podcast_urls if u not in existing_urls]
  66     rem = [e.podcast.url for e in existing if e.podcast.url not in podcast_urls]
  67
  68     #remove duplicates
  69     new = list(set(new))
  70     rem = list(set(rem))
  71
  72     for n in new:
  73         try:
  74             p, created = Podcast.objects.get_or_create(url=n)
  75         except IntegrityError, e:
  76             log('/upload: Error trying to get podcast object: %s (error: %s)' % (n, e))
  77             continue
  78
  79         try:
  80             SubscriptionAction.objects.create(podcast=p,action=SUBSCRIBE_ACTION, timestamp=datetime.now(), device=d)
  81         except IntegrityError, e:
  82             log('/upload: error while adding subscription: user: %s, podcast: %s, error: %s' % (user.id, p.id, e))
  83         except ValueError, ve:
  84             log('/upload: error while adding subscription: user: %s, podcast: %s, error: %s' % (user.id, p.id, e))
  85
  86     for r in rem:
  87         p, created = Podcast.objects.get_or_create(url=r)
  88         try:
  89             SubscriptionAction.objects.create(podcast=p, action=UNSUBSCRIBE_ACTION, timestamp=datetime.now(), device=d)
  90         except IntegrityError, e:
  91             log('/upload: error while removing subscription: user: %s, podcast: %s, error: %s' % (user.id, p.id, e))
  92
  93     return HttpResponse('@SUCCESS', mimetype='text/plain')
  94
  95 @csrf_exempt
  96 def getlist(request):
  97     emailaddr = request.GET.get('username', None)
  98     password = request.GET.get('password', None)
  99
 100     user = auth(emailaddr, password)
 101     if user is None:
 102         return HttpResponse('@AUTHFAIL', mimetype='text/plain')
 103
 104     d, created = Device.objects.get_or_create(user=user, uid=LEGACY_DEVICE_UID,
 105         defaults = {'type': 'unknown', 'name': LEGACY_DEVICE_NAME})
 106
 107     # We ignore deleted devices, because the Legacy API doesn't know such a concept
 108
 109     podcasts = [s.podcast for s in d.get_subscriptions()]
 110
 111     # FIXME: Get username and set a proper title (e.g. "thp's subscription list")
 112     title = 'Your subscription list'
 113     exporter = Exporter(title)
 114
 115     opml = exporter.generate(podcasts)
 116
 117     return HttpResponse(opml, mimetype='text/xml')
 118
 119 def auth(emailaddr, password):
 120     if emailaddr is None or password is None:
 121         return None
 122
 123     try:
 124         user = User.objects.get(email__exact=emailaddr)
 125     except User.DoesNotExist:
 126         return None
 127
 128     if not user.check_password(password):
 129         return None
 130
 131     if not user.is_active:
 132         return None
 133
 134     return user
 135