command.py 2.5 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384
  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(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(options):
  25. file_option = options.get('--file')
  26. if file_option:
  27. return file_option
  28. config_files = os.environ.get('COMPOSE_FILE')
  29. if config_files:
  30. return config_files.split(os.pathsep)
  31. return None
  32. def get_client(verbose=False, version=None, tls_config=None, host=None):
  33. client = docker_client(version=version, tls_config=tls_config, host=host)
  34. if verbose:
  35. version_info = six.iteritems(client.version())
  36. log.info(get_version_info('full'))
  37. log.info("Docker base_url: %s", client.base_url)
  38. log.info("Docker version: %s",
  39. ", ".join("%s=%s" % item for item in version_info))
  40. return verbose_proxy.VerboseProxy('docker', client)
  41. return client
  42. def get_project(project_dir, config_path=None, project_name=None, verbose=False,
  43. host=None, tls_config=None):
  44. config_details = config.find(project_dir, config_path)
  45. project_name = get_project_name(config_details.working_dir, project_name)
  46. config_data = config.load(config_details)
  47. api_version = os.environ.get(
  48. 'COMPOSE_API_VERSION',
  49. API_VERSIONS[config_data.version])
  50. client = get_client(
  51. verbose=verbose, version=api_version, tls_config=tls_config,
  52. host=host
  53. )
  54. return Project.from_config(project_name, config_data, client)
  55. def get_project_name(working_dir, project_name=None):
  56. def normalize_name(name):
  57. return re.sub(r'[^a-z0-9]', '', name.lower())
  58. project_name = project_name or os.environ.get('COMPOSE_PROJECT_NAME')
  59. if project_name:
  60. return normalize_name(project_name)
  61. project = os.path.basename(os.path.abspath(working_dir))
  62. if project:
  63. return normalize_name(project)
  64. return 'default'