mygpo/api/advanced/episode.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 import time
  19 from datetime import datetime
  20
  21 import dateutil.parser
  22
  23 from django.http import HttpResponseBadRequest, Http404
  24 from django.views.decorators.csrf import csrf_exempt
  25 from django.views.decorators.cache import never_cache
  26
  27 from mygpo.core import models
  28 from mygpo.api.httpresponse import JsonResponse
  29 from mygpo.api.exceptions import ParameterMissing
  30 from mygpo.api.sanitizing import sanitize_url
  31 from mygpo.api.backend import get_device
  32 from mygpo.users.models import Chapter
  33 from mygpo.utils import parse_time, parse_request_body
  34 from mygpo.decorators import allowed_methods
  35 from mygpo.api.basic_auth import require_valid_user, check_username
  36 from mygpo.db.couchdb.episode import episode_for_podcast_url
  37 from mygpo.db.couchdb.episode_state import episode_state_for_user_episode
  38
  39
  40 @csrf_exempt
  41 @require_valid_user
  42 @check_username
  43 @never_cache
  44 @allowed_methods(['POST', 'GET'])
  45 def chapters(request, username):
  46
  47     now = datetime.utcnow()
  48     now_ = int(time.mktime(now.timetuple()))
  49
  50     if request.method == 'POST':
  51         req = parse_request_body(request)
  52
  53         if not 'podcast' in req:
  54             return HttpResponseBadRequest('Podcast URL missing')
  55
  56         if not 'episode' in req:
  57             return HttpResponseBadRequest('Episode URL missing')
  58
  59         podcast_url = req.get('podcast', '')
  60         episode_url = req.get('episode', '')
  61         update_urls = []
  62
  63         # podcast sanitizing
  64         s_podcast_url = sanitize_url(podcast_url)
  65         if s_podcast_url != podcast_url:
  66             req['podcast'] = s_podcast_url
  67             update_urls.append((podcast_url, s_podcast_url))
  68
  69         # episode sanitizing
  70         s_episode_url = sanitize_url(episode_url, 'episode')
  71         if s_episode_url != episode_url:
  72             req['episode'] = s_episode_url
  73             update_urls.append((episode_url, s_episode_url))
  74
  75         if (s_podcast_url != '') and (s_episode_url != ''):
  76             try:
  77                 update_chapters(req, request.user)
  78             except ParameterMissing, e:
  79                 return HttpResponseBadRequest(e)
  80
  81         return JsonResponse({
  82             'update_url': update_url,
  83             'timestamp': now_
  84             })
  85
  86     elif request.method == 'GET':
  87         if not 'podcast' in request.GET:
  88             return HttpResponseBadRequest('podcast URL missing')
  89
  90         if not 'episode' in request.GET:
  91             return HttpResponseBadRequest('Episode URL missing')
  92
  93         podcast_url = request.GET['podcast']
  94         episode_url = request.GET['episode']
  95
  96         since_ = request.GET.get('since', None)
  97         try:
  98             since = datetime.fromtimestamp(float(since_)) if since_ else None
  99         except ValueError:
 100             return HttpResponseBadRequest('since-value is not a valid timestamp')
 101
 102         podcast_url = sanitize_url(podcast_url)
 103         episode_url = sanitize_url(episode_url, 'episode')
 104         episode = episode_for_podcast_url(podcast_url, episode_url)
 105
 106         if episode is None:
 107             raise Http404
 108
 109         e_state = episode_state_for_user_episode(request.user, episode)
 110
 111         chapterlist = sorted(e_state.chapters, key=lambda c: c.start)
 112
 113         if since:
 114             chapterlist = filter(lambda c: c.created >= since, chapters)
 115
 116         chapters = []
 117         for c in chapterlist:
 118             if c.device is not None:
 119                 device = request.user.get_device(c.device)
 120                 device_uid = device.uid
 121             else:
 122                 device_uid = None
 123
 124             chapters.append({
 125                 'start': c.start,
 126                 'end':   c.end,
 127                 'label': c.label,
 128                 'advertisement': c.advertisement,
 129                 'timestamp': c.created,
 130                 'device': device_uid
 131                 })
 132
 133         return JsonResponse({
 134             'chapters': chapters,
 135             'timestamp': now_
 136             })
 137
 138
 139 def update_chapters(req, user):
 140     podcast_url = sanitize_url(req['podcast'])
 141     episode_url = sanitize_url(req['episode'], 'episode')
 142
 143     episode = episode_for_podcast_url(podcast_url, episode_url,
 144             create=True)
 145
 146     e_state = episode_state_for_user_episode(request.user, episode)
 147
 148     device = None
 149     if 'device' in req:
 150         device = get_device(request.user, req['device'],
 151                 request.META.get('HTTP_USER_AGENT', ''), undelete=True)
 152
 153     timestamp = dateutil.parser.parse(req['timestamp']) if 'timestamp' in req else datetime.utcnow()
 154
 155     new_chapters = parse_new_chapters(request.user, req.get('chapters_add', []))
 156     rem_chapters = parse_rem_chapters(req.get('chapters_remove', []))
 157
 158     e_state.update_chapters(new_chapters, rem_chapters)
 159
 160
 161
 162 def parse_new_chapters(user, chapters):
 163     for c in chapters:
 164         if not 'start' in c:
 165             raise ParameterMissing('start parameter missing')
 166         start = parse_time(c['start'])
 167
 168         if not 'end' in c:
 169             raise ParameterMissing('end parameter missing')
 170         end = parse_time(c['end'])
 171
 172         label = c.get('label', '')
 173         adv = c.get('advertisement', False)
 174
 175         device_uid = c.get('device', None)
 176         if device_uid:
 177             device_id = get_device(user, device_uid,
 178                     request.META.get('HTTP_USER_AGENT', ''), undelete=True).id
 179         else:
 180             device_id = None
 181
 182         chapter = Chapter()
 183         chapter.device = device_id
 184         chapter.created = timestamp
 185         chapter.start = start
 186         chapter.end = end
 187         chapter.label = label
 188         chapter.advertisement = adv
 189
 190         yield chapter
 191
 192
 193 def parse_rem_chapters(chapers):
 194     for c in chapters:
 195         if not 'start' in c:
 196             raise ParameterMissing('start parameter missing')
 197         start = parse_time(c['start'])
 198
 199         if not 'end' in c:
 200             raise ParameterMissing('end parameter missing')
 201         end = parse_time(c['end'])
 202
 203         yield (start, end)