fix bug when no changes are attempted to save

NucleoTeam · Jan 6, 2024 · 8c357cf · 8c357cf
1 parent c3ecc12
commit 8c357cf
Show file tree

Hide file tree

Showing 3 changed files with 20 additions and 1 deletion.
diff --git a/build.gradle b/build.gradle
@@ -6,7 +6,7 @@ plugins {
 }
 
 group = 'com.nucleodb'
-version = '1.14.3'
+version = '1.14.4'
 
 repositories {
     mavenCentral()

diff --git a/src/main/java/com/nucleodb/library/database/tables/connection/ConnectionHandler.java b/src/main/java/com/nucleodb/library/database/tables/connection/ConnectionHandler.java
@@ -451,6 +451,13 @@ private boolean saveInternal(Connection connection, String changeUUID) {
       connection.versionIncrease();
       List<JsonOperations> changes = null;
       Connection oldConnection = connectionByUUID.get(connection.getUuid());
+      if(oldConnection==null){
+        try {
+          consumerResponse(null, changeUUID);
+        } catch (ExecutionException e) {
+          throw new RuntimeException(e);
+        }
+      }
       JsonPatch patch = JsonDiff.asJsonPatch(fromObject(oldConnection), fromObject(connection));
       try {
         String json = Serializer.getObjectMapper().getOmNonType().writeValueAsString(patch);
@@ -459,6 +466,12 @@ private boolean saveInternal(Connection connection, String changeUUID) {
           ConnectionUpdate updateEntry = new ConnectionUpdate(connection.getVersion(), json, changeUUID, connection.getUuid());
           producer.push(updateEntry.getUuid(), updateEntry.getVersion(), updateEntry, null);
           return true;
+        }else{
+          try {
+            consumerResponse(null, changeUUID);
+          } catch (ExecutionException e) {
+            throw new RuntimeException(e);
+          }
         }
       } catch (JsonProcessingException e) {
         throw new RuntimeException(e);

diff --git a/src/main/java/com/nucleodb/library/database/tables/table/DataTable.java b/src/main/java/com/nucleodb/library/database/tables/table/DataTable.java
@@ -555,6 +555,12 @@ private boolean saveInternal(DataEntry entry, String changeUUID) {
           Update updateEntry = new Update(changeUUID, entry, json);
           producer.push(updateEntry.getKey(), updateEntry.getVersion(), updateEntry, null);
           return true;
+        }else{
+          try {
+            consumerResponse(null, changeUUID);
+          } catch (ExecutionException e) {
+            throw new RuntimeException(e);
+          }
         }
       } catch (JsonProcessingException e) {
         e.printStackTrace();