# HG changeset patch
# User tatsuki
# Date 1467065170 -32400
# Node ID 725a0176a8732b61ca774bc1ce33eb1c4541dc3e
# Parent 5d033ad129b276fbdd1551919064e94a45cd3418
remove delete file
diff -r 5d033ad129b2 -r 725a0176a873 src/main/java/jp/ac/u_ryukyu/ie/cr/jungle/bbs/App.java
--- a/src/main/java/jp/ac/u_ryukyu/ie/cr/jungle/bbs/App.java Sun Feb 21 18:28:01 2016 +0900
+++ /dev/null Thu Jan 01 00:00:00 1970 +0000
@@ -1,83 +0,0 @@
-package jp.ac.u_ryukyu.ie.cr.jungle.bbs;
-
-import me.prettyprint.hector.api.HConsistencyLevel;
-import org.mortbay.jetty.Connector;
-import org.mortbay.jetty.Server;
-import org.mortbay.jetty.nio.SelectChannelConnector;
-import org.mortbay.jetty.servlet.ServletHandler;
-import org.mortbay.jetty.servlet.ServletHolder;
-import org.mortbay.thread.QueuedThreadPool;
-
-import javax.servlet.Servlet;
-
-
-/**
- * Hello world!
- *
- */
-public class App
-{
- public static void main( String[] args ) throws Exception
- {
- BulletinBoard cassaBBS = null;
- if(args.length == 0){
- cassaBBS = new JungleBulletinBoard();
- }else{
- HConsistencyLevel cLevel = HConsistencyLevel.QUORUM;
- int rep_factor = 1;
- int i=0;
- while(i 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 String sanitize(String str);
- GetAttributeImp getAttribute(String _bname, String _nodeNum, String revisionStr);
-}
diff -r 5d033ad129b2 -r 725a0176a873 src/main/java/jp/ac/u_ryukyu/ie/cr/jungle/bbs/CassandraBulletinBoard.java
--- a/src/main/java/jp/ac/u_ryukyu/ie/cr/jungle/bbs/CassandraBulletinBoard.java Sun Feb 21 18:28:01 2016 +0900
+++ /dev/null Thu Jan 01 00:00:00 1970 +0000
@@ -1,219 +0,0 @@
-package jp.ac.u_ryukyu.ie.cr.jungle.bbs;
-
-import me.prettyprint.cassandra.model.ConfigurableConsistencyLevel;
-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.HConsistencyLevel;
-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;
-import org.apache.cassandra.locator.SimpleStrategy;
-
-import java.util.*;
-
-public class CassandraBulletinBoard implements BulletinBoard
-{
- private final String address;
- private final String clusterName;
- private final Cluster cluster;
- private final String keyspace;
- private final ConfigurableConsistencyLevel configurableConsistencyLevel = new ConfigurableConsistencyLevel();
-
- private static final String COLUMN_FAMILY_BOARD = "boards";
- private final int REP_FACTOR;
-
- public CassandraBulletinBoard(String _clusterName,String _address,String _keyspaceName, HConsistencyLevel cLevel,int rep_factor )
- {
- address = _address;
- clusterName = _clusterName;
- keyspace = _keyspaceName;
- cluster = HFactory.getOrCreateCluster(clusterName,address);
- Map clmap = new HashMap();
- clmap.put(COLUMN_FAMILY_BOARD, cLevel);
- configurableConsistencyLevel.setReadCfConsistencyLevels(clmap);
- configurableConsistencyLevel.setWriteCfConsistencyLevels(clmap);
- REP_FACTOR = rep_factor;
- initialize();
- }
-
- public CassandraBulletinBoard(String _clusterName,String _address,String _keyspaceName, HConsistencyLevel cLevel)
- {
- this(_clusterName, _address, _keyspaceName, cLevel, 1);
- }
-
-
-
- private void initialize()
- {
- if(cluster.describeKeyspace(keyspace) == null){
- KeyspaceDefinition keyspaceDefinition = HFactory.createKeyspaceDefinition(keyspace,
- SimpleStrategy.class.getName(),REP_FACTOR,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, configurableConsistencyLevel);
- 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, configurableConsistencyLevel);
- 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, configurableConsistencyLevel);
- 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, configurableConsistencyLevel);
- 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);
- }
-
- public String sanitize( String str ) {
- if(str==null) {
- return str;
- }
- str = str.replaceAll("&" , "&" );
- str = str.replaceAll("<" , "<" );
- str = str.replaceAll(">" , ">" );
- str = str.replaceAll("\"", """);
- str = str.replaceAll("'" , "'" );
- return str;
- }
-
- public GetAttributeImp getAttribute(String _bname, String _nodeNum, String revisionStr) {
- return null; // 未実装 使うときに実装する
- }
-
-}
diff -r 5d033ad129b2 -r 725a0176a873 src/main/java/jp/ac/u_ryukyu/ie/cr/jungle/bbs/CreateBoardMessageServlet.java
--- a/src/main/java/jp/ac/u_ryukyu/ie/cr/jungle/bbs/CreateBoardMessageServlet.java Sun Feb 21 18:28:01 2016 +0900
+++ /dev/null Thu Jan 01 00:00:00 1970 +0000
@@ -1,39 +0,0 @@
-package jp.ac.u_ryukyu.ie.cr.jungle.bbs;
-
-import javax.servlet.http.HttpServlet;
-import javax.servlet.http.HttpServletRequest;
-import javax.servlet.http.HttpServletResponse;
-import java.io.PrintWriter;
-
-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 5d033ad129b2 -r 725a0176a873 src/main/java/jp/ac/u_ryukyu/ie/cr/jungle/bbs/CreateBoardServlet.java
--- a/src/main/java/jp/ac/u_ryukyu/ie/cr/jungle/bbs/CreateBoardServlet.java Sun Feb 21 18:28:01 2016 +0900
+++ /dev/null Thu Jan 01 00:00:00 1970 +0000
@@ -1,40 +0,0 @@
-package jp.ac.u_ryukyu.ie.cr.jungle.bbs;
-
-import org.apache.commons.lang.StringEscapeUtils;
-
-import javax.servlet.http.HttpServlet;
-import javax.servlet.http.HttpServletRequest;
-import javax.servlet.http.HttpServletResponse;
-import java.io.PrintWriter;
-
-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 = StringEscapeUtils.unescapeHtml(_req.getParameter(PARAM_BOARD_NAME));
- String author = StringEscapeUtils.unescapeHtml(_req.getParameter(PARAM_BOARD_AUTHOR));
- String msg = StringEscapeUtils.unescapeHtml(_req.getParameter(PARAM_BOARD_INITMESSAGE));
- String key = StringEscapeUtils.unescapeHtml(_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 5d033ad129b2 -r 725a0176a873 src/main/java/jp/ac/u_ryukyu/ie/cr/jungle/bbs/EditMessageServlet.java
--- a/src/main/java/jp/ac/u_ryukyu/ie/cr/jungle/bbs/EditMessageServlet.java Sun Feb 21 18:28:01 2016 +0900
+++ /dev/null Thu Jan 01 00:00:00 1970 +0000
@@ -1,63 +0,0 @@
-package jp.ac.u_ryukyu.ie.cr.jungle.bbs;
-
-import javax.servlet.http.HttpServlet;
-import javax.servlet.http.HttpServletRequest;
-import javax.servlet.http.HttpServletResponse;
-import java.io.PrintWriter;
-
-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);
- System.out.println("write");
-
- try{
- PrintWriter pw = _res.getWriter();
- pw.write("edit message
");
- pw.write("
\n");
- _pw.write("Message
\n");
- _pw.write("\n");
- GetAttributeImp attribute = bbs.getAttribute(_bname, "[-1]", "1");
- Iterator keys = attribute.getKeys();
-
- do {
- String key = keys.next();
- String mesage = attribute.getMessage(key);
- _pw.write("" + key + " = " + mesage + "
\n");
- }while(keys.hasNext());
-
- _pw.write("");
- _pw.flush();
- }
-}
diff -r 5d033ad129b2 -r 725a0176a873 src/main/java/jp/ac/u_ryukyu/ie/cr/jungle/bbs/ShowBoardsServlet.java
--- a/src/main/java/jp/ac/u_ryukyu/ie/cr/jungle/bbs/ShowBoardsServlet.java Sun Feb 21 18:28:01 2016 +0900
+++ /dev/null Thu Jan 01 00:00:00 1970 +0000
@@ -1,55 +0,0 @@
-package jp.ac.u_ryukyu.ie.cr.jungle.bbs;
-
-import javax.servlet.http.HttpServlet;
-import javax.servlet.http.HttpServletRequest;
-import javax.servlet.http.HttpServletResponse;
-import java.io.PrintWriter;
-
-public class ShowBoardsServlet extends HttpServlet
-{
- /**
- *
- */
- private static final long serialVersionUID = 1L;
- private final BulletinBoard bbs;
- private final String createBoardPath;
- private final String showBoardMessagePath;
-
- public ShowBoardsServlet(BulletinBoard _bbs, String _createBoardPath,String _showBoardMessagePath)
- {
- bbs = _bbs;
- createBoardPath = _createBoardPath;
- showBoardMessagePath = _showBoardMessagePath;
- }
-
- public void doGet(HttpServletRequest _req,HttpServletResponse _res)
- {
- try{
- _res.setCharacterEncoding("UTF-8");
- printBoard(_res.getWriter());
- }catch(Exception _e){
- _res.setStatus(500);
- }
-
- }
-
- private void printBoard(PrintWriter _pw) throws Exception
- {
- _pw.write("\n");
- _pw.write("BBS
\n");
- _pw.write("