@ -18,7 +18,6 @@ package org.thingsboard.server.service.edge.rpc.constructor;
import com.fasterxml.jackson.core.JsonProcessingException ;
import com.fasterxml.jackson.databind.JsonNode ;
import lombok.extern.slf4j.Slf4j ;
import org.jetbrains.annotations.NotNull ;
import org.junit.Assert ;
import org.junit.Before ;
import org.junit.Test ;
@ -315,7 +314,6 @@ public class RuleChainMsgConstructorTest {
}
@NotNull
private RuleNode getOutputNode ( RuleChainId ruleChainId ) throws JsonProcessingException {
return createRuleNode ( ruleChainId ,
"org.thingsboard.rule.engine.flow.TbRuleChainOutputNode" ,
@ -324,7 +322,6 @@ public class RuleChainMsgConstructorTest {
JacksonUtil . OBJECT_MAPPER . readTree ( "{\"description\":\"\",\"layoutX\":178,\"layoutY\":592}" ) ) ;
}
@NotNull
private RuleNode getCheckpointNode ( RuleChainId ruleChainId ) throws JsonProcessingException {
return createRuleNode ( ruleChainId ,
"org.thingsboard.rule.engine.flow.TbCheckpointNode" ,
@ -333,7 +330,6 @@ public class RuleChainMsgConstructorTest {
JacksonUtil . OBJECT_MAPPER . readTree ( "{\"description\":\"\",\"layoutX\":178,\"layoutY\":647}" ) ) ;
}
@NotNull
private RuleNode getSaveTimeSeriesNode ( RuleChainId ruleChainId ) throws JsonProcessingException {
return createRuleNode ( ruleChainId ,
"org.thingsboard.rule.engine.telemetry.TbMsgTimeseriesNode" ,
@ -342,7 +338,6 @@ public class RuleChainMsgConstructorTest {
JacksonUtil . OBJECT_MAPPER . readTree ( "{\"layoutX\":823,\"layoutY\":157}" ) ) ;
}
@NotNull
private RuleNode getMessageTypeSwitchNode ( RuleChainId ruleChainId ) throws JsonProcessingException {
return createRuleNode ( ruleChainId ,
"org.thingsboard.rule.engine.filter.TbMsgTypeSwitchNode" ,
@ -351,7 +346,6 @@ public class RuleChainMsgConstructorTest {
JacksonUtil . OBJECT_MAPPER . readTree ( "{\"layoutX\":347,\"layoutY\":149}" ) ) ;
}
@NotNull
private RuleNode getLogOtherNode ( RuleChainId ruleChainId ) throws JsonProcessingException {
return createRuleNode ( ruleChainId ,
"org.thingsboard.rule.engine.action.TbLogNode" ,
@ -360,7 +354,6 @@ public class RuleChainMsgConstructorTest {
JacksonUtil . OBJECT_MAPPER . readTree ( "{\"layoutX\":824,\"layoutY\":378}" ) ) ;
}
@NotNull
private RuleNode getPushToCloudNode ( RuleChainId ruleChainId ) throws JsonProcessingException {
return createRuleNode ( ruleChainId ,
"org.thingsboard.rule.engine.edge.TbMsgPushToCloudNode" ,
@ -369,7 +362,6 @@ public class RuleChainMsgConstructorTest {
JacksonUtil . OBJECT_MAPPER . readTree ( "{\"layoutX\":1129,\"layoutY\":52}" ) ) ;
}
@NotNull
private RuleNode getAcknowledgeNode ( RuleChainId ruleChainId ) throws JsonProcessingException {
return createRuleNode ( ruleChainId ,
"org.thingsboard.rule.engine.flow.TbAckNode" ,
@ -378,7 +370,6 @@ public class RuleChainMsgConstructorTest {
JacksonUtil . OBJECT_MAPPER . readTree ( "{\"description\":\"\",\"layoutX\":177,\"layoutY\":703}" ) ) ;
}
@NotNull
private RuleNode getDeviceProfileNode ( RuleChainId ruleChainId ) throws JsonProcessingException {
return createRuleNode ( ruleChainId ,
"org.thingsboard.rule.engine.profile.TbDeviceProfileNode" ,
@ -387,7 +378,6 @@ public class RuleChainMsgConstructorTest {
JacksonUtil . OBJECT_MAPPER . readTree ( "{\"description\":\"Process incoming messages from devices with the alarm rules defined in the device profile. Dispatch all incoming messages with \\\"Success\\\" relation type.\",\"layoutX\":187,\"layoutY\":468}" ) ) ;
}
@NotNull
private RuleNode getSaveClientAttributesNode ( RuleChainId ruleChainId ) throws JsonProcessingException {
return createRuleNode ( ruleChainId ,
"org.thingsboard.rule.engine.telemetry.TbMsgAttributesNode" ,
@ -396,7 +386,6 @@ public class RuleChainMsgConstructorTest {
JacksonUtil . OBJECT_MAPPER . readTree ( "{\"layoutX\":824,\"layoutY\":52}" ) ) ;
}
@NotNull
private RuleNode getLogRpcFromDeviceNode ( RuleChainId ruleChainId ) throws JsonProcessingException {
return createRuleNode ( ruleChainId ,
"org.thingsboard.rule.engine.action.TbLogNode" ,
@ -405,7 +394,6 @@ public class RuleChainMsgConstructorTest {
JacksonUtil . OBJECT_MAPPER . readTree ( "{\"layoutX\":825,\"layoutY\":266}" ) ) ;
}
@NotNull
private RuleNode getRpcCallRequestNode ( RuleChainId ruleChainId ) throws JsonProcessingException {
return createRuleNode ( ruleChainId ,
"org.thingsboard.rule.engine.rpc.TbSendRPCRequestNode" ,
@ -414,7 +402,6 @@ public class RuleChainMsgConstructorTest {
JacksonUtil . OBJECT_MAPPER . readTree ( "{\"layoutX\":824,\"layoutY\":466}" ) ) ;
}
@NotNull
private RuleNode getPushToAnalyticsNode ( RuleChainId ruleChainId ) throws JsonProcessingException {
return createRuleNode ( ruleChainId ,
"org.thingsboard.rule.engine.flow.TbRuleChainInputNode" ,