package org.simantics.acorn.internal;

import java.util.ArrayList;
import java.util.Arrays;
import java.util.List;

import org.simantics.acorn.ClusterManager;
import org.simantics.acorn.exception.AcornAccessVerificationException;
import org.simantics.acorn.exception.IllegalAcornStateException;
import org.simantics.acorn.lru.ClusterChangeSet;
import org.simantics.acorn.lru.ClusterStreamChunk;
import org.simantics.acorn.lru.ClusterChangeSet.Entry;
import org.simantics.acorn.lru.ClusterChangeSet.Type;
import org.simantics.db.exception.DatabaseException;
import org.simantics.db.service.ClusterUID;

public class UndoClusterUpdateProcessor extends ClusterUpdateProcessorBase {
	
	public final static boolean DEBUG = false;

	final private ClusterChangeSet ccs;
	
	private int oldValuesIndex = 0;
	private int statementMaskIndex = 0;
	
	final public List<Entry> entries = new ArrayList<Entry>();
	
	public UndoClusterUpdateProcessor(ClusterManager client, ClusterStreamChunk chunk, ClusterChangeSet ccs) throws DatabaseException {
		super(client, readOperation(client, chunk, ccs));
		this.ccs = ccs;
	}
	
	private static byte[] readOperation(ClusterManager manager, ClusterStreamChunk chunk, ClusterChangeSet ccs) throws AcornAccessVerificationException, IllegalAcornStateException {
		
//		ClusterStreamChunk chunk;
//		manager.streamLRU.acquireMutex();
//		try {
//			chunk = ccs.getChunk(manager);
//		} catch (Throwable t) {
//			throw new IllegalStateException(t);
//		} finally {
//			manager.streamLRU.releaseMutex();
//		}
//
//		chunk.acquireMutex();
//		try {
//		chunk.ve
			chunk.makeResident();
			return chunk.getOperation(ccs.chunkOffset);
//		} catch (Throwable t) {
//			throw new IllegalStateException(t);
//		} finally {
//			chunk.releaseMutex();
//		}
	}
	
	@Override
	void create() throws DatabaseException {
	}

	@Override
	void delete(int ri) throws DatabaseException {
		
		byte[] old = ccs.oldValues.get(oldValuesIndex);
		boolean oldValueEx = ccs.oldValueEx.get(oldValuesIndex) > 0;
		oldValuesIndex++;
		
		if(old != null) {
			entries.add(new Entry(ri, oldValueEx, old, null));
		}
		
	}

	@Override
	void modify(int resourceKey, long offset, int size, byte[] bytes, int pos)
			throws DatabaseException {
		
	}

	@Override
	void set(int resourceKey, byte[] bytes, int length)
			throws DatabaseException {

		byte[] old = ccs.oldValues.get(oldValuesIndex);
		boolean oldValueEx = ccs.oldValueEx.get(oldValuesIndex) > 0;
		oldValuesIndex++;

		entries.add(new Entry(resourceKey, oldValueEx, old, Arrays.copyOf(valueBuffer, length)));
		
	}

	@Override
	void claim(int resourceKey, int predicateKey, int objectKey, ClusterUID puid, ClusterUID ouid)
			throws DatabaseException {
		
		boolean add = ccs.statementMask.get(statementMaskIndex++) > 0;
		if(add) {
			entries.add(new Entry(Type.ADD, resourceKey, puid, predicateKey & 0xFFF, ouid, objectKey & 0xFFF));
		}
		
	}

	@Override
	void deny(int resourceKey, int predicateKey, int objectKey, ClusterUID puid, ClusterUID ouid)
			throws DatabaseException {
		
		boolean remove = ccs.statementMask.get(statementMaskIndex++) > 0;
		if(remove) {
			entries.add(new Entry(Type.REMOVE, resourceKey, puid, predicateKey & 0xFFF, ouid, objectKey & 0xFFF));
		}

	}
	
}