/*
 * ============LICENSE_START==========================================
 * ONAP Portal SDK
 * ===================================================================
 * Copyright © 2017 AT&T Intellectual Property. All rights reserved.
 * ===================================================================
 *
 * Unless otherwise specified, all software contained herein is licensed
 * under the Apache License, Version 2.0 (the "License");
 * you may not use this software 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.
 *
 * Unless otherwise specified, all documentation contained herein is licensed
 * under the Creative Commons License, Attribution 4.0 Intl. (the "License");
 * you may not use this documentation except in compliance with the License.
 * You may obtain a copy of the License at
 *
 *             https://creativecommons.org/licenses/by/4.0/
 *
 * Unless required by applicable law or agreed to in writing, documentation
 * 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.portalsdk.rnotebookintegration.service;

import java.util.Date;
import java.util.HashMap;
import java.util.Map;
import java.util.UUID;

import org.onap.portalsdk.core.logging.logic.EELFLoggerDelegate;
import org.onap.portalsdk.core.restful.domain.EcompUser;
import org.onap.portalsdk.core.service.DataAccessService;
import org.onap.portalsdk.rnotebookintegration.domain.RNoteBookCredentials;
import org.onap.portalsdk.rnotebookintegration.exception.RNotebookIntegrationException;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import com.fasterxml.jackson.core.JsonProcessingException;
import com.fasterxml.jackson.databind.ObjectMapper;

@Service("RNoteBookIntegrationService")
@Transactional
public class RNoteBookIntegrationServiceImpl implements RNoteBookIntegrationService {

	private static final EELFLoggerDelegate logger = EELFLoggerDelegate
			.getLogger(RNoteBookIntegrationServiceImpl.class);

	private static final long TOKEN_TTL = 50000L;

	@Autowired
	private DataAccessService dataAccessService;

	public DataAccessService getDataAccessService() {
		return dataAccessService;
	}

	public void setDataAccessService(DataAccessService dataAccessService) {
		this.dataAccessService = dataAccessService;
	}

	@Override
	public String getRNotebookCredentials(String token) throws RNotebookIntegrationException {
		String retString = "";

		try {
			RNoteBookCredentials notebookCredentials = (RNoteBookCredentials) this.getDataAccessService()
					.getDomainObject(RNoteBookCredentials.class, token, new HashMap<String, String>());
			if (notebookCredentials.getToken() == null || "".equals(notebookCredentials.getToken())) {
				throw new RNotebookIntegrationException(RNotebookIntegrationException.ERROR_CODE_TOKEN_INVALID);
			}
			Date currDate = new Date();
			if ((currDate.getTime() - notebookCredentials.getCreatedDate().getTime() > TOKEN_TTL)
					|| (notebookCredentials.getTokenReadDate() != null)) {
				throw new RNotebookIntegrationException(RNotebookIntegrationException.ERROR_CODE_TOKEN_EXPIRED);
			}
			ObjectMapper mapper = new ObjectMapper();

			try {
				EcompUser userInfo = mapper.readValue(notebookCredentials.getUserString(), EcompUser.class);
				notebookCredentials.setUserInfo(userInfo);
			} catch (JsonProcessingException me) {
				logger.error(EELFLoggerDelegate.errorLogger, "error converting string to user. from JSON", me);
			}

			try {
				Map<String, String> params = mapper.readValue(notebookCredentials.getParametersString(), Map.class);
				notebookCredentials.setParameters(params);
			} catch (JsonProcessingException me) {
				logger.error(EELFLoggerDelegate.errorLogger, "error converting string to parameters. from JSON", me);
			}

			// expiring the token
			try {
				notebookCredentials.setTokenReadDate(new Date());
				this.getDataAccessService().saveDomainObject(notebookCredentials, null);
			} catch (Exception e) {
				logger.error(EELFLoggerDelegate.errorLogger, "Error while expiring the token", e);
				throw new RNotebookIntegrationException(e);
			}
			retString = mapper.writeValueAsString(notebookCredentials);
		} catch (RNotebookIntegrationException re) {
			logger.error(EELFLoggerDelegate.errorLogger, "getRNotebookCredentials failed", re);
			throw re;
		} catch (Exception e) {
			logger.error(EELFLoggerDelegate.errorLogger, "Error while parsing the rcloud notebook credentials", e);
			throw new RNotebookIntegrationException(e);
		}

		return retString;
	}

	@Override
	public String saveRNotebookCredentials(String notebookId, EcompUser user, Map<String, String> params)
			throws RNotebookIntegrationException {

		String token = "";
		try {
			token = UUID.randomUUID().toString();
			ObjectMapper mapper = new ObjectMapper();
			RNoteBookCredentials rc = new RNoteBookCredentials();
			rc.setToken(token);
			rc.setCreatedDate(new Date());
			rc.setNotebookID(notebookId);
			rc.setParametersString(mapper.writeValueAsString(params));
			rc.setUserString(mapper.writeValueAsString(user));
			this.getDataAccessService().saveDomainObject(rc, null);
		} catch (Exception e) {
			logger.error(EELFLoggerDelegate.errorLogger, "Error while parsing the rcloud notebook credentials", e);
			throw new RNotebookIntegrationException(e);
		}
		return token;
	}

}