|
|
@ -37,14 +37,18 @@ import org.springframework.test.context.ContextConfiguration; |
|
|
import org.springframework.test.context.TestPropertySource; |
|
|
import org.springframework.test.context.TestPropertySource; |
|
|
import org.thingsboard.common.util.JacksonUtil; |
|
|
import org.thingsboard.common.util.JacksonUtil; |
|
|
import org.thingsboard.common.util.ThingsBoardExecutors; |
|
|
import org.thingsboard.common.util.ThingsBoardExecutors; |
|
|
|
|
|
import org.thingsboard.server.common.data.AdminSettings; |
|
|
import org.thingsboard.server.common.data.Customer; |
|
|
import org.thingsboard.server.common.data.Customer; |
|
|
import org.thingsboard.server.common.data.DataConstants; |
|
|
import org.thingsboard.server.common.data.DataConstants; |
|
|
import org.thingsboard.server.common.data.Device; |
|
|
import org.thingsboard.server.common.data.Device; |
|
|
|
|
|
import org.thingsboard.server.common.data.DeviceProfile; |
|
|
import org.thingsboard.server.common.data.EntitySubtype; |
|
|
import org.thingsboard.server.common.data.EntitySubtype; |
|
|
import org.thingsboard.server.common.data.StringUtils; |
|
|
import org.thingsboard.server.common.data.StringUtils; |
|
|
import org.thingsboard.server.common.data.Tenant; |
|
|
import org.thingsboard.server.common.data.Tenant; |
|
|
|
|
|
import org.thingsboard.server.common.data.TenantProfile; |
|
|
import org.thingsboard.server.common.data.User; |
|
|
import org.thingsboard.server.common.data.User; |
|
|
import org.thingsboard.server.common.data.asset.Asset; |
|
|
import org.thingsboard.server.common.data.asset.Asset; |
|
|
|
|
|
import org.thingsboard.server.common.data.asset.AssetProfile; |
|
|
import org.thingsboard.server.common.data.audit.ActionType; |
|
|
import org.thingsboard.server.common.data.audit.ActionType; |
|
|
import org.thingsboard.server.common.data.edge.Edge; |
|
|
import org.thingsboard.server.common.data.edge.Edge; |
|
|
import org.thingsboard.server.common.data.id.CustomerId; |
|
|
import org.thingsboard.server.common.data.id.CustomerId; |
|
|
@ -53,6 +57,8 @@ import org.thingsboard.server.common.data.id.TenantId; |
|
|
import org.thingsboard.server.common.data.id.TenantProfileId; |
|
|
import org.thingsboard.server.common.data.id.TenantProfileId; |
|
|
import org.thingsboard.server.common.data.page.PageData; |
|
|
import org.thingsboard.server.common.data.page.PageData; |
|
|
import org.thingsboard.server.common.data.page.PageLink; |
|
|
import org.thingsboard.server.common.data.page.PageLink; |
|
|
|
|
|
import org.thingsboard.server.common.data.queue.Queue; |
|
|
|
|
|
import org.thingsboard.server.common.data.rule.RuleChain; |
|
|
import org.thingsboard.server.common.data.security.Authority; |
|
|
import org.thingsboard.server.common.data.security.Authority; |
|
|
import org.thingsboard.server.common.data.security.model.JwtSettings; |
|
|
import org.thingsboard.server.common.data.security.model.JwtSettings; |
|
|
import org.thingsboard.server.dao.edge.EdgeDao; |
|
|
import org.thingsboard.server.dao.edge.EdgeDao; |
|
|
@ -78,7 +84,6 @@ import org.thingsboard.server.gen.edge.v1.UserUpdateMsg; |
|
|
import java.util.ArrayList; |
|
|
import java.util.ArrayList; |
|
|
import java.util.Collections; |
|
|
import java.util.Collections; |
|
|
import java.util.List; |
|
|
import java.util.List; |
|
|
import java.util.UUID; |
|
|
|
|
|
import java.util.concurrent.TimeUnit; |
|
|
import java.util.concurrent.TimeUnit; |
|
|
|
|
|
|
|
|
import static org.assertj.core.api.Assertions.assertThat; |
|
|
import static org.assertj.core.api.Assertions.assertThat; |
|
|
@ -121,7 +126,7 @@ public class EdgeControllerTest extends AbstractControllerTest { |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
@After |
|
|
@After |
|
|
public void teardownEdgeTest() throws Exception { |
|
|
public void teardownEdgeTest() { |
|
|
executor.shutdownNow(); |
|
|
executor.shutdownNow(); |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
@ -204,15 +209,13 @@ public class EdgeControllerTest extends AbstractControllerTest { |
|
|
|
|
|
|
|
|
@Test |
|
|
@Test |
|
|
public void testFindEdgeTypesByTenantId() throws Exception { |
|
|
public void testFindEdgeTypesByTenantId() throws Exception { |
|
|
List<Edge> edges = new ArrayList<>(); |
|
|
|
|
|
|
|
|
|
|
|
int cntEntity = 3; |
|
|
int cntEntity = 3; |
|
|
|
|
|
|
|
|
Mockito.reset(tbClusterService, auditLogService); |
|
|
Mockito.reset(tbClusterService, auditLogService); |
|
|
|
|
|
|
|
|
for (int i = 0; i < cntEntity; i++) { |
|
|
for (int i = 0; i < cntEntity; i++) { |
|
|
Edge edge = constructEdge("My edge B" + i, "typeB"); |
|
|
Edge edge = constructEdge("My edge B" + i, "typeB"); |
|
|
edges.add(doPost("/api/edge", edge, Edge.class)); |
|
|
doPost("/api/edge", edge, Edge.class); |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
testNotifyManyEntityManyTimeMsgToEdgeServiceNeverAdditionalInfoAny(new Edge(), new Edge(), |
|
|
testNotifyManyEntityManyTimeMsgToEdgeServiceNeverAdditionalInfoAny(new Edge(), new Edge(), |
|
|
@ -221,11 +224,11 @@ public class EdgeControllerTest extends AbstractControllerTest { |
|
|
|
|
|
|
|
|
for (int i = 0; i < 7; i++) { |
|
|
for (int i = 0; i < 7; i++) { |
|
|
Edge edge = constructEdge("My edge C" + i, "typeC"); |
|
|
Edge edge = constructEdge("My edge C" + i, "typeC"); |
|
|
edges.add(doPost("/api/edge", edge, Edge.class)); |
|
|
doPost("/api/edge", edge, Edge.class); |
|
|
} |
|
|
} |
|
|
for (int i = 0; i < 9; i++) { |
|
|
for (int i = 0; i < 9; i++) { |
|
|
Edge edge = constructEdge("My edge A" + i, "typeA"); |
|
|
Edge edge = constructEdge("My edge A" + i, "typeA"); |
|
|
edges.add(doPost("/api/edge", edge, Edge.class)); |
|
|
doPost("/api/edge", edge, Edge.class); |
|
|
} |
|
|
} |
|
|
List<EntitySubtype> edgeTypes = doGetTyped("/api/edge/types", |
|
|
List<EntitySubtype> edgeTypes = doGetTyped("/api/edge/types", |
|
|
new TypeReference<>() { |
|
|
new TypeReference<>() { |
|
|
@ -395,7 +398,7 @@ public class EdgeControllerTest extends AbstractControllerTest { |
|
|
List<Edge> edges = new ArrayList<>(Futures.allAsList(futures).get(TIMEOUT, TimeUnit.SECONDS)); |
|
|
List<Edge> edges = new ArrayList<>(Futures.allAsList(futures).get(TIMEOUT, TimeUnit.SECONDS)); |
|
|
List<Edge> loadedEdges = new ArrayList<>(); |
|
|
List<Edge> loadedEdges = new ArrayList<>(); |
|
|
PageLink pageLink = new PageLink(23); |
|
|
PageLink pageLink = new PageLink(23); |
|
|
PageData<Edge> pageData = null; |
|
|
PageData<Edge> pageData; |
|
|
do { |
|
|
do { |
|
|
pageData = doGetTypedWithPageLink("/api/tenant/edges?", |
|
|
pageData = doGetTypedWithPageLink("/api/tenant/edges?", |
|
|
new TypeReference<>() { |
|
|
new TypeReference<>() { |
|
|
@ -442,10 +445,10 @@ public class EdgeControllerTest extends AbstractControllerTest { |
|
|
|
|
|
|
|
|
List<Edge> loadedEdgesTitle1 = new ArrayList<>(); |
|
|
List<Edge> loadedEdgesTitle1 = new ArrayList<>(); |
|
|
PageLink pageLink = new PageLink(15, 0, title1); |
|
|
PageLink pageLink = new PageLink(15, 0, title1); |
|
|
PageData<Edge> pageData = null; |
|
|
PageData<Edge> pageData; |
|
|
do { |
|
|
do { |
|
|
pageData = doGetTypedWithPageLink("/api/tenant/edges?", |
|
|
pageData = doGetTypedWithPageLink("/api/tenant/edges?", |
|
|
new TypeReference<PageData<Edge>>() { |
|
|
new TypeReference<>() { |
|
|
}, pageLink); |
|
|
}, pageLink); |
|
|
loadedEdgesTitle1.addAll(pageData.getData()); |
|
|
loadedEdgesTitle1.addAll(pageData.getData()); |
|
|
if (pageData.hasNext()) { |
|
|
if (pageData.hasNext()) { |
|
|
@ -462,7 +465,7 @@ public class EdgeControllerTest extends AbstractControllerTest { |
|
|
pageLink = new PageLink(4, 0, title2); |
|
|
pageLink = new PageLink(4, 0, title2); |
|
|
do { |
|
|
do { |
|
|
pageData = doGetTypedWithPageLink("/api/tenant/edges?", |
|
|
pageData = doGetTypedWithPageLink("/api/tenant/edges?", |
|
|
new TypeReference<PageData<Edge>>() { |
|
|
new TypeReference<>() { |
|
|
}, pageLink); |
|
|
}, pageLink); |
|
|
loadedEdgesTitle2.addAll(pageData.getData()); |
|
|
loadedEdgesTitle2.addAll(pageData.getData()); |
|
|
if (pageData.hasNext()) { |
|
|
if (pageData.hasNext()) { |
|
|
@ -532,10 +535,10 @@ public class EdgeControllerTest extends AbstractControllerTest { |
|
|
|
|
|
|
|
|
List<Edge> loadedEdgesType1 = new ArrayList<>(); |
|
|
List<Edge> loadedEdgesType1 = new ArrayList<>(); |
|
|
PageLink pageLink = new PageLink(15); |
|
|
PageLink pageLink = new PageLink(15); |
|
|
PageData<Edge> pageData = null; |
|
|
PageData<Edge> pageData; |
|
|
do { |
|
|
do { |
|
|
pageData = doGetTypedWithPageLink("/api/tenant/edges?type={type}&", |
|
|
pageData = doGetTypedWithPageLink("/api/tenant/edges?type={type}&", |
|
|
new TypeReference<PageData<Edge>>() { |
|
|
new TypeReference<>() { |
|
|
}, pageLink, type1); |
|
|
}, pageLink, type1); |
|
|
loadedEdgesType1.addAll(pageData.getData()); |
|
|
loadedEdgesType1.addAll(pageData.getData()); |
|
|
if (pageData.hasNext()) { |
|
|
if (pageData.hasNext()) { |
|
|
@ -552,7 +555,7 @@ public class EdgeControllerTest extends AbstractControllerTest { |
|
|
pageLink = new PageLink(4); |
|
|
pageLink = new PageLink(4); |
|
|
do { |
|
|
do { |
|
|
pageData = doGetTypedWithPageLink("/api/tenant/edges?type={type}&", |
|
|
pageData = doGetTypedWithPageLink("/api/tenant/edges?type={type}&", |
|
|
new TypeReference<PageData<Edge>>() { |
|
|
new TypeReference<>() { |
|
|
}, pageLink, type2); |
|
|
}, pageLink, type2); |
|
|
loadedEdgesType2.addAll(pageData.getData()); |
|
|
loadedEdgesType2.addAll(pageData.getData()); |
|
|
if (pageData.hasNext()) { |
|
|
if (pageData.hasNext()) { |
|
|
@ -572,7 +575,7 @@ public class EdgeControllerTest extends AbstractControllerTest { |
|
|
|
|
|
|
|
|
pageLink = new PageLink(4); |
|
|
pageLink = new PageLink(4); |
|
|
pageData = doGetTypedWithPageLink("/api/tenant/edges?type={type}&", |
|
|
pageData = doGetTypedWithPageLink("/api/tenant/edges?type={type}&", |
|
|
new TypeReference<PageData<Edge>>() { |
|
|
new TypeReference<>() { |
|
|
}, pageLink, type1); |
|
|
}, pageLink, type1); |
|
|
Assert.assertFalse(pageData.hasNext()); |
|
|
Assert.assertFalse(pageData.hasNext()); |
|
|
Assert.assertEquals(0, pageData.getData().size()); |
|
|
Assert.assertEquals(0, pageData.getData().size()); |
|
|
@ -584,7 +587,7 @@ public class EdgeControllerTest extends AbstractControllerTest { |
|
|
|
|
|
|
|
|
pageLink = new PageLink(4); |
|
|
pageLink = new PageLink(4); |
|
|
pageData = doGetTypedWithPageLink("/api/tenant/edges?type={type}&", |
|
|
pageData = doGetTypedWithPageLink("/api/tenant/edges?type={type}&", |
|
|
new TypeReference<PageData<Edge>>() { |
|
|
new TypeReference<>() { |
|
|
}, pageLink, type2); |
|
|
}, pageLink, type2); |
|
|
Assert.assertFalse(pageData.hasNext()); |
|
|
Assert.assertFalse(pageData.hasNext()); |
|
|
Assert.assertEquals(0, pageData.getData().size()); |
|
|
Assert.assertEquals(0, pageData.getData().size()); |
|
|
@ -613,15 +616,14 @@ public class EdgeControllerTest extends AbstractControllerTest { |
|
|
|
|
|
|
|
|
testNotifyManyEntityManyTimeMsgToEdgeServiceEntityEqAny(new Edge(), new Edge(), |
|
|
testNotifyManyEntityManyTimeMsgToEdgeServiceEntityEqAny(new Edge(), new Edge(), |
|
|
tenantId, customerId, tenantAdminUser.getId(), tenantAdminUser.getEmail(), |
|
|
tenantId, customerId, tenantAdminUser.getId(), tenantAdminUser.getEmail(), |
|
|
ActionType.ASSIGNED_TO_CUSTOMER, cntEntity, cntEntity, cntEntity * 2, |
|
|
ActionType.ASSIGNED_TO_CUSTOMER, cntEntity, cntEntity, cntEntity * 2, "", "", ""); |
|
|
new String(), new String(), new String()); |
|
|
|
|
|
|
|
|
|
|
|
List<Edge> loadedEdges = new ArrayList<>(); |
|
|
List<Edge> loadedEdges = new ArrayList<>(); |
|
|
PageLink pageLink = new PageLink(23); |
|
|
PageLink pageLink = new PageLink(23); |
|
|
PageData<Edge> pageData = null; |
|
|
PageData<Edge> pageData = null; |
|
|
do { |
|
|
do { |
|
|
pageData = doGetTypedWithPageLink("/api/customer/" + customerId.getId().toString() + "/edges?", |
|
|
pageData = doGetTypedWithPageLink("/api/customer/" + customerId.getId().toString() + "/edges?", |
|
|
new TypeReference<PageData<Edge>>() { |
|
|
new TypeReference<>() { |
|
|
}, pageLink); |
|
|
}, pageLink); |
|
|
loadedEdges.addAll(pageData.getData()); |
|
|
loadedEdges.addAll(pageData.getData()); |
|
|
if (pageData.hasNext()) { |
|
|
if (pageData.hasNext()) { |
|
|
@ -679,7 +681,7 @@ public class EdgeControllerTest extends AbstractControllerTest { |
|
|
PageData<Edge> pageData = null; |
|
|
PageData<Edge> pageData = null; |
|
|
do { |
|
|
do { |
|
|
pageData = doGetTypedWithPageLink("/api/customer/" + customerId.getId().toString() + "/edges?", |
|
|
pageData = doGetTypedWithPageLink("/api/customer/" + customerId.getId().toString() + "/edges?", |
|
|
new TypeReference<PageData<Edge>>() { |
|
|
new TypeReference<>() { |
|
|
}, pageLink); |
|
|
}, pageLink); |
|
|
loadedEdgesTitle1.addAll(pageData.getData()); |
|
|
loadedEdgesTitle1.addAll(pageData.getData()); |
|
|
if (pageData.hasNext()) { |
|
|
if (pageData.hasNext()) { |
|
|
@ -696,7 +698,7 @@ public class EdgeControllerTest extends AbstractControllerTest { |
|
|
pageLink = new PageLink(4, 0, title2); |
|
|
pageLink = new PageLink(4, 0, title2); |
|
|
do { |
|
|
do { |
|
|
pageData = doGetTypedWithPageLink("/api/customer/" + customerId.getId().toString() + "/edges?", |
|
|
pageData = doGetTypedWithPageLink("/api/customer/" + customerId.getId().toString() + "/edges?", |
|
|
new TypeReference<PageData<Edge>>() { |
|
|
new TypeReference<>() { |
|
|
}, pageLink); |
|
|
}, pageLink); |
|
|
loadedEdgesTitle2.addAll(pageData.getData()); |
|
|
loadedEdgesTitle2.addAll(pageData.getData()); |
|
|
if (pageData.hasNext()) { |
|
|
if (pageData.hasNext()) { |
|
|
@ -723,7 +725,7 @@ public class EdgeControllerTest extends AbstractControllerTest { |
|
|
|
|
|
|
|
|
pageLink = new PageLink(4, 0, title1); |
|
|
pageLink = new PageLink(4, 0, title1); |
|
|
pageData = doGetTypedWithPageLink("/api/customer/" + customerId.getId().toString() + "/edges?", |
|
|
pageData = doGetTypedWithPageLink("/api/customer/" + customerId.getId().toString() + "/edges?", |
|
|
new TypeReference<PageData<Edge>>() { |
|
|
new TypeReference<>() { |
|
|
}, pageLink); |
|
|
}, pageLink); |
|
|
Assert.assertFalse(pageData.hasNext()); |
|
|
Assert.assertFalse(pageData.hasNext()); |
|
|
Assert.assertEquals(0, pageData.getData().size()); |
|
|
Assert.assertEquals(0, pageData.getData().size()); |
|
|
@ -735,7 +737,7 @@ public class EdgeControllerTest extends AbstractControllerTest { |
|
|
|
|
|
|
|
|
pageLink = new PageLink(4, 0, title2); |
|
|
pageLink = new PageLink(4, 0, title2); |
|
|
pageData = doGetTypedWithPageLink("/api/customer/" + customerId.getId().toString() + "/edges?", |
|
|
pageData = doGetTypedWithPageLink("/api/customer/" + customerId.getId().toString() + "/edges?", |
|
|
new TypeReference<PageData<Edge>>() { |
|
|
new TypeReference<>() { |
|
|
}, pageLink); |
|
|
}, pageLink); |
|
|
Assert.assertFalse(pageData.hasNext()); |
|
|
Assert.assertFalse(pageData.hasNext()); |
|
|
Assert.assertEquals(0, pageData.getData().size()); |
|
|
Assert.assertEquals(0, pageData.getData().size()); |
|
|
@ -784,10 +786,10 @@ public class EdgeControllerTest extends AbstractControllerTest { |
|
|
|
|
|
|
|
|
List<Edge> loadedEdgesType1 = new ArrayList<>(); |
|
|
List<Edge> loadedEdgesType1 = new ArrayList<>(); |
|
|
PageLink pageLink = new PageLink(15, 0, title1); |
|
|
PageLink pageLink = new PageLink(15, 0, title1); |
|
|
PageData<Edge> pageData = null; |
|
|
PageData<Edge> pageData; |
|
|
do { |
|
|
do { |
|
|
pageData = doGetTypedWithPageLink("/api/customer/" + customerId.getId().toString() + "/edges?type={type}&", |
|
|
pageData = doGetTypedWithPageLink("/api/customer/" + customerId.getId().toString() + "/edges?type={type}&", |
|
|
new TypeReference<PageData<Edge>>() { |
|
|
new TypeReference<>() { |
|
|
}, pageLink, type1); |
|
|
}, pageLink, type1); |
|
|
loadedEdgesType1.addAll(pageData.getData()); |
|
|
loadedEdgesType1.addAll(pageData.getData()); |
|
|
if (pageData.hasNext()) { |
|
|
if (pageData.hasNext()) { |
|
|
@ -804,7 +806,7 @@ public class EdgeControllerTest extends AbstractControllerTest { |
|
|
pageLink = new PageLink(4, 0, title2); |
|
|
pageLink = new PageLink(4, 0, title2); |
|
|
do { |
|
|
do { |
|
|
pageData = doGetTypedWithPageLink("/api/customer/" + customerId.getId().toString() + "/edges?type={type}&", |
|
|
pageData = doGetTypedWithPageLink("/api/customer/" + customerId.getId().toString() + "/edges?type={type}&", |
|
|
new TypeReference<PageData<Edge>>() { |
|
|
new TypeReference<>() { |
|
|
}, pageLink, type2); |
|
|
}, pageLink, type2); |
|
|
loadedEdgesType2.addAll(pageData.getData()); |
|
|
loadedEdgesType2.addAll(pageData.getData()); |
|
|
if (pageData.hasNext()) { |
|
|
if (pageData.hasNext()) { |
|
|
@ -824,7 +826,7 @@ public class EdgeControllerTest extends AbstractControllerTest { |
|
|
|
|
|
|
|
|
pageLink = new PageLink(4, 0, title1); |
|
|
pageLink = new PageLink(4, 0, title1); |
|
|
pageData = doGetTypedWithPageLink("/api/customer/" + customerId.getId().toString() + "/edges?type={type}&", |
|
|
pageData = doGetTypedWithPageLink("/api/customer/" + customerId.getId().toString() + "/edges?type={type}&", |
|
|
new TypeReference<PageData<Edge>>() { |
|
|
new TypeReference<>() { |
|
|
}, pageLink, type1); |
|
|
}, pageLink, type1); |
|
|
Assert.assertFalse(pageData.hasNext()); |
|
|
Assert.assertFalse(pageData.hasNext()); |
|
|
Assert.assertEquals(0, pageData.getData().size()); |
|
|
Assert.assertEquals(0, pageData.getData().size()); |
|
|
@ -836,7 +838,7 @@ public class EdgeControllerTest extends AbstractControllerTest { |
|
|
|
|
|
|
|
|
pageLink = new PageLink(4, 0, title2); |
|
|
pageLink = new PageLink(4, 0, title2); |
|
|
pageData = doGetTypedWithPageLink("/api/customer/" + customerId.getId().toString() + "/edges?type={type}&", |
|
|
pageData = doGetTypedWithPageLink("/api/customer/" + customerId.getId().toString() + "/edges?type={type}&", |
|
|
new TypeReference<PageData<Edge>>() { |
|
|
new TypeReference<>() { |
|
|
}, pageLink, type2); |
|
|
}, pageLink, type2); |
|
|
Assert.assertFalse(pageData.hasNext()); |
|
|
Assert.assertFalse(pageData.hasNext()); |
|
|
Assert.assertEquals(0, pageData.getData().size()); |
|
|
Assert.assertEquals(0, pageData.getData().size()); |
|
|
@ -936,8 +938,9 @@ public class EdgeControllerTest extends AbstractControllerTest { |
|
|
for (AbstractMessage message : messages) { |
|
|
for (AbstractMessage message : messages) { |
|
|
if (message instanceof QueueUpdateMsg) { |
|
|
if (message instanceof QueueUpdateMsg) { |
|
|
QueueUpdateMsg queueUpdateMsg = (QueueUpdateMsg) message; |
|
|
QueueUpdateMsg queueUpdateMsg = (QueueUpdateMsg) message; |
|
|
if (msgType.equals(queueUpdateMsg.getMsgType()) |
|
|
Queue queue = JacksonUtil.fromStringIgnoreUnknownProperties(queueUpdateMsg.getEntity(), Queue.class); |
|
|
&& name.equals(queueUpdateMsg.getName())) { |
|
|
Assert.assertNotNull(queue); |
|
|
|
|
|
if (msgType.equals(queueUpdateMsg.getMsgType()) && name.equals(queue.getName())) { |
|
|
messages.remove(message); |
|
|
messages.remove(message); |
|
|
return true; |
|
|
return true; |
|
|
} |
|
|
} |
|
|
@ -950,9 +953,11 @@ public class EdgeControllerTest extends AbstractControllerTest { |
|
|
for (AbstractMessage message : messages) { |
|
|
for (AbstractMessage message : messages) { |
|
|
if (message instanceof RuleChainUpdateMsg) { |
|
|
if (message instanceof RuleChainUpdateMsg) { |
|
|
RuleChainUpdateMsg ruleChainUpdateMsg = (RuleChainUpdateMsg) message; |
|
|
RuleChainUpdateMsg ruleChainUpdateMsg = (RuleChainUpdateMsg) message; |
|
|
|
|
|
RuleChain ruleChain = JacksonUtil.fromStringIgnoreUnknownProperties(ruleChainUpdateMsg.getEntity(), RuleChain.class); |
|
|
|
|
|
Assert.assertNotNull(ruleChain); |
|
|
if (msgType.equals(ruleChainUpdateMsg.getMsgType()) |
|
|
if (msgType.equals(ruleChainUpdateMsg.getMsgType()) |
|
|
&& name.equals(ruleChainUpdateMsg.getName()) |
|
|
&& name.equals(ruleChain.getName()) |
|
|
&& ruleChainUpdateMsg.getRoot()) { |
|
|
&& ruleChain.isRoot()) { |
|
|
messages.remove(message); |
|
|
messages.remove(message); |
|
|
return true; |
|
|
return true; |
|
|
} |
|
|
} |
|
|
@ -965,7 +970,9 @@ public class EdgeControllerTest extends AbstractControllerTest { |
|
|
for (AbstractMessage message : messages) { |
|
|
for (AbstractMessage message : messages) { |
|
|
if (message instanceof AdminSettingsUpdateMsg) { |
|
|
if (message instanceof AdminSettingsUpdateMsg) { |
|
|
AdminSettingsUpdateMsg adminSettingsUpdateMsg = (AdminSettingsUpdateMsg) message; |
|
|
AdminSettingsUpdateMsg adminSettingsUpdateMsg = (AdminSettingsUpdateMsg) message; |
|
|
if (key.equals(adminSettingsUpdateMsg.getKey())) { |
|
|
AdminSettings adminSettings = JacksonUtil.fromStringIgnoreUnknownProperties(adminSettingsUpdateMsg.getEntity(), AdminSettings.class); |
|
|
|
|
|
Assert.assertNotNull(adminSettings); |
|
|
|
|
|
if (key.equals(adminSettings.getKey())) { |
|
|
messages.remove(message); |
|
|
messages.remove(message); |
|
|
return true; |
|
|
return true; |
|
|
} |
|
|
} |
|
|
@ -978,8 +985,10 @@ public class EdgeControllerTest extends AbstractControllerTest { |
|
|
for (AbstractMessage message : messages) { |
|
|
for (AbstractMessage message : messages) { |
|
|
if (message instanceof DeviceProfileUpdateMsg) { |
|
|
if (message instanceof DeviceProfileUpdateMsg) { |
|
|
DeviceProfileUpdateMsg deviceProfileUpdateMsg = (DeviceProfileUpdateMsg) message; |
|
|
DeviceProfileUpdateMsg deviceProfileUpdateMsg = (DeviceProfileUpdateMsg) message; |
|
|
|
|
|
DeviceProfile deviceProfile = JacksonUtil.fromStringIgnoreUnknownProperties(deviceProfileUpdateMsg.getEntity(), DeviceProfile.class); |
|
|
|
|
|
Assert.assertNotNull(deviceProfile); |
|
|
if (msgType.equals(deviceProfileUpdateMsg.getMsgType()) |
|
|
if (msgType.equals(deviceProfileUpdateMsg.getMsgType()) |
|
|
&& name.equals(deviceProfileUpdateMsg.getName())) { |
|
|
&& name.equals(deviceProfile.getName())) { |
|
|
messages.remove(message); |
|
|
messages.remove(message); |
|
|
return true; |
|
|
return true; |
|
|
} |
|
|
} |
|
|
@ -992,8 +1001,10 @@ public class EdgeControllerTest extends AbstractControllerTest { |
|
|
for (AbstractMessage message : messages) { |
|
|
for (AbstractMessage message : messages) { |
|
|
if (message instanceof DeviceUpdateMsg) { |
|
|
if (message instanceof DeviceUpdateMsg) { |
|
|
DeviceUpdateMsg deviceUpdateMsg = (DeviceUpdateMsg) message; |
|
|
DeviceUpdateMsg deviceUpdateMsg = (DeviceUpdateMsg) message; |
|
|
|
|
|
Device device = JacksonUtil.fromStringIgnoreUnknownProperties(deviceUpdateMsg.getEntity(), Device.class); |
|
|
|
|
|
Assert.assertNotNull(device); |
|
|
if (msgType.equals(deviceUpdateMsg.getMsgType()) |
|
|
if (msgType.equals(deviceUpdateMsg.getMsgType()) |
|
|
&& name.equals(deviceUpdateMsg.getName())) { |
|
|
&& name.equals(device.getName())) { |
|
|
messages.remove(message); |
|
|
messages.remove(message); |
|
|
return true; |
|
|
return true; |
|
|
} |
|
|
} |
|
|
@ -1006,8 +1017,10 @@ public class EdgeControllerTest extends AbstractControllerTest { |
|
|
for (AbstractMessage message : messages) { |
|
|
for (AbstractMessage message : messages) { |
|
|
if (message instanceof AssetProfileUpdateMsg) { |
|
|
if (message instanceof AssetProfileUpdateMsg) { |
|
|
AssetProfileUpdateMsg assetProfileUpdateMsg = (AssetProfileUpdateMsg) message; |
|
|
AssetProfileUpdateMsg assetProfileUpdateMsg = (AssetProfileUpdateMsg) message; |
|
|
|
|
|
AssetProfile assetProfile = JacksonUtil.fromStringIgnoreUnknownProperties(assetProfileUpdateMsg.getEntity(), AssetProfile.class); |
|
|
|
|
|
Assert.assertNotNull(assetProfile); |
|
|
if (msgType.equals(assetProfileUpdateMsg.getMsgType()) |
|
|
if (msgType.equals(assetProfileUpdateMsg.getMsgType()) |
|
|
&& name.equals(assetProfileUpdateMsg.getName())) { |
|
|
&& name.equals(assetProfile.getName())) { |
|
|
messages.remove(message); |
|
|
messages.remove(message); |
|
|
return true; |
|
|
return true; |
|
|
} |
|
|
} |
|
|
@ -1020,8 +1033,10 @@ public class EdgeControllerTest extends AbstractControllerTest { |
|
|
for (AbstractMessage message : messages) { |
|
|
for (AbstractMessage message : messages) { |
|
|
if (message instanceof AssetUpdateMsg) { |
|
|
if (message instanceof AssetUpdateMsg) { |
|
|
AssetUpdateMsg assetUpdateMsg = (AssetUpdateMsg) message; |
|
|
AssetUpdateMsg assetUpdateMsg = (AssetUpdateMsg) message; |
|
|
|
|
|
Asset asset = JacksonUtil.fromStringIgnoreUnknownProperties(assetUpdateMsg.getEntity(), Asset.class); |
|
|
|
|
|
Assert.assertNotNull(asset); |
|
|
if (msgType.equals(assetUpdateMsg.getMsgType()) |
|
|
if (msgType.equals(assetUpdateMsg.getMsgType()) |
|
|
&& name.equals(assetUpdateMsg.getName())) { |
|
|
&& name.equals(asset.getName())) { |
|
|
messages.remove(message); |
|
|
messages.remove(message); |
|
|
return true; |
|
|
return true; |
|
|
} |
|
|
} |
|
|
@ -1034,9 +1049,11 @@ public class EdgeControllerTest extends AbstractControllerTest { |
|
|
for (AbstractMessage message : messages) { |
|
|
for (AbstractMessage message : messages) { |
|
|
if (message instanceof UserUpdateMsg) { |
|
|
if (message instanceof UserUpdateMsg) { |
|
|
UserUpdateMsg userUpdateMsg = (UserUpdateMsg) message; |
|
|
UserUpdateMsg userUpdateMsg = (UserUpdateMsg) message; |
|
|
|
|
|
User user = JacksonUtil.fromStringIgnoreUnknownProperties(userUpdateMsg.getEntity(), User.class); |
|
|
|
|
|
Assert.assertNotNull(user); |
|
|
if (msgType.equals(userUpdateMsg.getMsgType()) |
|
|
if (msgType.equals(userUpdateMsg.getMsgType()) |
|
|
&& email.equals(userUpdateMsg.getEmail()) |
|
|
&& email.equals(user.getEmail()) |
|
|
&& authority.name().equals(userUpdateMsg.getAuthority())) { |
|
|
&& authority.equals(user.getAuthority())) { |
|
|
messages.remove(message); |
|
|
messages.remove(message); |
|
|
return true; |
|
|
return true; |
|
|
} |
|
|
} |
|
|
@ -1049,8 +1066,10 @@ public class EdgeControllerTest extends AbstractControllerTest { |
|
|
for (AbstractMessage message : messages) { |
|
|
for (AbstractMessage message : messages) { |
|
|
if (message instanceof CustomerUpdateMsg) { |
|
|
if (message instanceof CustomerUpdateMsg) { |
|
|
CustomerUpdateMsg customerUpdateMsg = (CustomerUpdateMsg) message; |
|
|
CustomerUpdateMsg customerUpdateMsg = (CustomerUpdateMsg) message; |
|
|
|
|
|
Customer customer = JacksonUtil.fromStringIgnoreUnknownProperties(customerUpdateMsg.getEntity(), Customer.class); |
|
|
|
|
|
Assert.assertNotNull(customer); |
|
|
if (msgType.equals(customerUpdateMsg.getMsgType()) |
|
|
if (msgType.equals(customerUpdateMsg.getMsgType()) |
|
|
&& title.equals(customerUpdateMsg.getTitle())) { |
|
|
&& title.equals(customer.getTitle())) { |
|
|
messages.remove(message); |
|
|
messages.remove(message); |
|
|
return true; |
|
|
return true; |
|
|
} |
|
|
} |
|
|
@ -1063,9 +1082,10 @@ public class EdgeControllerTest extends AbstractControllerTest { |
|
|
for (AbstractMessage message : messages) { |
|
|
for (AbstractMessage message : messages) { |
|
|
if (message instanceof TenantUpdateMsg) { |
|
|
if (message instanceof TenantUpdateMsg) { |
|
|
TenantUpdateMsg tenantUpdateMsg = (TenantUpdateMsg) message; |
|
|
TenantUpdateMsg tenantUpdateMsg = (TenantUpdateMsg) message; |
|
|
TenantId tenantIdMsg = new TenantId(new UUID(tenantUpdateMsg.getIdMSB(), tenantUpdateMsg.getIdLSB())); |
|
|
Tenant tenant = JacksonUtil.fromStringIgnoreUnknownProperties(tenantUpdateMsg.getEntity(), Tenant.class); |
|
|
|
|
|
Assert.assertNotNull(tenant); |
|
|
if (UpdateMsgType.ENTITY_UPDATED_RPC_MESSAGE.equals(tenantUpdateMsg.getMsgType()) |
|
|
if (UpdateMsgType.ENTITY_UPDATED_RPC_MESSAGE.equals(tenantUpdateMsg.getMsgType()) |
|
|
&& tenantId1.equals(tenantIdMsg)) { |
|
|
&& tenantId1.equals(tenant.getId())) { |
|
|
messages.remove(message); |
|
|
messages.remove(message); |
|
|
return true; |
|
|
return true; |
|
|
} |
|
|
} |
|
|
@ -1078,9 +1098,10 @@ public class EdgeControllerTest extends AbstractControllerTest { |
|
|
for (AbstractMessage message : messages) { |
|
|
for (AbstractMessage message : messages) { |
|
|
if (message instanceof TenantProfileUpdateMsg) { |
|
|
if (message instanceof TenantProfileUpdateMsg) { |
|
|
TenantProfileUpdateMsg tenantProfileUpdateMsg = (TenantProfileUpdateMsg) message; |
|
|
TenantProfileUpdateMsg tenantProfileUpdateMsg = (TenantProfileUpdateMsg) message; |
|
|
TenantProfileId tenantProfileIdMsg = new TenantProfileId(new UUID(tenantProfileUpdateMsg.getIdMSB(), tenantProfileUpdateMsg.getIdLSB())); |
|
|
TenantProfile tenantProfile = JacksonUtil.fromStringIgnoreUnknownProperties(tenantProfileUpdateMsg.getEntity(), TenantProfile.class); |
|
|
|
|
|
Assert.assertNotNull(tenantProfile); |
|
|
if (UpdateMsgType.ENTITY_UPDATED_RPC_MESSAGE.equals(tenantProfileUpdateMsg.getMsgType()) |
|
|
if (UpdateMsgType.ENTITY_UPDATED_RPC_MESSAGE.equals(tenantProfileUpdateMsg.getMsgType()) |
|
|
&& tenantProfileId.equals(tenantProfileIdMsg)) { |
|
|
&& tenantProfileId.equals(tenantProfile.getId())) { |
|
|
messages.remove(message); |
|
|
messages.remove(message); |
|
|
return true; |
|
|
return true; |
|
|
} |
|
|
} |
|
|
|