VERSION = (0, 2, 1)
__version__ = '.'.join(map(str, VERSION))
import copy
import os
import re
import sys
import types
import yaml
import importlib
import pkgutil
import inspect
import warnings
from fabric.api import env
from fabric.tasks import WrappedCallableTask
from fabric.utils import _AliasDict
burlap_populate_stack = int(os.environ.get('BURLAP_POPULATE_STACK', 1))
import common
def _represent_dictorder(self, data):
#    if isinstance(data, type(env)):
#        return self.represent_mapping(',2002:map', data.items())
#    else:
    return self.represent_mapping(u',2002:map', data.items())
def _represent_tuple(self, data):
    return self.represent_sequence(u',2002:seq', data)
def _construct_tuple(self, node):
    return tuple(self.construct_sequence(node))
def _represent_function(self, data):
    return self.represent_scalar(u',2002:null', u'null')
yaml.add_representer(type(env), _represent_dictorder)
yaml.add_representer(_AliasDict, _represent_dictorder)
#yaml.add_representer(tuple, _represent_tuple) # we need tuples for hash keys
yaml.add_constructor(u',2002:python/tuple', _construct_tuple)
yaml.add_representer(types.FunctionType, _represent_function)
env_default = common.save_env()
# Variables cached per-role. Must be after deepcopy.
env._rc = type(env)()
def _get_environ_handler(name, d):
    Dynamically creates a Fabric task for each configuration role.
    def func(site=None, **kwargs):
        site = site or d.get('default_site') or env.SITE
        hostname = kwargs.get('hostname', kwargs.get('hn', kwargs.get('h')))
        # Load environment for current role.
        env[common.ROLE] = os.environ[common.ROLE] = name
        if site:
            env[common.SITE] = os.environ[common.SITE] = site
        # Load host retriever.
        retriever = None
        if env.hosts_retriever:
            # Dynamically retrieve hosts.
            module_name = '.'.join(env.hosts_retriever.split('.')[:-1])
            func_name = env.hosts_retriever.split('.')[-1]
            retriever = getattr(importlib.import_module(module_name), func_name)
        # Load host translator.
        translator = None
        if hostname:
            # Filter hosts list by a specific host name.
            module_name = '.'.join(env.hostname_translator.split('.')[:-1])
            func_name = env.hostname_translator.split('.')[-1]
            translator = getattr(importlib.import_module(module_name), func_name)
        # Re-load environment for current role, incase loading
        # the retriever/translator reset some environment values.
        env[common.ROLE] = os.environ[common.ROLE] = name
        if site:
            env[common.SITE] = os.environ[common.SITE] = site
#        print 'd:'
#        for k in sorted(d.keys()):
#            print k,d[k]
        #print 'env.vm_type0:',env.vm_type
        # Dynamically retrieve hosts.
        if env.hosts_retriever:
            env.hosts = list(retriever())
        #print 'env.vm_type1:',env.vm_type
        # Filter hosts list by a specific host name.
        if hostname:
            hostname = translator(hostname=hostname)
            _hosts = env.hosts
            env.hosts = [_ for _ in env.hosts if _ == hostname]
            assert env.hosts, \
                'Hostname %s does not match any known hosts.' % (hostname,)
        if env.is_local is None:
            if env.hosts:
                env.is_local = 'localhost' in env.hosts or '' in env.hosts
            elif env.host_string:
                env.is_local = 'localhost' in env.host_string or '' in env.host_string
        #print 'env.vm_type2:',env.vm_type
        print 'Loaded role %s.' % (name,)
    func.__doc__ = 'Sets enivronment variables for the "%s" role.' % (name,)
    return func
def update_merge(d, u):
    Recursively merges two dictionaries.
    Uses fabric's AttributeDict so you can reference values via dot-notation.
    e.g. env.value1.value2.value3...
    import collections
    for k, v in u.iteritems():
        if isinstance(v, collections.Mapping):
            r = update_merge(d.get(k, dict()), v)
            d[k] = r
            d[k] = u[k]
    return d
def find_yaml_settings_fn(name, local=False):
    if local:
        settings_fn = os.path.join(common.ROLE_DIR, name, 'settings_local.yaml')
        settings_fn = os.path.join(common.ROLE_DIR, name, 'settings.yaml')
    if os.path.isfile(settings_fn):
        return settings_fn
def load_yaml_settings(name, priors=None):
    config = type(env)()
    if priors is None:
        priors = set()
    if name in priors:
        return config
    settings_fn = find_yaml_settings_fn(name)
    if not settings_fn:
        warnings.warn('Warning: Could not find Yaml settings for role %s.' % (name,))
        return config
    config.update(yaml.safe_load(open(settings_fn)) or type(env)())
    if 'inherits' in config:
        parent_name = config['inherits']
        del config['inherits']
        parent_config = load_yaml_settings(parent_name, priors=priors)
        config = parent_config
    # Load local overrides.
    settings_local_fn = find_yaml_settings_fn(name, local=True)
    if settings_local_fn:
        config.update(yaml.safe_load(open(settings_local_fn)) or type(env)())
    return config
# Dynamically create a Fabric task for each role.
role_commands = {}
#_common = type(env)()
#_common_fn = os.path.join(common.ROLE_DIR, 'all', 'settings.yaml')
#if os.path.isfile(_common_fn):
#    _common = yaml.safe_load(open(_common_fn))
if os.path.isdir(common.ROLE_DIR):
    for _name in os.listdir(common.ROLE_DIR):
        _settings_fn = os.path.join(common.ROLE_DIR, _name, 'settings.yaml')
        if _name.startswith('.') or not os.path.isfile(_settings_fn):
        #print 'Checking %s...' % (_name,)
#        if _name == 'all' or not :
#            continue
#        _config = copy.deepcopy(_common)
#        _config.update(yaml.safe_load(open(_settings_fn)) or type(env)())
#        _settings_local_fn = os.path.join(common.ROLE_DIR, _name, 'settings_local.yaml')
#        if os.path.isfile(_settings_local_fn):
#            _config.update(yaml.safe_load(open(_settings_local_fn)) or type(env)())
        _config = load_yaml_settings(_name)
        _f = _get_environ_handler(_name, _config)
        _var_name = 'role_'+_name
        _f = WrappedCallableTask(_f, name=_name)
        exec "%s = _f" % (_var_name,)
        role_commands[_var_name] = _f
# Auto-import all sub-modules.
sub_modules = {}
sub_modules['common'] = common
__all__ = []
for loader, module_name, is_pkg in  pkgutil.walk_packages(__path__):
    if module_name in locals():
    module = loader.find_module(module_name).load_module(module_name)
    sub_modules[module_name] = module
    #print module
def populate_fabfile():
    Automatically includes all submodules and role selectors
    in the top-level fabfile using spooky-scary black magic.
    This allows us to avoid manually declaring imports for every module, e.g.
        import burlap.pip
        import burlap.vm
        import burlap...
    which has the added benefit of allowing us to manually call the commands
    without typing "burlap".
    This is soley for convenience. If not needed, it can be disabled
    by specifying the environment variable:
        export BURLAP_POPULATE_STACK=0
    stack = inspect.stack()
    fab_frame = None
    for frame_obj, script_fn, line, _, _, _ in stack:
        if '' in script_fn:
            fab_frame = frame_obj
    if not fab_frame:
        locals_ = fab_frame.f_locals
        for module_name, module in sub_modules.iteritems():
            locals_[module_name] = module
        for role_name, role_func in role_commands.iteritems():
            assert role_name not in sub_modules, \
                ('The role %s conflicts with a built-in submodule. '
                 'Please choose a different name.') % (role_name)
            locals_[role_name] = role_func
        locals_['common'] = common
        locals_['shell'] =
        locals_['info'] =
        #locals_['djshell'] = common.djshell
        locals_['tunnel'] = common.tunnel
        del stack
if burlap_populate_stack:
# Execute any callbacks registered by sub-modules.
# These are useful for calling inter-sub-module functions
# after the modules tasks are registered so task names don't get
# mistakenly registered under the wrong module.
for cb in env.post_callbacks: