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
|
package org.onap.sdc.dcae.utils;
import com.fasterxml.jackson.core.JsonProcessingException;
import com.fasterxml.jackson.databind.ObjectMapper;
import org.onap.sdc.dcae.composition.restmodels.sdc.Artifact;
import org.onap.sdc.dcae.enums.ArtifactGroupType;
import org.onap.sdc.dcae.enums.SdcConsumerInfo;
import org.springframework.util.Base64Utils;
import org.springframework.util.StringUtils;
import java.net.URI;
import java.net.URISyntaxException;
import java.util.ArrayList;
import java.util.EnumMap;
import java.util.List;
import java.util.stream.Collectors;
public class SdcRestClientUtils {
private static final String SDC_CATALOG_PATH = "/sdc/v1/catalog/";
// TODO consider moving params elsewhere (user/password/instanceId can be constant)
public static EnumMap<SdcConsumerInfo, String> extractConsumerInfoFromUri(URI configUri) {
EnumMap<SdcConsumerInfo, String> userInfoMap = new EnumMap<>(SdcConsumerInfo.class);
String userInfo = configUri.getUserInfo();
if (userInfo != null) {
userInfoMap.put(SdcConsumerInfo.AUTH, "Basic "+ Base64Utils.encodeToString(userInfo.getBytes()));
}
String fragment = configUri.getFragment();
if (fragment == null)
throw new IllegalArgumentException("The URI must contain a fragment specification, to be used as SDC instance id");
userInfoMap.put(SdcConsumerInfo.INSTANCE_ID, fragment);
try {
userInfoMap.put(SdcConsumerInfo.CATALOG_URL, new URI(configUri.getScheme(), null, configUri.getHost(), configUri.getPort(), configUri.getPath()+SDC_CATALOG_PATH, null, null).toString());
}
catch (URISyntaxException se) {
throw new IllegalArgumentException("Invalid uri", se);
}
return userInfoMap;
}
public static String buildResourceFilterQuery(String resourceType, String category, String subcategory) {
List<String> filters = new ArrayList<>();
if(!StringUtils.isEmpty(resourceType))
filters.add("resourceType="+resourceType);
if(!StringUtils.isEmpty(category))
filters.add("category="+category);
if(!StringUtils.isEmpty(subcategory))
filters.add("subCategory="+subcategory);
return "?"+filters.stream().collect(Collectors.joining("&"));
}
public static UserRemarks buildUserRemarksObject(String userRemarks) {
return new UserRemarks(userRemarks);
}
private static class UserRemarks {
private String userRemarks;
private UserRemarks(String userRemarks) {
this.userRemarks = userRemarks;
}
public String getUserRemarks() {
return userRemarks;
}
}
public static String artifactToString(Artifact artifact) throws JsonProcessingException {
ObjectMapper mapper = new ObjectMapper();
return mapper.writeValueAsString(artifact);
}
public static Artifact generateDeploymentArtifact(String description, String name, String type, String label, byte[] payload){
Artifact artifact = new Artifact();
artifact.setDescription(description);
artifact.setArtifactName(name);
artifact.setArtifactGroupType(ArtifactGroupType.DEPLOYMENT.name());
artifact.setArtifactType(type);
artifact.setArtifactLabel(label);
artifact.setPayloadData(Base64Utils.encodeToString(payload));
return artifact;
}
}
|
