/*-
 * ============LICENSE_START=======================================================
 * ONAP : CCSDK
 * ================================================================================
 * Copyright (C) 2017 AT&T Intellectual Property. All rights
 * 						reserved.
 * ================================================================================
 * Modifications Copyright (C) 2018 IBM.
 * ================================================================================
 * 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=========================================================
 */

package org.onap.ccsdk.sli.core.sli.provider.base;

import java.util.HashMap;
import java.util.Iterator;
import java.util.Map;
import java.util.Set;

import org.onap.ccsdk.sli.core.sli.SvcLogicAdaptor;
import org.onap.ccsdk.sli.core.sli.SvcLogicConstants;
import org.onap.ccsdk.sli.core.sli.SvcLogicContext;
import org.onap.ccsdk.sli.core.sli.SvcLogicException;
import org.onap.ccsdk.sli.core.sli.SvcLogicExpression;
import org.onap.ccsdk.sli.core.sli.SvcLogicNode;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

public class ConfigureNodeExecutor extends AbstractSvcLogicNodeExecutor {
	private static final Logger LOG = LoggerFactory
			.getLogger(ConfigureNodeExecutor.class);
	private static final String CAUGHT_EXCEPTION_MSG="Caught exception from ";
	private static final String ALREADY_ACTIVE= "already-active";
	private static final String NOT_FOUND= "not-found";

	public SvcLogicNode execute(SvcLogicServiceBase svc, SvcLogicNode node,
			SvcLogicContext ctx) throws SvcLogicException {

		String adaptorName = SvcLogicExpressionResolver.evaluate(
				node.getAttribute("adaptor"), node, ctx);
		String outValue = SvcLogicConstants.FAILURE;

		if (LOG.isDebugEnabled()) {
			LOG.debug("configure node encountered - looking for adaptor "
					+ adaptorName);
		}

		SvcLogicAdaptor adaptor = getAdaptor(adaptorName);

		if (adaptor != null) {
			String activate = SvcLogicExpressionResolver.evaluate(
					node.getAttribute("activate"), node, ctx);
			String key = SvcLogicExpressionResolver.evaluate(
					node.getAttribute("key"), node, ctx);

			boolean hasParms = false;
			
            Map<String, String> parmMap = getResolvedParameters(node,ctx);
            if(!parmMap.isEmpty()) {
                hasParms = true;
            }

			if (hasParms) {
				SvcLogicAdaptor.ConfigStatus confStatus = SvcLogicAdaptor.ConfigStatus.FAILURE;
				
				try {
					confStatus = adaptor.configure(key, parmMap, ctx);
				} catch (Exception e) {
					LOG.warn(CAUGHT_EXCEPTION_MSG+adaptorName+".configure", e);
					confStatus = SvcLogicAdaptor.ConfigStatus.FAILURE;
				}
				
				switch (confStatus) {
				case SUCCESS:
					outValue = SvcLogicConstants.SUCCESS;
					if ((activate != null) && (activate.length() > 0)) {
						if ("true".equalsIgnoreCase(activate)) {
							SvcLogicAdaptor.ConfigStatus activateStatus = SvcLogicAdaptor.ConfigStatus.FAILURE;
							
							try {
								activateStatus = adaptor.activate(key, ctx);
							} catch (Exception e) {

								LOG.warn(CAUGHT_EXCEPTION_MSG+adaptorName+".activate", e);
								activateStatus = SvcLogicAdaptor.ConfigStatus.FAILURE;
							}
							switch (activateStatus) {
							case SUCCESS:
								break;
							case ALREADY_ACTIVE:
								outValue = ALREADY_ACTIVE;
								break;
							case NOT_FOUND:
								outValue = NOT_FOUND;
								break;
							case NOT_READY:
								outValue = "not-ready";
								break;
							case FAILURE:
							default:
								outValue = SvcLogicConstants.FAILURE;
							}
						} else if ("false".equalsIgnoreCase(activate)) {
							SvcLogicAdaptor.ConfigStatus deactivateStatus = SvcLogicAdaptor.ConfigStatus.FAILURE;
							
							try {
								deactivateStatus = adaptor.deactivate(key, ctx);
							} catch (Exception e) {

								LOG.warn(CAUGHT_EXCEPTION_MSG+adaptorName+".deactivate", e);
								deactivateStatus = SvcLogicAdaptor.ConfigStatus.FAILURE;
							}
							switch (deactivateStatus) {
							case SUCCESS:
								break;
							case ALREADY_ACTIVE:
								outValue = ALREADY_ACTIVE;
								break;
							case NOT_FOUND:
								outValue = NOT_FOUND;
								break;
							case NOT_READY:
								outValue = "not-ready";
								break;
							case FAILURE:
							default:
								outValue = SvcLogicConstants.FAILURE;
							}
						}
					}
					break;
				case ALREADY_ACTIVE:
					outValue = ALREADY_ACTIVE;
					break;
				case NOT_FOUND:
					outValue = NOT_FOUND;
					break;
				case NOT_READY:
					outValue = "not-ready";
					break;
				case FAILURE:
				default:
					outValue = SvcLogicConstants.FAILURE;
				}
			} else {
				if ((activate != null) && (activate.length() > 0)) {
					if ("true".equalsIgnoreCase(activate)) {
						SvcLogicAdaptor.ConfigStatus activateStatus = SvcLogicAdaptor.ConfigStatus.FAILURE;
						try {
							activateStatus = adaptor.activate(key, ctx);
						} catch (Exception e) {
							LOG.warn(CAUGHT_EXCEPTION_MSG+adaptorName+".activate", e);
							activateStatus = SvcLogicAdaptor.ConfigStatus.FAILURE;
						}
						switch (activateStatus) {
						case SUCCESS:
							outValue = SvcLogicConstants.SUCCESS;
							break;
						case ALREADY_ACTIVE:
							outValue = ALREADY_ACTIVE;
							break;
						case NOT_FOUND:
							outValue = NOT_FOUND;
							break;
						case NOT_READY:
							outValue = "not-ready";
							break;
						case FAILURE:
						default:
							outValue = SvcLogicConstants.FAILURE;
						}
					} else if ("false".equalsIgnoreCase(activate)) {
						SvcLogicAdaptor.ConfigStatus deactivateStatus = SvcLogicAdaptor.ConfigStatus.FAILURE;
						
						try {
							deactivateStatus = adaptor.deactivate(key, ctx);
						} catch (Exception e) {
							LOG.warn(CAUGHT_EXCEPTION_MSG+adaptorName+".deactivate", e);
							deactivateStatus = SvcLogicAdaptor.ConfigStatus.FAILURE;
						}
						switch (deactivateStatus) {
						case SUCCESS:
							outValue = SvcLogicConstants.SUCCESS;
							break;
						case ALREADY_ACTIVE:
							outValue = ALREADY_ACTIVE;
							break;
						case NOT_FOUND:
							outValue = NOT_FOUND;
							break;
						case NOT_READY:
							outValue = "not-ready";
							break;
						case FAILURE:
						default:
							outValue = SvcLogicConstants.FAILURE;
						}
					}
				} else {
					LOG.warn("Nothing to configure - no parameters passed, and activate attribute is not set");
					outValue = SvcLogicConstants.SUCCESS;
				}
			}
		} else {
			if (LOG.isWarnEnabled()) {
				LOG.warn("Adaptor for " + adaptorName + " not found");
			}
		}

		SvcLogicNode nextNode = node.getOutcomeValue(outValue);
		if (nextNode != null) {
			if (LOG.isDebugEnabled()) {
				LOG.debug("about to execute " + outValue + " branch");
			}
			return (nextNode);
		}

		nextNode = node.getOutcomeValue("Other");
		if (nextNode != null) {
			if (LOG.isDebugEnabled()) {
				LOG.debug("about to execute Other branch");
			}
		} else {
			if (LOG.isDebugEnabled()) {
				LOG.debug("no " + outValue + " or Other branch found");
			}
		}
		return (nextNode);
	}

}