phantasma/app/video/views.py

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)