|
@@ -1,5 +1,6 @@
|
|
|
import codecs
|
|
|
import logging
|
|
|
+import operator
|
|
|
import os
|
|
|
import sys
|
|
|
from collections import namedtuple
|
|
@@ -389,54 +390,44 @@ def merge_service_dicts_from_files(base, override):
|
|
|
|
|
|
|
|
|
def merge_service_dicts(base, override):
|
|
|
- d = base.copy()
|
|
|
+ d = {}
|
|
|
|
|
|
- if 'environment' in base or 'environment' in override:
|
|
|
- d['environment'] = merge_environment(
|
|
|
- base.get('environment'),
|
|
|
- override.get('environment'),
|
|
|
- )
|
|
|
-
|
|
|
- path_mapping_keys = ['volumes', 'devices']
|
|
|
-
|
|
|
- for key in path_mapping_keys:
|
|
|
- if key in base or key in override:
|
|
|
- d[key] = merge_path_mappings(
|
|
|
- base.get(key),
|
|
|
- override.get(key),
|
|
|
- )
|
|
|
-
|
|
|
- if 'labels' in base or 'labels' in override:
|
|
|
- d['labels'] = merge_labels(
|
|
|
- base.get('labels'),
|
|
|
- override.get('labels'),
|
|
|
- )
|
|
|
+ def merge_field(field, merge_func, default=None):
|
|
|
+ if field in base or field in override:
|
|
|
+ d[field] = merge_func(
|
|
|
+ base.get(field, default),
|
|
|
+ override.get(field, default))
|
|
|
|
|
|
- if 'image' in override and 'build' in d:
|
|
|
- del d['build']
|
|
|
+ merge_field('environment', merge_environment)
|
|
|
+ merge_field('labels', merge_labels)
|
|
|
+ merge_image_or_build(base, override, d)
|
|
|
|
|
|
- if 'build' in override and 'image' in d:
|
|
|
- del d['image']
|
|
|
+ for field in ['volumes', 'devices']:
|
|
|
+ merge_field(field, merge_path_mappings)
|
|
|
|
|
|
- list_keys = ['ports', 'expose', 'external_links']
|
|
|
+ for field in ['ports', 'expose', 'external_links']:
|
|
|
+ merge_field(field, operator.add, default=[])
|
|
|
|
|
|
- for key in list_keys:
|
|
|
- if key in base or key in override:
|
|
|
- d[key] = base.get(key, []) + override.get(key, [])
|
|
|
+ for field in ['dns', 'dns_search']:
|
|
|
+ merge_field(field, merge_list_or_string)
|
|
|
|
|
|
- list_or_string_keys = ['dns', 'dns_search']
|
|
|
+ already_merged_keys = set(d) | {'image', 'build'}
|
|
|
+ for field in set(ALLOWED_KEYS) - already_merged_keys:
|
|
|
+ if field in base or field in override:
|
|
|
+ d[field] = override.get(field, base.get(field))
|
|
|
|
|
|
- for key in list_or_string_keys:
|
|
|
- if key in base or key in override:
|
|
|
- d[key] = to_list(base.get(key)) + to_list(override.get(key))
|
|
|
-
|
|
|
- already_merged_keys = ['environment', 'labels'] + path_mapping_keys + list_keys + list_or_string_keys
|
|
|
+ return d
|
|
|
|
|
|
- for k in set(ALLOWED_KEYS) - set(already_merged_keys):
|
|
|
- if k in override:
|
|
|
- d[k] = override[k]
|
|
|
|
|
|
- return d
|
|
|
+def merge_image_or_build(base, override, output):
|
|
|
+ if 'image' in override:
|
|
|
+ output['image'] = override['image']
|
|
|
+ elif 'build' in override:
|
|
|
+ output['build'] = override['build']
|
|
|
+ elif 'image' in base:
|
|
|
+ output['image'] = base['image']
|
|
|
+ elif 'build' in base:
|
|
|
+ output['build'] = base['build']
|
|
|
|
|
|
|
|
|
def merge_environment(base, override):
|
|
@@ -604,6 +595,10 @@ def expand_path(working_dir, path):
|
|
|
return os.path.abspath(os.path.join(working_dir, os.path.expanduser(path)))
|
|
|
|
|
|
|
|
|
+def merge_list_or_string(base, override):
|
|
|
+ return to_list(base) + to_list(override)
|
|
|
+
|
|
|
+
|
|
|
def to_list(value):
|
|
|
if value is None:
|
|
|
return []
|