ChronosXYZ/JGUN
1
0
Fork 0
mirror of https://github.com/ChronosX88/JGUN.git synced 2024-11-23 15:02:18 +00:00
Code Issues Projects Releases Wiki Activity

refactor: Change name of get data in request json

Browse Source
This commit is contained in:
ChronosX88 2019-10-01 23:37:26 +04:00
parent eca5e03b6f
commit b980bbd2b3
2 changed files with 5 additions and 17 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
src/main/java/io/github/chronosx88/JGUN/Dispatcher.java
View File

@ -36,7 +36,7 @@ public class Dispatcher {
JSONObject ack = handlePut(message);
peer.emit(ack.toString());
}
if(message.has("await")) {
if(message.has("get")) {
JSONObject ack = handleGet(message);
peer.emit(ack.toString());
}
@ -47,7 +47,7 @@ public class Dispatcher {
}
private JSONObject handleGet(JSONObject getData) {
InMemoryGraph getResults = Utils.getRequest(getData.getJSONObject("await"), graphStorage);
InMemoryGraph getResults = Utils.getRequest(getData.getJSONObject("get"), graphStorage);
return new JSONObject() // Acknowledgment
.put( "#", dup.track(Dup.random()) )
.put( "@", getData.getString("#") )
@ -56,23 +56,11 @@ public class Dispatcher {
}
private JSONObject handlePut(JSONObject message) {
InMemoryGraph diff = HAM.mix(new InMemoryGraph(message.getJSONObject("put")), graphStorage);
if(diff != null) {
for(Map.Entry<String, Node> entry : diff.entries()) {
if(changeListeners.containsKey(entry.getKey())) {
changeListeners.get(entry.getKey()).onChange(entry.getValue().toUserJSONObject());
}
if(forEachListeners.containsKey(entry.getKey())) {
for(Map.Entry<String, Object> jsonEntry : entry.getValue().values.toMap().entrySet()) {
forEachListeners.get(entry.getKey()).onChange(jsonEntry.getKey(), jsonEntry.getValue());
}
}
}
}
boolean success = HAM.mix(new InMemoryGraph(message.getJSONObject("put")), graphStorage, changeListeners, forEachListeners);
return new JSONObject() // Acknowledgment
.put( "#", dup.track(Dup.random()) )
.put( "@", message.getString("#") )
.put( "ok", true);
.put( "ok", success);
}
private void handleIncomingAck(JSONObject ack) {

2
src/main/java/io/github/chronosx88/JGUN/Utils.java
View File

@ -97,7 +97,7 @@ public class Utils {
if(field != null) {
getParameters.put(".", field);
}
jsonObject.put("await", getParameters);
jsonObject.put("get", getParameters);
return jsonObject;
}