view src/main/java/alice/jungle/operations/NetworkNodeOperation.java @ 177:6f104ab4eb81

fit jungle core but editMessage is not work
author tatsuki
date Mon, 01 Sep 2014 00:04:32 +0900
parents 7d9b7fcb4d9a
children 2828205bdc3a
line wrap: on
line source

package alice.jungle.operations;

import java.nio.ByteBuffer;

import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.Command;
import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.operations.NodeOperation;
import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.trasnformer.AppendChildAt;
import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.trasnformer.DeleteAttribute;
import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.trasnformer.DeleteChildAt;
import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.trasnformer.PutAttribute;
import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.util.Either;
import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.util.Error;

import org.msgpack.annotation.Message;

@Message
public class NetworkNodeOperation implements NodeOperation{

	public int pos;
	public String key;
	public ByteBuffer value;
	public int commandType;

	public final static int NUM_PUT_ATTRIBUTE = 1;
	public final static int NUM_APPEND_CHILD = 2;
	public final static int NUM_DELETE_CHILD = 3;
	public final static int NUM_DELETE_ATTRIBUTE = 4;
	
	public NetworkNodeOperation() {
		pos = -2;
		key = null;
		value = null;
		commandType = 0;
	}
	
	public NetworkNodeOperation(NodeOperation _op) {
		pos = _op.getPosition();
		key = _op.getKey();
		value = _op.getValue();
		commandType = getCommandType(_op.getCommand());
	}
	
	public static int getCommandType(Command c) {
		switch(c) {
		case PUT_ATTRIBUTE:
			return NUM_PUT_ATTRIBUTE;
		case APPEND_CHILD:
			return NUM_APPEND_CHILD;
		case DELETE_CHILD:
			return NUM_DELETE_CHILD;
		case DELETE_ATTRIBUTE:
			return NUM_DELETE_ATTRIBUTE;
		default:
			break;
		}
		return 0;
	}
	
	public static Command getCommand(int num) {
		switch(num) {
		case NUM_PUT_ATTRIBUTE:
			return Command.PUT_ATTRIBUTE;
		case NUM_APPEND_CHILD:
 			return Command.APPEND_CHILD;
		case NUM_DELETE_CHILD:
			return Command.DELETE_CHILD;
		case NUM_DELETE_ATTRIBUTE:
			return Command.DELETE_ATTRIBUTE;
		default:
			break;
		}
		return null;
	}
	
	public Command getCommand() {
		return getCommand(commandType);
	}

	public int getPosition() {
		return pos;
	}
	
	public String getKey() {
		return key;
	}
	
	public ByteBuffer getValue() {
		return value;
	}

/*	@Override
	public <T extends EditableNode<T>> Either<Error, T> invoke(T _target) {
		switch(getCommand(commandType)) {
		case PUT_ATTRIBUTE:
			PutAttribute putAttribute = new PutAttribute(key,value);
			return putAttribute.edit(_target);
		case APPEND_CHILD:
			AppendChildAt appendChildAt = new AppendChildAt(pos);
			return appendChildAt.edit(_target);
		case DELETE_CHILD:
			DeleteChildAt deleteChildAt = new DeleteChildAt(pos);
			return deleteChildAt.edit(_target);
		case DELETE_ATTRIBUTE:
			DeleteAttribute deleteAttribute = new DeleteAttribute(key);
			return deleteAttribute.edit(_target);
		default:
			break;
		}
		return null;
	}*/

}