command.py 3.1 KB

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