/*
 * SSSync, a Simple and Stupid Synchronizer for data with multi-valued attributes
 * Copyright (C) 2014  Ludovic Pouzenc <ludovic@pouzenc.fr>
 *  
 * This file is part of SSSync.
 *
 *  SSSync is free software: you can redistribute it and/or modify
 *  it under the terms of the GNU General Public License as published by
 *  the Free Software Foundation, either version 3 of the License, or
 *  (at your option) any later version.
 *
 *  SSSync is distributed in the hope that it will be useful,
 *  but WITHOUT ANY WARRANTY; without even the implied warranty of
 *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 *  GNU General Public License for more details.
 *
 *  You should have received a copy of the GNU General Public License
 *  along with SSSync.  If not, see <http://www.gnu.org/licenses/>
 */

package data.io.stub;

import java.util.Set;

import data.MVDataEntry;
import data.io.MVDataWriter;

/**
 * Stub writer implementation for automated tests.
 * 
 * @author lpouzenc
 */
public class StubDataWriter implements MVDataWriter {

	enum OpKind { INSERT, UPDATE, DELETE };
	
	private final int maxLogEntries;
	
	private OpKind opLog[];
	private MVDataEntry opData[];
	private int cursorLog;
	private boolean dryRun;
	
	public StubDataWriter(int maxLogEntries) {
		this.maxLogEntries = maxLogEntries;
		this.opLog = new OpKind[maxLogEntries];
		this.opData = new MVDataEntry[maxLogEntries];
		this.dryRun = false;
	}
	
	@Override
	public void insert(MVDataEntry newline) {
		if ( cursorLog >= maxLogEntries) {
			throw new IllegalStateException();
		}
		opLog[cursorLog]=OpKind.INSERT;
		opData[cursorLog]=newline;
		cursorLog++;
	}

	@Override
	public void update(MVDataEntry updatedLine, MVDataEntry originalLine, Set<String> attrToUpdate) {
		if ( cursorLog >= maxLogEntries) {
			throw new IllegalStateException();
		}
		opLog[cursorLog]=OpKind.UPDATE;
		opData[cursorLog]=updatedLine;
		cursorLog++;
	}

	@Override
	public void delete(MVDataEntry existingLine) {
		if ( cursorLog >= maxLogEntries) {
			throw new IllegalStateException();
		}
		opLog[cursorLog]=OpKind.DELETE;
		opData[cursorLog]=existingLine;
		cursorLog++;
	}
	
	@Override
	public String toString() {
		StringBuffer buf = new StringBuffer();
		
		for (int i = 0; i < cursorLog; i++) {
			buf.append(opLog[i] + ": " + opData[i] + "\n");
		}
		
		return buf.toString();
	}

	/**
	 * @return the opLog
	 */
	public OpKind[] getOpLog() {
		return opLog.clone();
	}

	/**
	 * @return the opData
	 */
	public MVDataEntry[] getOpData() {
		return opData.clone();
	}

	@Override
	public boolean isDryRun() {
		return dryRun;
	}

	@Override
	public void setDryRun(boolean dryRun) {
		this.dryRun = dryRun;
		
	}

}