Roll typ to v0.8.6 / re25b780b0b147580ef248c212b238446264d9d78

third_party/typ/typ/host.py

 # Copyright 2014 Dirk Pranke. All rights reserved.
 #
 # Licensed under the Apache License, Version 2.0 (the "License");
 # you may not use this file except in compliance with the License.
 # You may obtain a copy of the License at
 #
 #    http://www.apache.org/licenses/LICENSE-2.0
 #
 # Unless required by applicable law or agreed to in writing, software
 # distributed under the License is distributed on an "AS IS" BASIS,
@@ skipping 17 matching lines @@
 else:  # pragma: python3
     # pylint: disable=E0611
     assert sys.version_info.major == 3
     from urllib.request import urlopen, Request  # pylint: disable=F0401,E0611
 
 
 class Host(object):
     python_interpreter = sys.executable
     is_python3 = bool(sys.version_info.major == 3)
 
+    pathsep = os.pathsep
     sep = os.sep
     env = os.environ
 
     _orig_stdout = sys.stdout
     _orig_stderr = sys.stderr
 
     def __init__(self):
         self.logger = logging.getLogger()
         self._orig_logging_handlers = None
         self.stdout = sys.stdout
@@ skipping 22 matching lines @@
                                 stderr=subprocess.PIPE, stdin=stdin_pipe,
                                 env=env)
         if stdin_pipe:
             proc.stdin.write(stdin.encode('utf-8'))
         stdout, stderr = proc.communicate()
 
         # pylint type checking bug - pylint: disable=E1103
         return proc.returncode, stdout.decode('utf-8'), stderr.decode('utf-8')
 
     def call_inline(self, argv, env=None):
+        if isinstance(self.stdout, _TeedStream):  # pragma: no cover
+            ret, out, err = self.call(argv, env)
+            self.print_(out, end='')
+            self.print_(err, end='', stream=self.stderr)
+            return ret
         return subprocess.call(argv, stdin=self.stdin, stdout=self.stdout,
                                stderr=self.stderr, env=env)
 
     def chdir(self, *comps):
         return os.chdir(self.join(*comps))
 
     def cpu_count(self):
         return multiprocessing.cpu_count()
 
     def dirname(self, *comps):
@@ skipping 29 matching lines @@
         return os.path.isfile(os.path.join(*comps))
 
     def join(self, *comps):
         return os.path.join(*comps)
 
     def maybe_mkdir(self, *comps):
         path = self.abspath(self.join(*comps))
         if not self.exists(path):
             os.makedirs(path)
 
+    def mktempfile(self, delete=True):
+        return tempfile.NamedTemporaryFile(delete=delete)
+
     def mkdtemp(self, **kwargs):
         return tempfile.mkdtemp(**kwargs)
 
     def mtime(self, *comps):
         return os.stat(self.join(*comps)).st_mtime
 
     def print_(self, msg='', end='\n', stream=None):
         stream = stream or self.stdout
         stream.write(str(msg) + end)
         stream.flush()
@@ skipping 129 matching lines @@
         self.truncate(0)
         self.capturing = True
         self.diverting = divert
 
     def restore(self):
         msg = self.getvalue()
         self.truncate(0)
         self.capturing = False
         self.diverting = False
         return msg