package alice.jungle.persistent;

import java.io.EOFException;
import java.io.IOException;
import java.io.InputStream;

import org.msgpack.MessagePack;

import alice.jungle.operations.NetworkTreeOperationLog;
import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.persistent.ChangeList;
import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.persistent.ChangeListReader;

public class PersistentChangeListReader  implements ChangeListReader {
	
	private InputStream in;
	MessagePack msgpack = PersistentJournal.getMessagePack();

	public PersistentChangeListReader() {
		in = null;
	}
	
	public PersistentChangeListReader(InputStream _in) {
		in = _in;
	}
 	
	@Override
	public ChangeListReader newReader()
	{
		return new PersistentChangeListReader();
	}
	
	@Override 
	public ChangeList read()
	{
		try {
			final NetworkTreeOperationLog readLog = msgpack.read(in, NetworkTreeOperationLog.class);
			PersistentChangeList cl = new PersistentChangeList(readLog); 
			return cl;
		} catch (EOFException e){

		} catch (IOException e) {
		}
		return null;
	}
}