# HG changeset patch
# User one
# Date 1372390567 -32400
# Node ID c767e7af4d8874597c9b85c6df85778e347dcc80
# Parent  d2436fd71c617abedb5c17863de6bb438f3e3a96
add TestPutAttributeCodeSegmnet and StartJungleCodeSegment

diff -r d2436fd71c61 -r c767e7af4d88 src/jungle/test/codesegment/persistence/AliceJournal.java
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/src/jungle/test/codesegment/persistence/AliceJournal.java	Fri Jun 28 12:36:07 2013 +0900
@@ -0,0 +1,97 @@
+package jungle.test.codesegment.persistence;
+
+import java.nio.ByteBuffer;
+
+import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.persistent.ChangeList;
+import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.persistent.ChangeListReader;
+import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.persistent.ChangeListWriter;
+import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.persistent.Journal;
+import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.persistent.Result;
+import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.Command;
+import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.NodePath;
+import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.operations.NodeOperation;
+import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.operations.TreeOperation;
+import jungle.test.datasegment.store.operations.DefaultNodeOperationContainer;
+import jungle.test.datasegment.store.operations.DefaultTreeOperationContainer;
+
+public class AliceJournal implements Journal {
+	
+	private static final AliceChangeListWriter ALICE_WRITER = new AliceChangeListWriter();
+	private static final AliceChangeListReader ALICE_READER = new AliceChangeListReader();
+	@Override
+	public ChangeListReader getReader() {
+		return ALICE_READER;
+	}
+	@Override
+	public ChangeListWriter getWriter() {
+		return ALICE_WRITER;
+	}
+	
+	private static class AliceChangeListWriter implements ChangeListWriter
+	{
+		@Override
+		public Result write(ChangeList _operations)
+		{
+
+			/*
+			for(TreeOperation op : _operations){
+				DefaultTreeOperationContainer container = new DefaultTreeOperationContainer();
+				container.unconvert(op);
+				
+				cs.ods.update("local", "op", op);
+				
+			}
+			
+*/			
+			
+			
+			
+			
+			for(TreeOperation op : _operations){
+				NodePath p = op.getNodePath();
+				NodeOperation nodeOp = op.getNodeOperation();
+				Command c = nodeOp.getCommand();
+				String args = "";
+				switch(c){
+					case PUT_ATTRIBUTE:
+						String key = nodeOp.getKey();
+						ByteBuffer value = nodeOp.getValue();
+						if(value.limit() < 100){
+							args = String.format("key:%s,value:%s",key,new String(value.array()));
+						}else{
+							args = String.format("key:%s,value:%d",key,value.limit());
+						}
+						break;
+					case DELETE_ATTRIBUTE:
+						args = String.format("key:%s",nodeOp.getKey());
+						break;
+					case APPEND_CHILD:
+						args = String.format("pos:%d",nodeOp.getPosition());
+						break;
+					case DELETE_CHILD:
+						args = String.format("pos:%d",nodeOp.getPosition());
+						break;
+				}
+				System.out.println(String.format("[%s:%s:%s]",c,p,args));
+			}
+			return Result.SUCCESS;
+		}
+	}
+	
+	private static class AliceChangeListReader implements ChangeListReader
+	{
+		@Override
+		public ChangeListReader newReader()
+		{
+			return this;
+		}
+
+		@Override
+		public ChangeList read()
+		{
+			return null;
+		}
+	}
+	
+	
+}
diff -r d2436fd71c61 -r c767e7af4d88 src/jungle/test/codesegment/persistence/TestJungle.java
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/src/jungle/test/codesegment/persistence/TestJungle.java	Fri Jun 28 12:36:07 2013 +0900
@@ -0,0 +1,21 @@
+package jungle.test.codesegment.persistence;
+
+import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.Jungle;
+import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.JungleTree;
+import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.JungleTreeEditor;
+import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.TreeEditor;
+import jungle.test.codesegment.practice.JungleManager;
+import jungle.test.codesegment.practice.TestPutAttributeCodeSegment;
+
+public class TestJungle {
+	
+	public static void main(String[] args) {
+		JungleManager jm = new JungleManager();
+		JungleTree tree = jm.createTree("tree1");
+		JungleTreeEditor editor = tree.getTreeEditor();
+
+		new TestPutAttributeCodeSegment().execute();
+		
+	}
+
+}
diff -r d2436fd71c61 -r c767e7af4d88 src/jungle/test/codesegment/practice/StartJungleCodeSegment.java
--- a/src/jungle/test/codesegment/practice/StartJungleCodeSegment.java	Fri Jun 28 12:24:35 2013 +0900
+++ b/src/jungle/test/codesegment/practice/StartJungleCodeSegment.java	Fri Jun 28 12:36:07 2013 +0900
@@ -1,6 +1,13 @@
 package jungle.test.codesegment.practice;
 
+import java.io.IOException;
+import java.nio.ByteBuffer;
+
 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.JungleTree;
+import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.impl.DefaultNodePath;
+import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.operations.DefaultTreeOperation;
+import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.operations.PutAttributeOperation;
+import jungle.test.datasegment.store.operations.DefaultTreeOperationContainer;
 import alice.codesegment.CodeSegment;
 
 public class StartJungleCodeSegment {
@@ -9,6 +16,23 @@
 		JungleManager jm = new JungleManager();
 		JungleTree tree = jm.createTree("tree");
 		
+		/* Create TreeOperation */
+		String key = "hoge";
+		ByteBuffer b = ByteBuffer.wrap("messagepack value".getBytes());
+		PutAttributeOperation op = new PutAttributeOperation(key, b);
+		DefaultNodePath p = new DefaultNodePath();
+		p = p.add(1);
+		DefaultTreeOperation treeOp = new DefaultTreeOperation(p, op);
+
+		DefaultTreeOperationContainer treeOperationContainer = new DefaultTreeOperationContainer();
+		try {
+			treeOperationContainer.unconvert(treeOp);
+		} catch (IOException e) {
+			e.printStackTrace();
+		}
+
+		 TestPutAttributeCodeSegment cs = new TestPutAttributeCodeSegment();
+		cs.ods.update("local", "log", treeOperationContainer);
 		
 		
 	}
diff -r d2436fd71c61 -r c767e7af4d88 src/jungle/test/codesegment/practice/TestPutAttributeCodeSegment.java
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/src/jungle/test/codesegment/practice/TestPutAttributeCodeSegment.java	Fri Jun 28 12:36:07 2013 +0900
@@ -0,0 +1,30 @@
+package jungle.test.codesegment.practice;
+
+import org.msgpack.type.Value;
+
+import alice.codesegment.CodeSegment;
+import alice.datasegment.CommandType;
+import alice.datasegment.Receiver;
+
+public class TestPutAttributeCodeSegment extends CodeSegment {
+
+	Receiver arg1 = ids.create(CommandType.TAKE);
+	
+	public TestPutAttributeCodeSegment() {
+		arg1.setKey("log");
+	}
+	
+	
+	public void run() {
+		System.out.println("type = " + arg1.type);
+		System.out.println("index = " + arg1.index);
+		System.out.println("data = " + arg1.getVal());
+		System.out.println(((Value)arg1.getVal()).getType());
+
+		
+		
+		
+		
+	}
+
+}