/*-
 * ============LICENSE_START=======================================================
 * PolicyEngineClient
 * ================================================================================
 * Copyright (C) 2017 AT&T Intellectual Property. All rights reserved.
 * ================================================================================
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 * 
 *      http://www.apache.org/licenses/LICENSE-2.0
 * 
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 * ============LICENSE_END=========================================================
 */

/*
 *                        AT&T - PROPRIETARY
 *          THIS FILE CONTAINS PROPRIETARY INFORMATION OF
 *        AT&T AND IS NOT TO BE DISCLOSED OR USED EXCEPT IN
 *             ACCORDANCE WITH APPLICABLE AGREEMENTS.
 *
 *          Copyright (c) 2014 AT&T Knowledge Ventures
 *              Unpublished and Not for Publication
 *                     All Rights Reserved
 */
package org.onap.policyengine;

import java.io.IOException;
import java.util.ArrayList;
import java.util.Collection;
import java.util.Map;
import java.util.UUID;

import org.onap.policy.api.DecisionResponse;
import org.onap.policy.api.LoadedPolicy;
import org.onap.policy.api.NotificationScheme;
import org.onap.policy.api.PolicyConfig;
import org.onap.policy.api.PolicyConfigException;
import org.onap.policy.api.PolicyDecisionException;
import org.onap.policy.api.PolicyEngine;
import org.onap.policy.api.PolicyEventException;
import org.onap.policy.api.PolicyResponse;
import org.onap.policy.api.RemovedPolicy;

/**
 * Class contains static functions which make call to policy engine using API.
 * This class is used by generalTestClient.java
 * 
 * 
 * @version 1.0
 *
 */
public class PolicyEngineTestClient {
	/**
	 * This fuction make API call to policy engine to get config. And returns
	 * policy name, policy version and policy configStatus
	 * 
	 * @param org.onap.policyEngine
	 * @param onapComponentName
	 * @param configName
	 * @param configAttributes
	 * @return
	 */

	@SuppressWarnings("deprecation")
	public static ArrayList<String> getConfig(PolicyEngine policyEngine,
			String onapComponentName, String configName,
			Map<String, String> configAttributes) {
		ArrayList<String> resultReceived = new ArrayList<>();
		try {
			UUID requestID = UUID.randomUUID();
			Collection<PolicyConfig> policyConfigs;
			if (configName == null) {
				policyConfigs = policyEngine.getConfig(onapComponentName, requestID);
			} else {
				if (configAttributes == null) {
					policyConfigs = policyEngine.getConfig(onapComponentName,
							configName, requestID);
				} else {
					
					policyConfigs = policyEngine.getConfig(onapComponentName,
							configName, configAttributes, requestID);
				}
			}
			if (policyConfigs != null && !policyConfigs.isEmpty()) {
				for (PolicyConfig policyConfig : policyConfigs) {
					resultReceived.add("Policy Name: "
							+ policyConfig.getPolicyName()
							+ " Policy version: "
							+ policyConfig.getPolicyVersion() + " - "
							+ policyConfig.getPolicyConfigStatus());
				}
			}
		} catch (PolicyConfigException e) {
//			logger.error("Exception Occured"+e);
			resultReceived.add(""+e);
		}
		return resultReceived;
	}

	/**
	 * This functions make API call to policy engine to get decision. And
	 * returns policy Decision
	 * 
	 * @param org.onap.policyEngine
	 * @param onapComponentName
	 * @param decisionAttributes
	 * @return
	 */
	public static ArrayList<String> getDecision(PolicyEngine policyEngine,
			String onapComponentName, Map<String, String> decisionAttributes) {
		ArrayList<String> resultReceived = new ArrayList<>();
		// Decision example
		try {
			UUID requestID = UUID.randomUUID();
			@SuppressWarnings("deprecation")
			DecisionResponse policyDecision = policyEngine.getDecision(
					onapComponentName, decisionAttributes, requestID);
			resultReceived.add(policyDecision.getDecision().toString());
		} catch (PolicyDecisionException e) {
//			logger.error("Exception Occured"+e);
			resultReceived.add(""+e);
		}
		return resultReceived;
	}

	/**
	 * This function makes API call to policy engine to get action. And returns
	 * responseMessage and responseStatus
	 * 
	 * @param org.onap.policyEngine
	 * @param eventAttributes
	 * @return
	 */
	public static ArrayList<String> getAction(PolicyEngine policyEngine,
			Map<String, String> eventAttributes) {
		ArrayList<String> resultReceived = new ArrayList<>();
		try {
			UUID requestID = UUID.randomUUID();
			@SuppressWarnings("deprecation")
			Collection<PolicyResponse> policyResponses = policyEngine
					.sendEvent(eventAttributes, requestID);
			if (policyResponses != null && !policyResponses.isEmpty()) {
				for (PolicyResponse policyResponse : policyResponses) {
					resultReceived.add(policyResponse
							.getPolicyResponseMessage()
							+ " : "
							+ policyResponse.getPolicyResponseStatus());
				}
			}
		} catch (PolicyEventException e) {
//			logger.error("Exception Occured"+e);
			resultReceived.add(""+e);
		}
		return resultReceived;
	}

	/**
	 * This function makes API call to policy engine to get manual
	 * notifications.
	 * 
	 * @param org.onap.policyEngine
	 */

	public static void getManualNotifications(PolicyEngine policyEngine) {
		policyEngine.setScheme(NotificationScheme.MANUAL_ALL_NOTIFICATIONS);
		System.out.println(policyEngine.getNotification().getNotificationType());
		for (LoadedPolicy updated : policyEngine.getNotification().getLoadedPolicies()) {
			System.out.println(updated.getPolicyName());
			System.out.println(updated.getVersionNo());
			System.out.println(updated.getMatches());
		}
		for (RemovedPolicy removed : policyEngine.getNotification()
				.getRemovedPolicies()) {
			System.out.println(removed.getPolicyName());
			System.out.println(removed.getVersionNo());
		}
	}

	/**
	 * This function makes API call to policy engine to get automatic
	 * notifications.
	 * 
	 * @param org.onap.policyEngine
	 */
	public static void getAutoNotifications(PolicyEngine policyEngine) {
		Handler handler = new Handler();
		policyEngine.setNotification(NotificationScheme.AUTO_ALL_NOTIFICATIONS,
				handler);
		//
		System.out.println("Enter a any key to exit");
		try {
			System.in.read();
		} catch (IOException e) {
			//
		}
	}

}