Merge "Adding Junit"
[so.git] / bpmn / MSOCommonBPMN / src / main / java / org / openecomp / mso / client / adapter / vnf / AdapterRestClient.java
1 /*-
2  * ============LICENSE_START=======================================================
3  * ONAP - SO
4  * ================================================================================
5  * Copyright (C) 2017 AT&T Intellectual Property. All rights reserved.
6  * ================================================================================
7  * Licensed under the Apache License, Version 2.0 (the "License");
8  * you may not use this file except in compliance with the License.
9  * You may obtain a copy of the License at
10  *
11  *      http://www.apache.org/licenses/LICENSE-2.0
12  *
13  * Unless required by applicable law or agreed to in writing, software
14  * distributed under the License is distributed on an "AS IS" BASIS,
15  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
16  * See the License for the specific language governing permissions and
17  * limitations under the License.
18  * ============LICENSE_END=========================================================
19  */
20
21 package org.openecomp.mso.client.adapter.vnf;
22
23 import java.net.URI;
24 import java.security.GeneralSecurityException;
25 import java.util.Map;
26 import java.util.Optional;
27 import java.util.UUID;
28
29 import javax.ws.rs.client.ClientResponseFilter;
30 import javax.ws.rs.ext.ContextResolver;
31
32 import org.apache.commons.codec.binary.Base64;
33 import org.openecomp.mso.bpmn.common.util.CryptoUtils;
34 import org.openecomp.mso.client.ResponseExceptionMapperImpl;
35 import org.openecomp.mso.client.policy.JettisonStyleMapperProvider;
36 import org.openecomp.mso.client.policy.RestClient;
37
38 import com.fasterxml.jackson.databind.ObjectMapper;
39
40 public class AdapterRestClient extends RestClient {
41
42         private final AdapterRestProperties props;
43         public AdapterRestClient(AdapterRestProperties props, URI uri) {
44                 super(props, UUID.randomUUID(), Optional.of(uri));
45                 this.props = props;
46         }
47
48         public AdapterRestClient(AdapterRestProperties props, URI uri, String accept, String contentType) {
49                 super(props, UUID.randomUUID(), Optional.of(uri), accept, contentType);
50                 this.props = props;
51         }
52
53         @Override
54         protected void initializeHeaderMap(Map<String, String> headerMap) {
55                 headerMap.put("Authorization",
56                                 this.getBasicAuth(props.getAuth(), props.getKey()));
57         }
58
59         @Override
60         protected Optional<ClientResponseFilter> addResponseFilter() {
61                 return Optional.of(new ResponseExceptionMapperImpl());
62         }
63
64         @Override
65         public RestClient addRequestId(UUID requestId) {
66                 return null;
67         }
68
69         @Override
70         protected ContextResolver<ObjectMapper> getMapper() {
71                 return new JettisonStyleMapperProvider();
72         }
73         
74         private String getBasicAuth(String encryptedAuth, String msoKey) {
75                 if ((encryptedAuth == null || encryptedAuth.isEmpty()) || (msoKey == null || msoKey.isEmpty())) {
76                         return null;
77                 }
78                 try {
79                         String auth = CryptoUtils.decrypt(encryptedAuth, msoKey);
80                         byte[] encoded = Base64.encodeBase64(auth.getBytes());
81                         String encodedString = new String(encoded);
82                         encodedString = "Basic " + encodedString;
83                         return encodedString;
84                 } catch (GeneralSecurityException e) {
85                         this.logger.warn(e.getMessage(), e);
86                         return null;
87                 }
88         }
89 }