Skip to content

Commit

Permalink
More tests
Browse files Browse the repository at this point in the history
  • Loading branch information
@gthea
gthea committed Oct 31, 2023
1 parent 4089e3f commit 1ff6a3a
Show file tree
Hide file tree
Showing 4 changed files with 101 additions and 17 deletions.
2 changes: 1 addition & 1 deletion src/androidTest/java/tests/integration/sets/FlagSetsStreamingTest.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -134,7 +134,7 @@ public void sdkWithSetsConfiguredDeletedDueToNonMatchingSets() throws IOExceptio
assertTrue(firstChange);
assertTrue(secondChange);
assertTrue(thirdChange);
assertTrue(fourthChange);
assertFalse(fourthChange); // SDK_UPDATE should not be triggered since there were no changes to storage
}

@Test
Expand Down
83 changes: 69 additions & 14 deletions src/androidTest/java/tests/storage/SplitsStorageTest.java
View file
Original file line number Diff line number Diff line change
@@ -1,5 +1,8 @@
package tests.storage;

import static org.junit.Assert.assertFalse;
import static org.junit.Assert.assertTrue;

import android.content.Context;

import androidx.test.platform.app.InstrumentationRegistry;
Expand Down Expand Up @@ -282,8 +285,8 @@ public void updatedSplitTrafficType() {
mSplitsStorage.update(new ProcessedSplitChange(Arrays.asList(s2), empty, 1L, 0L));
mSplitsStorage.update(new ProcessedSplitChange(empty, Arrays.asList(s2ar), 1L, 0L));

Assert.assertTrue(mSplitsStorage.isValidTrafficType("tt"));
Assert.assertFalse(mSplitsStorage.isValidTrafficType("mytt"));
assertTrue(mSplitsStorage.isValidTrafficType("tt"));
assertFalse(mSplitsStorage.isValidTrafficType("mytt"));
}

@Test
Expand All @@ -300,8 +303,8 @@ public void changedTrafficTypeForSplit() {
mSplitsStorage.update(new ProcessedSplitChange(Arrays.asList(s1t1), empty, 1L, 0L));
mSplitsStorage.update(new ProcessedSplitChange(Arrays.asList(s1t2), empty, 1L, 0L));

Assert.assertFalse(mSplitsStorage.isValidTrafficType("tt"));
Assert.assertTrue(mSplitsStorage.isValidTrafficType("mytt"));
assertFalse(mSplitsStorage.isValidTrafficType("tt"));
assertTrue(mSplitsStorage.isValidTrafficType("mytt"));
}

@Test
Expand All @@ -320,8 +323,8 @@ public void existingChangedTrafficTypeForSplit() {
mSplitsStorage.update(new ProcessedSplitChange(Arrays.asList(s1t1), empty, 1L, 0L));
mSplitsStorage.update(new ProcessedSplitChange(Arrays.asList(s1t2), empty, 1L, 0L));

Assert.assertTrue(mSplitsStorage.isValidTrafficType("tt"));
Assert.assertTrue(mSplitsStorage.isValidTrafficType("mytt"));
assertTrue(mSplitsStorage.isValidTrafficType("tt"));
assertTrue(mSplitsStorage.isValidTrafficType("mytt"));
}

@Test
Expand All @@ -331,9 +334,9 @@ public void trafficTypesAreLoadedInMemoryWhenLoadingLocalSplits() {

mSplitsStorage.loadLocal();

Assert.assertTrue(mSplitsStorage.isValidTrafficType("test_type"));
Assert.assertTrue(mSplitsStorage.isValidTrafficType("test_type_2"));
Assert.assertFalse(mSplitsStorage.isValidTrafficType("invalid_type"));
assertTrue(mSplitsStorage.isValidTrafficType("test_type"));
assertTrue(mSplitsStorage.isValidTrafficType("test_type_2"));
assertFalse(mSplitsStorage.isValidTrafficType("invalid_type"));
}

@Test
Expand All @@ -346,9 +349,9 @@ public void loadedFromStorageTrafficTypesAreCorrectlyUpdated() {
Split updatedSplit = newSplit("split_test", Status.ACTIVE, "new_type");
mSplitsStorage.update(new ProcessedSplitChange(Collections.singletonList(updatedSplit), Collections.emptyList(), 1L, 0L));

Assert.assertFalse(mSplitsStorage.isValidTrafficType("test_type"));
Assert.assertTrue(mSplitsStorage.isValidTrafficType("new_type"));
Assert.assertTrue(mSplitsStorage.isValidTrafficType("test_type_2"));
assertFalse(mSplitsStorage.isValidTrafficType("test_type"));
assertTrue(mSplitsStorage.isValidTrafficType("new_type"));
assertTrue(mSplitsStorage.isValidTrafficType("test_type_2"));
}

@Test
Expand Down Expand Up @@ -382,7 +385,7 @@ public void flagSetsAreRemovedWhenUpdating() {
Collections.singletonList(newSplit("split_test", Status.ACTIVE, "test_type")), Collections.emptyList(),
1L, 0L));

Assert.assertFalse(initialSet1.isEmpty());
assertFalse(initialSet1.isEmpty());
Assert.assertEquals(Collections.emptySet(), mSplitsStorage.getNamesByFlagSets(Collections.singletonList("set_1")));
Assert.assertEquals(initialSet2, mSplitsStorage.getNamesByFlagSets(Collections.singletonList("set_2")));
}
Expand All @@ -398,11 +401,63 @@ public void updateWithoutChecksRemovesFromFlagSet() {

mSplitsStorage.updateWithoutChecks(newSplit("split_test", Status.ACTIVE, "test_type"));

Assert.assertFalse(initialSet1.isEmpty());
assertFalse(initialSet1.isEmpty());
Assert.assertEquals(Collections.emptySet(), mSplitsStorage.getNamesByFlagSets(Collections.singletonList("set_1")));
Assert.assertEquals(initialSet2, mSplitsStorage.getNamesByFlagSets(Collections.singletonList("set_2")));
}

@Test
public void updateReturnsTrueWhenFlagsHaveBeenRemovedFromStorage() {
mRoomDb.clearAllTables();
mRoomDb.splitDao().insert(Arrays.asList(newSplitEntity("split_test", "test_type", Collections.singleton("set_1")), newSplitEntity("split_test_2", "test_type_2", Collections.singleton("set_2"))));
mSplitsStorage.loadLocal();

ArrayList<Split> archivedSplits = new ArrayList<>();
archivedSplits.add(newSplit("split_test", Status.ARCHIVED, "test_type"));
boolean update = mSplitsStorage.update(new ProcessedSplitChange(new ArrayList<>(), archivedSplits, 1L, 0L));

assertTrue(update);
}

@Test
public void updateReturnsTrueWhenFlagsWereAddedToStorage() {
mRoomDb.clearAllTables();
mRoomDb.splitDao().insert(Arrays.asList(newSplitEntity("split_test", "test_type", Collections.singleton("set_1")), newSplitEntity("split_test_2", "test_type_2", Collections.singleton("set_2"))));
mSplitsStorage.loadLocal();

ArrayList<Split> activeSplits = new ArrayList<>();
activeSplits.add(newSplit("split_test_3", Status.ACTIVE, "test_type_2", Collections.singleton("set_2")));
boolean update = mSplitsStorage.update(new ProcessedSplitChange(activeSplits, new ArrayList<>(), 1L, 0L));

assertTrue(update);
}

@Test
public void updateReturnsTrueWhenFlagsWereUpdatedInStorage() {
mRoomDb.clearAllTables();
mRoomDb.splitDao().insert(Arrays.asList(newSplitEntity("split_test", "test_type", Collections.singleton("set_1")), newSplitEntity("split_test_2", "test_type_2", Collections.singleton("set_2"))));
mSplitsStorage.loadLocal();

ArrayList<Split> activeSplits = new ArrayList<>();
activeSplits.add(newSplit("split_test", Status.ACTIVE, "test_type", Collections.singleton("set_2")));
boolean update = mSplitsStorage.update(new ProcessedSplitChange(activeSplits, new ArrayList<>(), 1L, 0L));

assertTrue(update);
}

@Test
public void updateReturnsFalseWhenFlagsThatAreNotInStorageAreAttemptedToBeRemoved() {
mRoomDb.clearAllTables();
mRoomDb.splitDao().insert(Arrays.asList(newSplitEntity("split_test", "test_type", Collections.singleton("set_1")), newSplitEntity("split_test_2", "test_type_2", Collections.singleton("set_2"))));
mSplitsStorage.loadLocal();

ArrayList<Split> archivedSplits = new ArrayList<>();
archivedSplits.add(newSplit("split_test_3", Status.ACTIVE, "test_type_2", Collections.singleton("set_2")));
boolean update = mSplitsStorage.update(new ProcessedSplitChange(new ArrayList<>(), archivedSplits, 1L, 0L));

assertFalse(update);
}

private Split newSplit(String name, Status status, String trafficType) {
return newSplit(name, status, trafficType, Collections.emptySet());
}
Expand Down
2 changes: 1 addition & 1 deletion src/main/java/io/split/android/client/storage/splits/SplitsStorageImpl.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -82,7 +82,7 @@ public boolean update(ProcessedSplitChange splitChange) {
return false;
}

// return true if there is at least one split change; otherwise false
// this will be true if there is at least one split change; otherwise false
boolean result = false;

List<Split> activeSplits = splitChange.getActiveSplits();
Expand Down
31 changes: 30 additions & 1 deletion src/test/java/io/split/android/client/service/SplitInPlaceUpdateTaskTest.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -61,7 +61,6 @@ public void sseUpdateIsRecordedInTelemetryWhenOperationIsSuccessful() {

verify(mSplitChangeProcessor).process(mSplit, 123L);
verify(mSplitsStorage).update(processedSplitChange);
verify(mEventsManager).notifyInternalEvent(SplitInternalEvent.SPLITS_UPDATED);
verify(mTelemetryRuntimeProducer).recordUpdatesFromSSE(UpdatesFromSSEEnum.SPLITS);

assertEquals(result.getStatus(), SplitTaskExecutionStatus.SUCCESS);
Expand Down Expand Up @@ -98,4 +97,34 @@ public void exceptionDuringStorageUpdateReturnsErrorExecutionInfo() {

assertEquals(result.getStatus(), SplitTaskExecutionStatus.ERROR);
}

@Test
public void sdkUpdateIsNotTriggeredWhenStorageUpdateReturnsFalse() {
ProcessedSplitChange processedSplitChange = new ProcessedSplitChange(new ArrayList<>(), new ArrayList<>(), 0L, 0);

when(mSplitChangeProcessor.process(mSplit, 123L)).thenReturn(processedSplitChange);
when(mSplitsStorage.update(processedSplitChange)).thenReturn(false);

SplitTaskExecutionInfo result = mSplitInPlaceUpdateTask.execute();

verify(mSplitChangeProcessor).process(mSplit, 123L);
verify(mSplitsStorage).update(processedSplitChange);
verify(mEventsManager, never()).notifyInternalEvent(any());
verify(mTelemetryRuntimeProducer).recordUpdatesFromSSE(UpdatesFromSSEEnum.SPLITS);
}

@Test
public void sdkUpdateIsTriggeredWhenStorageUpdateReturnsTrue() {
ProcessedSplitChange processedSplitChange = new ProcessedSplitChange(new ArrayList<>(), new ArrayList<>(), 0L, 0);

when(mSplitChangeProcessor.process(mSplit, 123L)).thenReturn(processedSplitChange);
when(mSplitsStorage.update(processedSplitChange)).thenReturn(true);

SplitTaskExecutionInfo result = mSplitInPlaceUpdateTask.execute();

verify(mSplitChangeProcessor).process(mSplit, 123L);
verify(mSplitsStorage).update(processedSplitChange);
verify(mEventsManager).notifyInternalEvent(SplitInternalEvent.SPLITS_UPDATED);
verify(mTelemetryRuntimeProducer).recordUpdatesFromSSE(UpdatesFromSSEEnum.SPLITS);
}
}

0 comments on commit 1ff6a3a

Please sign in to comment.