# -*- coding: utf-8 -*-

# Execute with
# $ python spycis/__main__.py (2.6+)
# $ python -m spycis          (2.7+)

from __future__ import (
    absolute_import, division, generators,
    unicode_literals, print_function,
    nested_scopes, with_statement
)

import sys
import argparse
from mimetypes import guess_extension, guess_type
import logging
import os

if __package__ is None and not hasattr(sys, "frozen"):
    # direct call of __main__.py
    path = os.path.realpath(os.path.abspath(__file__))
    sys.path.append(os.path.dirname(os.path.dirname(path)))

from spycis import wrappers
from spycis.downloader import Downloader
from spycis.utils import (
    Color,
    set_color,
    get_absolute_path,
    is_local_file,
    is_stream_url,
    is_raw_url,
    urlparse,
)


__version__ = "0.0.6.1"


def get_logger():
    class LogFormatter(logging.Formatter):
        color = {
            "HEADER": '\033[95m',       # magenta
            "DEBUG": '\033[94m',        # blue
            "INFO": '\033[92m',         # green
            "WARNING": '\033[93m',      # yellow
            "WARN": '\033[93m',         # yellow
            "ERROR": '\033[91m',        # red
            "CRITICAL": '\033[41m',     # background red
            "FATAL": '\033[41m',        # background red
            "ENDC": '\033[0m',          # end formatting
        }

        def format(self, record):
            final_msg = super(LogFormatter, self).format(record)

            level = record.__dict__['levelname']
            fmessage = "{0}{1:<.200}{2}".format(
                LogFormatter.color[level],
                final_msg,
                LogFormatter.color['ENDC'],
            )
            return fmessage

    root = logging.getLogger()
    handler = logging.StreamHandler()
    bf = LogFormatter('%(levelname)s:%(module)s:%(message)s')
    handler.setFormatter(bf)
    root.addHandler(handler)

    return root


def get_version():
    return "Spycis v{}".format(__version__)


class SiteList(argparse.Action):

    def __call__(self, parser, namespace, values, option_string=None):
        print("List of available sites: ")
        print("\n".join(w.name for w in wrappers.get_instances()))
        print('')
        parser.exit()


def get_args():
    aparser = argparse.ArgumentParser()
    group = aparser.add_argument_group('Optionnel basique')

    group.add_argument("-r", "--raw-urls", metavar="sSSeEE",
                       help="Retourne les raw urls pour le code. "
                       "ex: `-r s02e31` ou `--raw-urls  s02e31`")
    group.add_argument("-s", "--stream-urls", metavar="sSSeEE",
                       help="Retourne les stream urls pour le code"
                       ". ex: `-s s02e31` ou `--stream-urls  s02e31`")
    group.add_argument("-p", "--position", type=int, default=1,
                       help="Options utilisé avec `-r` ou `-s` pour "
                       "specifié la positon¹. ex: `-p 2 -r s02e31`")

    group2 = aparser.add_argument_group('Optionnel bonus')
    group2.add_argument("--play", action="store_true",
                        help="Executer le premier fichier que "
                        "match le pattern. ex: `--play mp4`")
    group2.add_argument("--player", default="vlc",
                        help="Choisir le player pour l'option play "
                        "ex: `--player amarok`")
    group2.add_argument("--download", action="store_true",
                        help="Télécharge le premier fichier "
                        "que match le pattern. ex: `--download mp4`")
    group2.add_argument("--stream", action="store_true",
                        help="Ouvre streaming sur la porte specifié. "
                        "ex: `--stream 8080`")
    group2.add_argument("--stream-port", default=8080, type=int,
                        help="Streaming sur la porte HTTP choisi "
                        "ex: `--stream-port 9000`")
    group2.add_argument("--subtitles",
                        help="Ouvre streaming pour les soustitres "
                        "ex: `--subtitles mes_sous_titres.srt`")
    group2.add_argument("--pattern", default=".",
                        help="Specifie le pattern pour trier "
                        "ex: `--pattern .mp4`")

    group3 = aparser.add_argument_group('Optionnel avancée')
    group3.add_argument("-v", "--verbose", action="count",
                        help="active le mode verbose pour debugging")
    group3.add_argument("--site", default="tubeplus",
                        help="Changer le site de recherche. "
                        "ex: `--site sitename`")
    group3.add_argument("--site-list", action=SiteList, nargs="?",
                        help="lister les sites de recherche disponibles")
    group3.add_argument("--workers", action="store", type=int, default=4,
                        help="Nombre des threads pour l'execution "
                        "ex: `--workers 20`")
    group3.add_argument("--version", action='version',
                        version=get_version(), help="imprime version")

    group3.add_argument("query",
                        help="L'argument principale pour les recherches")

    args = aparser.parse_args()
    return args


def print_available_sites():
    print("")
    print("List of available sites: ")
    for site in wrappers.get_instances():
        print("  {}".format(site.name))
    print("")


def clean_search_by_code(func):
    from functools import wraps

    @wraps(func)
    def wrapper(*args, **kwargs):
        try:
            return func(*args, **kwargs)
        except ValueError as e:
            print('{}'.format(e.message))
            sys.exit(1)
    return wrapper


@clean_search_by_code
def run(args=None):
    if not args:
        args = get_args()

    logger = get_logger()
    if args.verbose:
        logger.setLevel(logging.DEBUG)
        raw_url_info = True if args.verbose > 1 else False
    else:
        logger.setLevel(logging.CRITICAL)
        raw_url_info = False

    downloader = Downloader(
        workers=args.workers, raw_url_info=raw_url_info)

    site = wrappers.get_instance(args.site)
    if not site:
        print("ERROR: Not an available site. try: `spycis --site-list`")
        sys.exit(1)

    if site.is_valid_url(url=args.query):
        """Get stream urls from media url from stream url specified"""
        logging.debug("Found valid media url: '{}'".format(args.query))

        url = args.query
        code = args.raw_urls if args.raw_urls else args.stream_urls
        streams = site.get_streams(url, code=code)
        if args.raw_urls:
            downloader.extract(s.url for s in streams)
        else:
            for stream in streams:
                fstr = "{:<60} {:<25} subtitles={}".format(
                    stream.url,
                    "[{}]".format(set_color(stream.language, Color.RED)),
                    stream.subtitles)
                print(fstr)

    elif is_stream_url(url=args.query):
        """Extract raw urls from stream url specified"""
        logging.debug("Found valid stream url: '{}'".format(args.query))

        url = args.query
        downloader.extract([url])

    elif is_raw_url(url=args.query) or is_local_file(path=args.query):
        """Add raw url or local file to raw url list"""
        logging.debug("Found valid file/raw url: '{}'".format(args.query))

        url = args.query
        if is_raw_url(url=url):
            parsed_url = urlparse(url)
            title = os.path.basename(parsed_url.path)
        elif is_local_file(path=url):
            filepath = get_absolute_path(url)
            title = os.path.basename(filepath)
        extension = guess_extension(guess_type(filepath)[0])

        info = {
            "id": "unknown",
            "webpage_url": "unknown",
            "title": title,
            "url": url,
            "ext": extension,
        }
        downloader.info_list.append(info)
        logging.debug('added raw url: {}'.format(info['url']))

    else:
        import pdb; pdb.set_trace()
        medias = site.search(args.query)
        try:
            position = args.position - 1 if args.position != 0 else args.position
            chosen_media_url = medias[position].url
        except IndexError:
            logging.error("Not a valid position")
            return None
        except TypeError:
            logging.error("No media url was found")
            return None

        code = (args.stream_urls if args.stream_urls else
                args.raw_urls if args.raw_urls else
                None)

        streams = site.get_streams(chosen_media_url, code=code)

        if args.stream_urls:
            """
            Obtenir les stream urls pour la position 0 ou
            autre si position specifié
            """
            for stream in streams:
                fstr = "{:<60} {:<25} subtitles={}".format(
                    stream.url,
                    "[{}]".format(set_color(stream.language, Color.RED)),
                    stream.subtitles)
                print(fstr)

        elif args.raw_urls:
            """
            Obtenir les raw urls pour la position 0 ou
            autre si position specifié
            """
            downloader.extract(s.url for s in streams)

        elif args.position:
            """
            Obtenir les raw urls pour la position de
            recherche specifié.

            Attention ça marche que pour les film, pour les series au moins
            un code episode doit être informé au format:-p 30 -r s01e01
            """
            downloader.extract(s.url for s in streams)

        else:
            for position, media in enumerate(medias, start=1):
                position_line = "{0:<15} {1:<15} {2:<55} [{3}] ({4})".format(
                    "[{}]".format(set_color(position, Color.YELLOW)),
                    [media.category],
                    set_color(repr("{:.42}".format(media.title)), Color.GREEN),
                    set_color(media.year, Color.YELLOW),
                    media.url
                )
                print(position_line)

    # Bonus options
    if args.download:
        pattern = args.pattern
        downloader.download(pattern=pattern,)
    elif args.play and downloader.info_list:
        pattern = args.pattern
        player = args.player
        downloader.play(pattern=pattern, player=player)
    elif args.stream and downloader.info_list:
        pattern = args.pattern
        stream_port = args.stream_port
        subtitles = args.subtitles
        downloader.stream(pattern=pattern,
                          stream_port=stream_port,
                          subtitles=subtitles)

if __name__ == '__main__':
    try:
        run(get_args())
    except KeyboardInterrupt:
        sys.stderr.flush()
        print("")

2e8ff25c7ed16ade70fa429bd8f4cb6e4f11b2b2
<mask token>


def get_logger():


    class LogFormatter(logging.Formatter):
        color = {'HEADER': '\x1b[95m', 'DEBUG': '\x1b[94m', 'INFO':
            '\x1b[92m', 'WARNING': '\x1b[93m', 'WARN': '\x1b[93m', 'ERROR':
            '\x1b[91m', 'CRITICAL': '\x1b[41m', 'FATAL': '\x1b[41m', 'ENDC':
            '\x1b[0m'}

        def format(self, record):
            final_msg = super(LogFormatter, self).format(record)
            level = record.__dict__['levelname']
            fmessage = '{0}{1:<.200}{2}'.format(LogFormatter.color[level],
                final_msg, LogFormatter.color['ENDC'])
            return fmessage
    root = logging.getLogger()
    handler = logging.StreamHandler()
    bf = LogFormatter('%(levelname)s:%(module)s:%(message)s')
    handler.setFormatter(bf)
    root.addHandler(handler)
    return root


def get_version():
    return 'Spycis v{}'.format(__version__)


class SiteList(argparse.Action):

    def __call__(self, parser, namespace, values, option_string=None):
        print('List of available sites: ')
        print('\n'.join(w.name for w in wrappers.get_instances()))
        print('')
        parser.exit()


<mask token>


def clean_search_by_code(func):
    from functools import wraps

    @wraps(func)
    def wrapper(*args, **kwargs):
        try:
            return func(*args, **kwargs)
        except ValueError as e:
            print('{}'.format(e.message))
            sys.exit(1)
    return wrapper


@clean_search_by_code
def run(args=None):
    if not args:
        args = get_args()
    logger = get_logger()
    if args.verbose:
        logger.setLevel(logging.DEBUG)
        raw_url_info = True if args.verbose > 1 else False
    else:
        logger.setLevel(logging.CRITICAL)
        raw_url_info = False
    downloader = Downloader(workers=args.workers, raw_url_info=raw_url_info)
    site = wrappers.get_instance(args.site)
    if not site:
        print('ERROR: Not an available site. try: `spycis --site-list`')
        sys.exit(1)
    if site.is_valid_url(url=args.query):
        """Get stream urls from media url from stream url specified"""
        logging.debug("Found valid media url: '{}'".format(args.query))
        url = args.query
        code = args.raw_urls if args.raw_urls else args.stream_urls
        streams = site.get_streams(url, code=code)
        if args.raw_urls:
            downloader.extract(s.url for s in streams)
        else:
            for stream in streams:
                fstr = '{:<60} {:<25} subtitles={}'.format(stream.url,
                    '[{}]'.format(set_color(stream.language, Color.RED)),
                    stream.subtitles)
                print(fstr)
    elif is_stream_url(url=args.query):
        """Extract raw urls from stream url specified"""
        logging.debug("Found valid stream url: '{}'".format(args.query))
        url = args.query
        downloader.extract([url])
    elif is_raw_url(url=args.query) or is_local_file(path=args.query):
        """Add raw url or local file to raw url list"""
        logging.debug("Found valid file/raw url: '{}'".format(args.query))
        url = args.query
        if is_raw_url(url=url):
            parsed_url = urlparse(url)
            title = os.path.basename(parsed_url.path)
        elif is_local_file(path=url):
            filepath = get_absolute_path(url)
            title = os.path.basename(filepath)
        extension = guess_extension(guess_type(filepath)[0])
        info = {'id': 'unknown', 'webpage_url': 'unknown', 'title': title,
            'url': url, 'ext': extension}
        downloader.info_list.append(info)
        logging.debug('added raw url: {}'.format(info['url']))
    else:
        import pdb
        pdb.set_trace()
        medias = site.search(args.query)
        try:
            position = (args.position - 1 if args.position != 0 else args.
                position)
            chosen_media_url = medias[position].url
        except IndexError:
            logging.error('Not a valid position')
            return None
        except TypeError:
            logging.error('No media url was found')
            return None
        code = (args.stream_urls if args.stream_urls else args.raw_urls if
            args.raw_urls else None)
        streams = site.get_streams(chosen_media_url, code=code)
        if args.stream_urls:
            """
            Obtenir les stream urls pour la position 0 ou
            autre si position specifié
            """
            for stream in streams:
                fstr = '{:<60} {:<25} subtitles={}'.format(stream.url,
                    '[{}]'.format(set_color(stream.language, Color.RED)),
                    stream.subtitles)
                print(fstr)
        elif args.raw_urls:
            """
            Obtenir les raw urls pour la position 0 ou
            autre si position specifié
            """
            downloader.extract(s.url for s in streams)
        elif args.position:
            """
            Obtenir les raw urls pour la position de
            recherche specifié.

            Attention ça marche que pour les film, pour les series au moins
            un code episode doit être informé au format:-p 30 -r s01e01
            """
            downloader.extract(s.url for s in streams)
        else:
            for position, media in enumerate(medias, start=1):
                position_line = '{0:<15} {1:<15} {2:<55} [{3}] ({4})'.format(
                    '[{}]'.format(set_color(position, Color.YELLOW)), [
                    media.category], set_color(repr('{:.42}'.format(media.
                    title)), Color.GREEN), set_color(media.year, Color.
                    YELLOW), media.url)
                print(position_line)
    if args.download:
        pattern = args.pattern
        downloader.download(pattern=pattern)
    elif args.play and downloader.info_list:
        pattern = args.pattern
        player = args.player
        downloader.play(pattern=pattern, player=player)
    elif args.stream and downloader.info_list:
        pattern = args.pattern
        stream_port = args.stream_port
        subtitles = args.subtitles
        downloader.stream(pattern=pattern, stream_port=stream_port,
            subtitles=subtitles)


<mask token>

<mask token>


def get_logger():


    class LogFormatter(logging.Formatter):
        color = {'HEADER': '\x1b[95m', 'DEBUG': '\x1b[94m', 'INFO':
            '\x1b[92m', 'WARNING': '\x1b[93m', 'WARN': '\x1b[93m', 'ERROR':
            '\x1b[91m', 'CRITICAL': '\x1b[41m', 'FATAL': '\x1b[41m', 'ENDC':
            '\x1b[0m'}

        def format(self, record):
            final_msg = super(LogFormatter, self).format(record)
            level = record.__dict__['levelname']
            fmessage = '{0}{1:<.200}{2}'.format(LogFormatter.color[level],
                final_msg, LogFormatter.color['ENDC'])
            return fmessage
    root = logging.getLogger()
    handler = logging.StreamHandler()
    bf = LogFormatter('%(levelname)s:%(module)s:%(message)s')
    handler.setFormatter(bf)
    root.addHandler(handler)
    return root


def get_version():
    return 'Spycis v{}'.format(__version__)


class SiteList(argparse.Action):

    def __call__(self, parser, namespace, values, option_string=None):
        print('List of available sites: ')
        print('\n'.join(w.name for w in wrappers.get_instances()))
        print('')
        parser.exit()


<mask token>


def print_available_sites():
    print('')
    print('List of available sites: ')
    for site in wrappers.get_instances():
        print('  {}'.format(site.name))
    print('')


def clean_search_by_code(func):
    from functools import wraps

    @wraps(func)
    def wrapper(*args, **kwargs):
        try:
            return func(*args, **kwargs)
        except ValueError as e:
            print('{}'.format(e.message))
            sys.exit(1)
    return wrapper


@clean_search_by_code
def run(args=None):
    if not args:
        args = get_args()
    logger = get_logger()
    if args.verbose:
        logger.setLevel(logging.DEBUG)
        raw_url_info = True if args.verbose > 1 else False
    else:
        logger.setLevel(logging.CRITICAL)
        raw_url_info = False
    downloader = Downloader(workers=args.workers, raw_url_info=raw_url_info)
    site = wrappers.get_instance(args.site)
    if not site:
        print('ERROR: Not an available site. try: `spycis --site-list`')
        sys.exit(1)
    if site.is_valid_url(url=args.query):
        """Get stream urls from media url from stream url specified"""
        logging.debug("Found valid media url: '{}'".format(args.query))
        url = args.query
        code = args.raw_urls if args.raw_urls else args.stream_urls
        streams = site.get_streams(url, code=code)
        if args.raw_urls:
            downloader.extract(s.url for s in streams)
        else:
            for stream in streams:
                fstr = '{:<60} {:<25} subtitles={}'.format(stream.url,
                    '[{}]'.format(set_color(stream.language, Color.RED)),
                    stream.subtitles)
                print(fstr)
    elif is_stream_url(url=args.query):
        """Extract raw urls from stream url specified"""
        logging.debug("Found valid stream url: '{}'".format(args.query))
        url = args.query
        downloader.extract([url])
    elif is_raw_url(url=args.query) or is_local_file(path=args.query):
        """Add raw url or local file to raw url list"""
        logging.debug("Found valid file/raw url: '{}'".format(args.query))
        url = args.query
        if is_raw_url(url=url):
            parsed_url = urlparse(url)
            title = os.path.basename(parsed_url.path)
        elif is_local_file(path=url):
            filepath = get_absolute_path(url)
            title = os.path.basename(filepath)
        extension = guess_extension(guess_type(filepath)[0])
        info = {'id': 'unknown', 'webpage_url': 'unknown', 'title': title,
            'url': url, 'ext': extension}
        downloader.info_list.append(info)
        logging.debug('added raw url: {}'.format(info['url']))
    else:
        import pdb
        pdb.set_trace()
        medias = site.search(args.query)
        try:
            position = (args.position - 1 if args.position != 0 else args.
                position)
            chosen_media_url = medias[position].url
        except IndexError:
            logging.error('Not a valid position')
            return None
        except TypeError:
            logging.error('No media url was found')
            return None
        code = (args.stream_urls if args.stream_urls else args.raw_urls if
            args.raw_urls else None)
        streams = site.get_streams(chosen_media_url, code=code)
        if args.stream_urls:
            """
            Obtenir les stream urls pour la position 0 ou
            autre si position specifié
            """
            for stream in streams:
                fstr = '{:<60} {:<25} subtitles={}'.format(stream.url,
                    '[{}]'.format(set_color(stream.language, Color.RED)),
                    stream.subtitles)
                print(fstr)
        elif args.raw_urls:
            """
            Obtenir les raw urls pour la position 0 ou
            autre si position specifié
            """
            downloader.extract(s.url for s in streams)
        elif args.position:
            """
            Obtenir les raw urls pour la position de
            recherche specifié.

            Attention ça marche que pour les film, pour les series au moins
            un code episode doit être informé au format:-p 30 -r s01e01
            """
            downloader.extract(s.url for s in streams)
        else:
            for position, media in enumerate(medias, start=1):
                position_line = '{0:<15} {1:<15} {2:<55} [{3}] ({4})'.format(
                    '[{}]'.format(set_color(position, Color.YELLOW)), [
                    media.category], set_color(repr('{:.42}'.format(media.
                    title)), Color.GREEN), set_color(media.year, Color.
                    YELLOW), media.url)
                print(position_line)
    if args.download:
        pattern = args.pattern
        downloader.download(pattern=pattern)
    elif args.play and downloader.info_list:
        pattern = args.pattern
        player = args.player
        downloader.play(pattern=pattern, player=player)
    elif args.stream and downloader.info_list:
        pattern = args.pattern
        stream_port = args.stream_port
        subtitles = args.subtitles
        downloader.stream(pattern=pattern, stream_port=stream_port,
            subtitles=subtitles)


<mask token>

<mask token>


def get_logger():


    class LogFormatter(logging.Formatter):
        color = {'HEADER': '\x1b[95m', 'DEBUG': '\x1b[94m', 'INFO':
            '\x1b[92m', 'WARNING': '\x1b[93m', 'WARN': '\x1b[93m', 'ERROR':
            '\x1b[91m', 'CRITICAL': '\x1b[41m', 'FATAL': '\x1b[41m', 'ENDC':
            '\x1b[0m'}

        def format(self, record):
            final_msg = super(LogFormatter, self).format(record)
            level = record.__dict__['levelname']
            fmessage = '{0}{1:<.200}{2}'.format(LogFormatter.color[level],
                final_msg, LogFormatter.color['ENDC'])
            return fmessage
    root = logging.getLogger()
    handler = logging.StreamHandler()
    bf = LogFormatter('%(levelname)s:%(module)s:%(message)s')
    handler.setFormatter(bf)
    root.addHandler(handler)
    return root


def get_version():
    return 'Spycis v{}'.format(__version__)


class SiteList(argparse.Action):

    def __call__(self, parser, namespace, values, option_string=None):
        print('List of available sites: ')
        print('\n'.join(w.name for w in wrappers.get_instances()))
        print('')
        parser.exit()


def get_args():
    aparser = argparse.ArgumentParser()
    group = aparser.add_argument_group('Optionnel basique')
    group.add_argument('-r', '--raw-urls', metavar='sSSeEE', help=
        'Retourne les raw urls pour le code. ex: `-r s02e31` ou `--raw-urls  s02e31`'
        )
    group.add_argument('-s', '--stream-urls', metavar='sSSeEE', help=
        'Retourne les stream urls pour le code. ex: `-s s02e31` ou `--stream-urls  s02e31`'
        )
    group.add_argument('-p', '--position', type=int, default=1, help=
        'Options utilisé avec `-r` ou `-s` pour specifié la positon¹. ex: `-p 2 -r s02e31`'
        )
    group2 = aparser.add_argument_group('Optionnel bonus')
    group2.add_argument('--play', action='store_true', help=
        'Executer le premier fichier que match le pattern. ex: `--play mp4`')
    group2.add_argument('--player', default='vlc', help=
        "Choisir le player pour l'option play ex: `--player amarok`")
    group2.add_argument('--download', action='store_true', help=
        'Télécharge le premier fichier que match le pattern. ex: `--download mp4`'
        )
    group2.add_argument('--stream', action='store_true', help=
        'Ouvre streaming sur la porte specifié. ex: `--stream 8080`')
    group2.add_argument('--stream-port', default=8080, type=int, help=
        'Streaming sur la porte HTTP choisi ex: `--stream-port 9000`')
    group2.add_argument('--subtitles', help=
        'Ouvre streaming pour les soustitres ex: `--subtitles mes_sous_titres.srt`'
        )
    group2.add_argument('--pattern', default='.', help=
        'Specifie le pattern pour trier ex: `--pattern .mp4`')
    group3 = aparser.add_argument_group('Optionnel avancée')
    group3.add_argument('-v', '--verbose', action='count', help=
        'active le mode verbose pour debugging')
    group3.add_argument('--site', default='tubeplus', help=
        'Changer le site de recherche. ex: `--site sitename`')
    group3.add_argument('--site-list', action=SiteList, nargs='?', help=
        'lister les sites de recherche disponibles')
    group3.add_argument('--workers', action='store', type=int, default=4,
        help="Nombre des threads pour l'execution ex: `--workers 20`")
    group3.add_argument('--version', action='version', version=get_version(
        ), help='imprime version')
    group3.add_argument('query', help=
        "L'argument principale pour les recherches")
    args = aparser.parse_args()
    return args


def print_available_sites():
    print('')
    print('List of available sites: ')
    for site in wrappers.get_instances():
        print('  {}'.format(site.name))
    print('')


def clean_search_by_code(func):
    from functools import wraps

    @wraps(func)
    def wrapper(*args, **kwargs):
        try:
            return func(*args, **kwargs)
        except ValueError as e:
            print('{}'.format(e.message))
            sys.exit(1)
    return wrapper


@clean_search_by_code
def run(args=None):
    if not args:
        args = get_args()
    logger = get_logger()
    if args.verbose:
        logger.setLevel(logging.DEBUG)
        raw_url_info = True if args.verbose > 1 else False
    else:
        logger.setLevel(logging.CRITICAL)
        raw_url_info = False
    downloader = Downloader(workers=args.workers, raw_url_info=raw_url_info)
    site = wrappers.get_instance(args.site)
    if not site:
        print('ERROR: Not an available site. try: `spycis --site-list`')
        sys.exit(1)
    if site.is_valid_url(url=args.query):
        """Get stream urls from media url from stream url specified"""
        logging.debug("Found valid media url: '{}'".format(args.query))
        url = args.query
        code = args.raw_urls if args.raw_urls else args.stream_urls
        streams = site.get_streams(url, code=code)
        if args.raw_urls:
            downloader.extract(s.url for s in streams)
        else:
            for stream in streams:
                fstr = '{:<60} {:<25} subtitles={}'.format(stream.url,
                    '[{}]'.format(set_color(stream.language, Color.RED)),
                    stream.subtitles)
                print(fstr)
    elif is_stream_url(url=args.query):
        """Extract raw urls from stream url specified"""
        logging.debug("Found valid stream url: '{}'".format(args.query))
        url = args.query
        downloader.extract([url])
    elif is_raw_url(url=args.query) or is_local_file(path=args.query):
        """Add raw url or local file to raw url list"""
        logging.debug("Found valid file/raw url: '{}'".format(args.query))
        url = args.query
        if is_raw_url(url=url):
            parsed_url = urlparse(url)
            title = os.path.basename(parsed_url.path)
        elif is_local_file(path=url):
            filepath = get_absolute_path(url)
            title = os.path.basename(filepath)
        extension = guess_extension(guess_type(filepath)[0])
        info = {'id': 'unknown', 'webpage_url': 'unknown', 'title': title,
            'url': url, 'ext': extension}
        downloader.info_list.append(info)
        logging.debug('added raw url: {}'.format(info['url']))
    else:
        import pdb
        pdb.set_trace()
        medias = site.search(args.query)
        try:
            position = (args.position - 1 if args.position != 0 else args.
                position)
            chosen_media_url = medias[position].url
        except IndexError:
            logging.error('Not a valid position')
            return None
        except TypeError:
            logging.error('No media url was found')
            return None
        code = (args.stream_urls if args.stream_urls else args.raw_urls if
            args.raw_urls else None)
        streams = site.get_streams(chosen_media_url, code=code)
        if args.stream_urls:
            """
            Obtenir les stream urls pour la position 0 ou
            autre si position specifié
            """
            for stream in streams:
                fstr = '{:<60} {:<25} subtitles={}'.format(stream.url,
                    '[{}]'.format(set_color(stream.language, Color.RED)),
                    stream.subtitles)
                print(fstr)
        elif args.raw_urls:
            """
            Obtenir les raw urls pour la position 0 ou
            autre si position specifié
            """
            downloader.extract(s.url for s in streams)
        elif args.position:
            """
            Obtenir les raw urls pour la position de
            recherche specifié.

            Attention ça marche que pour les film, pour les series au moins
            un code episode doit être informé au format:-p 30 -r s01e01
            """
            downloader.extract(s.url for s in streams)
        else:
            for position, media in enumerate(medias, start=1):
                position_line = '{0:<15} {1:<15} {2:<55} [{3}] ({4})'.format(
                    '[{}]'.format(set_color(position, Color.YELLOW)), [
                    media.category], set_color(repr('{:.42}'.format(media.
                    title)), Color.GREEN), set_color(media.year, Color.
                    YELLOW), media.url)
                print(position_line)
    if args.download:
        pattern = args.pattern
        downloader.download(pattern=pattern)
    elif args.play and downloader.info_list:
        pattern = args.pattern
        player = args.player
        downloader.play(pattern=pattern, player=player)
    elif args.stream and downloader.info_list:
        pattern = args.pattern
        stream_port = args.stream_port
        subtitles = args.subtitles
        downloader.stream(pattern=pattern, stream_port=stream_port,
            subtitles=subtitles)


<mask token>

<mask token>
if __package__ is None and not hasattr(sys, 'frozen'):
    path = os.path.realpath(os.path.abspath(__file__))
    sys.path.append(os.path.dirname(os.path.dirname(path)))
<mask token>
__version__ = '0.0.6.1'


def get_logger():


    class LogFormatter(logging.Formatter):
        color = {'HEADER': '\x1b[95m', 'DEBUG': '\x1b[94m', 'INFO':
            '\x1b[92m', 'WARNING': '\x1b[93m', 'WARN': '\x1b[93m', 'ERROR':
            '\x1b[91m', 'CRITICAL': '\x1b[41m', 'FATAL': '\x1b[41m', 'ENDC':
            '\x1b[0m'}

        def format(self, record):
            final_msg = super(LogFormatter, self).format(record)
            level = record.__dict__['levelname']
            fmessage = '{0}{1:<.200}{2}'.format(LogFormatter.color[level],
                final_msg, LogFormatter.color['ENDC'])
            return fmessage
    root = logging.getLogger()
    handler = logging.StreamHandler()
    bf = LogFormatter('%(levelname)s:%(module)s:%(message)s')
    handler.setFormatter(bf)
    root.addHandler(handler)
    return root


def get_version():
    return 'Spycis v{}'.format(__version__)


class SiteList(argparse.Action):

    def __call__(self, parser, namespace, values, option_string=None):
        print('List of available sites: ')
        print('\n'.join(w.name for w in wrappers.get_instances()))
        print('')
        parser.exit()


def get_args():
    aparser = argparse.ArgumentParser()
    group = aparser.add_argument_group('Optionnel basique')
    group.add_argument('-r', '--raw-urls', metavar='sSSeEE', help=
        'Retourne les raw urls pour le code. ex: `-r s02e31` ou `--raw-urls  s02e31`'
        )
    group.add_argument('-s', '--stream-urls', metavar='sSSeEE', help=
        'Retourne les stream urls pour le code. ex: `-s s02e31` ou `--stream-urls  s02e31`'
        )
    group.add_argument('-p', '--position', type=int, default=1, help=
        'Options utilisé avec `-r` ou `-s` pour specifié la positon¹. ex: `-p 2 -r s02e31`'
        )
    group2 = aparser.add_argument_group('Optionnel bonus')
    group2.add_argument('--play', action='store_true', help=
        'Executer le premier fichier que match le pattern. ex: `--play mp4`')
    group2.add_argument('--player', default='vlc', help=
        "Choisir le player pour l'option play ex: `--player amarok`")
    group2.add_argument('--download', action='store_true', help=
        'Télécharge le premier fichier que match le pattern. ex: `--download mp4`'
        )
    group2.add_argument('--stream', action='store_true', help=
        'Ouvre streaming sur la porte specifié. ex: `--stream 8080`')
    group2.add_argument('--stream-port', default=8080, type=int, help=
        'Streaming sur la porte HTTP choisi ex: `--stream-port 9000`')
    group2.add_argument('--subtitles', help=
        'Ouvre streaming pour les soustitres ex: `--subtitles mes_sous_titres.srt`'
        )
    group2.add_argument('--pattern', default='.', help=
        'Specifie le pattern pour trier ex: `--pattern .mp4`')
    group3 = aparser.add_argument_group('Optionnel avancée')
    group3.add_argument('-v', '--verbose', action='count', help=
        'active le mode verbose pour debugging')
    group3.add_argument('--site', default='tubeplus', help=
        'Changer le site de recherche. ex: `--site sitename`')
    group3.add_argument('--site-list', action=SiteList, nargs='?', help=
        'lister les sites de recherche disponibles')
    group3.add_argument('--workers', action='store', type=int, default=4,
        help="Nombre des threads pour l'execution ex: `--workers 20`")
    group3.add_argument('--version', action='version', version=get_version(
        ), help='imprime version')
    group3.add_argument('query', help=
        "L'argument principale pour les recherches")
    args = aparser.parse_args()
    return args


def print_available_sites():
    print('')
    print('List of available sites: ')
    for site in wrappers.get_instances():
        print('  {}'.format(site.name))
    print('')


def clean_search_by_code(func):
    from functools import wraps

    @wraps(func)
    def wrapper(*args, **kwargs):
        try:
            return func(*args, **kwargs)
        except ValueError as e:
            print('{}'.format(e.message))
            sys.exit(1)
    return wrapper


@clean_search_by_code
def run(args=None):
    if not args:
        args = get_args()
    logger = get_logger()
    if args.verbose:
        logger.setLevel(logging.DEBUG)
        raw_url_info = True if args.verbose > 1 else False
    else:
        logger.setLevel(logging.CRITICAL)
        raw_url_info = False
    downloader = Downloader(workers=args.workers, raw_url_info=raw_url_info)
    site = wrappers.get_instance(args.site)
    if not site:
        print('ERROR: Not an available site. try: `spycis --site-list`')
        sys.exit(1)
    if site.is_valid_url(url=args.query):
        """Get stream urls from media url from stream url specified"""
        logging.debug("Found valid media url: '{}'".format(args.query))
        url = args.query
        code = args.raw_urls if args.raw_urls else args.stream_urls
        streams = site.get_streams(url, code=code)
        if args.raw_urls:
            downloader.extract(s.url for s in streams)
        else:
            for stream in streams:
                fstr = '{:<60} {:<25} subtitles={}'.format(stream.url,
                    '[{}]'.format(set_color(stream.language, Color.RED)),
                    stream.subtitles)
                print(fstr)
    elif is_stream_url(url=args.query):
        """Extract raw urls from stream url specified"""
        logging.debug("Found valid stream url: '{}'".format(args.query))
        url = args.query
        downloader.extract([url])
    elif is_raw_url(url=args.query) or is_local_file(path=args.query):
        """Add raw url or local file to raw url list"""
        logging.debug("Found valid file/raw url: '{}'".format(args.query))
        url = args.query
        if is_raw_url(url=url):
            parsed_url = urlparse(url)
            title = os.path.basename(parsed_url.path)
        elif is_local_file(path=url):
            filepath = get_absolute_path(url)
            title = os.path.basename(filepath)
        extension = guess_extension(guess_type(filepath)[0])
        info = {'id': 'unknown', 'webpage_url': 'unknown', 'title': title,
            'url': url, 'ext': extension}
        downloader.info_list.append(info)
        logging.debug('added raw url: {}'.format(info['url']))
    else:
        import pdb
        pdb.set_trace()
        medias = site.search(args.query)
        try:
            position = (args.position - 1 if args.position != 0 else args.
                position)
            chosen_media_url = medias[position].url
        except IndexError:
            logging.error('Not a valid position')
            return None
        except TypeError:
            logging.error('No media url was found')
            return None
        code = (args.stream_urls if args.stream_urls else args.raw_urls if
            args.raw_urls else None)
        streams = site.get_streams(chosen_media_url, code=code)
        if args.stream_urls:
            """
            Obtenir les stream urls pour la position 0 ou
            autre si position specifié
            """
            for stream in streams:
                fstr = '{:<60} {:<25} subtitles={}'.format(stream.url,
                    '[{}]'.format(set_color(stream.language, Color.RED)),
                    stream.subtitles)
                print(fstr)
        elif args.raw_urls:
            """
            Obtenir les raw urls pour la position 0 ou
            autre si position specifié
            """
            downloader.extract(s.url for s in streams)
        elif args.position:
            """
            Obtenir les raw urls pour la position de
            recherche specifié.

            Attention ça marche que pour les film, pour les series au moins
            un code episode doit être informé au format:-p 30 -r s01e01
            """
            downloader.extract(s.url for s in streams)
        else:
            for position, media in enumerate(medias, start=1):
                position_line = '{0:<15} {1:<15} {2:<55} [{3}] ({4})'.format(
                    '[{}]'.format(set_color(position, Color.YELLOW)), [
                    media.category], set_color(repr('{:.42}'.format(media.
                    title)), Color.GREEN), set_color(media.year, Color.
                    YELLOW), media.url)
                print(position_line)
    if args.download:
        pattern = args.pattern
        downloader.download(pattern=pattern)
    elif args.play and downloader.info_list:
        pattern = args.pattern
        player = args.player
        downloader.play(pattern=pattern, player=player)
    elif args.stream and downloader.info_list:
        pattern = args.pattern
        stream_port = args.stream_port
        subtitles = args.subtitles
        downloader.stream(pattern=pattern, stream_port=stream_port,
            subtitles=subtitles)


if __name__ == '__main__':
    try:
        run(get_args())
    except KeyboardInterrupt:
        sys.stderr.flush()
        print('')

# -*- coding: utf-8 -*-

# Execute with
# $ python spycis/__main__.py (2.6+)
# $ python -m spycis          (2.7+)

from __future__ import (
    absolute_import, division, generators,
    unicode_literals, print_function,
    nested_scopes, with_statement
)

import sys
import argparse
from mimetypes import guess_extension, guess_type
import logging
import os

if __package__ is None and not hasattr(sys, "frozen"):
    # direct call of __main__.py
    path = os.path.realpath(os.path.abspath(__file__))
    sys.path.append(os.path.dirname(os.path.dirname(path)))

from spycis import wrappers
from spycis.downloader import Downloader
from spycis.utils import (
    Color,
    set_color,
    get_absolute_path,
    is_local_file,
    is_stream_url,
    is_raw_url,
    urlparse,
)


__version__ = "0.0.6.1"


def get_logger():
    class LogFormatter(logging.Formatter):
        color = {
            "HEADER": '\033[95m',       # magenta
            "DEBUG": '\033[94m',        # blue
            "INFO": '\033[92m',         # green
            "WARNING": '\033[93m',      # yellow
            "WARN": '\033[93m',         # yellow
            "ERROR": '\033[91m',        # red
            "CRITICAL": '\033[41m',     # background red
            "FATAL": '\033[41m',        # background red
            "ENDC": '\033[0m',          # end formatting
        }

        def format(self, record):
            final_msg = super(LogFormatter, self).format(record)

            level = record.__dict__['levelname']
            fmessage = "{0}{1:<.200}{2}".format(
                LogFormatter.color[level],
                final_msg,
                LogFormatter.color['ENDC'],
            )
            return fmessage

    root = logging.getLogger()
    handler = logging.StreamHandler()
    bf = LogFormatter('%(levelname)s:%(module)s:%(message)s')
    handler.setFormatter(bf)
    root.addHandler(handler)

    return root


def get_version():
    return "Spycis v{}".format(__version__)


class SiteList(argparse.Action):

    def __call__(self, parser, namespace, values, option_string=None):
        print("List of available sites: ")
        print("\n".join(w.name for w in wrappers.get_instances()))
        print('')
        parser.exit()


def get_args():
    aparser = argparse.ArgumentParser()
    group = aparser.add_argument_group('Optionnel basique')

    group.add_argument("-r", "--raw-urls", metavar="sSSeEE",
                       help="Retourne les raw urls pour le code. "
                       "ex: `-r s02e31` ou `--raw-urls  s02e31`")
    group.add_argument("-s", "--stream-urls", metavar="sSSeEE",
                       help="Retourne les stream urls pour le code"
                       ". ex: `-s s02e31` ou `--stream-urls  s02e31`")
    group.add_argument("-p", "--position", type=int, default=1,
                       help="Options utilisé avec `-r` ou `-s` pour "
                       "specifié la positon¹. ex: `-p 2 -r s02e31`")

    group2 = aparser.add_argument_group('Optionnel bonus')
    group2.add_argument("--play", action="store_true",
                        help="Executer le premier fichier que "
                        "match le pattern. ex: `--play mp4`")
    group2.add_argument("--player", default="vlc",
                        help="Choisir le player pour l'option play "
                        "ex: `--player amarok`")
    group2.add_argument("--download", action="store_true",
                        help="Télécharge le premier fichier "
                        "que match le pattern. ex: `--download mp4`")
    group2.add_argument("--stream", action="store_true",
                        help="Ouvre streaming sur la porte specifié. "
                        "ex: `--stream 8080`")
    group2.add_argument("--stream-port", default=8080, type=int,
                        help="Streaming sur la porte HTTP choisi "
                        "ex: `--stream-port 9000`")
    group2.add_argument("--subtitles",
                        help="Ouvre streaming pour les soustitres "
                        "ex: `--subtitles mes_sous_titres.srt`")
    group2.add_argument("--pattern", default=".",
                        help="Specifie le pattern pour trier "
                        "ex: `--pattern .mp4`")

    group3 = aparser.add_argument_group('Optionnel avancée')
    group3.add_argument("-v", "--verbose", action="count",
                        help="active le mode verbose pour debugging")
    group3.add_argument("--site", default="tubeplus",
                        help="Changer le site de recherche. "
                        "ex: `--site sitename`")
    group3.add_argument("--site-list", action=SiteList, nargs="?",
                        help="lister les sites de recherche disponibles")
    group3.add_argument("--workers", action="store", type=int, default=4,
                        help="Nombre des threads pour l'execution "
                        "ex: `--workers 20`")
    group3.add_argument("--version", action='version',
                        version=get_version(), help="imprime version")

    group3.add_argument("query",
                        help="L'argument principale pour les recherches")

    args = aparser.parse_args()
    return args


def print_available_sites():
    print("")
    print("List of available sites: ")
    for site in wrappers.get_instances():
        print("  {}".format(site.name))
    print("")


def clean_search_by_code(func):
    from functools import wraps

    @wraps(func)
    def wrapper(*args, **kwargs):
        try:
            return func(*args, **kwargs)
        except ValueError as e:
            print('{}'.format(e.message))
            sys.exit(1)
    return wrapper


@clean_search_by_code
def run(args=None):
    if not args:
        args = get_args()

    logger = get_logger()
    if args.verbose:
        logger.setLevel(logging.DEBUG)
        raw_url_info = True if args.verbose > 1 else False
    else:
        logger.setLevel(logging.CRITICAL)
        raw_url_info = False

    downloader = Downloader(
        workers=args.workers, raw_url_info=raw_url_info)

    site = wrappers.get_instance(args.site)
    if not site:
        print("ERROR: Not an available site. try: `spycis --site-list`")
        sys.exit(1)

    if site.is_valid_url(url=args.query):
        """Get stream urls from media url from stream url specified"""
        logging.debug("Found valid media url: '{}'".format(args.query))

        url = args.query
        code = args.raw_urls if args.raw_urls else args.stream_urls
        streams = site.get_streams(url, code=code)
        if args.raw_urls:
            downloader.extract(s.url for s in streams)
        else:
            for stream in streams:
                fstr = "{:<60} {:<25} subtitles={}".format(
                    stream.url,
                    "[{}]".format(set_color(stream.language, Color.RED)),
                    stream.subtitles)
                print(fstr)

    elif is_stream_url(url=args.query):
        """Extract raw urls from stream url specified"""
        logging.debug("Found valid stream url: '{}'".format(args.query))

        url = args.query
        downloader.extract([url])

    elif is_raw_url(url=args.query) or is_local_file(path=args.query):
        """Add raw url or local file to raw url list"""
        logging.debug("Found valid file/raw url: '{}'".format(args.query))

        url = args.query
        if is_raw_url(url=url):
            parsed_url = urlparse(url)
            title = os.path.basename(parsed_url.path)
        elif is_local_file(path=url):
            filepath = get_absolute_path(url)
            title = os.path.basename(filepath)
        extension = guess_extension(guess_type(filepath)[0])

        info = {
            "id": "unknown",
            "webpage_url": "unknown",
            "title": title,
            "url": url,
            "ext": extension,
        }
        downloader.info_list.append(info)
        logging.debug('added raw url: {}'.format(info['url']))

    else:
        import pdb; pdb.set_trace()
        medias = site.search(args.query)
        try:
            position = args.position - 1 if args.position != 0 else args.position
            chosen_media_url = medias[position].url
        except IndexError:
            logging.error("Not a valid position")
            return None
        except TypeError:
            logging.error("No media url was found")
            return None

        code = (args.stream_urls if args.stream_urls else
                args.raw_urls if args.raw_urls else
                None)

        streams = site.get_streams(chosen_media_url, code=code)

        if args.stream_urls:
            """
            Obtenir les stream urls pour la position 0 ou
            autre si position specifié
            """
            for stream in streams:
                fstr = "{:<60} {:<25} subtitles={}".format(
                    stream.url,
                    "[{}]".format(set_color(stream.language, Color.RED)),
                    stream.subtitles)
                print(fstr)

        elif args.raw_urls:
            """
            Obtenir les raw urls pour la position 0 ou
            autre si position specifié
            """
            downloader.extract(s.url for s in streams)

        elif args.position:
            """
            Obtenir les raw urls pour la position de
            recherche specifié.

            Attention ça marche que pour les film, pour les series au moins
            un code episode doit être informé au format:-p 30 -r s01e01
            """
            downloader.extract(s.url for s in streams)

        else:
            for position, media in enumerate(medias, start=1):
                position_line = "{0:<15} {1:<15} {2:<55} [{3}] ({4})".format(
                    "[{}]".format(set_color(position, Color.YELLOW)),
                    [media.category],
                    set_color(repr("{:.42}".format(media.title)), Color.GREEN),
                    set_color(media.year, Color.YELLOW),
                    media.url
                )
                print(position_line)

    # Bonus options
    if args.download:
        pattern = args.pattern
        downloader.download(pattern=pattern,)
    elif args.play and downloader.info_list:
        pattern = args.pattern
        player = args.player
        downloader.play(pattern=pattern, player=player)
    elif args.stream and downloader.info_list:
        pattern = args.pattern
        stream_port = args.stream_port
        subtitles = args.subtitles
        downloader.stream(pattern=pattern,
                          stream_port=stream_port,
                          subtitles=subtitles)

if __name__ == '__main__':
    try:
        run(get_args())
    except KeyboardInterrupt:
        sys.stderr.flush()
        print("")
