# HG changeset patch
# User one
# Date 1389395239 -32400
# Node ID 6104702a18804980ade6b9e86acf6fd98b031dc3
# Parent dacfa7eba84167fff60d5f3959813b3646804626
Added dependency bulletinboard in pom.xml
diff -r dacfa7eba841 -r 6104702a1880 .classpath
--- a/.classpath Sat Jan 11 06:33:54 2014 +0900
+++ b/.classpath Sat Jan 11 08:07:19 2014 +0900
@@ -1,96 +1,51 @@
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
\ No newline at end of file
diff -r dacfa7eba841 -r 6104702a1880 .project
--- a/.project Sat Jan 11 06:33:54 2014 +0900
+++ b/.project Sat Jan 11 08:07:19 2014 +0900
@@ -4,6 +4,7 @@
NO_M2ECLIPSE_SUPPORT: Project files created with the maven-eclipse-plugin are not supported in M2Eclipse.
jungle-core
+ bulletinboard
diff -r dacfa7eba841 -r 6104702a1880 pom.xml
--- a/pom.xml Sat Jan 11 06:33:54 2014 +0900
+++ b/pom.xml Sat Jan 11 08:07:19 2014 +0900
@@ -106,5 +106,12 @@
jungle-core
0.0.3-SNAPSHOT
+
+
+
+ jp.ac.u_ryukyu.ie.cr.shoshi.jungle
+ bulletinboard
+ 0.0.1-SNAPSHOT
+
diff -r dacfa7eba841 -r 6104702a1880 src/main/java/app/bbs/BoardMessage.java
--- a/src/main/java/app/bbs/BoardMessage.java Sat Jan 11 06:33:54 2014 +0900
+++ /dev/null Thu Jan 01 00:00:00 1970 +0000
@@ -1,8 +0,0 @@
-package app.bbs;
-
-public interface BoardMessage
-{
- public String getUUID();
- public String getAuthor();
- public String getMessage();
-}
diff -r dacfa7eba841 -r 6104702a1880 src/main/java/app/bbs/BulletinBoard.java
--- a/src/main/java/app/bbs/BulletinBoard.java Sat Jan 11 06:33:54 2014 +0900
+++ /dev/null Thu Jan 01 00:00:00 1970 +0000
@@ -1,11 +0,0 @@
-package app.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 dacfa7eba841 -r 6104702a1880 src/main/java/app/bbs/CassandraBulletinBoard.java
--- a/src/main/java/app/bbs/CassandraBulletinBoard.java Sat Jan 11 06:33:54 2014 +0900
+++ /dev/null Thu Jan 01 00:00:00 1970 +0000
@@ -1,191 +0,0 @@
-package app.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.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 dacfa7eba841 -r 6104702a1880 src/main/java/app/bbs/CreateBoardMessageServlet.java
--- a/src/main/java/app/bbs/CreateBoardMessageServlet.java Sat Jan 11 06:33:54 2014 +0900
+++ /dev/null Thu Jan 01 00:00:00 1970 +0000
@@ -1,40 +0,0 @@
-package app.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 dacfa7eba841 -r 6104702a1880 src/main/java/app/bbs/CreateBoardServlet.java
--- a/src/main/java/app/bbs/CreateBoardServlet.java Sat Jan 11 06:33:54 2014 +0900
+++ /dev/null Thu Jan 01 00:00:00 1970 +0000
@@ -1,39 +0,0 @@
-package app.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 dacfa7eba841 -r 6104702a1880 src/main/java/app/bbs/EditMessageServlet.java
--- a/src/main/java/app/bbs/EditMessageServlet.java Sat Jan 11 06:33:54 2014 +0900
+++ /dev/null Thu Jan 01 00:00:00 1970 +0000
@@ -1,64 +0,0 @@
-package app.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("