|
|
|
@ -104,7 +104,7 @@ public class TbResourceControllerTest extends AbstractControllerTest { |
|
|
|
resource.setFileName(DEFAULT_FILE_NAME); |
|
|
|
resource.setEncodedData(TEST_DATA); |
|
|
|
|
|
|
|
TbResource savedResource = save(resource); |
|
|
|
TbResourceInfo savedResource = save(resource); |
|
|
|
|
|
|
|
testNotifyEntityAllOneTimeLogEntityActionEntityEqClass(savedResource, savedResource.getId(), savedResource.getId(), |
|
|
|
savedTenant.getId(), tenantAdmin.getCustomerId(), tenantAdmin.getId(), tenantAdmin.getEmail(), |
|
|
|
@ -119,15 +119,15 @@ public class TbResourceControllerTest extends AbstractControllerTest { |
|
|
|
Assert.assertEquals(DEFAULT_FILE_NAME, savedResource.getResourceKey()); |
|
|
|
Assert.assertArrayEquals(resource.getData(), download(savedResource.getId())); |
|
|
|
|
|
|
|
savedResource.setTitle("My new resource"); |
|
|
|
savedResource.setData(null); |
|
|
|
TbResource foundResource = doGet("/api/resource/" + savedResource.getId().getId().toString(), TbResource.class); |
|
|
|
foundResource.setTitle("My new resource"); |
|
|
|
foundResource.setData(null); |
|
|
|
|
|
|
|
save(savedResource); |
|
|
|
savedResource = save(foundResource); |
|
|
|
|
|
|
|
TbResource foundResource = doGet("/api/resource/" + savedResource.getId().getId().toString(), TbResource.class); |
|
|
|
Assert.assertEquals(foundResource.getTitle(), savedResource.getTitle()); |
|
|
|
|
|
|
|
testNotifyEntityAllOneTimeLogEntityActionEntityEqClass(foundResource, foundResource.getId(), foundResource.getId(), |
|
|
|
testNotifyEntityAllOneTimeLogEntityActionEntityEqClass(savedResource, savedResource.getId(), savedResource.getId(), |
|
|
|
savedTenant.getId(), tenantAdmin.getCustomerId(), tenantAdmin.getId(), tenantAdmin.getEmail(), |
|
|
|
ActionType.UPDATED, ActionType.UPDATED); |
|
|
|
} |
|
|
|
@ -147,7 +147,7 @@ public class TbResourceControllerTest extends AbstractControllerTest { |
|
|
|
.andExpect(status().isBadRequest()) |
|
|
|
.andExpect(statusReason(containsString(msgError))); |
|
|
|
|
|
|
|
testNotifyEntityEqualsOneTimeServiceNeverError(resource, savedTenant.getId(), |
|
|
|
testNotifyEntityEqualsOneTimeServiceNeverError(new TbResourceInfo(resource), savedTenant.getId(), |
|
|
|
tenantAdmin.getId(), tenantAdmin.getEmail(), ActionType.ADDED, new DataValidationException(msgError)); |
|
|
|
} |
|
|
|
|
|
|
|
@ -159,7 +159,7 @@ public class TbResourceControllerTest extends AbstractControllerTest { |
|
|
|
resource.setFileName(DEFAULT_FILE_NAME); |
|
|
|
resource.setEncodedData(TEST_DATA); |
|
|
|
|
|
|
|
TbResource savedResource = save(resource); |
|
|
|
TbResourceInfo savedResource = save(resource); |
|
|
|
|
|
|
|
loginDifferentTenant(); |
|
|
|
|
|
|
|
@ -188,7 +188,7 @@ public class TbResourceControllerTest extends AbstractControllerTest { |
|
|
|
resource.setFileName(DEFAULT_FILE_NAME); |
|
|
|
resource.setEncodedData(TEST_DATA); |
|
|
|
|
|
|
|
TbResource savedResource = save(resource); |
|
|
|
TbResourceInfo savedResource = save(resource); |
|
|
|
|
|
|
|
TbResource foundResource = doGet("/api/resource/" + savedResource.getUuidId(), TbResource.class); |
|
|
|
Assert.assertNotNull(foundResource); |
|
|
|
@ -204,7 +204,7 @@ public class TbResourceControllerTest extends AbstractControllerTest { |
|
|
|
resource.setFileName(DEFAULT_FILE_NAME); |
|
|
|
resource.setEncodedData(TEST_DATA); |
|
|
|
|
|
|
|
TbResource savedResource = save(resource); |
|
|
|
TbResourceInfo savedResource = save(resource); |
|
|
|
|
|
|
|
Mockito.reset(tbClusterService, auditLogService); |
|
|
|
String resourceIdStr = savedResource.getId().getId().toString(); |
|
|
|
@ -229,7 +229,7 @@ public class TbResourceControllerTest extends AbstractControllerTest { |
|
|
|
resource.setFileName(DEFAULT_FILE_NAME); |
|
|
|
resource.setEncodedData(TEST_DATA); |
|
|
|
|
|
|
|
TbResource savedResource = save(resource); |
|
|
|
TbResourceInfo savedResource = save(resource); |
|
|
|
|
|
|
|
Mockito.reset(tbClusterService, auditLogService); |
|
|
|
String resourceIdStr = savedResource.getId().getId().toString(); |
|
|
|
@ -274,7 +274,7 @@ public class TbResourceControllerTest extends AbstractControllerTest { |
|
|
|
} |
|
|
|
} while (pageData.hasNext()); |
|
|
|
|
|
|
|
testNotifyManyEntityManyTimeMsgToEdgeServiceEntityEqAny(new TbResource(), new TbResource(), |
|
|
|
testNotifyManyEntityManyTimeMsgToEdgeServiceEntityEqAny(new TbResourceInfo(), new TbResourceInfo(), |
|
|
|
savedTenant.getId(), tenantAdmin.getCustomerId(), tenantAdmin.getId(), tenantAdmin.getEmail(), |
|
|
|
ActionType.ADDED, cntEntity, cntEntity, cntEntity); |
|
|
|
|
|
|
|
@ -322,7 +322,7 @@ public class TbResourceControllerTest extends AbstractControllerTest { |
|
|
|
} |
|
|
|
} while (pageData.hasNext()); |
|
|
|
|
|
|
|
testNotifyManyEntityManyTimeMsgToEdgeServiceEntityEqAny(new TbResource(), new TbResource(), |
|
|
|
testNotifyManyEntityManyTimeMsgToEdgeServiceEntityEqAny(new TbResourceInfo(), new TbResourceInfo(), |
|
|
|
savedTenant.getId(), tenantAdmin.getCustomerId(), tenantAdmin.getId(), tenantAdmin.getEmail(), ActionType.ADDED, |
|
|
|
jksCntEntity + lwm2mCntEntity, jksCntEntity + lwm2mCntEntity, jksCntEntity + lwm2mCntEntity); |
|
|
|
|
|
|
|
@ -414,7 +414,7 @@ public class TbResourceControllerTest extends AbstractControllerTest { |
|
|
|
resource.setResourceType(ResourceType.PKCS_12); |
|
|
|
resource.setFileName(i + DEFAULT_FILE_NAME_2); |
|
|
|
resource.setEncodedData(TEST_DATA); |
|
|
|
TbResource saved = save(resource); |
|
|
|
TbResourceInfo saved = save(resource); |
|
|
|
lwm2mesources.add(saved); |
|
|
|
} |
|
|
|
|
|
|
|
@ -536,7 +536,7 @@ public class TbResourceControllerTest extends AbstractControllerTest { |
|
|
|
resource.setFileName(JS_TEST_FILE_NAME); |
|
|
|
resource.setEncodedData(TEST_DATA); |
|
|
|
|
|
|
|
TbResource savedResource = save(resource); |
|
|
|
TbResourceInfo savedResource = save(resource); |
|
|
|
|
|
|
|
testNotifyEntityAllOneTimeLogEntityActionEntityEqClass(savedResource, savedResource.getId(), savedResource.getId(), |
|
|
|
savedTenant.getId(), tenantAdmin.getCustomerId(), tenantAdmin.getId(), tenantAdmin.getEmail(), |
|
|
|
@ -567,7 +567,7 @@ public class TbResourceControllerTest extends AbstractControllerTest { |
|
|
|
resource.setFileName(JS_TEST_FILE_NAME); |
|
|
|
resource.setEncodedData(TEST_DATA); |
|
|
|
|
|
|
|
TbResource savedResource = save(resource); |
|
|
|
TbResourceInfo savedResource = save(resource); |
|
|
|
|
|
|
|
//download as public customer
|
|
|
|
Device device = new Device(); |
|
|
|
@ -611,7 +611,7 @@ public class TbResourceControllerTest extends AbstractControllerTest { |
|
|
|
resource.setFileName(JS_TEST_FILE_NAME); |
|
|
|
resource.setEncodedData(TEST_DATA); |
|
|
|
|
|
|
|
TbResource savedResource = save(resource); |
|
|
|
TbResourceInfo savedResource = save(resource); |
|
|
|
|
|
|
|
loginDifferentTenant(); |
|
|
|
loginDifferentTenantCustomer(); |
|
|
|
@ -626,17 +626,19 @@ public class TbResourceControllerTest extends AbstractControllerTest { |
|
|
|
resource.setTitle("My resource"); |
|
|
|
resource.setFileName("3.pks"); |
|
|
|
resource.setEncodedData(TEST_DATA); |
|
|
|
TbResource savedResource = save(resource); |
|
|
|
TbResourceInfo savedResource = save(resource); |
|
|
|
resource.setEtag(savedResource.getEtag()); |
|
|
|
|
|
|
|
savedResource.setEncodedData(TEST_DATA); |
|
|
|
doPost("/api/resource", savedResource) |
|
|
|
TbResource foundResource = doGet("/api/resource/" + savedResource.getUuidId(), TbResource.class); |
|
|
|
|
|
|
|
foundResource.setEncodedData(TEST_DATA); |
|
|
|
doPost("/api/resource", foundResource) |
|
|
|
.andExpect(status().isBadRequest()) |
|
|
|
.andExpect(statusReason(containsString("can't be updated"))); |
|
|
|
|
|
|
|
savedResource.setData(null); |
|
|
|
savedResource.setTitle("Updated resource"); |
|
|
|
savedResource = doPost("/api/resource", savedResource, TbResource.class); |
|
|
|
foundResource.setData(null); |
|
|
|
foundResource.setTitle("Updated resource"); |
|
|
|
savedResource = doPost("/api/resource", foundResource, TbResource.class); |
|
|
|
assertThat(savedResource.getTitle()).isEqualTo("Updated resource"); |
|
|
|
assertThat(savedResource.getFileName()).isEqualTo(resource.getFileName()); |
|
|
|
assertThat(savedResource.getEtag()).isEqualTo(resource.getEtag()); |
|
|
|
@ -650,14 +652,16 @@ public class TbResourceControllerTest extends AbstractControllerTest { |
|
|
|
resource.setTitle("My resource"); |
|
|
|
resource.setFileName("module.js"); |
|
|
|
resource.setEncodedData(TEST_DATA); |
|
|
|
TbResource savedResource = save(resource); |
|
|
|
resource.setEtag(savedResource.getEtag()); |
|
|
|
TbResourceInfo savedResource = save(resource); |
|
|
|
|
|
|
|
TbResource foundResource = doGet("/api/resource/" + savedResource.getUuidId(), TbResource.class); |
|
|
|
resource.setEtag(foundResource.getEtag()); |
|
|
|
|
|
|
|
String newData = Base64.getEncoder().encodeToString(new byte[]{1, 2, 3}); |
|
|
|
savedResource.setEncodedData(newData); |
|
|
|
savedResource.setFileName("new-module.js"); |
|
|
|
savedResource.setTitle("Updated title"); |
|
|
|
savedResource = save(savedResource); |
|
|
|
foundResource.setEncodedData(newData); |
|
|
|
foundResource.setFileName("new-module.js"); |
|
|
|
foundResource.setTitle("Updated title"); |
|
|
|
savedResource = save(foundResource); |
|
|
|
|
|
|
|
assertThat(savedResource.getTitle()).isEqualTo("Updated title"); |
|
|
|
assertThat(savedResource.getFileName()).isEqualTo("new-module.js"); |
|
|
|
@ -669,7 +673,7 @@ public class TbResourceControllerTest extends AbstractControllerTest { |
|
|
|
public void testGetLwm2mListObjectsPage() throws Exception { |
|
|
|
loginTenantAdmin(); |
|
|
|
|
|
|
|
List<TbResource> resources = loadLwm2mResources(); |
|
|
|
List<TbResourceInfo> resources = loadLwm2mResources(); |
|
|
|
|
|
|
|
List<LwM2mObject> objects = |
|
|
|
doGetTyped("/api/resource/lwm2m/page?pageSize=100&page=0", new TypeReference<>() {}); |
|
|
|
@ -683,7 +687,7 @@ public class TbResourceControllerTest extends AbstractControllerTest { |
|
|
|
public void testGetLwm2mListObjects() throws Exception { |
|
|
|
loginTenantAdmin(); |
|
|
|
|
|
|
|
List<TbResource> resources = loadLwm2mResources(); |
|
|
|
List<TbResourceInfo> resources = loadLwm2mResources(); |
|
|
|
|
|
|
|
List<LwM2mObject> objects = |
|
|
|
doGetTyped("/api/resource/lwm2m?sortProperty=id&sortOrder=ASC&objectIds=3_1.2,5_1.2,19_1.1", new TypeReference<>() {}); |
|
|
|
@ -693,7 +697,7 @@ public class TbResourceControllerTest extends AbstractControllerTest { |
|
|
|
removeLoadResources(resources); |
|
|
|
} |
|
|
|
|
|
|
|
private TbResource save(TbResource tbResource) throws Exception { |
|
|
|
private TbResourceInfo save(TbResource tbResource) throws Exception { |
|
|
|
return doPostWithTypedResponse("/api/resource", tbResource, new TypeReference<>() { |
|
|
|
}); |
|
|
|
} |
|
|
|
@ -709,10 +713,10 @@ public class TbResourceControllerTest extends AbstractControllerTest { |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
private List<TbResource> loadLwm2mResources() throws Exception { |
|
|
|
private List<TbResourceInfo> loadLwm2mResources() throws Exception { |
|
|
|
var models = List.of("1", "2", "3", "5", "6", "9", "19", "3303"); |
|
|
|
|
|
|
|
List<TbResource> resources = new ArrayList<>(models.size()); |
|
|
|
List<TbResourceInfo> resources = new ArrayList<>(models.size()); |
|
|
|
|
|
|
|
for (String model : models) { |
|
|
|
String fileName = model + ".xml"; |
|
|
|
@ -728,7 +732,7 @@ public class TbResourceControllerTest extends AbstractControllerTest { |
|
|
|
return resources; |
|
|
|
} |
|
|
|
|
|
|
|
private void removeLoadResources(List<TbResource> resources) throws Exception { |
|
|
|
private void removeLoadResources(List<TbResourceInfo> resources) throws Exception { |
|
|
|
for (TbResourceInfo resource : resources) { |
|
|
|
doDelete("/api/resource/" + resource.getId().getId().toString()) |
|
|
|
.andExpect(status().isOk()); |
|
|
|
|