command.py 2.7 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687
  1. from __future__ import absolute_import
  2. from __future__ import unicode_literals
  3. import logging
  4. import os
  5. import re
  6. import six
  7. from . import verbose_proxy
  8. from .. import config
  9. from ..const import API_VERSIONS
  10. from ..project import Project
  11. from .docker_client import docker_client
  12. from .docker_client import tls_config_from_options
  13. from .utils import get_version_info
  14. log = logging.getLogger(__name__)
  15. def project_from_options(project_dir, options):
  16. return get_project(
  17. project_dir,
  18. get_config_path_from_options(project_dir, options),
  19. project_name=options.get('--project-name'),
  20. verbose=options.get('--verbose'),
  21. host=options.get('--host'),
  22. tls_config=tls_config_from_options(options),
  23. )
  24. def get_config_path_from_options(base_dir, options):
  25. file_option = options.get('--file')
  26. if file_option:
  27. return file_option
  28. environment = config.environment.get_instance(base_dir)
  29. config_files = environment.get('COMPOSE_FILE')
  30. if config_files:
  31. return config_files.split(os.pathsep)
  32. return None
  33. def get_client(verbose=False, version=None, tls_config=None, host=None):
  34. client = docker_client(version=version, tls_config=tls_config, host=host)
  35. if verbose:
  36. version_info = six.iteritems(client.version())
  37. log.info(get_version_info('full'))
  38. log.info("Docker base_url: %s", client.base_url)
  39. log.info("Docker version: %s",
  40. ", ".join("%s=%s" % item for item in version_info))
  41. return verbose_proxy.VerboseProxy('docker', client)
  42. return client
  43. def get_project(project_dir, config_path=None, project_name=None, verbose=False,
  44. host=None, tls_config=None):
  45. config_details = config.find(project_dir, config_path)
  46. project_name = get_project_name(config_details.working_dir, project_name)
  47. config_data = config.load(config_details)
  48. environment = config.environment.get_instance(project_dir)
  49. api_version = environment.get(
  50. 'COMPOSE_API_VERSION',
  51. API_VERSIONS[config_data.version])
  52. client = get_client(
  53. verbose=verbose, version=api_version, tls_config=tls_config,
  54. host=host
  55. )
  56. return Project.from_config(project_name, config_data, client)
  57. def get_project_name(working_dir, project_name=None):
  58. def normalize_name(name):
  59. return re.sub(r'[^a-z0-9]', '', name.lower())
  60. environment = config.environment.get_instance(working_dir)
  61. project_name = project_name or environment.get('COMPOSE_PROJECT_NAME')
  62. if project_name:
  63. return normalize_name(project_name)
  64. project = os.path.basename(os.path.abspath(working_dir))
  65. if project:
  66. return normalize_name(project)
  67. return 'default'