|
|
|
@ -26,6 +26,7 @@ import org.mockito.stubbing.Answer; |
|
|
|
import org.springframework.beans.factory.annotation.Autowired; |
|
|
|
import org.springframework.test.util.ReflectionTestUtils; |
|
|
|
import org.thingsboard.rule.engine.flow.TbRuleChainInputNodeConfiguration; |
|
|
|
import org.thingsboard.rule.engine.metadata.FetchTo; |
|
|
|
import org.thingsboard.rule.engine.metadata.TbGetAttributesNodeConfiguration; |
|
|
|
import org.thingsboard.server.actors.ActorSystemContext; |
|
|
|
import org.thingsboard.server.common.data.DataConstants; |
|
|
|
@ -138,6 +139,7 @@ public abstract class AbstractRuleEngineFlowIntegrationTest extends AbstractRule |
|
|
|
ruleNode1.setType(org.thingsboard.rule.engine.metadata.TbGetAttributesNode.class.getName()); |
|
|
|
ruleNode1.setDebugMode(true); |
|
|
|
TbGetAttributesNodeConfiguration configuration1 = new TbGetAttributesNodeConfiguration(); |
|
|
|
configuration1.setFetchTo(FetchTo.METADATA); |
|
|
|
configuration1.setServerAttributeNames(Collections.singletonList("serverAttributeKey1")); |
|
|
|
ruleNode1.setConfiguration(mapper.valueToTree(configuration1)); |
|
|
|
|
|
|
|
@ -146,6 +148,7 @@ public abstract class AbstractRuleEngineFlowIntegrationTest extends AbstractRule |
|
|
|
ruleNode2.setType(org.thingsboard.rule.engine.metadata.TbGetAttributesNode.class.getName()); |
|
|
|
ruleNode2.setDebugMode(true); |
|
|
|
TbGetAttributesNodeConfiguration configuration2 = new TbGetAttributesNodeConfiguration(); |
|
|
|
configuration2.setFetchTo(FetchTo.METADATA); |
|
|
|
configuration2.setServerAttributeNames(Collections.singletonList("serverAttributeKey2")); |
|
|
|
ruleNode2.setConfiguration(mapper.valueToTree(configuration2)); |
|
|
|
|
|
|
|
@ -240,6 +243,7 @@ public abstract class AbstractRuleEngineFlowIntegrationTest extends AbstractRule |
|
|
|
ruleNode1.setType(org.thingsboard.rule.engine.metadata.TbGetAttributesNode.class.getName()); |
|
|
|
ruleNode1.setDebugMode(true); |
|
|
|
TbGetAttributesNodeConfiguration configuration1 = new TbGetAttributesNodeConfiguration(); |
|
|
|
configuration1.setFetchTo(FetchTo.METADATA); |
|
|
|
configuration1.setServerAttributeNames(Collections.singletonList("serverAttributeKey1")); |
|
|
|
ruleNode1.setConfiguration(mapper.valueToTree(configuration1)); |
|
|
|
|
|
|
|
@ -272,6 +276,7 @@ public abstract class AbstractRuleEngineFlowIntegrationTest extends AbstractRule |
|
|
|
ruleNode2.setType(org.thingsboard.rule.engine.metadata.TbGetAttributesNode.class.getName()); |
|
|
|
ruleNode2.setDebugMode(true); |
|
|
|
TbGetAttributesNodeConfiguration configuration2 = new TbGetAttributesNodeConfiguration(); |
|
|
|
configuration2.setFetchTo(FetchTo.METADATA); |
|
|
|
configuration2.setServerAttributeNames(Collections.singletonList("serverAttributeKey2")); |
|
|
|
ruleNode2.setConfiguration(mapper.valueToTree(configuration2)); |
|
|
|
|
|
|
|
|