| 1 | # -*- coding: utf-8 -*- |
|---|
| 2 | # Copyright (C) 2007-2010 Samalyse SARL |
|---|
| 3 | # Copyright (C) 2010-2011 Parisson SARL |
|---|
| 4 | |
|---|
| 5 | # This software is a computer program whose purpose is to backup, analyse, |
|---|
| 6 | # transcode and stream any audio content with its metadata over a web frontend. |
|---|
| 7 | |
|---|
| 8 | # This software is governed by the CeCILL license under French law and |
|---|
| 9 | # abiding by the rules of distribution of free software. You can use, |
|---|
| 10 | # modify and/ or redistribute the software under the terms of the CeCILL |
|---|
| 11 | # license as circulated by CEA, CNRS and INRIA at the following URL |
|---|
| 12 | # "http://www.cecill.info". |
|---|
| 13 | |
|---|
| 14 | # As a counterpart to the access to the source code and rights to copy, |
|---|
| 15 | # modify and redistribute granted by the license, users are provided only |
|---|
| 16 | # with a limited warranty and the software's author, the holder of the |
|---|
| 17 | # economic rights, and the successive licensors have only limited |
|---|
| 18 | # liability. |
|---|
| 19 | |
|---|
| 20 | # In this respect, the user's attention is drawn to the risks associated |
|---|
| 21 | # with loading, using, modifying and/or developing or reproducing the |
|---|
| 22 | # software by the user in light of its specific status of free software, |
|---|
| 23 | # that may mean that it is complicated to manipulate, and that also |
|---|
| 24 | # therefore means that it is reserved for developers and experienced |
|---|
| 25 | # professionals having in-depth computer knowledge. Users are therefore |
|---|
| 26 | # encouraged to load and test the software's suitability as regards their |
|---|
| 27 | # requirements in conditions enabling the security of their systems and/or |
|---|
| 28 | # data to be ensured and, more generally, to use and operate it in the |
|---|
| 29 | # same conditions as regards security. |
|---|
| 30 | |
|---|
| 31 | # The fact that you are presently reading this means that you have had |
|---|
| 32 | # knowledge of the CeCILL license and that you accept its terms. |
|---|
| 33 | |
|---|
| 34 | # Authors: Olivier Guilyardi <olivier@samalyse.com> |
|---|
| 35 | # Guillaume Pellerin <yomguy@parisson.com> |
|---|
| 36 | |
|---|
| 37 | import re |
|---|
| 38 | import os |
|---|
| 39 | import sys |
|---|
| 40 | import csv |
|---|
| 41 | import time |
|---|
| 42 | import random |
|---|
| 43 | import datetime |
|---|
| 44 | import timeside |
|---|
| 45 | |
|---|
| 46 | from jsonrpc import jsonrpc_method |
|---|
| 47 | |
|---|
| 48 | from django.utils.decorators import method_decorator |
|---|
| 49 | from django.contrib.auth import authenticate, login |
|---|
| 50 | from django.template import RequestContext, loader |
|---|
| 51 | from django import template |
|---|
| 52 | from django.http import HttpResponse, HttpResponseRedirect |
|---|
| 53 | from django.http import Http404 |
|---|
| 54 | from django.shortcuts import render_to_response, redirect |
|---|
| 55 | from django.views.generic import list_detail |
|---|
| 56 | from django.conf import settings |
|---|
| 57 | from django.contrib import auth |
|---|
| 58 | from django.contrib import messages |
|---|
| 59 | from django.contrib.auth.decorators import login_required, permission_required |
|---|
| 60 | from django.core.context_processors import csrf |
|---|
| 61 | from django.forms.models import modelformset_factory, inlineformset_factory |
|---|
| 62 | from django.contrib.auth.models import User |
|---|
| 63 | from django.utils.translation import ugettext |
|---|
| 64 | from django.contrib.auth.forms import UserChangeForm |
|---|
| 65 | from django.core.exceptions import ObjectDoesNotExist |
|---|
| 66 | from django.contrib.syndication.views import Feed |
|---|
| 67 | |
|---|
| 68 | from telemeta.models import * |
|---|
| 69 | import telemeta.models |
|---|
| 70 | import telemeta.interop.oai as oai |
|---|
| 71 | from telemeta.interop.oaidatasource import TelemetaOAIDataSource |
|---|
| 72 | from telemeta.util.unaccent import unaccent |
|---|
| 73 | from telemeta.util.unaccent import unaccent_icmp |
|---|
| 74 | from telemeta.util.logger import Logger |
|---|
| 75 | from telemeta.util.unicode import UnicodeWriter |
|---|
| 76 | from telemeta.cache import TelemetaCache |
|---|
| 77 | import telemeta.web.pages as pages |
|---|
| 78 | |
|---|
| 79 | |
|---|
| 80 | def render(request, template, data = None, mimetype = None): |
|---|
| 81 | return render_to_response(template, data, context_instance=RequestContext(request), |
|---|
| 82 | mimetype=mimetype) |
|---|
| 83 | |
|---|
| 84 | def stream_from_processor(__decoder, __processor, __flag): |
|---|
| 85 | while True: |
|---|
| 86 | __frames, eodproc = __processor.process(*__decoder.process()) |
|---|
| 87 | if eodproc: |
|---|
| 88 | __flag.value = True |
|---|
| 89 | __flag.save() |
|---|
| 90 | break |
|---|
| 91 | yield __processor.chunk |
|---|
| 92 | |
|---|
| 93 | def stream_from_file(__file): |
|---|
| 94 | chunk_size = 0x10000 |
|---|
| 95 | f = open(__file, 'r') |
|---|
| 96 | while True: |
|---|
| 97 | __chunk = f.read(chunk_size) |
|---|
| 98 | if not len(__chunk): |
|---|
| 99 | f.close() |
|---|
| 100 | break |
|---|
| 101 | yield __chunk |
|---|
| 102 | |
|---|
| 103 | def get_public_access(access, year_from=None, year_to=None): |
|---|
| 104 | # Rolling publishing date : public access is given when time between recorded year |
|---|
| 105 | # and current year is over the settings value PUBLIC_ACCESS_PERIOD |
|---|
| 106 | if year_from and not year_from == 0: |
|---|
| 107 | year = year_from |
|---|
| 108 | elif year_to and not year_to == 0: |
|---|
| 109 | year = year_to |
|---|
| 110 | else: |
|---|
| 111 | year = 0 |
|---|
| 112 | if access == 'full': |
|---|
| 113 | public_access = True |
|---|
| 114 | else: |
|---|
| 115 | public_access = False |
|---|
| 116 | if year and not year == 'None': |
|---|
| 117 | year_now = datetime.datetime.now().strftime("%Y") |
|---|
| 118 | if int(year_now) - int(year) >= settings.TELEMETA_PUBLIC_ACCESS_PERIOD: |
|---|
| 119 | public_access = True |
|---|
| 120 | else: |
|---|
| 121 | public_access = False |
|---|
| 122 | return public_access |
|---|
| 123 | |
|---|
| 124 | def get_revisions(nb): |
|---|
| 125 | last_revisions = Revision.objects.order_by('-time')[0:nb] |
|---|
| 126 | revisions = [] |
|---|
| 127 | for revision in last_revisions: |
|---|
| 128 | if revision.element_type == 'item': |
|---|
| 129 | try: |
|---|
| 130 | element = MediaItem.objects.get(pk=revision.element_id) |
|---|
| 131 | except: |
|---|
| 132 | element = None |
|---|
| 133 | if revision.element_type == 'collection': |
|---|
| 134 | try: |
|---|
| 135 | element = MediaCollection.objects.get(pk=revision.element_id) |
|---|
| 136 | except: |
|---|
| 137 | element = None |
|---|
| 138 | if revision.element_type == 'marker': |
|---|
| 139 | try: |
|---|
| 140 | element = MediaItemMarker.objects.get(pk=revision.element_id) |
|---|
| 141 | except: |
|---|
| 142 | element = None |
|---|
| 143 | if not element == None: |
|---|
| 144 | revisions.append({'revision': revision, 'element': element}) |
|---|
| 145 | return revisions |
|---|
| 146 | |
|---|
| 147 | def get_playlists(request, user=None): |
|---|
| 148 | if not user: |
|---|
| 149 | user = request.user |
|---|
| 150 | playlists = [] |
|---|
| 151 | if user.is_authenticated(): |
|---|
| 152 | user_playlists = Playlist.objects.filter(author=user) |
|---|
| 153 | for playlist in user_playlists: |
|---|
| 154 | playlist_resources = PlaylistResource.objects.filter(playlist=playlist) |
|---|
| 155 | resources = [] |
|---|
| 156 | for resource in playlist_resources: |
|---|
| 157 | try: |
|---|
| 158 | if resource.resource_type == 'item': |
|---|
| 159 | element = MediaItem.objects.get(id=resource.resource_id) |
|---|
| 160 | if resource.resource_type == 'collection': |
|---|
| 161 | element = MediaCollection.objects.get(id=resource.resource_id) |
|---|
| 162 | if resource.resource_type == 'marker': |
|---|
| 163 | element = MediaItemMarker.objects.get(id=resource.resource_id) |
|---|
| 164 | except: |
|---|
| 165 | element = None |
|---|
| 166 | resources.append({'element': element, 'type': resource.resource_type, 'public_id': resource.public_id }) |
|---|
| 167 | playlists.append({'playlist': playlist, 'resources': resources}) |
|---|
| 168 | return playlists |
|---|
| 169 | |
|---|
| 170 | |
|---|
| 171 | class GeneralView(object): |
|---|
| 172 | """Provide general web UI methods""" |
|---|
| 173 | |
|---|
| 174 | def index(self, request): |
|---|
| 175 | """Render the homepage""" |
|---|
| 176 | if not request.user.is_authenticated(): |
|---|
| 177 | template = loader.get_template('telemeta/index.html') |
|---|
| 178 | |
|---|
| 179 | sound_items = MediaItem.objects.sound() |
|---|
| 180 | _sound_pub_items = [] |
|---|
| 181 | for item in sound_items: |
|---|
| 182 | if get_public_access(item.public_access, str(item.recorded_from_date).split('-')[0], |
|---|
| 183 | str(item.recorded_to_date).split('-')[0]): |
|---|
| 184 | _sound_pub_items.append(item) |
|---|
| 185 | |
|---|
| 186 | random.shuffle(_sound_pub_items) |
|---|
| 187 | if len(_sound_pub_items) != 0: |
|---|
| 188 | sound_pub_item = _sound_pub_items[0] |
|---|
| 189 | else: |
|---|
| 190 | sound_pub_item = None |
|---|
| 191 | if len(_sound_pub_items) == 2: |
|---|
| 192 | sound_pub_items = [_sound_pub_items[1]] |
|---|
| 193 | elif len(_sound_pub_items) > 2: |
|---|
| 194 | sound_pub_items = _sound_pub_items[1:3] |
|---|
| 195 | else: |
|---|
| 196 | sound_pub_items = None |
|---|
| 197 | |
|---|
| 198 | revisions = get_revisions(4) |
|---|
| 199 | context = RequestContext(request, { |
|---|
| 200 | 'page_content': pages.get_page_content(request, 'home', ignore_slash_issue=True), |
|---|
| 201 | 'revisions': revisions, 'sound_pub_items': sound_pub_items, |
|---|
| 202 | 'sound_pub_item': sound_pub_item }) |
|---|
| 203 | return HttpResponse(template.render(context)) |
|---|
| 204 | else: |
|---|
| 205 | template='telemeta/home.html' |
|---|
| 206 | playlists = get_playlists(request) |
|---|
| 207 | revisions = get_revisions(15) |
|---|
| 208 | searches = Search.objects.filter(username=request.user) |
|---|
| 209 | return render(request, template, {'playlists': playlists, 'searches': searches, |
|---|
| 210 | 'revisions': revisions,}) |
|---|
| 211 | |
|---|
| 212 | def edit_search(self, request, criteria=None): |
|---|
| 213 | year_min, year_max = MediaCollection.objects.all().recording_year_range() |
|---|
| 214 | rec_years = year_min and year_max and range(year_min, year_max + 1) or [] |
|---|
| 215 | year_min, year_max = MediaCollection.objects.all().publishing_year_range() |
|---|
| 216 | pub_years = year_min and year_max and range(year_min, year_max + 1) or [] |
|---|
| 217 | return render(request, 'telemeta/search_criteria.html', { |
|---|
| 218 | 'rec_years': rec_years, |
|---|
| 219 | 'pub_years': pub_years, |
|---|
| 220 | 'ethnic_groups': MediaItem.objects.all().ethnic_groups(), |
|---|
| 221 | 'criteria': criteria |
|---|
| 222 | }) |
|---|
| 223 | |
|---|
| 224 | def handle_oai_request(self, request): |
|---|
| 225 | host = request.META['HTTP_HOST'] |
|---|
| 226 | datasource = TelemetaOAIDataSource() |
|---|
| 227 | repository_name = settings.TELEMETA_ORGANIZATION |
|---|
| 228 | url = 'http://' + host + request.path |
|---|
| 229 | admin = settings.ADMINS[0][1] |
|---|
| 230 | provider = oai.DataProvider(datasource, repository_name, url, admin) |
|---|
| 231 | args = request.GET.copy() |
|---|
| 232 | args.update(request.POST) |
|---|
| 233 | return HttpResponse(provider.handle(args), mimetype='text/xml') |
|---|
| 234 | |
|---|
| 235 | def render_flatpage(self, request, path): |
|---|
| 236 | try: |
|---|
| 237 | content = pages.get_page_content(request, path) |
|---|
| 238 | except pages.MalformedPagePath: |
|---|
| 239 | return redirect(request.path + '/') |
|---|
| 240 | |
|---|
| 241 | if isinstance(content, pages.PageAttachment): |
|---|
| 242 | return HttpResponse(content, content.mimetype()) |
|---|
| 243 | else: |
|---|
| 244 | return render(request, 'telemeta/flatpage.html', {'page_content': content }) |
|---|
| 245 | |
|---|
| 246 | def logout(self, request): |
|---|
| 247 | auth.logout(request) |
|---|
| 248 | return redirect('telemeta-home') |
|---|
| 249 | |
|---|
| 250 | def search(self, request, type = None): |
|---|
| 251 | """Perform a search through collections and items metadata""" |
|---|
| 252 | collections = MediaCollection.objects.enriched() |
|---|
| 253 | items = MediaItem.objects.enriched() |
|---|
| 254 | input = request.REQUEST |
|---|
| 255 | criteria = {} |
|---|
| 256 | |
|---|
| 257 | switch = { |
|---|
| 258 | 'pattern': lambda value: ( |
|---|
| 259 | collections.quick_search(value), |
|---|
| 260 | items.quick_search(value)), |
|---|
| 261 | 'title': lambda value: ( |
|---|
| 262 | collections.word_search('title', value), |
|---|
| 263 | items.by_title(value)), |
|---|
| 264 | 'location': lambda value: ( |
|---|
| 265 | collections.by_location(Location.objects.get(name=value)), |
|---|
| 266 | items.by_location(Location.objects.get(name=value))), |
|---|
| 267 | 'continent': lambda value: ( |
|---|
| 268 | collections.by_continent(value), |
|---|
| 269 | items.filter(continent = value)), |
|---|
| 270 | 'ethnic_group': lambda value: ( |
|---|
| 271 | collections.by_ethnic_group(value), |
|---|
| 272 | items.filter(ethnic_group = value), |
|---|
| 273 | EthnicGroup.objects.get(pk=value)), |
|---|
| 274 | 'creator': lambda value: ( |
|---|
| 275 | collections.word_search('creator', value), |
|---|
| 276 | items.word_search('collection__creator', value)), |
|---|
| 277 | 'collector': lambda value: ( |
|---|
| 278 | collections.by_fuzzy_collector(value), |
|---|
| 279 | items.by_fuzzy_collector(value)), |
|---|
| 280 | 'rec_year_from': lambda value: ( |
|---|
| 281 | collections.by_recording_year(int(value), int(input.get('rec_year_to', value))), |
|---|
| 282 | items.by_recording_date(datetime.date(int(value), 1, 1), |
|---|
| 283 | datetime.date(int(input.get('rec_year_to', value)), 12, 31))), |
|---|
| 284 | 'rec_year_to': lambda value: (collections, items), |
|---|
| 285 | 'pub_year_from': lambda value: ( |
|---|
| 286 | collections.by_publish_year(int(value), int(input.get('pub_year_to', value))), |
|---|
| 287 | items.by_publish_year(int(value), int(input.get('pub_year_to', value)))), |
|---|
| 288 | 'pub_year_to': lambda value: (collections, items), |
|---|
| 289 | } |
|---|
| 290 | |
|---|
| 291 | for key, value in input.items(): |
|---|
| 292 | func = switch.get(key) |
|---|
| 293 | if func and value and value != "0": |
|---|
| 294 | try: |
|---|
| 295 | res = func(value) |
|---|
| 296 | if len(res) > 2: |
|---|
| 297 | collections, items, value = res |
|---|
| 298 | else: |
|---|
| 299 | collections, items = res |
|---|
| 300 | except ObjectDoesNotExist: |
|---|
| 301 | collections = collections.none() |
|---|
| 302 | items = items.none() |
|---|
| 303 | |
|---|
| 304 | criteria[key] = value |
|---|
| 305 | |
|---|
| 306 | if type is None: |
|---|
| 307 | if collections.count(): |
|---|
| 308 | type = 'collections' |
|---|
| 309 | else: |
|---|
| 310 | type = 'items' |
|---|
| 311 | |
|---|
| 312 | if type == 'items': |
|---|
| 313 | objects = items |
|---|
| 314 | else: |
|---|
| 315 | objects = collections |
|---|
| 316 | |
|---|
| 317 | return list_detail.object_list(request, objects, |
|---|
| 318 | template_name='telemeta/search_results.html', paginate_by=20, |
|---|
| 319 | extra_context={'criteria': criteria, 'collections_num': collections.count(), |
|---|
| 320 | 'items_num': items.count(), 'type' : type}) |
|---|
| 321 | |
|---|
| 322 | def complete_location(self, request, with_items=True): |
|---|
| 323 | input = request.REQUEST |
|---|
| 324 | |
|---|
| 325 | token = input['q'] |
|---|
| 326 | limit = int(input['limit']) |
|---|
| 327 | if with_items: |
|---|
| 328 | locations = MediaItem.objects.all().locations() |
|---|
| 329 | else: |
|---|
| 330 | locations = Location.objects.all() |
|---|
| 331 | |
|---|
| 332 | locations = locations.filter(name__istartswith=token).order_by('name')[:limit] |
|---|
| 333 | data = [unicode(l) + " (%d items)" % l.items().count() for l in locations] |
|---|
| 334 | |
|---|
| 335 | return HttpResponse("\n".join(data)) |
|---|
| 336 | |
|---|
| 337 | def users(self, request): |
|---|
| 338 | users = User.objects.all() |
|---|
| 339 | return render(request, 'telemeta/users.html', {'users': users}) |
|---|
| 340 | |
|---|
| 341 | class CollectionView(object): |
|---|
| 342 | """Provide Collections web UI methods""" |
|---|
| 343 | |
|---|
| 344 | def collection_detail(self, request, public_id, template='telemeta/collection_detail.html'): |
|---|
| 345 | collection = MediaCollection.objects.get(public_id=public_id) |
|---|
| 346 | items = collection.items.enriched() |
|---|
| 347 | items = items.order_by('code', 'old_code') |
|---|
| 348 | |
|---|
| 349 | if collection.public_access == 'none' and not (request.user.is_staff or request.user.is_superuser): |
|---|
| 350 | mess = ugettext('Access not allowed') |
|---|
| 351 | title = ugettext('Collection') + ' : ' + public_id + ' : ' + mess |
|---|
| 352 | description = ugettext('Please login or contact the website administator to get a private access.') |
|---|
| 353 | messages.error(request, title) |
|---|
| 354 | return render(request, 'telemeta/messages.html', {'description' : description}) |
|---|
| 355 | |
|---|
| 356 | public_access = get_public_access(collection.public_access, collection.recorded_from_year, |
|---|
| 357 | collection.recorded_to_year) |
|---|
| 358 | playlists = get_playlists(request) |
|---|
| 359 | |
|---|
| 360 | return render(request, template, {'collection': collection, 'playlists': playlists, 'public_access': public_access, 'items': items}) |
|---|
| 361 | |
|---|
| 362 | @method_decorator(permission_required('telemeta.change_mediacollection')) |
|---|
| 363 | def collection_edit(self, request, public_id, template='telemeta/collection_edit.html'): |
|---|
| 364 | collection = MediaCollection.objects.get(public_id=public_id) |
|---|
| 365 | if request.method == 'POST': |
|---|
| 366 | form = MediaCollectionForm(data=request.POST, files=request.FILES, instance=collection) |
|---|
| 367 | if form.is_valid(): |
|---|
| 368 | code = form.cleaned_data['code'] |
|---|
| 369 | if not code: |
|---|
| 370 | code = public_id |
|---|
| 371 | form.save() |
|---|
| 372 | collection.set_revision(request.user) |
|---|
| 373 | return HttpResponseRedirect('/collections/'+code) |
|---|
| 374 | else: |
|---|
| 375 | form = MediaCollectionForm(instance=collection) |
|---|
| 376 | |
|---|
| 377 | return render(request, template, {'collection': collection, "form": form,}) |
|---|
| 378 | |
|---|
| 379 | @method_decorator(permission_required('telemeta.add_mediacollection')) |
|---|
| 380 | def collection_add(self, request, template='telemeta/collection_add.html'): |
|---|
| 381 | collection = MediaCollection() |
|---|
| 382 | if request.method == 'POST': |
|---|
| 383 | form = MediaCollectionForm(data=request.POST, files=request.FILES, instance=collection) |
|---|
| 384 | if form.is_valid(): |
|---|
| 385 | code = form.cleaned_data['code'] |
|---|
| 386 | if not code: |
|---|
| 387 | code = public_id |
|---|
| 388 | form.save() |
|---|
| 389 | collection.set_revision(request.user) |
|---|
| 390 | return HttpResponseRedirect('/collections/'+code) |
|---|
| 391 | else: |
|---|
| 392 | form = MediaCollectionForm(instance=collection) |
|---|
| 393 | |
|---|
| 394 | return render(request, template, {'collection': collection, "form": form,}) |
|---|
| 395 | |
|---|
| 396 | @method_decorator(permission_required('telemeta.add_mediacollection')) |
|---|
| 397 | def collection_copy(self, request, public_id, template='telemeta/collection_edit.html'): |
|---|
| 398 | if request.method == 'POST': |
|---|
| 399 | new_collection = MediaCollection() |
|---|
| 400 | form = MediaCollectionForm(data=request.POST, files=request.FILES, instance=new_collection) |
|---|
| 401 | if form.is_valid(): |
|---|
| 402 | code = form.cleaned_data['code'] |
|---|
| 403 | if not code: |
|---|
| 404 | code = public_id |
|---|
| 405 | form.save() |
|---|
| 406 | new_collection.set_revision(request.user) |
|---|
| 407 | return HttpResponseRedirect('/collections/'+code) |
|---|
| 408 | else: |
|---|
| 409 | collection = MediaCollection.objects.get(public_id=public_id) |
|---|
| 410 | form = MediaCollectionForm(instance=collection) |
|---|
| 411 | |
|---|
| 412 | return render(request, template, {'collection': collection, "form": form,}) |
|---|
| 413 | |
|---|
| 414 | def collection_playlist(self, request, public_id, template, mimetype): |
|---|
| 415 | try: |
|---|
| 416 | collection = MediaCollection.objects.get(public_id=public_id) |
|---|
| 417 | except ObjectDoesNotExist: |
|---|
| 418 | raise Http404 |
|---|
| 419 | |
|---|
| 420 | template = loader.get_template(template) |
|---|
| 421 | context = RequestContext(request, {'collection': collection, 'host': request.META['HTTP_HOST']}) |
|---|
| 422 | return HttpResponse(template.render(context), mimetype=mimetype) |
|---|
| 423 | |
|---|
| 424 | @method_decorator(permission_required('telemeta.delete_mediacollection')) |
|---|
| 425 | def collection_delete(self, request, public_id): |
|---|
| 426 | """Delete a given collection""" |
|---|
| 427 | collection = MediaCollection.objects.get(public_id=public_id) |
|---|
| 428 | collection.delete() |
|---|
| 429 | return HttpResponseRedirect('/collections/') |
|---|
| 430 | |
|---|
| 431 | |
|---|
| 432 | class ItemView(object): |
|---|
| 433 | """Provide Collections web UI methods""" |
|---|
| 434 | |
|---|
| 435 | graphers = timeside.core.processors(timeside.api.IGrapher) |
|---|
| 436 | decoders = timeside.core.processors(timeside.api.IDecoder) |
|---|
| 437 | encoders = timeside.core.processors(timeside.api.IEncoder) |
|---|
| 438 | analyzers = timeside.core.processors(timeside.api.IAnalyzer) |
|---|
| 439 | cache_data = TelemetaCache(settings.TELEMETA_DATA_CACHE_DIR) |
|---|
| 440 | cache_export = TelemetaCache(settings.TELEMETA_EXPORT_CACHE_DIR) |
|---|
| 441 | |
|---|
| 442 | def item_previous_next(self, item): |
|---|
| 443 | # Get previous and next items |
|---|
| 444 | pks = [] |
|---|
| 445 | items = MediaItem.objects.filter(collection=item.collection) |
|---|
| 446 | items = items.order_by('code', 'old_code') |
|---|
| 447 | |
|---|
| 448 | if len(items) > 1: |
|---|
| 449 | for it in items: |
|---|
| 450 | pks.append(it.pk) |
|---|
| 451 | for pk in pks: |
|---|
| 452 | if pk == item.pk: |
|---|
| 453 | if pk == pks[0]: |
|---|
| 454 | previous_pk = pks[-1] |
|---|
| 455 | next_pk = pks[1] |
|---|
| 456 | elif pk == pks[-1]: |
|---|
| 457 | previous_pk = pks[-2] |
|---|
| 458 | next_pk = pks[0] |
|---|
| 459 | else: |
|---|
| 460 | previous_pk = pks[pks.index(pk)-1] |
|---|
| 461 | next_pk = pks[pks.index(pk)+1] |
|---|
| 462 | for it in items: |
|---|
| 463 | if it.pk == previous_pk: |
|---|
| 464 | previous = it |
|---|
| 465 | if it.pk == next_pk: |
|---|
| 466 | next = it |
|---|
| 467 | previous = previous.public_id |
|---|
| 468 | next = next.public_id |
|---|
| 469 | else: |
|---|
| 470 | previous = item.public_id |
|---|
| 471 | next = item.public_id |
|---|
| 472 | |
|---|
| 473 | return previous, next |
|---|
| 474 | |
|---|
| 475 | def item_detail(self, request, public_id=None, marker_id=None, width=None, height=None, |
|---|
| 476 | template='telemeta/mediaitem_detail.html'): |
|---|
| 477 | """Show the details of a given item""" |
|---|
| 478 | |
|---|
| 479 | if not public_id and marker_id: |
|---|
| 480 | marker = MediaItemMarker.objects.get(public_id=marker_id) |
|---|
| 481 | item_id = marker.item_id |
|---|
| 482 | item = MediaItem.objects.get(id=item_id) |
|---|
| 483 | else: |
|---|
| 484 | item = MediaItem.objects.get(public_id=public_id) |
|---|
| 485 | |
|---|
| 486 | item_public_access = item.public_access != 'none' or item.collection.public_access != 'none' |
|---|
| 487 | if not item_public_access and not (request.user.is_staff or request.user.is_superuser): |
|---|
| 488 | mess = ugettext('Access not allowed') |
|---|
| 489 | title = ugettext('Item') + ' : ' + public_id + ' : ' + mess |
|---|
| 490 | description = ugettext('Please login or contact the website administator to get a private access.') |
|---|
| 491 | messages.error(request, title) |
|---|
| 492 | return render(request, 'telemeta/messages.html', {'description' : description}) |
|---|
| 493 | |
|---|
| 494 | # Get TimeSide processors |
|---|
| 495 | formats = [] |
|---|
| 496 | for encoder in self.encoders: |
|---|
| 497 | formats.append({'name': encoder.format(), 'extension': encoder.file_extension()}) |
|---|
| 498 | |
|---|
| 499 | graphers = [] |
|---|
| 500 | for grapher in self.graphers: |
|---|
| 501 | graphers.append({'name':grapher.name(), 'id': grapher.id()}) |
|---|
| 502 | if request.REQUEST.has_key('grapher_id'): |
|---|
| 503 | grapher_id = request.REQUEST['grapher_id'] |
|---|
| 504 | else: |
|---|
| 505 | grapher_id = 'waveform' |
|---|
| 506 | |
|---|
| 507 | previous, next = self.item_previous_next(item) |
|---|
| 508 | self.item_analyze(item) |
|---|
| 509 | playlists = get_playlists(request) |
|---|
| 510 | public_access = get_public_access(item.public_access, str(item.recorded_from_date).split('-')[0], |
|---|
| 511 | str(item.recorded_to_date).split('-')[0]) |
|---|
| 512 | |
|---|
| 513 | related_files = MediaItemRelatedFile.objects.filter(item=item) |
|---|
| 514 | for file in related_files: |
|---|
| 515 | if not file.mime_type: |
|---|
| 516 | file.set_mime_type() |
|---|
| 517 | file.save() |
|---|
| 518 | if not file.title and file.url: |
|---|
| 519 | try: |
|---|
| 520 | from lxml import etree |
|---|
| 521 | parser = etree.HTMLParser() |
|---|
| 522 | tree = etree.parse(file.url, parser) |
|---|
| 523 | title = tree.find(".//title").text |
|---|
| 524 | title = title.replace('\n', '').strip() |
|---|
| 525 | file.title = title |
|---|
| 526 | except: |
|---|
| 527 | file.title = file.url |
|---|
| 528 | file.save() |
|---|
| 529 | |
|---|
| 530 | return render(request, template, |
|---|
| 531 | {'item': item, 'export_formats': formats, |
|---|
| 532 | 'visualizers': graphers, 'visualizer_id': grapher_id, |
|---|
| 533 | 'audio_export_enabled': getattr(settings, 'TELEMETA_DOWNLOAD_ENABLED', True), |
|---|
| 534 | 'previous' : previous, 'next' : next, 'marker': marker_id, 'playlists' : playlists, |
|---|
| 535 | 'public_access': public_access, 'width': width, 'height': height, |
|---|
| 536 | 'related_files': related_files, |
|---|
| 537 | }) |
|---|
| 538 | |
|---|
| 539 | @method_decorator(permission_required('telemeta.change_mediaitem')) |
|---|
| 540 | def item_edit(self, request, public_id, template='telemeta/mediaitem_edit.html'): |
|---|
| 541 | """Edit a given item""" |
|---|
| 542 | item = MediaItem.objects.get(public_id=public_id) |
|---|
| 543 | |
|---|
| 544 | formats = [] |
|---|
| 545 | for encoder in self.encoders: |
|---|
| 546 | formats.append({'name': encoder.format(), 'extension': encoder.file_extension()}) |
|---|
| 547 | |
|---|
| 548 | graphers = [] |
|---|
| 549 | for grapher in self.graphers: |
|---|
| 550 | graphers.append({'name':grapher.name(), 'id': grapher.id()}) |
|---|
| 551 | if request.REQUEST.has_key('grapher_id'): |
|---|
| 552 | grapher_id = request.REQUEST['grapher_id'] |
|---|
| 553 | else: |
|---|
| 554 | grapher_id = 'waveform' |
|---|
| 555 | |
|---|
| 556 | previous, next = self.item_previous_next(item) |
|---|
| 557 | self.item_analyze(item) |
|---|
| 558 | |
|---|
| 559 | if request.method == 'POST': |
|---|
| 560 | form = MediaItemForm(data=request.POST, files=request.FILES, instance=item) |
|---|
| 561 | if form.is_valid(): |
|---|
| 562 | form.save() |
|---|
| 563 | code = form.cleaned_data['code'] |
|---|
| 564 | if not code: |
|---|
| 565 | code = str(item.id) |
|---|
| 566 | if form.files: |
|---|
| 567 | self.cache_data.delete_item_data(code) |
|---|
| 568 | self.cache_export.delete_item_data(code) |
|---|
| 569 | flags = MediaItemTranscodingFlag.objects.filter(item=item) |
|---|
| 570 | analyses = MediaItemAnalysis.objects.filter(item=item) |
|---|
| 571 | for flag in flags: |
|---|
| 572 | flag.delete() |
|---|
| 573 | for analysis in analyses: |
|---|
| 574 | analysis.delete() |
|---|
| 575 | item.set_revision(request.user) |
|---|
| 576 | return HttpResponseRedirect('/items/'+code) |
|---|
| 577 | else: |
|---|
| 578 | form = MediaItemForm(instance=item) |
|---|
| 579 | |
|---|
| 580 | return render(request, template, |
|---|
| 581 | {'item': item, 'export_formats': formats, |
|---|
| 582 | 'visualizers': graphers, 'visualizer_id': grapher_id, |
|---|
| 583 | 'audio_export_enabled': getattr(settings, 'TELEMETA_DOWNLOAD_ENABLED', True), "form": form, |
|---|
| 584 | 'previous' : previous, 'next' : next, |
|---|
| 585 | }) |
|---|
| 586 | |
|---|
| 587 | def related_file_stream(self, request, item_public_id, file_id): |
|---|
| 588 | item = MediaItem.objects.get(public_id=item_public_id) |
|---|
| 589 | file = MediaItemRelatedFile.objects.get(item=item, id=file_id) |
|---|
| 590 | response = HttpResponse(stream_from_file(file.file.path), mimetype=file.mime_type) |
|---|
| 591 | # response['Content-Disposition'] = 'attachment' |
|---|
| 592 | return response |
|---|
| 593 | |
|---|
| 594 | @method_decorator(permission_required('telemeta.change_mediaitem')) |
|---|
| 595 | def related_file_edit(self, request, public_id, template): |
|---|
| 596 | item = MediaItem.objects.get(public_id=public_id) |
|---|
| 597 | MediaItemRelatedFileFormSet = inlineformset_factory(MediaItem, MediaItemRelatedFile, form=MediaItemRelatedFileForm) |
|---|
| 598 | if request.method == 'POST': |
|---|
| 599 | formset = MediaItemRelatedFileFormSet(data=request.POST, files=request.FILES, instance=item) |
|---|
| 600 | if formset.is_valid(): |
|---|
| 601 | formset.save() |
|---|
| 602 | return HttpResponseRedirect('/items/'+public_id) |
|---|
| 603 | else: |
|---|
| 604 | formset = MediaItemRelatedFileFormSet(instance=item) |
|---|
| 605 | |
|---|
| 606 | return render(request, template, {'item': item, 'formset': formset,}) |
|---|
| 607 | |
|---|
| 608 | @method_decorator(permission_required('telemeta.add_mediaitem')) |
|---|
| 609 | def item_add(self, request, public_id=None, template='telemeta/mediaitem_add.html'): |
|---|
| 610 | """Add an item""" |
|---|
| 611 | if public_id: |
|---|
| 612 | collection = MediaCollection.objects.get(public_id=public_id) |
|---|
| 613 | item = MediaItem(collection=collection) |
|---|
| 614 | else: |
|---|
| 615 | item = MediaItem() |
|---|
| 616 | if request.method == 'POST': |
|---|
| 617 | form = MediaItemForm(data=request.POST, files=request.FILES, instance=item) |
|---|
| 618 | if form.is_valid(): |
|---|
| 619 | form.save() |
|---|
| 620 | item.set_revision(request.user) |
|---|
| 621 | code = form.cleaned_data['code'] |
|---|
| 622 | if not code: |
|---|
| 623 | code = str(item.id) |
|---|
| 624 | return HttpResponseRedirect('/items/'+code) |
|---|
| 625 | else: |
|---|
| 626 | form = MediaItemForm(instance=item) |
|---|
| 627 | |
|---|
| 628 | return render(request, template, {'item': item, 'form': form}) |
|---|
| 629 | |
|---|
| 630 | @method_decorator(permission_required('telemeta.add_mediaitem')) |
|---|
| 631 | def item_copy(self, request, public_id, template='telemeta/mediaitem_copy.html'): |
|---|
| 632 | """Copy a given item""" |
|---|
| 633 | if request.method == 'POST': |
|---|
| 634 | new_item = MediaItem() |
|---|
| 635 | form = MediaItemForm(data=request.POST, files=request.FILES, instance=new_item) |
|---|
| 636 | if form.is_valid(): |
|---|
| 637 | form.save() |
|---|
| 638 | code = form.cleaned_data['code'] |
|---|
| 639 | if not code: |
|---|
| 640 | code = str(new_item.id) |
|---|
| 641 | new_item.set_revision(request.user) |
|---|
| 642 | return HttpResponseRedirect('/items/'+code) |
|---|
| 643 | else: |
|---|
| 644 | item = MediaItem.objects.get(public_id=public_id) |
|---|
| 645 | form = MediaItemForm(instance=item) |
|---|
| 646 | form.file = None |
|---|
| 647 | |
|---|
| 648 | return render(request, template, {'item': item, "form": form}) |
|---|
| 649 | |
|---|
| 650 | @method_decorator(permission_required('telemeta.delete_mediaitem')) |
|---|
| 651 | def item_delete(self, request, public_id): |
|---|
| 652 | """Delete a given item""" |
|---|
| 653 | item = MediaItem.objects.get(public_id=public_id) |
|---|
| 654 | collection = item.collection |
|---|
| 655 | item.delete() |
|---|
| 656 | return HttpResponseRedirect('/collections/'+collection.code) |
|---|
| 657 | |
|---|
| 658 | def item_analyze(self, item): |
|---|
| 659 | analyses = MediaItemAnalysis.objects.filter(item=item) |
|---|
| 660 | |
|---|
| 661 | if analyses: |
|---|
| 662 | if not item.approx_duration: |
|---|
| 663 | for analysis in analyses: |
|---|
| 664 | if analysis.id == 'duration': |
|---|
| 665 | value = analysis.value |
|---|
| 666 | time = value.split(':') |
|---|
| 667 | time[2] = time[2].split('.')[0] |
|---|
| 668 | time = ':'.join(time) |
|---|
| 669 | item.approx_duration = str(time) |
|---|
| 670 | item.save() |
|---|
| 671 | else: |
|---|
| 672 | analyzers = [] |
|---|
| 673 | analyzers_sub = [] |
|---|
| 674 | if item.file: |
|---|
| 675 | decoder = timeside.decoder.FileDecoder(item.file.path) |
|---|
| 676 | pipe = decoder |
|---|
| 677 | for analyzer in self.analyzers: |
|---|
| 678 | subpipe = analyzer() |
|---|
| 679 | analyzers_sub.append(subpipe) |
|---|
| 680 | pipe = pipe | subpipe |
|---|
| 681 | pipe.run() |
|---|
| 682 | |
|---|
| 683 | mime_type = decoder.format() |
|---|
| 684 | analysis = MediaItemAnalysis(item=item, name='MIME type', |
|---|
| 685 | analyzer_id='mime_type', unit='', value=mime_type) |
|---|
| 686 | analysis.save() |
|---|
| 687 | analysis = MediaItemAnalysis(item=item, name='Channels', |
|---|
| 688 | analyzer_id='channels', |
|---|
| 689 | unit='', value=decoder.channels()) |
|---|
| 690 | analysis.save() |
|---|
| 691 | analysis = MediaItemAnalysis(item=item, name='Samplerate', |
|---|
| 692 | analyzer_id='samplerate', unit='Hz', |
|---|
| 693 | value=unicode(decoder.audiorate)) |
|---|
| 694 | analysis.save() |
|---|
| 695 | analysis = MediaItemAnalysis(item=item, name='Resolution', |
|---|
| 696 | analyzer_id='resolution', unit='bits', |
|---|
| 697 | value=unicode(decoder.audiowidth)) |
|---|
| 698 | analysis.save() |
|---|
| 699 | |
|---|
| 700 | for analyzer in analyzers_sub: |
|---|
| 701 | value = analyzer.result() |
|---|
| 702 | if analyzer.id() == 'duration': |
|---|
| 703 | approx_value = int(round(value)) |
|---|
| 704 | item.approx_duration = approx_value |
|---|
| 705 | try: |
|---|
| 706 | item.save() |
|---|
| 707 | except: |
|---|
| 708 | pass |
|---|
| 709 | value = datetime.timedelta(0,value) |
|---|
| 710 | |
|---|
| 711 | analysis = MediaItemAnalysis(item=item, name=analyzer.name(), |
|---|
| 712 | analyzer_id=analyzer.id(), |
|---|
| 713 | unit=analyzer.unit(), value=str(value)) |
|---|
| 714 | analysis.save() |
|---|
| 715 | |
|---|
| 716 | def item_analyze_xml(self, request, public_id): |
|---|
| 717 | item = MediaItem.objects.get(public_id=public_id) |
|---|
| 718 | analyses = MediaItemAnalysis.objects.filter(item=item) |
|---|
| 719 | analyzers = [] |
|---|
| 720 | for analysis in analyses: |
|---|
| 721 | analyzers.append(analysis.to_dict()) |
|---|
| 722 | mime_type = 'text/xml' |
|---|
| 723 | response = HttpResponse(self.cache_data.get_analyzer_xml(analyzers), mimetype=mime_type) |
|---|
| 724 | response['Content-Disposition'] = 'attachment; filename='+public_id+'.xml' |
|---|
| 725 | return response |
|---|
| 726 | |
|---|
| 727 | def item_visualize(self, request, public_id, visualizer_id, width, height): |
|---|
| 728 | item = MediaItem.objects.get(public_id=public_id) |
|---|
| 729 | mime_type = 'image/png' |
|---|
| 730 | grapher_id = visualizer_id |
|---|
| 731 | |
|---|
| 732 | for grapher in self.graphers: |
|---|
| 733 | if grapher.id() == grapher_id: |
|---|
| 734 | break |
|---|
| 735 | |
|---|
| 736 | if grapher.id() != grapher_id: |
|---|
| 737 | raise Http404 |
|---|
| 738 | |
|---|
| 739 | size = width + '_' + height |
|---|
| 740 | image_file = '.'.join([public_id, grapher_id, size, 'png']) |
|---|
| 741 | |
|---|
| 742 | if not self.cache_data.exists(image_file): |
|---|
| 743 | if item.file: |
|---|
| 744 | path = self.cache_data.dir + os.sep + image_file |
|---|
| 745 | decoder = timeside.decoder.FileDecoder(item.file.path) |
|---|
| 746 | graph = grapher(width = int(width), height = int(height)) |
|---|
| 747 | pipe = decoder | graph |
|---|
| 748 | pipe.run() |
|---|
| 749 | graph.watermark('timeside', opacity=.6, margin=(5,5)) |
|---|
| 750 | f = open(path, 'w') |
|---|
| 751 | graph.render(path) |
|---|
| 752 | f.close() |
|---|
| 753 | |
|---|
| 754 | response = HttpResponse(self.cache_data.read_stream_bin(image_file), mimetype=mime_type) |
|---|
| 755 | return response |
|---|
| 756 | |
|---|
| 757 | def list_export_extensions(self): |
|---|
| 758 | "Return the recognized item export file extensions, as a list" |
|---|
| 759 | list = [] |
|---|
| 760 | for encoder in self.encoders: |
|---|
| 761 | list.append(encoder.file_extension()) |
|---|
| 762 | return list |
|---|
| 763 | |
|---|
| 764 | def item_export(self, request, public_id, extension): |
|---|
| 765 | """Export a given media item in the specified format (OGG, FLAC, ...)""" |
|---|
| 766 | |
|---|
| 767 | item = MediaItem.objects.get(public_id=public_id) |
|---|
| 768 | public_access = get_public_access(item.public_access, |
|---|
| 769 | str(item.recorded_from_date).split('-')[0], |
|---|
| 770 | str(item.recorded_to_date).split('-')[0]) |
|---|
| 771 | |
|---|
| 772 | if (not public_access or not extension in settings.TELEMETA_STREAMING_FORMATS) and \ |
|---|
| 773 | not (request.user.has_perm('telemeta.can_play_all_items') or request.user.is_superuser): |
|---|
| 774 | mess = ugettext('Access not allowed') |
|---|
| 775 | title = 'Item file : ' + public_id + '.' + extension + ' : ' + mess |
|---|
| 776 | description = ugettext('Please login or contact the website administator to get a private access.') |
|---|
| 777 | messages.error(request, title) |
|---|
| 778 | return render(request, 'telemeta/messages.html', {'description' : description}) |
|---|
| 779 | |
|---|
| 780 | for encoder in self.encoders: |
|---|
| 781 | if encoder.file_extension() == extension: |
|---|
| 782 | break |
|---|
| 783 | |
|---|
| 784 | if encoder.file_extension() != extension: |
|---|
| 785 | raise Http404('Unknown export file extension: %s' % extension) |
|---|
| 786 | |
|---|
| 787 | mime_type = encoder.mime_type() |
|---|
| 788 | file = public_id + '.' + encoder.file_extension() |
|---|
| 789 | audio = item.file.path |
|---|
| 790 | |
|---|
| 791 | flag = MediaItemTranscodingFlag.objects.filter(item=item, mime_type=mime_type) |
|---|
| 792 | if not flag: |
|---|
| 793 | flag = MediaItemTranscodingFlag(item=item, mime_type=mime_type) |
|---|
| 794 | flag.value = False |
|---|
| 795 | flag.save() |
|---|
| 796 | else: |
|---|
| 797 | flag = flag[0] |
|---|
| 798 | |
|---|
| 799 | analyzers = self.item_analyze(item) |
|---|
| 800 | if analyzers: |
|---|
| 801 | for analyzer in analyzers: |
|---|
| 802 | if analyzer['id'] == 'mime_type': |
|---|
| 803 | format = analyzer['value'] |
|---|
| 804 | else: |
|---|
| 805 | decoder = timeside.decoder.FileDecoder(audio) |
|---|
| 806 | format = decoder.format() |
|---|
| 807 | |
|---|
| 808 | if mime_type in format: |
|---|
| 809 | # source > stream |
|---|
| 810 | response = HttpResponse(stream_from_file(audio), mimetype = mime_type) |
|---|
| 811 | |
|---|
| 812 | else: |
|---|
| 813 | dc_metadata = dublincore.express_item(item).to_list() |
|---|
| 814 | mapping = DublinCoreToFormatMetadata(extension) |
|---|
| 815 | metadata = mapping.get_metadata(dc_metadata) |
|---|
| 816 | media = self.cache_export.dir + os.sep + file |
|---|
| 817 | if not self.cache_export.exists(file) or flag.value == False: |
|---|
| 818 | # source > encoder > stream |
|---|
| 819 | decoder = timeside.decoder.FileDecoder(audio) |
|---|
| 820 | decoder.setup() |
|---|
| 821 | proc = encoder(media, streaming=True) |
|---|
| 822 | proc.setup(channels=decoder.channels(), samplerate=decoder.samplerate()) |
|---|
| 823 | proc.set_metadata(metadata) |
|---|
| 824 | response = HttpResponse(stream_from_processor(decoder, proc, flag), mimetype = mime_type) |
|---|
| 825 | else: |
|---|
| 826 | # cache > stream |
|---|
| 827 | proc = encoder(media) |
|---|
| 828 | proc.set_metadata(metadata) |
|---|
| 829 | proc.write_metadata() |
|---|
| 830 | response = HttpResponse(self.cache_export.read_stream_bin(file), mimetype = mime_type) |
|---|
| 831 | |
|---|
| 832 | response['Content-Disposition'] = 'attachment' |
|---|
| 833 | return response |
|---|
| 834 | |
|---|
| 835 | def item_playlist(self, request, public_id, template, mimetype): |
|---|
| 836 | try: |
|---|
| 837 | item = MediaItem.objects.get(public_id=public_id) |
|---|
| 838 | except ObjectDoesNotExist: |
|---|
| 839 | raise Http404 |
|---|
| 840 | |
|---|
| 841 | template = loader.get_template(template) |
|---|
| 842 | context = RequestContext(request, {'item': item, 'host': request.META['HTTP_HOST']}) |
|---|
| 843 | return HttpResponse(template.render(context), mimetype=mimetype) |
|---|
| 844 | |
|---|
| 845 | @method_decorator(permission_required('telemeta.change_mediaitem')) |
|---|
| 846 | def item_performances_edit(self, request, public_id, template): |
|---|
| 847 | item = MediaItem.objects.get(public_id=public_id) |
|---|
| 848 | PerformanceFormSet = inlineformset_factory(MediaItem, MediaItemPerformance, form=MediaItemPerformanceForm) |
|---|
| 849 | if request.method == 'POST': |
|---|
| 850 | formset = PerformanceFormSet(data=request.POST, instance=item) |
|---|
| 851 | if formset.is_valid(): |
|---|
| 852 | formset.save() |
|---|
| 853 | return HttpResponseRedirect('/items/'+public_id) |
|---|
| 854 | else: |
|---|
| 855 | formset = PerformanceFormSet(instance=item) |
|---|
| 856 | return render(request, template, {'item': item, 'formset': formset,}) |
|---|
| 857 | |
|---|
| 858 | @method_decorator(permission_required('telemeta.change_mediaitem')) |
|---|
| 859 | def item_keywords_edit(self, request, public_id, template): |
|---|
| 860 | item = MediaItem.objects.get(public_id=public_id) |
|---|
| 861 | FormSet = inlineformset_factory(MediaItem, MediaItemKeyword) |
|---|
| 862 | if request.method == 'POST': |
|---|
| 863 | formset = FormSet(data=request.POST, instance=item) |
|---|
| 864 | if formset.is_valid(): |
|---|
| 865 | formset.save() |
|---|
| 866 | return HttpResponseRedirect('/items/'+public_id) |
|---|
| 867 | else: |
|---|
| 868 | formset = FormSet(instance=item) |
|---|
| 869 | return render(request, template, {'item': item, 'formset': formset,}) |
|---|
| 870 | |
|---|
| 871 | |
|---|
| 872 | class AdminView(object): |
|---|
| 873 | """Provide Admin web UI methods""" |
|---|
| 874 | |
|---|
| 875 | @method_decorator(permission_required('sites.change_site')) |
|---|
| 876 | def admin_index(self, request): |
|---|
| 877 | return render(request, 'telemeta/admin.html', self.__get_admin_context_vars()) |
|---|
| 878 | |
|---|
| 879 | @method_decorator(permission_required('sites.change_site')) |
|---|
| 880 | def admin_general(self, request): |
|---|
| 881 | return render(request, 'telemeta/admin_general.html', self.__get_admin_context_vars()) |
|---|
| 882 | |
|---|
| 883 | @method_decorator(permission_required('sites.change_site')) |
|---|
| 884 | def admin_enumerations(self, request): |
|---|
| 885 | return render(request, 'telemeta/admin_enumerations.html', self.__get_admin_context_vars()) |
|---|
| 886 | |
|---|
| 887 | @method_decorator(permission_required('sites.change_site')) |
|---|
| 888 | def admin_users(self, request): |
|---|
| 889 | users = User.objects.all() |
|---|
| 890 | return render(request, 'telemeta/admin_users.html', {'users': users}) |
|---|
| 891 | |
|---|
| 892 | def __get_enumerations_list(self): |
|---|
| 893 | from django.db.models import get_models |
|---|
| 894 | models = get_models(telemeta.models) |
|---|
| 895 | |
|---|
| 896 | enumerations = [] |
|---|
| 897 | for model in models: |
|---|
| 898 | if issubclass(model, Enumeration): |
|---|
| 899 | enumerations.append({"name": model._meta.verbose_name, |
|---|
| 900 | "id": model._meta.module_name}) |
|---|
| 901 | |
|---|
| 902 | cmp = lambda obj1, obj2: unaccent_icmp(obj1['name'], obj2['name']) |
|---|
| 903 | enumerations.sort(cmp) |
|---|
| 904 | return enumerations |
|---|
| 905 | |
|---|
| 906 | def __get_admin_context_vars(self): |
|---|
| 907 | return {"enumerations": self.__get_enumerations_list()} |
|---|
| 908 | |
|---|
| 909 | def __get_enumeration(self, id): |
|---|
| 910 | from django.db.models import get_models |
|---|
| 911 | models = get_models(telemeta.models) |
|---|
| 912 | for model in models: |
|---|
| 913 | if model._meta.module_name == id: |
|---|
| 914 | break |
|---|
| 915 | |
|---|
| 916 | if model._meta.module_name != id: |
|---|
| 917 | return None |
|---|
| 918 | |
|---|
| 919 | return model |
|---|
| 920 | |
|---|
| 921 | @method_decorator(permission_required('telemeta.change_keyword')) |
|---|
| 922 | def edit_enumeration(self, request, enumeration_id): |
|---|
| 923 | |
|---|
| 924 | enumeration = self.__get_enumeration(enumeration_id) |
|---|
| 925 | if enumeration == None: |
|---|
| 926 | raise Http404 |
|---|
| 927 | |
|---|
| 928 | vars = self.__get_admin_context_vars() |
|---|
| 929 | vars["enumeration_id"] = enumeration._meta.module_name |
|---|
| 930 | vars["enumeration_name"] = enumeration._meta.verbose_name |
|---|
| 931 | vars["enumeration_values"] = enumeration.objects.all() |
|---|
| 932 | return render(request, 'telemeta/enumeration_edit.html', vars) |
|---|
| 933 | |
|---|
| 934 | @method_decorator(permission_required('telemeta.add_keyword')) |
|---|
| 935 | def add_to_enumeration(self, request, enumeration_id): |
|---|
| 936 | |
|---|
| 937 | enumeration = self.__get_enumeration(enumeration_id) |
|---|
| 938 | if enumeration == None: |
|---|
| 939 | raise Http404 |
|---|
| 940 | |
|---|
| 941 | enumeration_value = enumeration(value=request.POST['value']) |
|---|
| 942 | enumeration_value.save() |
|---|
| 943 | |
|---|
| 944 | return self.edit_enumeration(request, enumeration_id) |
|---|
| 945 | |
|---|
| 946 | @method_decorator(permission_required('telemeta.change_keyword')) |
|---|
| 947 | def update_enumeration(self, request, enumeration_id): |
|---|
| 948 | |
|---|
| 949 | enumeration = self.__get_enumeration(enumeration_id) |
|---|
| 950 | if enumeration == None: |
|---|
| 951 | raise Http404 |
|---|
| 952 | |
|---|
| 953 | if request.method == 'POST': |
|---|
| 954 | enumeration.objects.filter(id__in=request.POST.getlist('sel')).delete() |
|---|
| 955 | |
|---|
| 956 | return self.edit_enumeration(request, enumeration_id) |
|---|
| 957 | |
|---|
| 958 | @method_decorator(permission_required('telemeta.change_keyword')) |
|---|
| 959 | def edit_enumeration_value(self, request, enumeration_id, value_id): |
|---|
| 960 | |
|---|
| 961 | enumeration = self.__get_enumeration(enumeration_id) |
|---|
| 962 | if enumeration == None: |
|---|
| 963 | raise Http404 |
|---|
| 964 | |
|---|
| 965 | vars = self.__get_admin_context_vars() |
|---|
| 966 | vars["enumeration_id"] = enumeration._meta.module_name |
|---|
| 967 | vars["enumeration_name"] = enumeration._meta.verbose_name |
|---|
| 968 | vars["enumeration_record"] = enumeration.objects.get(id__exact=value_id) |
|---|
| 969 | return render(request, 'telemeta/enumeration_edit_value.html', vars) |
|---|
| 970 | |
|---|
| 971 | @method_decorator(permission_required('telemeta.change_keyword')) |
|---|
| 972 | def update_enumeration_value(self, request, enumeration_id, value_id): |
|---|
| 973 | |
|---|
| 974 | if request.method == 'POST': |
|---|
| 975 | enumeration = self.__get_enumeration(enumeration_id) |
|---|
| 976 | if enumeration == None: |
|---|
| 977 | raise Http404 |
|---|
| 978 | |
|---|
| 979 | record = enumeration.objects.get(id__exact=value_id) |
|---|
| 980 | record.value = request.POST["value"] |
|---|
| 981 | record.save() |
|---|
| 982 | |
|---|
| 983 | return self.edit_enumeration(request, enumeration_id) |
|---|
| 984 | |
|---|
| 985 | |
|---|
| 986 | class InstrumentView(object): |
|---|
| 987 | """Provide Instrument web UI methods""" |
|---|
| 988 | |
|---|
| 989 | @method_decorator(permission_required('telemeta.change_instrument')) |
|---|
| 990 | def edit_instrument(self, request): |
|---|
| 991 | |
|---|
| 992 | instruments = Instrument.objects.all().order_by('name') |
|---|
| 993 | if instruments == None: |
|---|
| 994 | raise Http404 |
|---|
| 995 | return render(request, 'telemeta/instrument_edit.html', {'instruments': instruments}) |
|---|
| 996 | |
|---|
| 997 | @method_decorator(permission_required('telemeta.add_instrument')) |
|---|
| 998 | def add_to_instrument(self, request): |
|---|
| 999 | |
|---|
| 1000 | if request.method == 'POST': |
|---|
| 1001 | instrument = Instrument(name=request.POST['value']) |
|---|
| 1002 | instrument.save() |
|---|
| 1003 | |
|---|
| 1004 | return self.edit_instrument(request) |
|---|
| 1005 | |
|---|
| 1006 | @method_decorator(permission_required('telemeta.change_instrument')) |
|---|
| 1007 | def update_instrument(self, request): |
|---|
| 1008 | |
|---|
| 1009 | if request.method == 'POST': |
|---|
| 1010 | Instrument.objects.filter(id__in=request.POST.getlist('sel')).delete() |
|---|
| 1011 | |
|---|
| 1012 | return self.edit_instrument(request) |
|---|
| 1013 | |
|---|
| 1014 | @method_decorator(permission_required('telemeta.change_instrument')) |
|---|
| 1015 | def edit_instrument_value(self, request, value_id): |
|---|
| 1016 | instrument = Instrument.objects.get(id__exact=value_id) |
|---|
| 1017 | |
|---|
| 1018 | return render(request, 'telemeta/instrument_edit_value.html', {'instrument': instrument}) |
|---|
| 1019 | |
|---|
| 1020 | @method_decorator(permission_required('telemeta.change_instrument')) |
|---|
| 1021 | def update_instrument_value(self, request, value_id): |
|---|
| 1022 | |
|---|
| 1023 | if request.method == 'POST': |
|---|
| 1024 | instrument = Instrument.objects.get(id__exact=value_id) |
|---|
| 1025 | instrument.name = request.POST["value"] |
|---|
| 1026 | instrument.save() |
|---|
| 1027 | |
|---|
| 1028 | return self.edit_instrument(request) |
|---|
| 1029 | |
|---|
| 1030 | |
|---|
| 1031 | class GeoView(object): |
|---|
| 1032 | """Provide Geo web UI methods""" |
|---|
| 1033 | |
|---|
| 1034 | def list_continents(self, request): |
|---|
| 1035 | continents = MediaItem.objects.all().countries(group_by_continent=True) |
|---|
| 1036 | return render(request, 'telemeta/geo_continents.html', |
|---|
| 1037 | {'continents': continents, 'gmap_key': settings.TELEMETA_GMAP_KEY }) |
|---|
| 1038 | |
|---|
| 1039 | def country_info(self, request, id): |
|---|
| 1040 | country = Location.objects.get(pk=id) |
|---|
| 1041 | return render(request, 'telemeta/country_info.html', { |
|---|
| 1042 | 'country': country, 'continent': country.continents()[0]}) |
|---|
| 1043 | |
|---|
| 1044 | def list_countries(self, request, continent): |
|---|
| 1045 | continent = Location.objects.by_flatname(continent)[0] |
|---|
| 1046 | countries = MediaItem.objects.by_location(continent).countries() |
|---|
| 1047 | |
|---|
| 1048 | return render(request, 'telemeta/geo_countries.html', { |
|---|
| 1049 | 'continent': continent, |
|---|
| 1050 | 'countries': countries |
|---|
| 1051 | }) |
|---|
| 1052 | |
|---|
| 1053 | def list_country_collections(self, request, continent, country): |
|---|
| 1054 | continent = Location.objects.by_flatname(continent)[0] |
|---|
| 1055 | country = Location.objects.by_flatname(country)[0] |
|---|
| 1056 | objects = MediaCollection.objects.enriched().by_location(country) |
|---|
| 1057 | return list_detail.object_list(request, objects, |
|---|
| 1058 | template_name='telemeta/geo_country_collections.html', paginate_by=20, |
|---|
| 1059 | extra_context={'country': country, 'continent': continent}) |
|---|
| 1060 | |
|---|
| 1061 | def list_country_items(self, request, continent, country): |
|---|
| 1062 | continent = Location.objects.by_flatname(continent)[0] |
|---|
| 1063 | country = Location.objects.by_flatname(country)[0] |
|---|
| 1064 | objects = MediaItem.objects.enriched().by_location(country) |
|---|
| 1065 | return list_detail.object_list(request, objects, |
|---|
| 1066 | template_name='telemeta/geo_country_items.html', paginate_by=20, |
|---|
| 1067 | extra_context={'country': country, 'continent': continent}) |
|---|
| 1068 | |
|---|
| 1069 | class MarkerView(object): |
|---|
| 1070 | """Provide Collections web UI methods""" |
|---|
| 1071 | |
|---|
| 1072 | @jsonrpc_method('telemeta.add_marker') |
|---|
| 1073 | def add_marker(request, marker): |
|---|
| 1074 | # marker must be a dict |
|---|
| 1075 | if isinstance(marker, dict): |
|---|
| 1076 | item_id = marker['item_id'] |
|---|
| 1077 | item = MediaItem.objects.get(id=item_id) |
|---|
| 1078 | m = MediaItemMarker(item=item) |
|---|
| 1079 | m.public_id = marker['public_id'] |
|---|
| 1080 | m.time = float(marker['time']) |
|---|
| 1081 | m.title = marker['title'] |
|---|
| 1082 | m.description = marker['description'] |
|---|
| 1083 | m.author = User.objects.get(username=marker['author']) |
|---|
| 1084 | m.save() |
|---|
| 1085 | m.set_revision(request.user) |
|---|
| 1086 | else: |
|---|
| 1087 | raise 'Error : Bad marker dictionnary' |
|---|
| 1088 | |
|---|
| 1089 | @jsonrpc_method('telemeta.del_marker') |
|---|
| 1090 | def del_marker(request, public_id): |
|---|
| 1091 | m = MediaItemMarker.objects.get(public_id=public_id) |
|---|
| 1092 | m.delete() |
|---|
| 1093 | |
|---|
| 1094 | @jsonrpc_method('telemeta.get_markers') |
|---|
| 1095 | def get_markers(request, item_id): |
|---|
| 1096 | item = MediaItem.objects.get(id=item_id) |
|---|
| 1097 | markers = MediaItemMarker.objects.filter(item=item) |
|---|
| 1098 | list = [] |
|---|
| 1099 | for marker in markers: |
|---|
| 1100 | dict = {} |
|---|
| 1101 | dict['public_id'] = marker.public_id |
|---|
| 1102 | dict['time'] = str(marker.time) |
|---|
| 1103 | dict['title'] = marker.title |
|---|
| 1104 | dict['description'] = marker.description |
|---|
| 1105 | dict['author'] = marker.author.username |
|---|
| 1106 | list.append(dict) |
|---|
| 1107 | return list |
|---|
| 1108 | |
|---|
| 1109 | @jsonrpc_method('telemeta.update_marker') |
|---|
| 1110 | def update_marker(request, marker): |
|---|
| 1111 | if isinstance(marker, dict): |
|---|
| 1112 | m = MediaItemMarker.objects.get(public_id=marker['public_id']) |
|---|
| 1113 | m.time = float(marker['time']) |
|---|
| 1114 | m.title = marker['title'] |
|---|
| 1115 | m.description = marker['description'] |
|---|
| 1116 | m.save() |
|---|
| 1117 | m.set_revision(request.user) |
|---|
| 1118 | else: |
|---|
| 1119 | raise 'Error : Bad marker dictionnary' |
|---|
| 1120 | |
|---|
| 1121 | @jsonrpc_method('telemeta.get_marker_id') |
|---|
| 1122 | def get_marker_id(request, public_id): |
|---|
| 1123 | marker = MediaItemMarker.objects.get(public_id=public_id) |
|---|
| 1124 | return marker.id |
|---|
| 1125 | |
|---|
| 1126 | class PlaylistView(object): |
|---|
| 1127 | """Provide Collections web UI methods""" |
|---|
| 1128 | |
|---|
| 1129 | @jsonrpc_method('telemeta.add_playlist') |
|---|
| 1130 | def add_playlist(request, playlist): |
|---|
| 1131 | # playlist must be a dict |
|---|
| 1132 | if isinstance(playlist, dict): |
|---|
| 1133 | m = Playlist() |
|---|
| 1134 | m.public_id = playlist['public_id'] |
|---|
| 1135 | m.title = playlist['title'] |
|---|
| 1136 | m.description = playlist['description'] |
|---|
| 1137 | m.author = request.user |
|---|
| 1138 | m.save() |
|---|
| 1139 | else: |
|---|
| 1140 | raise 'Error : Bad playlist dictionnary' |
|---|
| 1141 | |
|---|
| 1142 | @jsonrpc_method('telemeta.del_playlist') |
|---|
| 1143 | def del_playlist(request, public_id): |
|---|
| 1144 | m = Playlist.objects.get(public_id=public_id) |
|---|
| 1145 | m.delete() |
|---|
| 1146 | |
|---|
| 1147 | @jsonrpc_method('telemeta.update_playlist') |
|---|
| 1148 | def update_playlist(request, playlist): |
|---|
| 1149 | if isinstance(playlist, dict): |
|---|
| 1150 | m = Playlist.objects.get(public_id=playlist['public_id']) |
|---|
| 1151 | m.title = float(playlist['title']) |
|---|
| 1152 | m.description = playlist['description'] |
|---|
| 1153 | m.save() |
|---|
| 1154 | else: |
|---|
| 1155 | raise 'Error : Bad playlist dictionnary' |
|---|
| 1156 | |
|---|
| 1157 | @jsonrpc_method('telemeta.add_playlist_resource') |
|---|
| 1158 | def add_playlist_resource(request, playlist_id, playlist_resource): |
|---|
| 1159 | # playlist_resource must be a dict |
|---|
| 1160 | if isinstance(playlist_resource, dict): |
|---|
| 1161 | m = PlaylistResource() |
|---|
| 1162 | m.public_id = playlist_resource['public_id'] |
|---|
| 1163 | m.playlist = Playlist.objects.get(public_id=playlist_id, author=request.user) |
|---|
| 1164 | m.resource_type = playlist_resource['resource_type'] |
|---|
| 1165 | m.resource_id = playlist_resource['resource_id'] |
|---|
| 1166 | m.save() |
|---|
| 1167 | else: |
|---|
| 1168 | raise 'Error : Bad playlist_resource dictionnary' |
|---|
| 1169 | |
|---|
| 1170 | @jsonrpc_method('telemeta.del_playlist_resource') |
|---|
| 1171 | def del_playlist_resource(request, public_id): |
|---|
| 1172 | m = PlaylistResource.objects.get(public_id=public_id) |
|---|
| 1173 | m.delete() |
|---|
| 1174 | |
|---|
| 1175 | |
|---|
| 1176 | def playlist_csv_export(self, request, public_id, resource_type): |
|---|
| 1177 | playlist = Playlist.objects.get(public_id=public_id, author=request.user) |
|---|
| 1178 | resources = PlaylistResource.objects.filter(playlist=playlist) |
|---|
| 1179 | response = HttpResponse(mimetype='text/csv') |
|---|
| 1180 | response['Content-Disposition'] = 'attachment; filename='+playlist.title+'_'+resource_type+'.csv' |
|---|
| 1181 | writer = UnicodeWriter(response) |
|---|
| 1182 | |
|---|
| 1183 | elements = [] |
|---|
| 1184 | for resource in resources: |
|---|
| 1185 | if resource_type == 'items': |
|---|
| 1186 | if resource.resource_type == 'collection': |
|---|
| 1187 | collection = MediaCollection.objects.get(id=resource.resource_id) |
|---|
| 1188 | collection_items = MediaItem.objects.filter(collection=collection) |
|---|
| 1189 | for item in collection_items: |
|---|
| 1190 | elements.append(item) |
|---|
| 1191 | elif resource.resource_type == 'item': |
|---|
| 1192 | item = MediaItem.objects.get(id=resource.resource_id) |
|---|
| 1193 | elements.append(item) |
|---|
| 1194 | |
|---|
| 1195 | elif resource_type == 'collections': |
|---|
| 1196 | if resource.resource_type == 'collection': |
|---|
| 1197 | collection = MediaCollection.objects.get(id=resource.resource_id) |
|---|
| 1198 | elements.append(collection) |
|---|
| 1199 | |
|---|
| 1200 | if elements: |
|---|
| 1201 | element = elements[0].to_dict() |
|---|
| 1202 | tags = element.keys() |
|---|
| 1203 | # code and title on the two first column |
|---|
| 1204 | tags.remove('code') |
|---|
| 1205 | tags.remove('title') |
|---|
| 1206 | tags.sort() |
|---|
| 1207 | tags.insert(0, 'title') |
|---|
| 1208 | tags.insert(0, 'code') |
|---|
| 1209 | writer.writerow(tags) |
|---|
| 1210 | |
|---|
| 1211 | for element in elements: |
|---|
| 1212 | data = [] |
|---|
| 1213 | element = element.to_dict() |
|---|
| 1214 | for tag in tags: |
|---|
| 1215 | data.append(element[tag]) |
|---|
| 1216 | writer.writerow(data) |
|---|
| 1217 | return response |
|---|
| 1218 | |
|---|
| 1219 | |
|---|
| 1220 | class ProfileView(object): |
|---|
| 1221 | """Provide Collections web UI methods""" |
|---|
| 1222 | |
|---|
| 1223 | @method_decorator(login_required) |
|---|
| 1224 | def profile_detail(self, request, username, template='telemeta/profile_detail.html'): |
|---|
| 1225 | user = User.objects.get(username=username) |
|---|
| 1226 | try: |
|---|
| 1227 | profile = user.get_profile() |
|---|
| 1228 | except: |
|---|
| 1229 | profile = None |
|---|
| 1230 | playlists = get_playlists(request, user) |
|---|
| 1231 | return render(request, template, {'profile' : profile, 'usr': user, 'playlists': playlists}) |
|---|
| 1232 | |
|---|
| 1233 | def profile_edit(self, request, username, template='telemeta/profile_edit.html'): |
|---|
| 1234 | if request.user.is_superuser: |
|---|
| 1235 | user_hidden_fields = ['profile-user', 'user-password', 'user-last_login', 'user-date_joined'] |
|---|
| 1236 | else: |
|---|
| 1237 | user_hidden_fields = ['user-username', 'user-is_staff', 'profile-user', 'user-is_active', |
|---|
| 1238 | 'user-password', 'user-last_login', 'user-date_joined', 'user-groups', |
|---|
| 1239 | 'user-user_permissions', 'user-is_superuser', 'profile-expiration_date'] |
|---|
| 1240 | |
|---|
| 1241 | user = User.objects.get(username=username) |
|---|
| 1242 | if user != request.user and not request.user.is_staff: |
|---|
| 1243 | mess = ugettext('Access not allowed') |
|---|
| 1244 | title = ugettext('User profile') + ' : ' + username + ' : ' + mess |
|---|
| 1245 | description = ugettext('Please login or contact the website administator to get a private access.') |
|---|
| 1246 | messages.error(request, title) |
|---|
| 1247 | return render(request, 'telemeta/messages.html', {'description' : description}) |
|---|
| 1248 | |
|---|
| 1249 | try: |
|---|
| 1250 | profile = user.get_profile() |
|---|
| 1251 | except: |
|---|
| 1252 | profile = UserProfile(user=user) |
|---|
| 1253 | |
|---|
| 1254 | if request.method == 'POST': |
|---|
| 1255 | user_form = UserChangeForm(request.POST, instance=user, prefix='user') |
|---|
| 1256 | profile_form = UserProfileForm(request.POST, instance=profile, prefix='profile') |
|---|
| 1257 | if user_form.is_valid() and profile_form.is_valid(): |
|---|
| 1258 | user_form.save() |
|---|
| 1259 | profile_form.save() |
|---|
| 1260 | return HttpResponseRedirect('/users/'+username+'/profile/') |
|---|
| 1261 | else: |
|---|
| 1262 | user_form = UserChangeForm(instance=user, prefix='user') |
|---|
| 1263 | profile_form = UserProfileForm(instance=profile, prefix='profile') |
|---|
| 1264 | forms = [user_form, profile_form] |
|---|
| 1265 | return render(request, template, {'forms': forms, 'usr': user, 'user_hidden_fields': user_hidden_fields}) |
|---|
| 1266 | |
|---|
| 1267 | |
|---|
| 1268 | class LastestRevisionsFeed(Feed): |
|---|
| 1269 | "the RSS feed of the lastest revisions" |
|---|
| 1270 | |
|---|
| 1271 | organization = settings.TELEMETA_ORGANIZATION |
|---|
| 1272 | subjects = settings.TELEMETA_SUBJECTS |
|---|
| 1273 | tags = ['title', 'description', 'comment'] |
|---|
| 1274 | title = organization + ' - Telemeta - ' + ugettext('Last changes') |
|---|
| 1275 | link = "" |
|---|
| 1276 | description = ' '.join([subject.decode('utf-8') for subject in subjects]) |
|---|
| 1277 | n_items = 100 |
|---|
| 1278 | |
|---|
| 1279 | def items(self): |
|---|
| 1280 | return get_revisions(self.n_items) |
|---|
| 1281 | |
|---|
| 1282 | def item_title(self, r): |
|---|
| 1283 | element = r['element'] |
|---|
| 1284 | if element.title == '': |
|---|
| 1285 | title = str(element.public_id) |
|---|
| 1286 | else: |
|---|
| 1287 | title = element.title |
|---|
| 1288 | return element.element_type + ' : ' + title |
|---|
| 1289 | |
|---|
| 1290 | def item_description(self, r): |
|---|
| 1291 | revision = r['revision'] |
|---|
| 1292 | element = r['element'] |
|---|
| 1293 | description = '<b>modified by ' + revision.user.username + ' on ' + unicode(revision.time) + '</b><br /><br />' |
|---|
| 1294 | dict = element.to_dict() |
|---|
| 1295 | for tag in dict.keys(): |
|---|
| 1296 | try: |
|---|
| 1297 | value = dict[tag] |
|---|
| 1298 | if value != '': |
|---|
| 1299 | description += tag + ' : ' + value + '<br />' |
|---|
| 1300 | except: |
|---|
| 1301 | continue |
|---|
| 1302 | return description.encode('utf-8') |
|---|
| 1303 | |
|---|
| 1304 | def item_link(self, r): |
|---|
| 1305 | revision = r['revision'] |
|---|
| 1306 | element = r['element'] |
|---|
| 1307 | link = '/' + revision.element_type + 's/' + str(element.public_id) |
|---|
| 1308 | return link |
|---|
| 1309 | |
|---|
| 1310 | |
|---|