'''

List flv and f4v medias, replace them with mp4 urls and update the content and projects.

'''

import csv

import logging

import re

from itertools import chain

import requests

from django.conf import settings

from django.contrib.sites.models import Site

from django.core.management.base import BaseCommand

from django.core import management

from lxml import etree

from ldt.ldt_utils import models

#this function replace bad suffixs and prefixs of some media URL

#by a new one, beginning with "http" and ending with ".mp4"

    '''

    to https

    '''

    if source[len(source)-3:len(source)] == 'MP4' or source[len(source)-3:len(source)] == 'mp4'\

        or not re.match(r".*\..{3}$", source):

        tomp4 = 0

    if tomp4 == 1:

        source = source[0:len(source)-3]+"mp4"

    if source[0:5] == "https":

        return source

    elif source[0:4] == "http" or source[0:4] == "sftp":

        return "https"+source[4:len(source)]

    elif source[0:7] == "/video/":

        return "https://media.iri.centrepompidou.fr"+source

    elif source[0:6] == "video/" or source[0:6] == "audio/":

        return "https://media.iri.centrepompidou.fr/"+source

    elif vidpath == 'rtmp://media.iri.centrepompidou.fr/ddc_player/video/regardssignes/' or \

        vidpath == 'rtmp://media.iri.centrepompidou.fr/ddc_player/mp4:video/regardssignes/':

        return "https://media.iri.centrepompidou.fr/video/regardssignes/"+source

    elif source[0:4] == "mp4:":

        if vidpath == 'rtmp://media.iri.centrepompidou.fr/ddc_player/':

            if re.match(r".*\..{3}$", source):

                return "https://media.iri.centrepompidou.fr/" + source[4:]

            return "https://media.iri.centrepompidou.fr/" + source[4:] + ".mp4"

    return "https://media.iri.centrepompidou.fr/video/ldtplatform/"+source

    '''

    '''

    return len(models.Content.objects.filter(media_obj_id=source.id))

    '''

    '''

        return len(models.Project.objects.filter\

                (content=models.Content.objects.filter(media_obj_id=source.id)[0]))

    return 0

    '''

    construct youtube video oembed link

    '''

    if re.match(r".*feature=player_embedded.+", source) != None:

        return "http://www.youtube.com/oembed?url=http://youtube.com/watch?v="\

        + source[len(source)-11:] +"&format=json"

    return "http://www.youtube.com/oembed?url=" + source + "&format=json"

class Command(BaseCommand):

    '''

    Command class

    '''

    help = 'delete medias without contents, replace media\'s source by a new URL'

        '''

        construct ldt embed

        '''

        return "http://{base_url}ldtplatform/ldt/embed/v3/config?json_url=" \

                   "http://{base_url}ldtplatform/ldt/cljson/id/{ldt_id}&" \

                   "player_id=player_project_{ldt_id}&" \

        '''

        change media objects' videopath and source if necessary

        change project .ldt

        '''

        basesrc = element.src

        if force:

            element.videopath = ''

            element.save()

        if newsrc != None:

            if force:

                element.src = newsrc

                element.save()

                "Media",

                basesrc,

                "Yes",

                "changing source/videopath",

                newsrc, "\'\'"

                ])

                "Project",

                element.src,

                "Yes",

                "initializing object(no project)"

                ])

            if force:

                mycontentid = models.Content.objects.filter(media_obj_id=element.id)[0].iri_id

                try:

                    management.call_command('initfrontproject', mycontentid)

                except Exception:

                    return

                self.stdout.write(" Initializing project", ending='')

            else:

                self.stdout.write(" Project has to be initialized ", ending='')

                return

        ldtproj = models.Project.objects.filter\

        (content=models.Content.objects.filter(media_obj_id=element.id)[0])

        for singleproject in ldtproj:

            if root.xpath('medias/media') == []:

                self.stdout.write(" le .ldt ne contient pas de media", ending='')

                continue

            if root.xpath('medias/media')[0].get("video") != '':

                if force:

                    root.xpath('medias/media')[0].set("video", '')

                    "Project",

                    embedurl,

                    "Yes",

                    "changing .ldt /medias/media/video",

                    "\'\'"

                    ])

                singleproject.ldt = etree.tostring(root)

                singleproject.save()

        element.save()

    def handle(self, *args, **options):

        '''

        handle

        '''

            "Object type",

            "which object",

            "Change ?",

            "What(if Y)/Why (if N)",

            "How"

            ])

        j = 0

        files1 = models.Media.objects.all() #this list contains every media

        for elem1 in files1:

                if force:

                    elem1.delete()  #if there is no content

                    #linked to the media, the media is removed for the database

                    self.stdout.write(" No content found, media has been removed")

                else:

                    self.stdout.write(" No content found, media will be removed")

                    "Media",

                    elem1.src,

                    "Yes",

                    "deleting object (no content)"

                    ])

                j += 1

                continue

            if re.match(r".*\.youtube\.com.*", elem1.src) != None\

            or re.match(r".*youtu\.be.+", elem1.src) != None:

                if requests.get(myembed).status_code == 404:

                    self.stdout.write("%s : Video doesn't exists"% elem1.src)

                        ldtproj = models.Project.objects.get(id=models.Content.objects.filter\

                        (media_obj_id=elem1.id)[0].front_project_id).ldt

                        if root.xpath('annotations/content/ensemble/decoupage/elements/element')\

                        == []:

                            if force:

                                elem1.delete()

                                self.stdout.write("video doesn't exist anymore : media deleted")

                                "Media/Content/Project",

                                elem1.src,

                                "Yes",

                                "deleting(Video doesn't exist anymore + empty projects)"

                                ])

                            j += 1

                else:

        if force:

            self.stdout.write("%s files deleted"%j)

        else:

            self.stdout.write("%s files to delete"%j)

        i = 0

        files = list(chain(

            models.Media.objects.filter(src__iregex=r".*.flv$"),

            models.Media.objects.filter(src__iregex=r".*.f4v$"),

            models.Media.objects.filter(src__iregex=r".*.m4v$"),

            models.Media.objects.filter(src__iregex=r".*.mp4$").exclude(src__iregex=r"^https://.*"),

            models.Media.objects.filter(src__iregex=r"^mp4:.*").exclude(src__iregex=r".*\..{3}$")

        ))

        for elem in files:

            self.stdout.write(" \n%s/%s files done"%(i+1, len(files)), ending='')

            i += 1

                continue

            mysrc = elem.src

            try:

                res = requests.head(newsource, timeout=10).status_code

            except requests.ConnectionError:

                self.stdout.write(" connection error", ending='')

                try:

                    res = requests.head(elem, timeout=10).status_code

                except requests.ConnectionError:

                        "Media",

                        mysrc,

                        "No",

                        "connection error",

                        newsource

                        ])

                    continue

                except (requests.exceptions.MissingSchema, requests.exceptions.InvalidSchema):

                        "Media",

                        mysrc,

                        "No",

                        "missing schema on base source!",

                        newsource

                        ])

                    continue

                except requests.exceptions.Timeout:

                        "Media",

                        mysrc,

                        "No",

                        "TIMEOUT!",

                        newsource

                        ])

                    continue

                else:

                        "Media",

                        mysrc,

                        "No",

                        "use source link : website doesn't work with https",

                        newsource

                        ])

                    continue

            except (requests.exceptions.MissingSchema, requests.exceptions.InvalidSchema):

                self.stdout.write(" Missing schema !", ending='')

                    "Media",

                    mysrc,

                    "No",

                    "missing schema!",

                    newsource

                    ])

                continue

            except requests.exceptions.Timeout:

                self.stdout.write(" Timeout !", ending='')

                    "Media",

                    mysrc,

                    "No",

                    "TIMEOUT!",

                    newsource

                    ])

                continue

            if res > 400:

                try:

                    timeout=10).status_code

                except (requests.exceptions.Timeout, requests.ConnectionError):

                    self.stdout.write(" can't access source/new files", ending='')

                    res = "connection error"

                        "Media",

                        mysrc,

                        "No",

                        "website doesn't exist anymore",

                        newsource

                        ])

                    continue

                if ressrc == 404:

                    self.stdout.write(" can't access source/new files", ending='')

                        "Media",

                        mysrc,

                        "No",

                        "can't access source/new files",

                        newsource

                        ])

                elif ressrc == 200:

                    self.stdout.write(

                        " file not transcoded yet :"

                        ending='')

                        "Media",

                        mysrc,

                        "No",

                        "file not transcoded yet : keep source extension",

                        newsource

                        ])

                continue

            self.stdout.write(" It works", ending='')

            alreadyin = False

            for everyelem in models.Media.objects.all():

                if newsource == everyelem.src:

                    alreadyin = True

                    break

            if alreadyin:

                self.stdout.write(" element already in table", ending='')