revert to using upsert (#233)

hypertrace · Aug 28, 2024 · 829a71c · 829a71c
1 parent 6620851
commit 829a71c
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/...g-service-impl/src/main/java/org/hypertrace/config/service/store/DocumentConfigStore.java b/...g-service-impl/src/main/java/org/hypertrace/config/service/store/DocumentConfigStore.java
@@ -94,7 +94,7 @@ public UpsertedConfig writeConfig(
             .asRuntimeException();
       }
     } else {
-      collection.createOrReplace(latestDocKey, latestConfigDocument);
+      collection.upsert(latestDocKey, latestConfigDocument);
     }
 
     return optionalPreviousConfig

diff --git a/...rvice-impl/src/test/java/org/hypertrace/config/service/store/DocumentConfigStoreTest.java b/...rvice-impl/src/test/java/org/hypertrace/config/service/store/DocumentConfigStoreTest.java
@@ -89,7 +89,7 @@ void WriteConfigForCreate() throws IOException {
 
     ArgumentCaptor<Key> keyCaptor = ArgumentCaptor.forClass(Key.class);
     ArgumentCaptor<Document> documentCaptor = ArgumentCaptor.forClass(Document.class);
-    verify(collection, times(1)).createOrReplace(keyCaptor.capture(), documentCaptor.capture());
+    verify(collection, times(1)).upsert(keyCaptor.capture(), documentCaptor.capture());
 
     Key key = keyCaptor.getValue();
     Document document = documentCaptor.getValue();
@@ -129,7 +129,7 @@ void WriteConfigForUpdateWithoutUpsertCondition() throws IOException {
 
     ArgumentCaptor<Key> keyCaptor = ArgumentCaptor.forClass(Key.class);
     ArgumentCaptor<Document> documentCaptor = ArgumentCaptor.forClass(Document.class);
-    verify(collection, times(1)).createOrReplace(keyCaptor.capture(), documentCaptor.capture());
+    verify(collection, times(1)).upsert(keyCaptor.capture(), documentCaptor.capture());
 
     Key key = keyCaptor.getValue();
     Document document = documentCaptor.getValue();