# flake8: noqa
import importlib
import site
import subprocess
import sys
import time

PY2 = sys.version_info[0] == 2
WIN = sys.platform == 'win32'


try:
    from _thread import interrupt_main
except ImportError:
    from thread import interrupt_main


try:
    from importlib.util import source_from_cache as _source_from_cache
except ImportError:
    try:
        # fallback on python < 3.5
        from imp import source_from_cache as _source_from_cache
    except ImportError:
        # fallback on python 2.x
        _source_from_cache = None


def get_py_path(path):
    if _source_from_cache:
        try:
            return _source_from_cache(path)
        except ValueError:
            # fallback for solitary *.pyc files outside of __pycache__
            pass

    return path[:-1]


try:
    import cPickle as pickle
except ImportError:
    import pickle


if PY2 or sys.version_info[1] < 5:
    from glob import glob as gg

    def glob(pathname, recursive=False):
        return gg(pathname)


else:
    from glob import glob


def get_site_packages():  # pragma: no cover
    try:
        paths = site.getsitepackages()
        if site.ENABLE_USER_SITE:
            paths.append(site.getusersitepackages())
        return paths

    # virtualenv does not ship with a getsitepackages impl so we fallback
    # to using distutils if we can
    # https://github.com/pypa/virtualenv/issues/355
    except Exception:
        try:
            from distutils.sysconfig import get_python_lib

            return [get_python_lib()]

        # just incase, don't fail here, it's not worth it
        except Exception:
            return []


################################################
# cross-compatible metaclass implementation
# Copyright (c) 2010-2012 Benjamin Peterson
def with_metaclass(meta, base=object):
    """Create a base class with a metaclass."""
    return meta("%sBase" % meta.__name__, (base,), {})


if PY2:

    def subprocess_wait_with_timeout(process, timeout):
        max_time = time.time() + timeout
        while process.poll() is None:
            dt = max_time - time.time()
            if dt <= 0:
                break
            if dt > 0.5:
                dt = 0.5
            time.sleep(dt)
        return process.poll()


else:

    def subprocess_wait_with_timeout(process, timeout):
        try:
            return process.wait(timeout)
        except subprocess.TimeoutExpired:
            pass