command.py 3.7 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118
  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 requests.exceptions import ConnectionError
  8. from requests.exceptions import SSLError
  9. from . import errors
  10. from . import verbose_proxy
  11. from .. import __version__
  12. from .. import config
  13. from ..project import Project
  14. from ..service import ConfigError
  15. from .docker_client import docker_client
  16. from .docopt_command import DocoptCommand
  17. from .utils import call_silently
  18. from .utils import is_mac
  19. from .utils import is_ubuntu
  20. log = logging.getLogger(__name__)
  21. class Command(DocoptCommand):
  22. base_dir = '.'
  23. def dispatch(self, *args, **kwargs):
  24. try:
  25. super(Command, self).dispatch(*args, **kwargs)
  26. except SSLError as e:
  27. raise errors.UserError('SSL error: %s' % e)
  28. except ConnectionError:
  29. if call_silently(['which', 'docker']) != 0:
  30. if is_mac():
  31. raise errors.DockerNotFoundMac()
  32. elif is_ubuntu():
  33. raise errors.DockerNotFoundUbuntu()
  34. else:
  35. raise errors.DockerNotFoundGeneric()
  36. elif call_silently(['which', 'boot2docker']) == 0:
  37. raise errors.ConnectionErrorBoot2Docker()
  38. else:
  39. raise errors.ConnectionErrorGeneric(self.get_client().base_url)
  40. def perform_command(self, options, handler, command_options):
  41. if options['COMMAND'] in ('help', 'version'):
  42. # Skip looking up the compose file.
  43. handler(None, command_options)
  44. return
  45. project = get_project(
  46. self.base_dir,
  47. get_config_path(options.get('--file')),
  48. project_name=options.get('--project-name'),
  49. verbose=options.get('--verbose'))
  50. handler(project, command_options)
  51. def get_config_path(file_option):
  52. if file_option:
  53. return file_option
  54. if 'FIG_FILE' in os.environ:
  55. log.warn('The FIG_FILE environment variable is deprecated.')
  56. log.warn('Please use COMPOSE_FILE instead.')
  57. config_file = os.environ.get('COMPOSE_FILE') or os.environ.get('FIG_FILE')
  58. return [config_file] if config_file else None
  59. def get_client(verbose=False):
  60. client = docker_client()
  61. if verbose:
  62. version_info = six.iteritems(client.version())
  63. log.info("Compose version %s", __version__)
  64. log.info("Docker base_url: %s", client.base_url)
  65. log.info("Docker version: %s",
  66. ", ".join("%s=%s" % item for item in version_info))
  67. return verbose_proxy.VerboseProxy('docker', client)
  68. return client
  69. def get_project(base_dir, config_path=None, project_name=None, verbose=False):
  70. config_details = config.find(base_dir, config_path)
  71. try:
  72. return Project.from_dicts(
  73. get_project_name(config_details.working_dir, project_name),
  74. config.load(config_details),
  75. get_client(verbose=verbose))
  76. except ConfigError as e:
  77. raise errors.UserError(six.text_type(e))
  78. def get_project_name(working_dir, project_name=None):
  79. def normalize_name(name):
  80. return re.sub(r'[^a-z0-9]', '', name.lower())
  81. if 'FIG_PROJECT_NAME' in os.environ:
  82. log.warn('The FIG_PROJECT_NAME environment variable is deprecated.')
  83. log.warn('Please use COMPOSE_PROJECT_NAME instead.')
  84. project_name = (
  85. project_name or
  86. os.environ.get('COMPOSE_PROJECT_NAME') or
  87. os.environ.get('FIG_PROJECT_NAME'))
  88. if project_name is not None:
  89. return normalize_name(project_name)
  90. project = os.path.basename(os.path.abspath(working_dir))
  91. if project:
  92. return normalize_name(project)
  93. return 'default'