Mercurial > hg > Members > nobuyasu > jungle-network

comparison src/main/java/jungle/app/bbs/NetworkJungleBulletinBoard.java @ 105:f9e29a52efd3

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
Move some files
author one
date Tue, 26 Nov 2013 06:43:10 +0900
parents src/jungle/app/bbs/NetworkJungleBulletinBoard.java@75cf01a430a6
children
comparison
equal deleted inserted replaced
104:03bf62bb699e 105:f9e29a52efd3
1 package jungle.app.bbs;
2
3 import java.nio.ByteBuffer;
4 import java.util.Date;
5 import java.util.concurrent.atomic.AtomicInteger;
6
7 import alice.jungle.core.NetworkDefaultJungle;
8 import alice.jungle.persistent.AliceJournal;
9 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.Jungle;
10 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.JungleTree;
11 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.JungleTreeEditor;
12 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.core.Children;
13 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.core.Node;
14 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.impl.DefaultNodePath;
15 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.impl.DefaultTreeEditor;
16 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.trasnformer.EditableNode;
17 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.trasnformer.NodeEditor;
18 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.traverser.DefaultTraverser;
19 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.util.DefaultEither;
20 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.util.Either;
21 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.util.Error;
22 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.util.IterableConverter;
23
24 public class NetworkJungleBulletinBoard implements BulletinBoard
25 {
26 private final Jungle jungle;
27
28 public NetworkJungleBulletinBoard(String _uuid)
29 {
30 jungle = new NetworkDefaultJungle(new AliceJournal(), _uuid,new DefaultTreeEditor(new DefaultTraverser()));
31 jungle.createNewTree("boards");
32 JungleManager.setJungle(jungle);
33 }
34
35 public Iterable<String> getBoards()
36 {
37 JungleTree tree = jungle.getTreeByName("boards");
38 Node node = tree.getRootNode();
39 Children<Node> chs = node.getChildren();
40
41 IterableConverter.Converter<String,Node> converter = new IterableConverter.Converter<String,Node>(){
42 public String conv(Node _b) {
43 ByteBuffer e = _b.getAttributes().get("name");
44 return new String(e.array());
45 }
46 };
47
48 return new IterableConverter<String,Node>(chs,converter);
49 }
50
51 public void createBoards(final String _name,final String _author,final String _initMessage,final String _editKey)
52 {
53 if(null == jungle.createNewTree(_name)){
54 throw new IllegalStateException();
55 }
56
57 JungleTree tree = jungle.getTreeByName("boards");
58 JungleTreeEditor editor = tree.getTreeEditor();
59 DefaultNodePath root = new DefaultNodePath();
60 Either<Error,JungleTreeEditor> either = editor.addNewChildAt(root,0);
61 if(either.isA()){
62 throw new IllegalStateException();
63 }
64 editor = either.b();
65
66 either = editor.putAttribute(root.add(0),"name",ByteBuffer.wrap(_name.getBytes()));
67 if(either.isA()){
68 throw new IllegalStateException();
69 }
70 editor = either.b();
71 Either<Error,JungleTreeEditor> result = editor.success();
72 if(result.isA()){
73 throw new IllegalStateException();
74 }
75 final long timestamp = new Date().getTime();
76
77
78 tree = jungle.getTreeByName(_name);
79 editor = tree.getTreeEditor();
80 either = editor.addNewChildAt(root,0);
81 if(either.isA()){
82 throw new IllegalStateException();
83 }
84 editor = either.b();
85
86 NodeEditor e = new NodeEditor(){
87 public <T extends EditableNode<T>> Either<Error, T> edit(T _e){
88 _e = _e.getAttributes().put("author",ByteBuffer.wrap(_author.getBytes())).b();
89 _e = _e.getAttributes().put("mes",ByteBuffer.wrap(_initMessage.getBytes())).b();
90 _e = _e.getAttributes().put("key",ByteBuffer.wrap(_editKey.getBytes())).b();
91 ByteBuffer tBuffer = ByteBuffer.allocate(16);
92 _e = _e.getAttributes().put("timestamp",tBuffer.putLong(timestamp)).b();
93 return DefaultEither.newB(_e);
94 }
95 };
96
97 either = editor.edit(root.add(0),e);
98 if(either.isA()){
99 throw new IllegalStateException();
100 }
101 editor = either.b();
102 editor.success();
103
104 }
105
106 public void createBoardMessage(final String _board,final String _author,final String _message,final String _editKey)
107 {
108 JungleTree tree = jungle.getTreeByName(_board);
109 if(tree == null){
110 throw new IllegalStateException();
111 }
112
113 Either<Error, JungleTreeEditor> either;
114 do{
115 Node node = tree.getRootNode();
116 int size = node.getChildren().size();
117 DefaultNodePath path = new DefaultNodePath();
118
119 JungleTreeEditor editor = tree.getTreeEditor();
120 either = editor.addNewChildAt(path,size);
121 if(either.isA()){
122 throw new IllegalStateException();
123 }
124 editor = either.b();
125 final long timestamp = new Date().getTime();
126 NodeEditor e = new NodeEditor(){
127 public <T extends EditableNode<T>> Either<Error, T> edit(T _e){
128 _e = _e.getAttributes().put("author",ByteBuffer.wrap(_author.getBytes())).b();
129 _e = _e.getAttributes().put("mes",ByteBuffer.wrap(_message.getBytes())).b();
130 _e = _e.getAttributes().put("key",ByteBuffer.wrap(_editKey.getBytes())).b();
131 ByteBuffer tBuffer = ByteBuffer.allocate(16);
132 _e = _e.getAttributes().put("timestamp",tBuffer.putLong(timestamp)).b();
133 return DefaultEither.newB(_e);
134 }
135 };
136 path = path.add(size);
137 either = editor.edit(path,e);
138 if(either.isA()){
139 throw new IllegalStateException();
140 }
141 editor = either.b();
142 either = editor.success();
143
144 }while(either.isA());
145 /* Put DataSegment */
146 }
147
148 public void editMessage(String _board,String _uuid,final String _author,final String _message,final String _editKey)
149 {
150 for(;;) {
151 DefaultNodePath path = new DefaultNodePath();
152 path = path.add(Integer.parseInt(_uuid));
153
154 JungleTree tree = jungle.getTreeByName(_board);
155 JungleTreeEditor editor = tree.getTreeEditor();
156 final long timestamp = new Date().getTime();
157 NodeEditor e = new NodeEditor(){
158 public <T extends EditableNode<T>> Either<Error, T> edit(T _e){
159 _e = _e.getAttributes().put("author",ByteBuffer.wrap(_author.getBytes())).b();
160 _e = _e.getAttributes().put("mes",ByteBuffer.wrap(_message.getBytes())).b();
161 _e = _e.getAttributes().put("key",ByteBuffer.wrap(_editKey.getBytes())).b();
162 ByteBuffer tBuffer = ByteBuffer.allocate(16);
163 _e = _e.getAttributes().put("timestamp",tBuffer.putLong(timestamp)).b();
164 return DefaultEither.newB(_e);
165 }
166 };
167
168 Either<Error, JungleTreeEditor> either = editor.edit(path,e);
169 if(either.isA()){
170 throw new IllegalStateException();
171 }
172 editor = either.b();
173 either = editor.success();
174 if(!either.isA()) {
175 return;
176 }
177 }
178
179 }
180
181 public Iterable<BoardMessage> getMessages(String _boardName)
182 {
183 JungleTree tree = jungle.getTreeByName(_boardName);
184 Node node = tree.getRootNode();
185 Children<Node> chs = node.getChildren();
186
187 final AtomicInteger counter = new AtomicInteger(0);
188 IterableConverter.Converter<BoardMessage,Node> converter = new IterableConverter.Converter<BoardMessage,Node>(){
189 public BoardMessage conv(Node _b) {
190 String uuid = Integer.toString(counter.get());
191 String author = new String(_b.getAttributes().get("author").array());
192 String message = new String(_b.getAttributes().get("mes").array());
193 counter.incrementAndGet();
194 return new BoardMessageImpl(author,message,uuid);
195 }
196 };
197
198 return new IterableConverter<BoardMessage,Node>(chs,converter);
199 }
200
201
202
203 private static class BoardMessageImpl implements BoardMessage
204 {
205 private final String author;
206 private final String message;
207 private final String uuid;
208
209 public BoardMessageImpl(String _author,String _message,String _uuid)
210 {
211 author = _author;
212 message = _message;
213 uuid = _uuid;
214 }
215
216 public String getAuthor()
217 {
218 return author;
219 }
220
221 public String getMessage()
222 {
223 return message;
224 }
225
226 public String getUUID()
227 {
228 return uuid;
229 }
230 }
231 }