CLI: Support getting metadata from metadataCenter

dubbogo-cli/cmd/show.go

@@ -43,9 +43,15 @@ func init() {
 	rootCmd.AddCommand(showCmd)
 	showCmd.Flags().String("r", "r", "")
 	showCmd.Flags().String("h", "h", "")
+	showCmd.Flags().Bool("mc", false, "Get Metadata in MetadataCenter or not")
 }
 
 func show(cmd *cobra.Command, _ []string) {
+	var (
+		methodsMap map[string][]string
+		err error
+	)
+
 	registry, err := cmd.Flags().GetString("r")
 	if err != nil {
 		panic(err)
@@ -59,7 +65,18 @@ func show(cmd *cobra.Command, _ []string) {
 		log.Print("registry not support")
 		return
 	}
-	methodsMap, err := fact("dubbogo-cli", []string{host}).ShowChildren()
+
+	metadataCenter, err := cmd.Flags().GetBool("mc")
+	if err != nil {
+		panic(err)
+	}
+
+	if metadataCenter {
+		methodsMap, err = fact("dubbogo-cli", []string{host}).ShowMetadataCenterChildren()
+	} else {
+		methodsMap, err = fact("dubbogo-cli", []string{host}).ShowChildren()
+	}
+
 	if err != nil {
 		panic(err)
 	}

dubbogo-cli/metadata/metadata.go

@@ -24,6 +24,7 @@ import (
 // MetaData meta data from registration center
 type MetaData interface {
 	ShowChildren() (map[string][]string, error)
+	ShowMetadataCenterChildren() (map[string][]string, error)
 }
 
 // Factory metaData factory function

dubbogo-cli/metadata/zookeeper/zookeeper.go

@@ -18,6 +18,7 @@
 package zookeeper
 
 import (
+	"encoding/json"
 	"fmt"
 	"log"
 	"time"
@@ -30,6 +31,7 @@ import (
 import (
 	"dubbo.apache.org/dubbo-go/v3/common"
 	"dubbo.apache.org/dubbo-go/v3/dubbogo-cli/metadata"
+	"dubbo.apache.org/dubbo-go/v3/metadata/definition"
 )
 
 func init() {
@@ -104,3 +106,51 @@ func (z *ZookeeperMetadataReport) ShowChildren() (map[string][]string, error) {
 	}
 	return methodsMap, nil
 }
+
+func (z *ZookeeperMetadataReport) ShowMetadataCenterChildren() (map[string][]string, error) {
+	methodsMap := map[string][]string{}
+	inters, err := z.GetChildren("metadata")
+	if err != nil {
+		return nil, err
+	}
+	for _, inter := range inters {
+		path := "metadata/" + inter
+		var methods []string
+		z.searchMetadataProvider(path, &methods)
+
+		if _, ok := methodsMap[inter]; !ok && len(methods) != 0 {
+			methodsMap[inter] = make([]string, 0)
+		}
+		for _, method := range methods {
+			methodsMap[inter] = append(methodsMap[inter], method)
+		}
+	}
+	return methodsMap, nil
+}
+
+func (z *ZookeeperMetadataReport) searchMetadataProvider(path string, methods *[]string) {
+	interChildren, err := z.GetChildren(path)
+	if err != nil {
+		return
+	}
+	for _, interChild := range interChildren {
+		if interChild == "provider" {
+			content , _, err := z.client.GetContent("/" + "dubbo" + "/" + path + "/" + interChild)
+			if err != nil {
+				fmt.Printf("Zookeeper Get Content Error: %v\n", err)
+				return
+			}
+
+			var serviceDefinition definition.FullServiceDefinition
+			err = json.Unmarshal(content, &serviceDefinition)
+			if err != nil {
+				fmt.Printf("Json Unmarshal fail: %v\n", err)
+			}
+			for _, method := range serviceDefinition.Methods {
+				*methods = append(*methods, method.Name)
+			}
+		} else {
+			z.searchMetadataProvider(path + "/" + interChild, methods)
+		}
+	}
+}