1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
|
// Copyright 2017 Yahoo Holdings. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root.
package com.yahoo.config.model.api;
import com.yahoo.config.provision.ApplicationId;
import com.yahoo.config.provision.TenantName;
import java.util.Collections;
import java.util.LinkedHashMap;
import java.util.List;
import java.util.Map;
import java.util.Optional;
import java.util.Set;
import java.util.stream.Collectors;
public class SuperModel {
private final Map<TenantName, Map<ApplicationId, ApplicationInfo>> models;
public SuperModel() {
this.models = Collections.emptyMap();
}
public SuperModel(Map<TenantName, Map<ApplicationId, ApplicationInfo>> models) {
this.models = models;
}
/**
* Do NOT mutate the returned map.
* TODO: Make the returned map immutable (and type to Map<ApplicationId, ApplicationInfo>)
*/
public Map<TenantName, Map<ApplicationId, ApplicationInfo>> getAllModels() {
return models;
}
public Set<ApplicationId> getAllApplicationIds() {
return models.values().stream().flatMap(entry -> entry.keySet().stream())
.collect(Collectors.toSet());
}
public List<ApplicationInfo> getAllApplicationInfos() {
return models.values().stream().flatMap(entry -> entry.values().stream()).collect(Collectors.toList());
}
public Optional<ApplicationInfo> getApplicationInfo(ApplicationId applicationId) {
Map<ApplicationId, ApplicationInfo> tenantInfo = models.get(applicationId.tenant());
if (tenantInfo == null) {
return Optional.empty();
}
ApplicationInfo applicationInfo = tenantInfo.get(applicationId);
if (applicationInfo == null) {
return Optional.empty();
}
return Optional.of(applicationInfo);
}
public SuperModel cloneAndSetApplication(ApplicationInfo application) {
TenantName tenant = application.getApplicationId().tenant();
Map<TenantName, Map<ApplicationId, ApplicationInfo>> newModels = cloneModels(models);
if (!newModels.containsKey(tenant)) {
// New application has been activated
newModels.put(tenant, new LinkedHashMap<>());
} else {
// Application has been redeployed
}
newModels.get(tenant).put(application.getApplicationId(), application);
return new SuperModel(newModels);
}
public SuperModel cloneAndRemoveApplication(ApplicationId applicationId) {
Map<TenantName, Map<ApplicationId, ApplicationInfo>> newModels = cloneModels(models);
if (newModels.containsKey(applicationId.tenant())) {
newModels.get(applicationId.tenant()).remove(applicationId);
if (newModels.get(applicationId.tenant()).isEmpty()) {
newModels.remove(applicationId.tenant());
}
}
return new SuperModel(newModels);
}
private static Map<TenantName, Map<ApplicationId, ApplicationInfo>> cloneModels(
Map<TenantName, Map<ApplicationId, ApplicationInfo>> models) {
Map<TenantName, Map<ApplicationId, ApplicationInfo>> newModels = new LinkedHashMap<>();
for (Map.Entry<TenantName, Map<ApplicationId, ApplicationInfo>> entry : models.entrySet()) {
Map<ApplicationId, ApplicationInfo> appMap = new LinkedHashMap<>();
newModels.put(entry.getKey(), appMap);
for (Map.Entry<ApplicationId, ApplicationInfo> appEntry : entry.getValue().entrySet()) {
appMap.put(appEntry.getKey(), appEntry.getValue());
}
}
return newModels;
}
}
|
