# Path: src/rosrepo/util.py
# def yaml_load(stream, Loader=SafeLoader):
# def yaml_dump(data, stream=None, Dumper=SafeDumper, **kwargs):
#     def __init__(self, *args, **kwargs):
#     def __str__(self):
#     def __getitem__(self, item):
#     def __setitem__(self, item, value):
#     def __len__(self):
# def is_deprecated_package(manifest):
# def deprecated_package_info(manifest):
# def path_has_prefix(path, prefix):
# def has_package_path(obj, paths):
# def env_path_list_contains(path_list, path):
# def makedirs(path):
# def write_atomic(filepath, data, mode=0o644, ignore_fail=False):
# def isatty(fd):
# def get_terminal_size():
# def find_program(program):
#     def is_exe(fpath):
# def getmtime(path):
# def call_process(args, bufsize=0, stdin=None, stdout=None, stderr=None, cwd=None, env=None, input_data=None):
# def create_multiprocess_manager():
# def _worker_init(worker_init, worker_init_args):
# def run_multiprocess_workers(worker, workload, worker_init=None, worker_init_args=(), jobs=None, timeout=None):
# class NamedTuple(object):
# class UserError(RuntimeError):
# 
# Path: src/rosrepo/ui.py
# def error(text, use_color=None):
#     prog = "rosrepo"
#     msg("@!@{rf}%s: error: %s" % (prog, text), indent_next=len(prog) + 9)


from .util import UserError, YAMLError
from pickle import PickleError
from .ui import error
from pygit2 import GitError
    from argparse import SUPPRESS
    from . import __version__
    from argparse import SUPPRESS, FileType
import sys
import traceback
                import rosrepo.cmd_bash
                import rosrepo.cmd_build
                import rosrepo.cmd_include_exclude
                import rosrepo.cmd_clean
                import rosrepo.cmd_config
                import rosrepo.cmd_depend
                import rosrepo.cmd_git
                import rosrepo.cmd_init
                import rosrepo.cmd_list
                import rosrepo.cmd_export
                import rosrepo.cmd_find
                import rosrepo.cmd_test
    import argparse
            if args.func == CMD_BUILD:
                return rosrepo.cmd_build.run(args)
            if args.func == CMD_INCLUDE_EXCLUDE:
                return rosrepo.cmd_include_exclude.run(args)
            if args.func == CMD_CLEAN:
                return rosrepo.cmd_clean.run(args)
            if args.func == CMD_CONFIG:
                return rosrepo.cmd_config.run(args)
            if args.func == CMD_DEPEND:
                return rosrepo.cmd_depend.run(args)
            if args.func == CMD_GIT:
                return rosrepo.cmd_git.run(args)
            if args.func == CMD_INIT:
                return rosrepo.cmd_init.run(args)
            if args.func == CMD_LIST:
                return rosrepo.cmd_list.run(args)
            if args.func == CMD_EXPORT:
                return rosrepo.cmd_export.run(args)
            if args.func == CMD_FIND:
                return rosrepo.cmd_find.run(args)
            if args.func == CMD_TEST:
                return rosrepo.cmd_test.run(args)
        error("no command\n")
    except UserError as e:
        if args.stacktrace:
            traceback.print_exc()
        error("%s\n" % str(e))
    except YAMLError as e:
        if args.stacktrace:
            traceback.print_exc()

# Path: src/rosrepo/util.py
# def yaml_load(stream, Loader=SafeLoader):
# def yaml_dump(data, stream=None, Dumper=SafeDumper, **kwargs):
#     def __init__(self, *args, **kwargs):
#     def __str__(self):
#     def __getitem__(self, item):
#     def __setitem__(self, item, value):
#     def __len__(self):
# def is_deprecated_package(manifest):
# def deprecated_package_info(manifest):
# def path_has_prefix(path, prefix):
# def has_package_path(obj, paths):
# def env_path_list_contains(path_list, path):
# def makedirs(path):
# def write_atomic(filepath, data, mode=0o644, ignore_fail=False):
# def isatty(fd):
# def get_terminal_size():
# def find_program(program):
#     def is_exe(fpath):
# def getmtime(path):
# def call_process(args, bufsize=0, stdin=None, stdout=None, stderr=None, cwd=None, env=None, input_data=None):
# def create_multiprocess_manager():
# def _worker_init(worker_init, worker_init_args):
# def run_multiprocess_workers(worker, workload, worker_init=None, worker_init_args=(), jobs=None, timeout=None):
# class NamedTuple(object):
# class UserError(RuntimeError):
# 
# Path: src/rosrepo/ui.py
# def error(text, use_color=None):
#     prog = "rosrepo"
#     msg("@!@{rf}%s: error: %s" % (prog, text), indent_next=len(prog) + 9)


# Path: src/rosrepo/main.py
from .util import UserError, YAMLError
from pickle import PickleError
from .ui import error
from pygit2 import GitError
    from argparse import SUPPRESS
    from . import __version__
    from argparse import SUPPRESS, FileType
import sys
import traceback
                import rosrepo.cmd_bash
                import rosrepo.cmd_build
                import rosrepo.cmd_include_exclude
                import rosrepo.cmd_clean
                import rosrepo.cmd_config
                import rosrepo.cmd_depend
                import rosrepo.cmd_git
                import rosrepo.cmd_init
                import rosrepo.cmd_list
                import rosrepo.cmd_export
                import rosrepo.cmd_find
                import rosrepo.cmd_test
    import argparse

            if args.func == CMD_BUILD:
                return rosrepo.cmd_build.run(args)
            if args.func == CMD_INCLUDE_EXCLUDE:
                return rosrepo.cmd_include_exclude.run(args)
            if args.func == CMD_CLEAN:
                return rosrepo.cmd_clean.run(args)
            if args.func == CMD_CONFIG:
                return rosrepo.cmd_config.run(args)
            if args.func == CMD_DEPEND:
                return rosrepo.cmd_depend.run(args)
            if args.func == CMD_GIT:
                return rosrepo.cmd_git.run(args)
            if args.func == CMD_INIT:
                return rosrepo.cmd_init.run(args)
            if args.func == CMD_LIST:
                return rosrepo.cmd_list.run(args)
            if args.func == CMD_EXPORT:
                return rosrepo.cmd_export.run(args)
            if args.func == CMD_FIND:
                return rosrepo.cmd_find.run(args)
            if args.func == CMD_TEST:
                return rosrepo.cmd_test.run(args)
        error("no command\n")
    except UserError as e:
        if args.stacktrace:
            traceback.print_exc()
        error("%s\n" % str(e))
    except YAMLError as e:
        if args.stacktrace:
            traceback.print_exc()

        error("YAML: %s\n\n" % str(e))