【fix】修复设置属性，指令下发，单双向

pkg/rule_engine/nodes/action_rpc_respond_node.go

@@ -1,49 +0,0 @@
-package nodes
-
-import (
-	"pandax/iothub/client/mqttclient"
-	"pandax/pkg/rule_engine/message"
-)
-
-type rpcRespondNode struct {
-	bareNode
-	RequestId int `json:"requestId"`
-}
-
-type rpcRespondFactory struct{}
-
-func (f rpcRespondFactory) Name() string     { return "RpcRespondNode" }
-func (f rpcRespondFactory) Category() string { return NODE_CATEGORY_ACTION }
-func (f rpcRespondFactory) Labels() []string { return []string{"Success", "Failure"} }
-func (f rpcRespondFactory) Create(id string, meta Metadata) (Node, error) {
-	node := &rpcRespondNode{
-		bareNode: newBareNode(f.Name(), id, meta, f.Labels()),
-	}
-	return decodePath(meta, node)
-}
-
-func (n *rpcRespondNode) Handle(msg *message.Message) error {
-	successLableNode := n.GetLinkedNode("Success")
-	failureLableNode := n.GetLinkedNode("Failure")
-	RequestId := n.RequestId
-	if RequestId == 0 {
-		RequestId = int(msg.Metadata.GetValue("requestId").(float64))
-	}
-	var datas = mqttclient.RpcPayload{
-		Method: msg.Msg.GetValue("method").(string),
-		Params: msg.Msg.GetValue("params"),
-	}
-	rpc := &mqttclient.RpcRequest{Client: mqttclient.MqttClient, RequestId: RequestId}
-	err := rpc.RespondTpc(datas)
-	if err != nil {
-		if failureLableNode != nil {
-			return failureLableNode.Handle(msg)
-		} else {
-			return err
-		}
-	}
-	if successLableNode != nil {
-		return successLableNode.Handle(msg)
-	}
-	return nil
-}