command.py 3.0 KB

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