diff --git a/pkg/rule_engine/nodes/transform_metadata_node.go b/pkg/rule_engine/nodes/action_switch_meta_node.go similarity index 66% rename from pkg/rule_engine/nodes/transform_metadata_node.go rename to pkg/rule_engine/nodes/action_switch_meta_node.go index aa63296..656fa34 100644 --- a/pkg/rule_engine/nodes/transform_metadata_node.go +++ b/pkg/rule_engine/nodes/action_switch_meta_node.go @@ -5,24 +5,24 @@ import ( "pandax/pkg/rule_engine/message" ) -type transformMetadataNode struct { +type switchMetaNode struct { bareNode DeviceId string `json:"deviceId" yaml:"deviceId"` } -type transformMetadataNodeFactory struct{} +type switchMetaNodeFactory struct{} -func (f transformMetadataNodeFactory) Name() string { return "MetadataKeyNode" } -func (f transformMetadataNodeFactory) Category() string { return NODE_CATEGORY_TRANSFORM } -func (f transformMetadataNodeFactory) Labels() []string { return []string{"Success", "Failure"} } -func (f transformMetadataNodeFactory) Create(id string, meta Properties) (Node, error) { - node := &transformMetadataNode{ +func (f switchMetaNodeFactory) Name() string { return "SwitchMetaNode" } +func (f switchMetaNodeFactory) Category() string { return NODE_CATEGORY_ACTION } +func (f switchMetaNodeFactory) Labels() []string { return []string{"Success", "Failure"} } +func (f switchMetaNodeFactory) Create(id string, meta Properties) (Node, error) { + node := &switchMetaNode{ bareNode: newBareNode(f.Name(), id, meta, f.Labels()), } return decodePath(meta, node) } -func (n *transformMetadataNode) Handle(msg *message.Message) error { +func (n *switchMetaNode) Handle(msg *message.Message) error { n.Debug(msg, message.DEBUGIN, "") successLabelNode := n.GetLinkedNode("Success") diff --git a/pkg/rule_engine/nodes/init.go b/pkg/rule_engine/nodes/init.go index 634517e..f79e4c8 100644 --- a/pkg/rule_engine/nodes/init.go +++ b/pkg/rule_engine/nodes/init.go @@ -11,7 +11,6 @@ func init() { RegisterFactory(transformDeleteKeyNodeFactory{}) RegisterFactory(transformRenameKeyNodeFactory{}) RegisterFactory(transformScriptNodeFactory{}) - RegisterFactory(transformMetadataNodeFactory{}) RegisterFactory(createAlarmNodeFactory{}) RegisterFactory(clearAlarmNodeFactory{}) @@ -31,4 +30,5 @@ func init() { RegisterFactory(externalRuleChainNodeFactory{}) RegisterFactory(rpcRequestFromDeviceFactory{}) RegisterFactory(rpcRequestToDeviceNodeFactory{}) + RegisterFactory(switchMetaNodeFactory{}) }