package org.onap.vid.scheduler; import com.att.eelf.configuration.EELFLogger; import com.google.common.collect.ImmutableMap; import com.google.common.collect.Maps; import io.joshworks.restclient.http.HttpResponse; import org.eclipse.jetty.util.security.Password; import org.onap.portalsdk.core.logging.logic.EELFLoggerDelegate; import org.onap.portalsdk.core.util.SystemProperties; import org.onap.vid.client.SyncRestClient; import org.onap.vid.client.SyncRestClientInterface; import org.onap.vid.exceptions.GenericUncheckedException; import org.onap.vid.utils.Logging; import org.springframework.http.HttpMethod; import org.springframework.stereotype.Service; import java.util.Base64; import java.util.Collections; import java.util.Map; import java.util.function.Function; import static org.onap.vid.utils.Logging.REQUEST_ID_HEADER_KEY; @Service public class SchedulerRestInterface implements SchedulerRestInterfaceIfc { final private static EELFLogger outgoingRequestsLogger = Logging.getRequestsLogger("scheduler"); private static EELFLoggerDelegate logger = EELFLoggerDelegate.getLogger(SchedulerRestInterface.class); private SyncRestClientInterface syncRestClient; private Function propertyGetter; private Map commonHeaders; public SchedulerRestInterface() { this.propertyGetter = SystemProperties::getProperty; } public SchedulerRestInterface(Function propertyGetter) { this.propertyGetter = propertyGetter; } public void initRestClient() { logger.info("Starting to initialize rest client "); String authStringEnc = calcEncodedAuthString(); commonHeaders = Maps.newHashMap(); commonHeaders.put("Authorization", "Basic " + authStringEnc); syncRestClient = new SyncRestClient(); logger.info("\t<== Client Initialized \n"); } public void Get(T t, String sourceId, String path, org.onap.vid.scheduler.RestObject restObject) { initRestClient(); String methodName = "Get"; String url = String.format("%s%s", propertyGetter.apply(SchedulerProperties.SCHEDULER_SERVER_URL_VAL), path); Logging.logRequest(outgoingRequestsLogger, HttpMethod.GET, url); Map requestHeaders = ImmutableMap.builder() .putAll(commonHeaders) .put(REQUEST_ID_HEADER_KEY, Logging.extractOrGenerateRequestId()).build(); final HttpResponse response = ((HttpResponse) syncRestClient.get(url, requestHeaders, Collections.emptyMap(), t.getClass())); Logging.logResponse(outgoingRequestsLogger, HttpMethod.GET, url, response); int status = response.getStatus(); restObject.setStatusCode(status); if (status == 200) { t = response.getBody(); restObject.set(t); } else { throw new GenericUncheckedException(String.format("%s with status=%d, url=%s", methodName, status, url)); } } public void Delete(T t, String sourceID, String path, org.onap.vid.scheduler.RestObject restObject) { initRestClient(); String url = String.format("%s%s", propertyGetter.apply(SchedulerProperties.SCHEDULER_SERVER_URL_VAL), path); Logging.logRequest(outgoingRequestsLogger, HttpMethod.DELETE, url); Map requestHeaders = ImmutableMap.builder() .putAll(commonHeaders) .put(REQUEST_ID_HEADER_KEY, Logging.extractOrGenerateRequestId()).build(); final HttpResponse response = (HttpResponse) syncRestClient.delete(url, requestHeaders, t.getClass()); Logging.logResponse(outgoingRequestsLogger, HttpMethod.DELETE, url, response); int status = response.getStatus(); restObject.setStatusCode(status); t = response.getBody(); restObject.set(t); } public T getInstance(Class clazz) throws IllegalAccessException, InstantiationException { return clazz.newInstance(); } private String calcEncodedAuthString() { String retrievedUsername = propertyGetter.apply(SchedulerProperties.SCHEDULER_USER_NAME_VAL); final String username = retrievedUsername.isEmpty() ? "" : retrievedUsername; String retrievedPassword = propertyGetter.apply(SchedulerProperties.SCHEDULER_PASSWORD_VAL); final String password = retrievedPassword.isEmpty() ? "" : getDeobfuscatedPassword(retrievedPassword); return Base64.getEncoder().encodeToString((username + ":" + password).getBytes()); } private static String getDeobfuscatedPassword(String password) { return password.contains("OBF:") ? Password.deobfuscate(password) : password; } }