/*******************************************************************************
 * ============LICENSE_START==================================================
 * * org.onap.dmaap
 * * ===========================================================================
 * * Copyright © 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====================================================
 * *
 * * ECOMP is a trademark and service mark of AT&T Intellectual Property.
 * *
 ******************************************************************************/

package com.att.research.datarouter.provisioning.beans;

import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Types;
import java.text.ParseException;
import java.util.LinkedHashMap;

import org.json.LOGJSONObject;

/**
 * The representation of a Publish Record, as retrieved from the DB.
 * @author Robert Eby
 * @version $Id: PublishRecord.java,v 1.6 2013/10/28 18:06:53 eby Exp $
 */
public class PublishRecord extends BaseLogRecord {
	private String feedFileid;
	private String remoteAddr;
	private String user;
	private int status;

	public PublishRecord(String[] pp) throws ParseException {
		super(pp);
//		This is too slow!
//		Matcher m = Pattern.compile(".*/publish/(\\d+)/(.*)$").matcher(pp[4]);
//		if (!m.matches())
//			throw new ParseException("bad pattern", 0);
//		this.feedFileid = m.group(2);
		int ix = pp[4].indexOf("/publish/");
		if (ix < 0)
			throw new ParseException("bad pattern", 0);
		ix = pp[4].indexOf('/', ix+9);
		if (ix < 0)
			throw new ParseException("bad pattern", 0);
		this.feedFileid = pp[4].substring(ix+1);
		this.remoteAddr = pp[8];
		this.user       = pp[9];
		this.status     = Integer.parseInt(pp[10]);
	}
	public PublishRecord(ResultSet rs) throws SQLException {
		super(rs);
		this.feedFileid = rs.getString("FEED_FILEID");
		this.remoteAddr = rs.getString("REMOTE_ADDR");
		this.user       = rs.getString("USER");
		this.status     = rs.getInt("STATUS");
	}
	public String getFeedFileid() {
		return feedFileid;
	}

	public void setFeedFileid(String feedFileid) {
		this.feedFileid = feedFileid;
	}

	public String getRemoteAddr() {
		return remoteAddr;
	}

	public void setRemoteAddr(String remoteAddr) {
		this.remoteAddr = remoteAddr;
	}

	public String getUser() {
		return user;
	}

	public void setUser(String user) {
		this.user = user;
	}

	public int getStatus() {
		return status;
	}

	public void setStatus(int status) {
		this.status = status;
	}
	
	
	public LOGJSONObject reOrderObject(LOGJSONObject jo) {
		LinkedHashMap<String,Object> logrecordObj = new LinkedHashMap<String,Object>();
		
		
		logrecordObj.put("statusCode", jo.get("statusCode"));
		logrecordObj.put("publishId", jo.get("publishId"));
		logrecordObj.put("requestURI", jo.get("requestURI"));
		logrecordObj.put("sourceIP", jo.get("sourceIP"));
		logrecordObj.put("method", jo.get("method"));
		logrecordObj.put("contentType", jo.get("contentType"));
		logrecordObj.put("endpointId", jo.get("endpointId"));
		logrecordObj.put("type", jo.get("type"));
		logrecordObj.put("date", jo.get("date"));
		logrecordObj.put("contentLength", jo.get("contentLength"));
		
		LOGJSONObject newjo = new LOGJSONObject(logrecordObj);
		return newjo;
	}
	
	@Override
	public LOGJSONObject asJSONObject() {
		LOGJSONObject jo = super.asJSONObject();
		jo.put("type", "pub");
//		jo.put("feedFileid", feedFileid);
//		jo.put("remoteAddr", remoteAddr);
//		jo.put("user", user);
		jo.put("sourceIP", remoteAddr);
		jo.put("endpointId", user);
		jo.put("statusCode", status);
		
		LOGJSONObject newjo = this.reOrderObject(jo);
		
		return newjo;
	}
	@Override
	public void load(PreparedStatement ps) throws SQLException {
		ps.setString(1, "pub");		// field 1: type
		super.load(ps);				// loads fields 2-8
		ps.setString( 9, getFeedFileid());
		ps.setString(10, getRemoteAddr());
		ps.setString(11, getUser());
		ps.setInt   (12, getStatus());
		ps.setNull  (13, Types.INTEGER);
		ps.setNull  (14, Types.VARCHAR);
		ps.setNull  (15, Types.INTEGER);
		ps.setNull  (16, Types.INTEGER);
		ps.setNull  (17, Types.VARCHAR);
		ps.setNull  (19, Types.BIGINT);
	}
}