Add more test cases on QualifiedDataSourceDispatchEventBuilder

apache · Sep 16, 2024 · 0683fb0 · 0683fb0
1 parent 3af653d
commit 0683fb0
Showing 1 changed file with 16 additions and 17 deletions.
diff --git a/...phere/mode/manager/cluster/event/builder/QualifiedDataSourceDispatchEventBuilderTest.java b/...phere/mode/manager/cluster/event/builder/QualifiedDataSourceDispatchEventBuilderTest.java
@@ -36,30 +36,29 @@ class QualifiedDataSourceDispatchEventBuilderTest {
     private final QualifiedDataSourceDispatchEventBuilder builder = new QualifiedDataSourceDispatchEventBuilder();
 
     @Test
-    void assertCreateEnabledQualifiedDataSourceChangedEvent() {
-        Optional<DispatchEvent> actual = builder.build(new DataChangedEvent("/nodes/qualified_data_sources/replica_query_db.readwrite_ds.replica_ds_0", "state: ENABLED\n", Type.ADDED));
-        assertTrue(actual.isPresent());
-        QualifiedDataSourceStateEvent actualEvent = (QualifiedDataSourceStateEvent) actual.get();
-        assertThat(actualEvent.getQualifiedDataSource().getDatabaseName(), is("replica_query_db"));
-        assertThat(actualEvent.getQualifiedDataSource().getGroupName(), is("readwrite_ds"));
-        assertThat(actualEvent.getQualifiedDataSource().getDataSourceName(), is("replica_ds_0"));
-        assertThat(actualEvent.getStatus().getState(), is(DataSourceState.ENABLED));
+    void assertGetSubscribedKey() {
+        assertThat(builder.getSubscribedKey(), is("/nodes/qualified_data_sources"));
     }
 
     @Test
-    void assertCreateDisabledQualifiedDataSourceChangedEvent() {
-        Optional<DispatchEvent> actual = builder.build(new DataChangedEvent("/nodes/qualified_data_sources/replica_query_db.readwrite_ds.replica_ds_0", "state: DISABLED\n", Type.DELETED));
+    void assertBuildQualifiedDataSourceStateEvent() {
+        Optional<DispatchEvent> actual = builder.build(new DataChangedEvent("/nodes/qualified_data_sources/foo_db.foo_group.foo_ds", "state: ENABLED", Type.ADDED));
         assertTrue(actual.isPresent());
-        QualifiedDataSourceStateEvent actualEvent = (QualifiedDataSourceStateEvent) actual.get();
-        assertThat(actualEvent.getQualifiedDataSource().getDatabaseName(), is("replica_query_db"));
-        assertThat(actualEvent.getQualifiedDataSource().getGroupName(), is("readwrite_ds"));
-        assertThat(actualEvent.getQualifiedDataSource().getDataSourceName(), is("replica_ds_0"));
-        assertThat(actualEvent.getStatus().getState(), is(DataSourceState.DISABLED));
+        assertThat(((QualifiedDataSourceStateEvent) actual.get()).getQualifiedDataSource().getDatabaseName(), is("foo_db"));
+        assertThat(((QualifiedDataSourceStateEvent) actual.get()).getQualifiedDataSource().getGroupName(), is("foo_group"));
+        assertThat(((QualifiedDataSourceStateEvent) actual.get()).getQualifiedDataSource().getDataSourceName(), is("foo_ds"));
+        assertThat(((QualifiedDataSourceStateEvent) actual.get()).getStatus().getState(), is(DataSourceState.ENABLED));
+    }
+
+    @Test
+    void assertBuildWithEmptyValue() {
+        Optional<DispatchEvent> actual = builder.build(new DataChangedEvent("/nodes/qualified_data_sources/foo_db.foo_group.foo_ds", "", Type.ADDED));
+        assertFalse(actual.isPresent());
     }
 
     @Test
-    void assertCreateEmptyEvent() {
-        Optional<DispatchEvent> actual = builder.build(new DataChangedEvent("/nodes/qualified_data_sources/replica_query_db.readwrite_ds.replica_ds_0", "", Type.ADDED));
+    void assertBuildWithoutQualifiedDataSource() {
+        Optional<DispatchEvent> actual = builder.build(new DataChangedEvent("/nodes/qualified_data_sources", "state: DISABLED", Type.ADDED));
         assertFalse(actual.isPresent());
     }
 }