/*-
 * ============LICENSE_START=======================================================
 * PROJECT
 * ================================================================================
 * 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=========================================================
 */

package org.openecomp.dcae.commonFunction;



import java.io.IOException;

import java.net.URL;
import java.nio.charset.Charset;
import java.nio.file.Files;
import java.nio.file.Paths;
import java.util.Iterator;
import java.util.LinkedList;
import java.util.List;
import java.util.Map;

import java.util.Queue;
import java.util.concurrent.LinkedBlockingQueue;

import javax.servlet.ServletException;

import org.apache.catalina.LifecycleException;
import org.json.JSONArray;
import org.json.JSONException;
import org.json.JSONObject;
import org.openecomp.dcae.restapi.RestfulCollectorServlet;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;


import com.att.nsa.apiServer.ApiServer;
import com.att.nsa.apiServer.ApiServerConnector;
import com.att.nsa.apiServer.endpoints.NsaBaseEndpoint;
import com.att.nsa.cmdLine.NsaCommandLineUtil;
import com.att.nsa.drumlin.service.framework.DrumlinServlet;
import com.att.nsa.drumlin.till.nv.rrNvReadable;
import com.att.nsa.drumlin.till.nv.impl.nvPropertiesFile;
import com.att.nsa.drumlin.till.nv.impl.nvReadableStack;
import com.att.nsa.drumlin.till.nv.impl.nvReadableTable;
import com.att.nsa.drumlin.till.nv.rrNvReadable.invalidSettingValue;
import com.att.nsa.drumlin.till.nv.rrNvReadable.loadException;
import com.att.nsa.drumlin.till.nv.rrNvReadable.missingReqdSetting;
import com.fasterxml.jackson.core.JsonParseException;
import com.fasterxml.jackson.databind.JsonNode;
import com.github.fge.jsonschema.exceptions.ProcessingException;
import com.github.fge.jsonschema.main.JsonSchema;
import com.github.fge.jsonschema.main.JsonSchemaFactory;
import com.github.fge.jsonschema.report.ProcessingMessage;
import com.github.fge.jsonschema.report.ProcessingReport;
import com.github.fge.jsonschema.util.JsonLoader;


public class CommonStartup extends NsaBaseEndpoint implements Runnable
{
	public static final String kConfig = "c";

	public static final String kSetting_Port = "collector.service.port";
	public static final int kDefault_Port = 8080;
	
	public static final String kSetting_SecurePort = "collector.service.secure.port";
	public static final int kDefault_SecurePort = -1; 
	
	public static final String kSetting_KeystorePassfile = "collector.keystore.passwordfile";
	public static final String kDefault_KeystorePassfile = "../etc/passwordfile";	
	public static final String kSetting_KeystoreFile = "collector.keystore.file.location";
	public static final String kDefault_KeystoreFile = "../etc/keystore";
	public static final String kSetting_KeyAlias = "collector.keystore.alias";
	public static final String kDefault_KeyAlias = "tomcat";

	public static final String kSetting_ProcessingConfigs = "collector.hpprocessing";
	protected static final String[] kDefault_ProcessingConfigs = new String[] { "etc/HPProcessingConfig.json" };

	public static final String kSetting_MaxQueuedEvents = "collector.inputQueue.maxPending";
	public static final int kDefault_MaxQueuedEvents = 1024*4;
	
	public static final String kSetting_schemaValidator = "collector.schema.checkflag";
	public static final int kDefault_schemaValidator = -1; 
	
	public static final String kSetting_schemaFile = "collector.schema.file";
	public static final String kSetting_ExceptionConfig = "exceptionConfig";
	
	public static final String kSetting_dmaapStreamid = "collector.dmaap.streamid";
	
	public static final String kSetting_authflag = "header.authflag";
	public static final int kDefault_authflag = 0;
	
	public static final String kSetting_authid = "header.authid";
	public static final String kSetting_authpwd = "header.authpwd";
	public static final String kSetting_authstore = "header.authstore";
	public static final String kSetting_authlist = "header.authlist";
	
	
	
	public static final Logger inlog = LoggerFactory.getLogger ("org.openecomp.dcae.commonFunction.input" );
	public static final Logger oplog = LoggerFactory.getLogger ("org.openecomp.dcae.commonFunction.output");
	public static final Logger eplog = LoggerFactory.getLogger ("org.openecomp.dcae.commonFunction.error");
	public static final Logger metriclog = LoggerFactory.getLogger ("com.att.ecomp.metrics" );
	
	public static int schema_Validatorflag = -1;
	public static int authflag = 1;
	public static String schemaFile = null;
	public static String exceptionConfig = null;
	public static String cambriaConfigFile = null;
	private boolean listnerstatus = false;
	static String streamid = null;
	
	private CommonStartup(rrNvReadable settings) throws loadException, missingReqdSetting, IOException, rrNvReadable.missingReqdSetting, rrNvReadable.invalidSettingValue, ServletException, InterruptedException
	{
		final List<ApiServerConnector> connectors = new LinkedList<ApiServerConnector> ();

		if (settings.getInt ( kSetting_Port, kDefault_Port ) > 0)
		{
			// http service
				connectors.add (
					new ApiServerConnector.Builder ( settings.getInt ( kSetting_Port, kDefault_Port ) )
					.secure ( false )
					.build ()
				);
		}

		// optional https service		
		final int securePort = settings.getInt(kSetting_SecurePort, kDefault_SecurePort);
		final String keystoreFile = settings.getString(kSetting_KeystoreFile, kDefault_KeystoreFile);
		final String keystorePasswordFile = settings.getString(kSetting_KeystorePassfile, kDefault_KeystorePassfile);
		final String keyAlias = settings.getString (kSetting_KeyAlias, kDefault_KeyAlias);
		
		
		if (securePort > 0)
		{
			final String kSetting_KeystorePass = readFile(keystorePasswordFile, Charset.defaultCharset());
				connectors.add(new ApiServerConnector.Builder(securePort)
					.secure(true)
					.keystorePassword(kSetting_KeystorePass)
					.keystoreFile(keystoreFile)
					.keyAlias(keyAlias)
					.build());

		}

		//Reading other config properties
		
		schema_Validatorflag = settings.getInt(kSetting_schemaValidator, kDefault_schemaValidator );
		if (schema_Validatorflag > 0){
			schemaFile =  settings.getString(kSetting_schemaFile,null);	
		}
		exceptionConfig = settings.getString(kSetting_ExceptionConfig, null);
		authflag = settings.getInt(CommonStartup.kSetting_authflag, CommonStartup.kDefault_authflag );
		String [] currentconffile = settings.getStrings (CommonStartup.kSetting_ProcessingConfigs,	CommonStartup.kDefault_ProcessingConfigs ) ;
		cambriaConfigFile= currentconffile[0] ;
		streamid = settings.getString(kSetting_dmaapStreamid,null);

		fTomcatServer = new ApiServer.Builder(connectors, new RestfulCollectorServlet(settings))
			.encodeSlashes(true)
			.name("collector")
			.build();
		
		
		//Load override exception map 
		CustomExceptionLoader.LoadMap();
		setListnerstatus(true);
	}

	public static void main ( String[] args )
	{
		try
		{
			// process command line arguments
			final Map<String, String> argMap = NsaCommandLineUtil.processCmdLine ( args, true );
			final String config = NsaCommandLineUtil.getSetting ( argMap, kConfig, "collector.properties" );
			final URL settingStream = DrumlinServlet.findStream ( config, CommonStartup.class );

			final nvReadableStack settings = new nvReadableStack ();
			settings.push ( new nvPropertiesFile ( settingStream ) );
			settings.push ( new nvReadableTable ( argMap ) );
			
			fProcessingInputQueue = new LinkedBlockingQueue<JSONObject> (CommonStartup.kDefault_MaxQueuedEvents);
			CommonStartup cs= new CommonStartup ( settings );

			Thread csmain = new Thread(cs);
			csmain.start();
			
			EventProcessor ep = new EventProcessor ();
			Thread epThread=new Thread(ep);
		    epThread.start();
			
			//cs.startAndAwait ();
			
		}
		catch ( loadException | missingReqdSetting  | IOException | invalidSettingValue | ServletException | InterruptedException e )
		{
			CommonStartup.eplog.error("FATAL_STARTUP_ERROR" + e.getMessage() );
			throw new RuntimeException ( e );
		}
	}

	public void run() {
		try {
			fTomcatServer.start ();
		} catch (LifecycleException | IOException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		fTomcatServer.await ();
	}

    public boolean isListnerstatus() {
		return listnerstatus;
	}

	public void setListnerstatus(boolean listnerstatus) {
		this.listnerstatus = listnerstatus;
	}
		public static Queue<JSONObject> getProcessingInputQueue ()
	{
		return fProcessingInputQueue;
	}
	
	public static class QueueFullException extends Exception
	{
		private static final long serialVersionUID = 1L;
	}
	
	
	public static void handleEvents ( JSONArray a ) throws QueueFullException, JSONException, IOException
	{
		final Queue<JSONObject> queue = getProcessingInputQueue ();
		try
		{
			
			CommonStartup.metriclog.info("EVENT_PUBLISH_START" );
			for (int i = 0; i < a.length(); i++) {
					if ( !queue.offer ( a.getJSONObject(i) ) )	{
						throw new QueueFullException ();
					}
					
			} 
			log.debug("CommonStartup.handleEvents:EVENTS has been published successfully!");
			CommonStartup.metriclog.info("EVENT_PUBLISH_END");
			//ecomplogger.debug(secloggerMessageEnum.SEC_COLLECT_AND_PULIBISH_SUCCESS);

		}
		catch ( JSONException e ){
			throw e;
			
		}
	}

		
	static String readFile(String path, Charset encoding) 
			  throws IOException 
			{
			    byte[] encoded = Files.readAllBytes(Paths.get(path));
			    String pwd = new String(encoded);
			    return pwd.substring(0,pwd.length()-1);
			}

	
	public static String schemavalidate( String jsonData, String jsonSchema) {
	    ProcessingReport report = null;
	    String result = "false";
	    
	    try {
	        //System.out.println("Applying schema: @<@<"+jsonSchema+">@>@ to data: #<#<"+jsonData+">#>#");
	    	log.trace("Schema validation for event:" + jsonData);
	        JsonNode schemaNode = JsonLoader.fromString(jsonSchema);
	        JsonNode data = JsonLoader.fromString(jsonData);         
	        JsonSchemaFactory factory = JsonSchemaFactory.byDefault(); 
	        JsonSchema schema = factory.getJsonSchema(schemaNode);
	        report = schema.validate(data);
	    } catch (JsonParseException e) {
	    	log.error("schemavalidate:JsonParseException for event:" + jsonData );
	    	System.out.println(e.getMessage());
	        return e.getMessage().toString();
	    } catch (ProcessingException e) {  
	    	log.error("schemavalidate:Processing exception for event:" + jsonData );
	    	System.out.println(e.getMessage());
	    	return e.getMessage().toString();
	    } catch (IOException e) {
	        log.error("schemavalidate:IO exception; something went wrong trying to read json data for event:" + jsonData);
	        System.out.println(e.getMessage());
	        return e.getMessage().toString();
	    }
	    if (report != null) {
	        Iterator<ProcessingMessage> iter = report.iterator();
	        while (iter.hasNext()) {
	            ProcessingMessage pm = iter.next();
	            log.trace("Processing Message: "+pm.getMessage());
	        }
	        result = String.valueOf(report.isSuccess());
	    }
	    try {
	    log.trace("Validation Result:" +result + " Validation report:" + report);
	    }
	    catch (NullPointerException e){
	    	log.error("schemavalidate:NullpointerException on report");
	    }
	    return result;
	}

	

	static LinkedBlockingQueue<JSONObject> fProcessingInputQueue;
	private static ApiServer fTomcatServer = null;
	private static final Logger log = LoggerFactory.getLogger ( CommonStartup.class );
}