# -*- coding: utf-8 -*-
# Copyright (C) 2012 Anaconda, Inc
# SPDX-License-Identifier: BSD-3-Clause
from __future__ import absolute_import, division, print_function, unicode_literals

from collections import namedtuple
from io import StringIO
from logging import getLogger
import os
from os.path import abspath
from conda.auxlib.compat import shlex_split_unicode
import sys
from subprocess import CalledProcessError, PIPE, Popen
from ..utils import wrap_subprocess_call

from .logging import TRACE
from .. import ACTIVE_SUBPROCESSES
from ..auxlib.ish import dals
from ..common.compat import (
    ensure_binary,
    string_types,
    encode_arguments,
    encode_environment,
    isiterable,
)
from ..gateways.disk.delete import rm_rf
from ..base.context import context

log = getLogger(__name__)
Response = namedtuple('Response', ('stdout', 'stderr', 'rc'))


def _format_output(command_str, cwd, rc, stdout, stderr):
    return dals("""
    $ %s
    ==> cwd: %s <==
    ==> exit code: %d <==
    ==> stdout <==
    %s
    ==> stderr <==
    %s
    """) % (command_str, cwd, rc, stdout, stderr)


def any_subprocess(args, prefix, env=None, cwd=None):
    script_caller, command_args = wrap_subprocess_call(
        context.root_prefix,
        prefix,
        context.dev,
        context.verbosity >= 2,
        args,
    )
    process = Popen(
        command_args,
        cwd=cwd or prefix,
        universal_newlines=False,
        stdout=PIPE,
        stderr=PIPE,
        env=env,
    )
    stdout, stderr = process.communicate()
    if script_caller is not None:
        if 'CONDA_TEST_SAVE_TEMPS' not in os.environ:
            rm_rf(script_caller)
        else:
            log.warning('CONDA_TEST_SAVE_TEMPS :: retaining pip run_script {}'.format(
                script_caller))
    if hasattr(stdout, 'decode'):
        stdout = stdout.decode('utf-8', errors='replace')
    if hasattr(stderr, 'decode'):
        stderr = stderr.decode('utf-8', errors='replace')
    return stdout, stderr, process.returncode


def subprocess_call(command, env=None, path=None, stdin=None, raise_on_error=True,
                    capture_output=True, live_stream=False):
    """This utility function should be preferred for all conda subprocessing.
    It handles multiple tricky details.
    """
    env = encode_environment(env if env else os.environ)
    cwd = sys.prefix if path is None else abspath(path)
    if not isiterable(command):
        command = shlex_split_unicode(command)
    command_str = command if isinstance(command, string_types) else ' '.join(command)
    log.debug("executing>> %s", command_str)

    if capture_output:
        p = Popen(encode_arguments(command), cwd=cwd, stdin=PIPE, stdout=PIPE, stderr=PIPE,
                  env=env)
        ACTIVE_SUBPROCESSES.add(p)
        stdin = ensure_binary(stdin) if isinstance(stdin, string_types) else stdin

        if live_stream:
            stdout, stderr = _realtime_output_for_subprocess(p)
        else:
            stdout, stderr = p.communicate(input=stdin)

        if hasattr(stdout, "decode"):
            stdout = stdout.decode('utf-8', errors='replace')
        if hasattr(stderr, "decode"):
            stderr = stderr.decode('utf-8', errors='replace')
        rc = p.returncode
        ACTIVE_SUBPROCESSES.remove(p)
    elif stdin:
        raise ValueError("When passing stdin, output needs to be captured")
    else:
        p = Popen(encode_arguments(command), cwd=cwd, env=env)
        ACTIVE_SUBPROCESSES.add(p)
        p.communicate()
        rc = p.returncode
        ACTIVE_SUBPROCESSES.remove(p)
        stdout = None
        stderr = None

    if (raise_on_error and rc != 0) or log.isEnabledFor(TRACE):
        formatted_output = _format_output(command_str, cwd, rc, stdout, stderr)
    if raise_on_error and rc != 0:
        log.info(formatted_output)
        raise CalledProcessError(rc, command,
                                 output=formatted_output)
    if log.isEnabledFor(TRACE):
        log.trace(formatted_output)

    return Response(stdout, stderr, int(rc))


def _realtime_output_for_subprocess(p):
    """Consumes the stdout and stderr streams from the subprocess in real-time.
    """
    stdout_io = StringIO()
    stderr_io = StringIO()
    while True:
        buff = p.stdout.readline()
        if hasattr(buff, "decode"):
            buff = buff.decode('utf-8', errors='replace')
        if buff == '' and p.poll() is not None:
            break
        if buff:
            stdout_io.write(buff)
            print(buff, file=sys.stdout, end='')

        errbuff = p.stderr.readline()
        if hasattr(errbuff, "decode"):
            errbuff = errbuff.decode('utf-8', errors='replace')
        if errbuff:
            stderr_io.write(errbuff)
            print(errbuff, file=sys.stderr, end='')

    p.wait()

    stdout = stdout_io.getvalue()
    stderr = stderr_io.getvalue()

    return stdout, stderr


def _subprocess_clean_env(env, clean_python=True, clean_conda=True):
    dels = []
    if clean_python:
        dels.extend(('PYTHONPATH', 'PYTHONHOME'))
    if clean_conda:
        dels.extend(('CONDA_ROOT', 'CONDA_PROMPT_MODIFIER',
                     'CONDA_EXE', 'CONDA_DEFAULT_ENV'))
    for key in dels:
        if key in env:
            del env[key]


def subprocess_call_with_clean_env(command, path=None, stdin=None, raise_on_error=True,
                                   clean_python=True, clean_conda=True):
    # Any of these env vars are likely to mess the whole thing up.
    # This has been seen to be the case with PYTHONPATH.
    env = os.environ.copy()
    _subprocess_clean_env(env, clean_python, clean_conda)
    # env['CONDA_DLL_SEARCH_MODIFICATION_ENABLE'] = '1'
    return subprocess_call(command, env=env, path=path, stdin=stdin, raise_on_error=raise_on_error)