"""

    conda repo upload CONDA_PACKAGE_1.bz2

##### See Also

  * [Uploading a Conda Package](https://team-docs.anaconda.com/en/latest/user/package.html#upload-pack)


"""
from __future__ import unicode_literals

import argparse
import tempfile
import logging
import subprocess

from glob import glob

from six.moves import input


import requests
import os
from os.path import join, basename


from ..utils.config import get_config, PACKAGE_TYPES, DEFAULT_CONFIG
from ..utils.detect import detect_package_type, get_attrs
from .. import errors
from .base import SubCommandBase

logger = logging.getLogger('repo_cli')


def verbose_package_type(pkg_type, lowercase=True):
    verbose_type = PACKAGE_TYPES.get(pkg_type, 'unknown')
    if lowercase:
        verbose_type = verbose_type.lower()
    return verbose_type


def determine_package_type(filename, args):
    """
    return the file type from the inspected package or from the
    -t/--package-type argument
    """
    if args.package_type:
        package_type = args.package_type
    else:
        logger.info('Detecting file type...')

        package_type = detect_package_type(filename)

        if package_type is None:
            message = 'Could not detect package type of file %r please specify package ' \
                      'type with option --package-type' % filename
            logger.error(message)
            raise errors.RepoCLIError(message)

        logger.info('File type is "%s"', package_type)

    return package_type


def get_default_channel(base_url, token, verify_ssl):
    url = join(base_url, 'account', 'me')
    logger.debug(f'[UPLOAD] Getting user default channel from {url}')
    response = requests.get(url, headers={'X-Auth': f'{token}'}, verify=verify_ssl)
    return response


def upload_file(base_url, token, filepath, channel, verify_ssl):
    url = join(base_url, 'channels', channel, 'artifacts')
    statinfo = os.stat(filepath)
    filename = basename(filepath)
    logger.debug(f'[UPLOAD] Using token {token} on {base_url}')
    multipart_form_data = {
        'content': (filename, open(filepath, 'rb')),
        'filetype': (None, 'conda1'),
        'size': (None, statinfo.st_size)
    }
    logger.info(f'Uploading to {url}...')
    response = requests.post(url, files=multipart_form_data, headers={'X-Auth': f'{token}'}, verify=verify_ssl)
    return response


def windows_glob(item):
    if os.name == 'nt' and '*' in item:
        return glob(item)
    else:
        return [item]


class SubCommand(SubCommandBase):
    name = "upload"


    def main(self):
        # config = get_config(site=args.site)
        # url = config.get('url')
        if not self.access_token:
            raise errors.Unauthorized

        channels = self.args.channels
        if not channels:
            # In this case the user didn't specify any channel. Means we need to get
            # the user default channel
            channels = [self.api.get_default_channel()]
            if not channels[0]:
                raise errors.NoDefaultChannel("User default channel is not specified. Please set it in the user account or use -c option.")

        for filepath in self.args.files:
            for fp in filepath:
                for channel in channels:
                    logger.debug(f'Using token {self.access_token}')
                    package_type = determine_package_type(fp, self.args)
                    resp = self.api.upload_file(fp, channel, package_type)
                    if resp.status_code in [201, 200]:
                        logger.info(
                            f'File {fp} successfully uploaded to {self.api.base_url}/repo{channel} with response {resp.status_code}')
                        logger.debug(f'Server responded with {resp.content}')
                    else:
                        if resp.status_code == 401:
                            raise errors.Unauthorized()
                        else:
                            msg = f'Error uploading {fp} to {self.api.base_url}::{channel}. ' \
                                f'Server responded with status code {resp.status_code}.\n' \
                                f'Error details: {resp.content}\n'
                            logger.error(msg)


    def add_parser(self, subparsers):
            description = 'Upload packages to your Anaconda Team Edition repository'
            self.subparser = parser = subparsers.add_parser('upload',
                                           formatter_class=argparse.RawDescriptionHelpFormatter,
                                           help=description, description=description,
                                           epilog=__doc__)
            parser.add_argument('files', nargs='+', help='Distributions to upload', default=[], type=windows_glob)

            parser.add_argument('-c', '--channel', action='append', default=[], metavar='CHANNELS', dest='channels')
            parser.add_argument('--no-progress', help="Don't show upload progress", action='store_true')

            mgroup = parser.add_argument_group('metadata options')

            # To preserve current behavior
            pkgs = PACKAGE_TYPES.copy()
            # pkgs.pop('conda')
            # pkgs.pop('pypi')
            pkg_types = ', '.join(list(pkgs.keys()))
            mgroup.add_argument('-t', '--package-type',
                                help='Set the package type [{0}]. Defaults to autodetect'.format(pkg_types))

            group = parser.add_mutually_exclusive_group()
            group.add_argument('-i', '--interactive', action='store_const',
                               help='Run an interactive prompt if any packages are missing',
                               dest='mode', const='interactive')
            # group.add_argument('-f', '--fail', help='Fail if a package or release does not exist (default)',
            #                    action='store_const', dest='mode', const='fail')
            # group.add_argument('--force', help='Force a package upload regardless of errors',
            #                    action='store_const', dest='mode', const='force')
            # group.add_argument('--skip-existing', help='Skip errors on package batch upload if it already exists',
            #                    action='store_const', dest='mode', const='skip')

            parser.set_defaults(main=self.main)