128 lines
4 KiB
Python
128 lines
4 KiB
Python
import logging
|
|
import json
|
|
from collections import Counter
|
|
|
|
from django.shortcuts import render, redirect, get_object_or_404
|
|
from django.views.decorators.csrf import csrf_exempt
|
|
from django.conf import settings
|
|
from django.contrib.gis.geoip2 import GeoIP2, GeoIP2Exception
|
|
import ox.geo
|
|
|
|
from . import models
|
|
|
|
logger = logging.getLogger(__name__)
|
|
|
|
stream_prefix_cache = {}
|
|
|
|
def get_ip(request):
|
|
if 'HTTP_X_FORWARDED_FOR' in request.META:
|
|
ip = request.META['HTTP_X_FORWARDED_FOR'].split(',')[0]
|
|
else:
|
|
ip = request.META['REMOTE_ADDR']
|
|
if ip.startswith('::ffff:'):
|
|
ip = ip[len('::ffff:'):]
|
|
return ip
|
|
|
|
def get_stream_prefix(request):
|
|
#domain = settings.DEFAULT_PANDORA_API.split('/')[2]
|
|
domain = 'njp.ma'
|
|
prefix = "https://media.v1.%s" % domain
|
|
cdn = {
|
|
'Eastern Asia': "https://media.v2.%s" % domain,
|
|
'Southern Asia': "https://media.v2.%s" % domain,
|
|
'Asia': "https://media.v2.%s" % domain,
|
|
}
|
|
ip = get_ip(request)
|
|
if ip in stream_prefix_cache:
|
|
return stream_prefix_cache[ip]
|
|
try:
|
|
g = GeoIP2()
|
|
country = g.country(ip)
|
|
if country:
|
|
country = ox.get_country_name(country['country_code'])
|
|
info = ox.geo.get_country(country)
|
|
for key in ('name', 'region', 'continent'):
|
|
location = info.get(key)
|
|
#print(location)
|
|
if location in cdn:
|
|
stream_prefix_cache[ip] = cdn[location]
|
|
return cdn[location]
|
|
except:
|
|
logger.error('using default prefix, no geoip data found, run ./mange.py update_geoio', exc_info=True)
|
|
stream_prefix_cache[ip] = prefix
|
|
return prefix
|
|
stream_prefix_cache[ip] = prefix
|
|
return prefix
|
|
|
|
def films(request):
|
|
context = {}
|
|
context['films'] = models.Film.objects.filter(public=True).order_by('position', 'data__title')
|
|
types = []
|
|
for f in context['films']:
|
|
types += [t.capitalize() for t in f.data['type']]
|
|
types = Counter(types)
|
|
context['types'] = []
|
|
for t in sorted(types):
|
|
context['types'].append({
|
|
'title': '%s (%s)' % (t, types[t]), 'value': t
|
|
})
|
|
|
|
context['stream_prefix'] = get_stream_prefix(request)
|
|
context['settings'] = settings
|
|
return render(request, 'films.html', context)
|
|
|
|
def film(request, slug):
|
|
context = {}
|
|
context['film'] = get_object_or_404(models.Film, slug=slug)
|
|
context['settings'] = settings
|
|
context['stream_prefix'] = get_stream_prefix(request)
|
|
context['pandora_url'] = settings.DEFAULT_PANDORA_API.replace('/api/', '')
|
|
return render(request, 'film.html', context)
|
|
|
|
def film_play(request, slug, id):
|
|
context = {}
|
|
context['settings'] = settings
|
|
context['config'] = json.dumps({
|
|
'layer': 'transcripts',
|
|
'item': id
|
|
})
|
|
context['stream_prefix'] = get_stream_prefix(request)
|
|
context['pandora_url'] = settings.DEFAULT_PANDORA_API.replace('/api/', '')
|
|
return render(request, 'film_play.html', context)
|
|
|
|
def edits(request):
|
|
context = {}
|
|
context['edits'] = models.Edit.objects.filter(public=True).order_by('created')
|
|
return render(request, 'edits.html', context)
|
|
|
|
def edit(request, slug):
|
|
context = {}
|
|
context['edit'] = get_object_or_404(models.Edit, slug=slug)
|
|
context['settings'] = settings
|
|
return render(request, 'edit.html', context)
|
|
|
|
def edit_play(request, slug, lang):
|
|
context = {}
|
|
context['edit'] = get_object_or_404(models.Edit, slug=slug)
|
|
context['lang'] = lang
|
|
context['settings'] = settings
|
|
return render(request, 'edit_play.html', context)
|
|
|
|
def tv(request):
|
|
context = {}
|
|
context['settings'] = settings
|
|
return render(request, 'tv.html', context)
|
|
|
|
|
|
@csrf_exempt
|
|
def pandoraAPI(request):
|
|
import ox
|
|
from .utils import render_to_json_response
|
|
import json
|
|
data = json.loads(request.body.decode())
|
|
print('pandora request', data)
|
|
api = ox.api.signin('https://pad.ma/api/')
|
|
data = getattr(api, data['action'])(**data['data'])
|
|
print('response', data)
|
|
return render_to_json_response(data)
|
|
|