feat():modify API (#455)

xstream/server/server/rest.go

@@ -90,7 +90,7 @@ func createRestServer(port int) *http.Server {
 
 	r.HandleFunc("/metadata/sinks", sinksMetaHandler).Methods(http.MethodGet)
 	r.HandleFunc("/metadata/sinks/{name}", newSinkMetaHandler).Methods(http.MethodGet)
-	r.HandleFunc("/metadata/sinks/{name}/{ruleId}", showSinkMetaHandler).Methods(http.MethodGet)
+	r.HandleFunc("/metadata/sinks/rule/{id}", showSinkMetaHandler).Methods(http.MethodGet)
 
 	r.HandleFunc("/metadata/sources", sourcesMetaHandler).Methods(http.MethodGet)
 	r.HandleFunc("/metadata/sources/{name}", sourceMetaHandler).Methods(http.MethodGet)
@@ -437,8 +437,7 @@ func newSinkMetaHandler(w http.ResponseWriter, r *http.Request) {
 func showSinkMetaHandler(w http.ResponseWriter, r *http.Request) {
 	defer r.Body.Close()
 	vars := mux.Vars(r)
-	pluginName := vars["name"]
-	ruleid := vars["ruleId"]
+	ruleid := vars["id"]
 
 	rule, err := ruleProcessor.GetRuleByName(ruleid)
 	if err != nil {
@@ -446,7 +445,7 @@ func showSinkMetaHandler(w http.ResponseWriter, r *http.Request) {
 		return
 	}
 
-	ptrMetadata, err := plugins.GetSinkMeta(pluginName, rule)
+	ptrMetadata, err := plugins.GetSinkMeta("", rule)
 	if err != nil {
 		handleError(w, err, "metadata error", logger)
 		return