# HG changeset patch
# User one
# Date 1373282758 -32400
# Node ID d8ee57a1c2c6885cedb129a4e76ace7de29c8144
# Parent ed4c2e6ab5d1e591e2ec7e0d70af9a40e3ec718b
add pom.xml and bbs
diff -r ed4c2e6ab5d1 -r d8ee57a1c2c6 .classpath
--- a/.classpath Mon Jul 08 20:10:47 2013 +0900
+++ b/.classpath Mon Jul 08 20:25:58 2013 +0900
@@ -1,15 +1,26 @@
-
-
+
+
+
+
+
+
-
-
-
-
+
+
+
+
+
+
+
+
+
+
+
diff -r ed4c2e6ab5d1 -r d8ee57a1c2c6 .project
--- a/.project Mon Jul 08 20:10:47 2013 +0900
+++ b/.project Mon Jul 08 20:25:58 2013 +0900
@@ -10,8 +10,14 @@
+
+ org.eclipse.m2e.core.maven2Builder
+
+
+
+ org.eclipse.m2e.core.maven2Nature
org.eclipse.jdt.core.javanature
diff -r ed4c2e6ab5d1 -r d8ee57a1c2c6 .settings/org.eclipse.jdt.core.prefs
--- a/.settings/org.eclipse.jdt.core.prefs Mon Jul 08 20:10:47 2013 +0900
+++ b/.settings/org.eclipse.jdt.core.prefs Mon Jul 08 20:25:58 2013 +0900
@@ -1,5 +1,5 @@
-#Sun Jun 30 04:20:41 JST 2013
+eclipse.preferences.version=1
org.eclipse.jdt.core.compiler.codegen.targetPlatform=1.6
-eclipse.preferences.version=1
+org.eclipse.jdt.core.compiler.compliance=1.6
+org.eclipse.jdt.core.compiler.problem.forbiddenReference=warning
org.eclipse.jdt.core.compiler.source=1.6
-org.eclipse.jdt.core.compiler.compliance=1.6
diff -r ed4c2e6ab5d1 -r d8ee57a1c2c6 .settings/org.eclipse.m2e.core.prefs
--- /dev/null Thu Jan 01 00:00:00 1970 +0000
+++ b/.settings/org.eclipse.m2e.core.prefs Mon Jul 08 20:25:58 2013 +0900
@@ -0,0 +1,4 @@
+activeProfiles=
+eclipse.preferences.version=1
+resolveWorkspaceProjects=true
+version=1
diff -r ed4c2e6ab5d1 -r d8ee57a1c2c6 pom.xml
--- /dev/null Thu Jan 01 00:00:00 1970 +0000
+++ b/pom.xml Mon Jul 08 20:25:58 2013 +0900
@@ -0,0 +1,54 @@
+
+ 4.0.0
+ jungle-network
+ jungle-network
+ 0.0.1-SNAPSHOT
+
+ src
+
+
+ maven-compiler-plugin
+ 3.0
+
+ 1.6
+ 1.6
+
+
+
+
+
+ UTF-8
+
+
+
+ junit
+ junit
+ 3.8.1
+
+
+ org.mortbay.jetty
+ jetty
+ 6.1.26
+
+
+ org.hectorclient
+ hector-core
+ 1.1-2
+
+
+ org.apache.cassandra
+ cassandra-all
+ 1.2.1
+
+
+ com.eaio.uuid
+ uuid
+ 3.2
+
+
+ jungle
+ jungle-core
+ 0.0.1-SNAPSHOT
+
+
+
diff -r ed4c2e6ab5d1 -r d8ee57a1c2c6 src/alice/jungle/remote/RemoteConfig.java
--- /dev/null Thu Jan 01 00:00:00 1970 +0000
+++ b/src/alice/jungle/remote/RemoteConfig.java Mon Jul 08 20:25:58 2013 +0900
@@ -0,0 +1,24 @@
+package alice.jungle.remote;
+import alice.daemon.Config;
+
+
+public class RemoteConfig extends Config {
+
+ public String hostname;
+ public int connectPort = 10000;
+ public String key;
+
+ public RemoteConfig(String[] args) {
+ super(args);
+ for (int i = 0; i< args.length; i++) {
+ if ("-h".equals(args[i])) {
+ hostname = args[++i];
+ } else if ("-cp".equals(args[i])) {
+ connectPort = Integer.parseInt(args[++i]);
+ } else if ("-key".equals(args[i])) {
+ key = args[++i];
+ }
+ }
+ }
+
+}
diff -r ed4c2e6ab5d1 -r d8ee57a1c2c6 src/jungle/test/bbs/App.java
--- /dev/null Thu Jan 01 00:00:00 1970 +0000
+++ b/src/jungle/test/bbs/App.java Mon Jul 08 20:25:58 2013 +0900
@@ -0,0 +1,46 @@
+package jungle.test.bbs;
+
+import javax.servlet.Servlet;
+
+import org.mortbay.jetty.Server;
+import org.mortbay.jetty.servlet.ServletHandler;
+import org.mortbay.jetty.servlet.ServletHolder;
+
+/**
+ * Hello world!
+ *
+ */
+public class App
+{
+ public static void main( String[] args ) throws Exception
+ {
+ BulletinBoard cassaBBS = null;
+ if(args.length == 0){
+ cassaBBS = new JungleBulletinBoard();
+ }else{
+ cassaBBS = new CassandraBulletinBoard("test-cluster","localhost:9160","cassaBBS2");
+ }
+
+
+ String createBoardMessagePath = "/createBoardMessage";
+ String createBoardPath = "/createBoard";
+ String editMessagePath = "/editMessage";
+ String showBoardMessagePath = "/showBoardMessage";
+
+ Servlet createBoardMessage = new CreateBoardMessageServlet(cassaBBS);
+ Servlet createBoard = new CreateBoardServlet(cassaBBS);
+ Servlet editBoardMessage = new EditMessageServlet(cassaBBS);
+ Servlet index = new ShowBoardsServlet(cassaBBS,createBoardPath,showBoardMessagePath);
+ Servlet board = new ShowBoardMessageServlet(cassaBBS,createBoardMessagePath,editMessagePath);
+
+ Server serv = new Server(8080);
+ ServletHandler context = new ServletHandler();
+ context.addServletWithMapping(new ServletHolder(createBoardMessage),createBoardMessagePath);
+ context.addServletWithMapping(new ServletHolder(createBoard),createBoardPath);
+ context.addServletWithMapping(new ServletHolder(editBoardMessage),editMessagePath);
+ context.addServletWithMapping(new ServletHolder(index),"/");
+ context.addServletWithMapping(new ServletHolder(board),showBoardMessagePath);
+ serv.addHandler(context);
+ serv.start();
+ }
+}
diff -r ed4c2e6ab5d1 -r d8ee57a1c2c6 src/jungle/test/bbs/BoardMessage.java
--- /dev/null Thu Jan 01 00:00:00 1970 +0000
+++ b/src/jungle/test/bbs/BoardMessage.java Mon Jul 08 20:25:58 2013 +0900
@@ -0,0 +1,8 @@
+package jungle.test.bbs;
+
+public interface BoardMessage
+{
+ public String getUUID();
+ public String getAuthor();
+ public String getMessage();
+}
diff -r ed4c2e6ab5d1 -r d8ee57a1c2c6 src/jungle/test/bbs/BulletinBoard.java
--- /dev/null Thu Jan 01 00:00:00 1970 +0000
+++ b/src/jungle/test/bbs/BulletinBoard.java Mon Jul 08 20:25:58 2013 +0900
@@ -0,0 +1,11 @@
+package jungle.test.bbs;
+
+public interface BulletinBoard
+{
+ public Iterable getBoards();
+ public void createBoards(String _name,String _author,String _initMessage,String _editKey);
+ public void createBoardMessage(String _board,String _author,String _message,String _editKey);
+ public void editMessage(String _board,String _uuid,String _author,String _message,String _editKey);
+
+ public Iterable getMessages(String _boardName);
+}
diff -r ed4c2e6ab5d1 -r d8ee57a1c2c6 src/jungle/test/bbs/CassandraBulletinBoard.java
--- /dev/null Thu Jan 01 00:00:00 1970 +0000
+++ b/src/jungle/test/bbs/CassandraBulletinBoard.java Mon Jul 08 20:25:58 2013 +0900
@@ -0,0 +1,192 @@
+package jungle.test.bbs;
+
+import java.util.Collections;
+import java.util.List;
+import java.util.UUID;
+
+import org.apache.cassandra.locator.SimpleStrategy;
+
+import me.prettyprint.cassandra.serializers.StringSerializer;
+import me.prettyprint.cassandra.serializers.UUIDSerializer;
+import me.prettyprint.cassandra.service.CassandraHost;
+import me.prettyprint.cassandra.service.template.SuperCfResult;
+import me.prettyprint.cassandra.service.template.SuperCfUpdater;
+import me.prettyprint.cassandra.service.template.ThriftSuperCfTemplate;
+import me.prettyprint.cassandra.utils.TimeUUIDUtils;
+import me.prettyprint.hector.api.Cluster;
+import me.prettyprint.hector.api.Keyspace;
+import me.prettyprint.hector.api.beans.HSuperColumn;
+import me.prettyprint.hector.api.beans.OrderedSuperRows;
+import me.prettyprint.hector.api.beans.SuperRow;
+import me.prettyprint.hector.api.beans.SuperSlice;
+import me.prettyprint.hector.api.ddl.ColumnFamilyDefinition;
+import me.prettyprint.hector.api.ddl.ColumnType;
+import me.prettyprint.hector.api.ddl.ComparatorType;
+import me.prettyprint.hector.api.ddl.KeyspaceDefinition;
+import me.prettyprint.hector.api.factory.HFactory;
+import me.prettyprint.hector.api.query.QueryResult;
+import me.prettyprint.hector.api.query.RangeSuperSlicesQuery;
+import me.prettyprint.hector.api.query.SuperSliceQuery;
+
+public class CassandraBulletinBoard implements BulletinBoard
+{
+ private final String address;
+ private final String clusterName;
+ private final Cluster cluster;
+ private final String keyspace;
+
+ private static final String COLUMN_FAMILY_BOARD = "boards";
+
+ public CassandraBulletinBoard(String _clusterName,String _address,String _keyspaceName)
+ {
+ address = _address;
+ clusterName = _clusterName;
+ keyspace = _keyspaceName;
+ cluster = HFactory.getOrCreateCluster(clusterName,address);
+
+ initialize();
+ }
+
+ private void initialize()
+ {
+ if(cluster.describeKeyspace(keyspace) == null){
+ KeyspaceDefinition keyspaceDefinition = HFactory.createKeyspaceDefinition(keyspace,
+ SimpleStrategy.class.getName(),1,Collections. emptyList());
+ cluster.addKeyspace(keyspaceDefinition,false);
+ ColumnFamilyDefinition columnFamilyDefinition = HFactory.createColumnFamilyDefinition(keyspace,COLUMN_FAMILY_BOARD,ComparatorType.UUIDTYPE);
+ columnFamilyDefinition.setColumnType(ColumnType.SUPER);
+ cluster.addColumnFamily(columnFamilyDefinition);
+ }
+ }
+
+ public Iterable getBoards()
+ {
+ Keyspace ksp = HFactory.createKeyspace(keyspace, cluster);
+ RangeSuperSlicesQuery query = HFactory.createRangeSuperSlicesQuery(ksp,StringSerializer.get(),
+ UUIDSerializer.get(),StringSerializer.get(),StringSerializer.get());
+ query.setColumnFamily(COLUMN_FAMILY_BOARD).setKeys(null,null).setRange(null,null,false,0);
+
+ QueryResult> result = query.execute();
+ OrderedSuperRows rows = result.get();
+ List> list = rows.getList();
+
+ IterableConverter.Converter> converter
+ = new IterableConverter.Converter>(){
+ public String conv(SuperRow _b) {
+ return _b.getKey();
+ }
+ };
+
+ return new IterableConverter>(list,converter);
+ }
+
+ private static final String COLUMN_MESSAGE_AUTHOR = "author";
+ private static final String COLUMN_MESSAGE_BODY = "message";
+ private static final String COLUMN_MESSAGE_EDIT_KEY = "edit";
+
+ public void createBoardMessage(UUID _time,String _name,String _author,String _message,String _editKey)
+ {
+ Keyspace ksp = HFactory.createKeyspace(keyspace,cluster);
+ ThriftSuperCfTemplate template =
+ new ThriftSuperCfTemplate(ksp,COLUMN_FAMILY_BOARD,StringSerializer.get(),
+ UUIDSerializer.get(),StringSerializer.get());
+
+ SuperCfUpdater updater = template.createUpdater(_name,_time);
+ updater.setString(COLUMN_MESSAGE_AUTHOR,_author);
+ updater.setString(COLUMN_MESSAGE_BODY,_message);
+ updater.setString(COLUMN_MESSAGE_EDIT_KEY,_editKey);
+
+ template.update(updater);
+ }
+
+ public void createBoards(String _name,String _author,String _initMessage,String _editKey)
+ {
+ UUID time = TimeUUIDUtils.getTimeUUID(0);
+ createBoardMessage(time,_name,_author,_initMessage,_editKey);
+ }
+
+ public Iterable getMessages(String _boardName)
+ {
+ Keyspace ksp = HFactory.createKeyspace(keyspace,cluster);
+ SuperSliceQuery query = HFactory.createSuperSliceQuery(ksp, StringSerializer.get(), UUIDSerializer.get(), StringSerializer.get(), StringSerializer.get());
+
+ UUID start = TimeUUIDUtils.getTimeUUID(0);
+ query.setKey(_boardName).setColumnFamily(COLUMN_FAMILY_BOARD).setRange(start,null,false,100);
+
+ QueryResult> result = query.execute();
+ SuperSlice ss = result.get();
+ List> list = ss.getSuperColumns();
+
+ IterableConverter.Converter> converter =
+ new IterableConverter.Converter>(){
+ public BoardMessage conv(HSuperColumn _b){
+ UUID uuid = _b.getName();
+ String author = _b.getSubColumnByName(COLUMN_MESSAGE_AUTHOR).getValue();
+ String message = _b.getSubColumnByName(COLUMN_MESSAGE_BODY).getValue();
+ BoardMessageImpl bm = new BoardMessageImpl(author,message,uuid.toString());
+ return bm;
+ }
+ };
+
+
+ return new IterableConverter>(list,converter);
+ }
+
+ private static class BoardMessageImpl implements BoardMessage
+ {
+ private final String author;
+ private final String message;
+ private final String uuid;
+
+ public BoardMessageImpl(String _author,String _message,String _uuid)
+ {
+ author = _author;
+ message = _message;
+ uuid = _uuid;
+ }
+
+ public String getAuthor()
+ {
+ return author;
+ }
+
+ public String getMessage()
+ {
+ return message;
+ }
+
+ public String getUUID()
+ {
+ return uuid;
+ }
+ }
+
+ public void createBoardMessage(String _board, String _author, String _message,String _editKey)
+ {
+ UUID time = TimeUUIDUtils.getUniqueTimeUUIDinMillis();
+ createBoardMessage(time,_board,_author,_message,_editKey);
+ }
+
+ public void editMessage(String _board,String _uuid,String _author,String _message,String _editKey)
+ {
+ Keyspace ksp = HFactory.createKeyspace(keyspace, cluster);
+ UUID time = UUID.fromString(_uuid);
+ ThriftSuperCfTemplate template =
+ new ThriftSuperCfTemplate(ksp,COLUMN_FAMILY_BOARD,StringSerializer.get(),
+ UUIDSerializer.get(),StringSerializer.get());
+
+ SuperCfResult result = template.querySuperColumn(_board,time);
+ String editKey = result.getString(COLUMN_MESSAGE_EDIT_KEY);
+ if(!editKey.equals(editKey)){
+ return;
+ }
+
+ SuperCfUpdater updater = template.createUpdater(_board,time);
+ updater.setString(COLUMN_MESSAGE_AUTHOR,_author);
+ updater.setString(COLUMN_MESSAGE_BODY,_message);
+ updater.setString(COLUMN_MESSAGE_EDIT_KEY,_editKey);
+
+ template.update(updater);
+ }
+
+}
diff -r ed4c2e6ab5d1 -r d8ee57a1c2c6 src/jungle/test/bbs/CreateBoardMessageServlet.java
--- /dev/null Thu Jan 01 00:00:00 1970 +0000
+++ b/src/jungle/test/bbs/CreateBoardMessageServlet.java Mon Jul 08 20:25:58 2013 +0900
@@ -0,0 +1,40 @@
+package jungle.test.bbs;
+
+import java.io.PrintWriter;
+
+import javax.servlet.http.HttpServlet;
+import javax.servlet.http.HttpServletRequest;
+import javax.servlet.http.HttpServletResponse;
+
+public class CreateBoardMessageServlet extends HttpServlet
+{
+ private final BulletinBoard bbs;
+ private static final String PARAM_BOARD_NAME = "bname";
+ private static final String PARAM_BOARD_AUTHOR = "author";
+ private static final String PARAM_BOARD_MESSAGE= "msg";
+ private static final String PARAM_BOARD_EDITKEY = "key";
+
+ private static final long serialVersionUID = 1L;
+
+ public CreateBoardMessageServlet(BulletinBoard _bbs)
+ {
+ bbs = _bbs;
+ }
+
+ @Override
+ public void doPost(HttpServletRequest _req,HttpServletResponse _res)
+ {
+ String boardName = _req.getParameter(PARAM_BOARD_NAME);
+ String author = _req.getParameter(PARAM_BOARD_AUTHOR);
+ String msg = _req.getParameter(PARAM_BOARD_MESSAGE);
+ String key = _req.getParameter(PARAM_BOARD_EDITKEY);
+
+ try{
+ bbs.createBoardMessage(boardName,author,msg,key);
+ PrintWriter pw = _res.getWriter();
+ pw.write("successfully written");
+ }catch(Exception _e){
+ _res.setStatus(500);
+ }
+ }
+}
diff -r ed4c2e6ab5d1 -r d8ee57a1c2c6 src/jungle/test/bbs/CreateBoardServlet.java
--- /dev/null Thu Jan 01 00:00:00 1970 +0000
+++ b/src/jungle/test/bbs/CreateBoardServlet.java Mon Jul 08 20:25:58 2013 +0900
@@ -0,0 +1,39 @@
+package jungle.test.bbs;
+
+import java.io.PrintWriter;
+
+import javax.servlet.http.HttpServlet;
+import javax.servlet.http.HttpServletRequest;
+import javax.servlet.http.HttpServletResponse;
+
+public class CreateBoardServlet extends HttpServlet
+{
+ private final BulletinBoard bbs;
+ private static final String PARAM_BOARD_NAME = "bname";
+ private static final String PARAM_BOARD_AUTHOR = "author";
+ private static final String PARAM_BOARD_INITMESSAGE= "msg";
+ private static final String PARAM_BOARD_EDITKEY = "key";
+
+ private static final long serialVersionUID = 1L;
+
+ public CreateBoardServlet(BulletinBoard _bbs)
+ {
+ bbs = _bbs;
+ }
+
+ public void doPost(HttpServletRequest _req,HttpServletResponse _res)
+ {
+ String boardName = _req.getParameter(PARAM_BOARD_NAME);
+ String author = _req.getParameter(PARAM_BOARD_AUTHOR);
+ String msg = _req.getParameter(PARAM_BOARD_INITMESSAGE);
+ String key = _req.getParameter(PARAM_BOARD_EDITKEY);
+
+ try{
+ bbs.createBoards(boardName,author,msg,key);
+ PrintWriter pw = _res.getWriter();
+ pw.write("successfully written");
+ }catch(Exception _e){
+ _res.setStatus(500);
+ }
+ }
+}
diff -r ed4c2e6ab5d1 -r d8ee57a1c2c6 src/jungle/test/bbs/EditMessageServlet.java
--- /dev/null Thu Jan 01 00:00:00 1970 +0000
+++ b/src/jungle/test/bbs/EditMessageServlet.java Mon Jul 08 20:25:58 2013 +0900
@@ -0,0 +1,64 @@
+package jungle.test.bbs;
+
+import java.io.PrintWriter;
+
+import javax.servlet.http.HttpServlet;
+import javax.servlet.http.HttpServletRequest;
+import javax.servlet.http.HttpServletResponse;
+
+public class EditMessageServlet extends HttpServlet
+{
+ private final BulletinBoard bbs;
+ private static final String PARAM_BOARD_NAME = "bname";
+ private static final String PARAM_BOARD_MSGID = "uuid";
+ private static final String PARAM_BOARD_AUTHOR = "author";
+ private static final String PARAM_BOARD_MESSAGE= "msg";
+ private static final String PARAM_BOARD_EDITKEY = "key";
+
+ private static final long serialVersionUID = 1L;
+
+ public EditMessageServlet(BulletinBoard _bbs)
+ {
+ bbs = _bbs;
+ }
+
+ public void doGet(HttpServletRequest _req,HttpServletResponse _res)
+ {
+ String bname = _req.getParameter(PARAM_BOARD_NAME);
+ String uuid = _req.getParameter(PARAM_BOARD_MSGID);
+
+
+ try{
+ PrintWriter pw = _res.getWriter();
+ pw.write("edit message
");
+ pw.write("