Rest data info id list

server/server/session/src/main/java/com/alipay/sofa/registry/server/session/resource/SessionDigestResource.java

@@ -146,14 +146,18 @@ public Map<String, Object> getPushSwitch() {
     @Path("getDataInfoIdList")
     @Produces(MediaType.APPLICATION_JSON)
     public Collection<String> getDataInfoIdList() {
+        Collection<String> ret = new ArrayList<>();
+        ret.addAll(sessionInterests.getInterestDataInfoIds());
+        ret.addAll(sessionDataStore.getStoreDataInfoIds());
         return sessionInterests.getInterestDataInfoIds();
     }
 
     @GET
     @Path("checkSumDataInfoIdList")
     @Produces(MediaType.APPLICATION_JSON)
     public int checkSumDataInfoIdList() {
-        return sessionInterests.getInterestDataInfoIds().hashCode();
+        return sessionInterests.getInterestDataInfoIds().hashCode()
+               + sessionDataStore.getStoreDataInfoIds().hashCode();
     }
 
     private void fillServerList(String type,

server/server/session/src/main/java/com/alipay/sofa/registry/server/session/store/DataStore.java

@@ -27,8 +27,26 @@
  */
 public interface DataStore extends DataManager<Publisher, String, String> {
 
+    /**
+     * get all publishers by dataInfoId
+     * @param dataInfoId
+     * @return
+     */
     Collection<Publisher> getStoreDataByDataInfoId(String dataInfoId);
 
+    /***
+     * get Publiser by registerId and dataInfoId
+     * @param registerId
+     * @param dataInfoId
+     * @return
+     */
     Publisher queryById(String registerId, String dataInfoId);
 
+    /**
+     * get all publisher dataInfoIds
+     *
+     * @return
+     */
+    Collection<String> getStoreDataInfoIds();
+
 }

server/server/session/src/main/java/com/alipay/sofa/registry/server/session/store/SessionDataStore.java

@@ -195,6 +195,11 @@ public Publisher queryById(String registerId, String dataInfoId) {
         return publishers.get(registerId);
     }
 
+    @Override
+    public Collection<String> getStoreDataInfoIds() {
+        return registry.keySet();
+    }
+
     @Override
     public long count() {
         AtomicLong count = new AtomicLong(0);