serialize.py 2.0 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576
  1. from __future__ import absolute_import
  2. from __future__ import unicode_literals
  3. import six
  4. import yaml
  5. from compose.config import types
  6. from compose.config.config import V1
  7. from compose.config.config import V2_1
  8. def serialize_config_type(dumper, data):
  9. representer = dumper.represent_str if six.PY3 else dumper.represent_unicode
  10. return representer(data.repr())
  11. yaml.SafeDumper.add_representer(types.VolumeFromSpec, serialize_config_type)
  12. yaml.SafeDumper.add_representer(types.VolumeSpec, serialize_config_type)
  13. def denormalize_config(config):
  14. denormalized_services = [
  15. denormalize_service_dict(service_dict, config.version)
  16. for service_dict in config.services
  17. ]
  18. services = {
  19. service_dict.pop('name'): service_dict
  20. for service_dict in denormalized_services
  21. }
  22. networks = config.networks.copy()
  23. for net_name, net_conf in networks.items():
  24. if 'external_name' in net_conf:
  25. del net_conf['external_name']
  26. volumes = config.volumes.copy()
  27. for vol_name, vol_conf in volumes.items():
  28. if 'external_name' in vol_conf:
  29. del vol_conf['external_name']
  30. version = config.version
  31. if version == V1:
  32. version = V2_1
  33. return {
  34. 'version': version,
  35. 'services': services,
  36. 'networks': networks,
  37. 'volumes': volumes,
  38. }
  39. def serialize_config(config):
  40. return yaml.safe_dump(
  41. denormalize_config(config),
  42. default_flow_style=False,
  43. indent=2,
  44. width=80)
  45. def denormalize_service_dict(service_dict, version):
  46. service_dict = service_dict.copy()
  47. if 'restart' in service_dict:
  48. service_dict['restart'] = types.serialize_restart_spec(
  49. service_dict['restart']
  50. )
  51. if version == V1 and 'network_mode' not in service_dict:
  52. service_dict['network_mode'] = 'bridge'
  53. if 'depends_on' in service_dict and version != V2_1:
  54. service_dict['depends_on'] = sorted([
  55. svc for svc in service_dict['depends_on'].keys()
  56. ])
  57. return service_dict