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

Now when flattening happen, instead of new node ID, we use the path from root of a graph

Browse Source
This commit is contained in:
ChronosX88 2019-05-08 20:39:23 +04:00
parent 2ab66392b2
commit ae574f15e7
1 changed files with 26 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -5,6 +5,9 @@ import io.github.chronosx88.JGUN.storageBackends.InMemoryGraph;
import io.github.chronosx88.JGUN.storageBackends.StorageBackend; import io.github.chronosx88.JGUN.storageBackends.StorageBackend;
import org.json.JSONObject; import org.json.JSONObject;
import java.util.ArrayList;
import java.util.concurrent.ConcurrentSkipListSet;
public class Utils { public class Utils {
public static Thread setTimeout(Runnable runnable, int delay){ public static Thread setTimeout(Runnable runnable, int delay){
Thread thread = new Thread(() -> { Thread thread = new Thread(() -> {
@ -59,21 +62,26 @@ public class Utils {
for (String objectKey : data.keySet()) { for (String objectKey : data.keySet()) {
JSONObject object = data.getJSONObject(objectKey); JSONObject object = data.getJSONObject(objectKey);
Node node = Utils.newNode(objectKey, object); Node node = Utils.newNode(objectKey, object);
prepareNodeForPut(node, result); ArrayList<String> path = new ArrayList<>();
path.add(objectKey);
prepareNodeForPut(node, result, path);
} }
return result; return result;
} }
private static void prepareNodeForPut(Node node, InMemoryGraph result) { private static void prepareNodeForPut(Node node, InMemoryGraph result, ArrayList<String> path) {
for (String key : node.values.keySet()) { for(String key : new ConcurrentSkipListSet<>(node.values.keySet())) {
Object value = node.values.get(key); Object value = node.values.get(key);
if(value instanceof JSONObject) { if(value instanceof JSONObject) {
String soul = Dup.random(); path.add(key);
String soul = "";
soul = String.join("/", path);
Node tmpNode = Utils.newNode(soul, (JSONObject) value); Node tmpNode = Utils.newNode(soul, (JSONObject) value);
node.values.remove(key); node.values.remove(key);
node.values.put(key, new JSONObject().put("#", soul)); node.values.put(key, new JSONObject().put("#", soul));
prepareNodeForPut(tmpNode, result); prepareNodeForPut(tmpNode, result, new ArrayList<>(path));
result.addNode(soul, tmpNode); result.addNode(soul, tmpNode);
path.remove(key);
} }
} }
result.addNode(node.soul, node); result.addNode(node.soul, node);
@ -97,4 +105,17 @@ public class Utils {
jsonObject.put("put", data); jsonObject.put("put", data);
return jsonObject; return jsonObject;
} }
/**
* This check current nodes for existing IDs in our storage, and if there are existing IDs, it means to replace them.
* Prevents trailing nodes in storage
* @param incomingGraph The graph that came to us over the wire.
* @param graphStorage Graph storage in which the incoming graph will be saved
* @return Prepared graph for saving
*/
/*public static InMemoryGraph checkIncomingNodesForID(InMemoryGraph incomingGraph, StorageBackend graphStorage) {
for (Node node : incomingGraph.nodes()) {
for(node)
}
}*/
} }