[shardingsphere] branch master updated: Add more assertions in MetaDataChangedWatcherTest (#10765)

[zh...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

zhangliang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/shardingsphere.git


The following commit(s) were added to refs/heads/master by this push:
     new 99a093d  Add more assertions in MetaDataChangedWatcherTest (#10765)
99a093d is described below

commit 99a093d484c4ad0665befbadf49a70b427fa87fc
Author: Da Xiang Huang <lo...@foxmail.com>
AuthorDate: Fri Jun 11 20:43:59 2021 +0800

    Add more assertions in MetaDataChangedWatcherTest (#10765)
---
 .../watcher/MetaDataChangedWatcherTest.java        | 74 +++++++++++++++++++++-
 1 file changed, 72 insertions(+), 2 deletions(-)

diff --git a/shardingsphere-governance/shardingsphere-governance-core/src/test/java/org/apache/shardingsphere/governance/core/registry/metadata/watcher/MetaDataChangedWatcherTest.java b/shardingsphere-governance/shardingsphere-governance-core/src/test/java/org/apache/shardingsphere/governance/core/registry/metadata/watcher/MetaDataChangedWatcherTest.java
index c9cfad4..2df9369 100644
--- a/shardingsphere-governance/shardingsphere-governance-core/src/test/java/org/apache/shardingsphere/governance/core/registry/metadata/watcher/MetaDataChangedWatcherTest.java
+++ b/shardingsphere-governance/shardingsphere-governance-core/src/test/java/org/apache/shardingsphere/governance/core/registry/metadata/watcher/MetaDataChangedWatcherTest.java
@@ -25,13 +25,83 @@ import org.junit.Test;
 import java.util.Optional;
 
 import static org.junit.Assert.assertFalse;
+import static org.junit.Assert.assertTrue;
 
 public final class MetaDataChangedWatcherTest {
     
     @Test
     public void assertCreateEventWithInvalidPath() {
-        DataChangedEvent dataChangedEvent = new DataChangedEvent("/metadata_invalid/sharding_db", "encrypt_db", Type.UPDATED);
-        Optional<GovernanceEvent> actual = new MetaDataChangedWatcher().createGovernanceEvent(dataChangedEvent);
+        String key = "/metadata_invalid/sharding_db";
+        String value = "encrypt_db";
+        Optional<GovernanceEvent> actual = createEvent(key, value, Type.UPDATED);
+        assertFalse(actual.isPresent());
+        actual = createEvent(key, value, Type.ADDED);
+        assertFalse(actual.isPresent());
+        actual = createEvent(key, value, Type.DELETED);
+        assertFalse(actual.isPresent());
+        actual = createEvent(key, value, Type.IGNORED);
+        assertFalse(actual.isPresent());
+    }
+    
+    @Test
+    public void assertCreateAddedEvent() {
+        String key = "/metadata/sharding_db";
+        String value = "encrypt_db";
+        Optional<GovernanceEvent> actual = createEvent(key, value, Type.UPDATED);
+        assertTrue(actual.isPresent());
+        actual = createEvent(key, value, Type.ADDED);
+        assertTrue(actual.isPresent());
+        actual = createEvent(key, value, Type.IGNORED);
         assertFalse(actual.isPresent());
     }
+    
+    @Test
+    public void assertEmptyValue() {
+        String key = "/metadata/sharding_db/dataSources";
+        Optional<GovernanceEvent> actual = createEvent(key, null, Type.UPDATED);
+        assertFalse(actual.isPresent());
+    }
+    
+    @Test
+    public void assertCreateDeletedEvent() {
+        String key = "/metadata/sharding_db";
+        String value = "encrypt_db";
+        Optional<GovernanceEvent> actual = createEvent(key, value, Type.DELETED);
+        assertTrue(actual.isPresent());
+    }
+    
+    @Test
+    public void assertCreateDataSourceChangedEvent() {
+        String key = "/metadata/sharding_db/dataSources";
+        String value = "{}";
+        Optional<GovernanceEvent> actual = createEvent(key, value, Type.UPDATED);
+        assertTrue(actual.isPresent());
+    }
+    
+    @Test
+    public void assertCreateRuleChangedEvent() {
+        String key = "/metadata/sharding_db/rules";
+        Optional<GovernanceEvent> actual = createEvent(key, "[]", Type.UPDATED);
+        assertTrue(actual.isPresent());
+    }
+    
+    @Test
+    public void assertCreateCachedEvent() {
+        String key = "/metadata/sharding_db/rules/cache";
+        Optional<GovernanceEvent> actual = createEvent(key, "[]", Type.UPDATED);
+        assertTrue(actual.isPresent());
+    }
+    
+    @Test
+    public void assertCreateSchemaChangedEvent() {
+        String key = "/metadata/sharding_db/schema";
+        Optional<GovernanceEvent> actual = createEvent(key, "{}", Type.UPDATED);
+        assertTrue(actual.isPresent());
+    }
+    
+    private Optional<GovernanceEvent> createEvent(final String key, final String value, final Type type) {
+        DataChangedEvent dataChangedEvent = new DataChangedEvent(key, value, type);
+        Optional<GovernanceEvent> actual = new MetaDataChangedWatcher().createGovernanceEvent(dataChangedEvent);
+        return actual;
+    }
 }