text: # -*- coding: utf-8 -*- #
  # Copyright 2021 Google LLC. 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,
  # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  # See the License for the specific language governing permissions and
  # limitations under the License.
  """Utilities for local mode."""
  
  from __future__ import absolute_import
  from __future__ import division
  from __future__ import unicode_literals
  
  import io
  import os
  import subprocess
  import sys
  
  from googlecloudsdk.core.util import files
  
  
  def ExecuteCommand(cmd, input_str=None, file=None):
    """Executes shell commands in subprocess.
  
    Executes the supplied command with the supplied standard input string, streams
    the output to stdout, and returns the process's return code.
  
    Args:
      cmd: (List[str]) Strings to send in as the command.
      input_str: (str) if supplied, it will be passed as stdin to the supplied
        command. if None, stdin will get closed immediately.
      file: optional file-like object (stream), the output from the executed
        process's stdout will get sent to this stream. Defaults to sys.stdout.
  
    Returns:
      return code of the process
    """
    if file is None:
      file = sys.stdout
  
    with subprocess.Popen(
        cmd,
        stdin=subprocess.PIPE,
        stdout=subprocess.PIPE,
        stderr=subprocess.STDOUT,
        universal_newlines=False,
        bufsize=1) as p:
      if input_str:
        p.stdin.write(input_str.encode('utf-8'))
      p.stdin.close()
  
      out = io.TextIOWrapper(p.stdout, newline='')
  
      for line in out:
        file.write(line)
        file.flush()
      else:
        # Flush to force the contents to display.
        file.flush()
  
    return p.returncode
  
  
  def ModuleToPath(module_name):
    """Converts the supplied python module into corresponding python file.
  
    Args:
      module_name: (str) A python module name (separated by dots)
  
    Returns:
      A string representing a python file path.
    """
    return module_name.replace('.', os.path.sep) + '.py'
  
  
  def ClearPyCache(root_dir=None):
    """Removes generic `__pycache__` folder and  '*.pyc' '*.pyo' files."""
    root_dir = root_dir or files.GetCWD()
  
    is_cleaned = False
    for name in os.listdir(root_dir):
      item = os.path.join(root_dir, name)
      if os.path.isdir(item):
        if name == '__pycache__':
          files.RmTree(item)
          is_cleaned = True
      else:
        _, ext = os.path.splitext(name)
        if ext in ['.pyc', '.pyo']:
          os.remove(item)
          is_cleaned = True
  
    return is_cleaned
  