package org.epics.css.dal.simple.impl;

import org.epics.css.dal.CharacteristicInfo;
import org.epics.css.dal.DataExchangeException;
import org.epics.css.dal.DynamicValueProperty;
import org.epics.css.dal.Response;
import org.epics.css.dal.Timestamp;
import org.epics.css.dal.impl.ResponseImpl;
import org.epics.css.dal.simple.AnyData;
import org.epics.css.dal.simple.AnyDataChannel;
import org.epics.css.dal.simple.MetaData;
import org.epics.css.dal.simple.Severity;

public abstract class AbstractAnyDataImpl<T> implements AnyData {
	
	private final DynamicValueProperty<T> property;
	protected final Response<T> response;
	private MetaData metaData;
	private long beamID;
	
	public AbstractAnyDataImpl(DynamicValueProperty<T> property, long beamID) {
		this.property = property;
		Response<T> r= property.getLatestValueResponse();
		if (r==null || r.getValue()==null) {
			response= new ResponseImpl<T>(property, null, confirmValue(this.property.getLatestReceivedValue()), "value", false, null, property.getCondition(), null, true);
		} else {
			this.response = r; 
		}
		
		if (property.isMetaDataInitialized()) {
			metaData = extractMetaData();
		} else {
		    //----- Fix to get meta data for channels that already have a proxy in a different simple dal broker
//			metaData = extractMetaData();
//			if (metaData == null) {
//				metaData = MetaDataImpl.createUninitializedMetaData();
//			}
			//----- end of fix 
			//----- current version
			 metaData = MetaDataImpl.createUninitializedMetaData();
			//----- end of current version
		}
		
		this.beamID=beamID;
	}
	
	protected abstract T confirmValue(T value);
	
	public long getBeamID() {
		return beamID;
	}
	
	public AnyDataChannel getParentChannel() {
		return property;
	}

	public DynamicValueProperty<?> getParentProperty() {
		return property;
	}
	
	public MetaData getMetaData() {
		// TODO if MetaData changes this is how it could be reset
//		if (metaData == null) {
//			metaData = extractMetaData();
//		}
		return metaData;
	}
	
	public Quality getQuality() {
		return Quality.Original;
	}

	public Severity getSeverity() {
		return response.getCondition();
	}

	public String getStatus() {
		return DynamicValueConditionConverterUtil.extractStatusInfo(response.getCondition());
	}

	public Timestamp getTimestamp() {
		return DynamicValueConditionConverterUtil.extractTimestampInfo(response.getCondition());
	}
	
	public boolean isValid() {
		// TODO other option: response.getCondition().hasValue()
		return response.getError() == null;
	}
	
	private MetaData extractMetaData() {
		try {
			return (MetaData) property.getCharacteristic(CharacteristicInfo.C_META_DATA.getName());
		} catch (DataExchangeException e) {
			e.printStackTrace();
			return null;
		}
	}
	
}

package org.epics.css.dal.simple.impl;

import org.epics.css.dal.CharacteristicInfo;
import org.epics.css.dal.DataExchangeException;
import org.epics.css.dal.DynamicValueProperty;
import org.epics.css.dal.Response;
import org.epics.css.dal.Timestamp;
import org.epics.css.dal.impl.ResponseImpl;
import org.epics.css.dal.simple.AnyData;
import org.epics.css.dal.simple.AnyDataChannel;
import org.epics.css.dal.simple.MetaData;
import org.epics.css.dal.simple.Severity;

public abstract class AbstractAnyDataImpl<T> implements AnyData {
	
	private final DynamicValueProperty<T> property;
	protected final Response<T> response;
	private MetaData metaData;
	private long beamID;
	
	public AbstractAnyDataImpl(DynamicValueProperty<T> property, long beamID) {
		this.property = property;
		Response<T> r= property.getLatestValueResponse();
		if (r==null || r.getValue()==null) {
			response= new ResponseImpl<T>(property, null, confirmValue(this.property.getLatestReceivedValue()), "value", false, null, property.getCondition(), null, true);
		} else {
			this.response = r; 
		}
		
		if (property.isMetaDataInitialized()) {
			metaData = extractMetaData();
		} else {
		    //----- Fix to get meta data for channels that already have a proxy in a different simple dal broker
			metaData = extractMetaData();
			if (metaData == null) {
				metaData = MetaDataImpl.createUninitializedMetaData();
			}
			//----- end of fix 
			//----- current version
//			 metaData = MetaDataImpl.createUninitializedMetaData();
			//----- end of current version
		}
		
		this.beamID=beamID;
	}
	
	protected abstract T confirmValue(T value);
	
	public long getBeamID() {
		return beamID;
	}
	
	public AnyDataChannel getParentChannel() {
		return property;
	}

	public DynamicValueProperty<?> getParentProperty() {
		return property;
	}
	
	public MetaData getMetaData() {
		// TODO if MetaData changes this is how it could be reset
//		if (metaData == null) {
//			metaData = extractMetaData();
//		}
		return metaData;
	}
	
	public Quality getQuality() {
		return Quality.Original;
	}

	public Severity getSeverity() {
		return response.getCondition();
	}

	public String getStatus() {
		return DynamicValueConditionConverterUtil.extractStatusInfo(response.getCondition());
	}

	public Timestamp getTimestamp() {
		return DynamicValueConditionConverterUtil.extractTimestampInfo(response.getCondition());
	}
	
	public boolean isValid() {
		// TODO other option: response.getCondition().hasValue()
		return response.getError() == null;
	}
	
	private MetaData extractMetaData() {
		try {
			return (MetaData) property.getCharacteristic(CharacteristicInfo.C_META_DATA.getName());
		} catch (DataExchangeException e) {
			e.printStackTrace();
			return null;
		}
	}
	
}

enable fix for meta data