Merge pull request #12939 from irynamatveieva/black-box-tests
Added black box tests for cf
This commit is contained in:
Viacheslav Klimov
GitHub
commit
881d47020f
@ -28,6 +28,7 @@ import io.restassured.internal.ValidatableResponseImpl;
|
||||
import io.restassured.path.json.JsonPath;
|
||||
import io.restassured.response.ValidatableResponse;
|
||||
import io.restassured.specification.RequestSpecification;
|
||||
import org.thingsboard.server.common.data.AttributeScope;
|
||||
import org.thingsboard.server.common.data.Customer;
|
||||
import org.thingsboard.server.common.data.Dashboard;
|
||||
import org.thingsboard.server.common.data.Device;
|
||||
@ -40,10 +41,12 @@ import org.thingsboard.server.common.data.User;
|
||||
import org.thingsboard.server.common.data.alarm.Alarm;
|
||||
import org.thingsboard.server.common.data.asset.Asset;
|
||||
import org.thingsboard.server.common.data.asset.AssetProfile;
|
||||
import org.thingsboard.server.common.data.cf.CalculatedField;
|
||||
import org.thingsboard.server.common.data.event.EventType;
|
||||
import org.thingsboard.server.common.data.id.AlarmId;
|
||||
import org.thingsboard.server.common.data.id.AssetId;
|
||||
import org.thingsboard.server.common.data.id.AssetProfileId;
|
||||
import org.thingsboard.server.common.data.id.CalculatedFieldId;
|
||||
import org.thingsboard.server.common.data.id.CustomerId;
|
||||
import org.thingsboard.server.common.data.id.DashboardId;
|
||||
import org.thingsboard.server.common.data.id.DeviceId;
|
||||
@ -146,6 +149,14 @@ public class TestRestClient {
|
||||
.as(ObjectNode.class);
|
||||
}
|
||||
|
||||
public CalculatedField postCalculatedField(CalculatedField calculatedField) {
|
||||
return given().spec(requestSpec).body(calculatedField)
|
||||
.post("/api/calculatedField")
|
||||
.then()
|
||||
.statusCode(HTTP_OK)
|
||||
.extract()
|
||||
.as(CalculatedField.class);
|
||||
}
|
||||
|
||||
public Device getDeviceByName(String deviceName) {
|
||||
return given().spec(requestSpec).pathParam("deviceName", deviceName)
|
||||
@ -212,9 +223,16 @@ public class TestRestClient {
|
||||
.statusCode(anyOf(is(HTTP_OK), is(HTTP_NOT_FOUND)));
|
||||
}
|
||||
|
||||
public ValidatableResponse postTelemetryAttribute(String entityType, DeviceId deviceId, String scope, JsonNode attribute) {
|
||||
public ValidatableResponse deleteCalculatedFieldIfExists(CalculatedFieldId calculatedFieldId) {
|
||||
return given().spec(requestSpec)
|
||||
.delete("/api/calculatedField/{calculatedFieldId}", calculatedFieldId.getId())
|
||||
.then()
|
||||
.statusCode(anyOf(is(HTTP_OK), is(HTTP_NOT_FOUND)));
|
||||
}
|
||||
|
||||
public ValidatableResponse postTelemetryAttribute(EntityId entityId, String scope, JsonNode attribute) {
|
||||
return given().spec(requestSpec).body(attribute)
|
||||
.post("/api/plugins/telemetry/{entityType}/{entityId}/attributes/{scope}", entityType, deviceId.getId(), scope)
|
||||
.post("/api/plugins/telemetry/{entityType}/{entityId}/attributes/{scope}", entityId.getEntityType(), entityId.getId(), scope)
|
||||
.then()
|
||||
.statusCode(HTTP_OK);
|
||||
}
|
||||
@ -237,6 +255,15 @@ public class TestRestClient {
|
||||
.as(JsonNode.class);
|
||||
}
|
||||
|
||||
public JsonNode getAttributes(EntityId entityId, AttributeScope scope, String keys) {
|
||||
return given().spec(requestSpec)
|
||||
.get("/api/plugins/telemetry/{entityType}/{entityId}/values/attributes/{scope}?keys={keys}", entityId.getEntityType(), entityId.getId(), scope, keys)
|
||||
.then()
|
||||
.statusCode(HTTP_OK)
|
||||
.extract()
|
||||
.as(JsonNode.class);
|
||||
}
|
||||
|
||||
public JsonNode getLatestTelemetry(EntityId entityId) {
|
||||
return given().spec(requestSpec)
|
||||
.get("/api/plugins/telemetry/" + entityId.getEntityType().name() + "/" + entityId.getId() + "/values/timeseries")
|
||||
@ -640,6 +667,7 @@ public class TestRestClient {
|
||||
.then()
|
||||
.statusCode(anyOf(is(HTTP_OK), is(HTTP_BAD_REQUEST)));
|
||||
}
|
||||
|
||||
public void deleteDeviceProfileIfExists(DeviceProfile deviceProfile) {
|
||||
given().spec(requestSpec)
|
||||
.delete("/api/deviceProfile/" + deviceProfile.getId().getId().toString())
|
||||
@ -653,11 +681,11 @@ public class TestRestClient {
|
||||
.get("/api/tenant/devices?deviceName={deviceName}")
|
||||
.then()
|
||||
.statusCode(anyOf(is(HTTP_OK), is(HTTP_NOT_FOUND)));
|
||||
if(((ValidatableResponseImpl) response).extract().response().getStatusCode()==HTTP_OK){
|
||||
return response.extract()
|
||||
if (((ValidatableResponseImpl) response).extract().response().getStatusCode() == HTTP_OK) {
|
||||
return response.extract()
|
||||
.as(Device.class);
|
||||
} else {
|
||||
return null;
|
||||
return null;
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
@ -0,0 +1,368 @@
|
||||
/**
|
||||
* Copyright © 2016-2025 The Thingsboard Authors
|
||||
*
|
||||
* Licensed under the Apache License, Version 2.0 (the "License");
|
||||
* you may not use this file except in compliance with the License.
|
||||
* You may obtain a copy of the License at
|
||||
*
|
||||
* http://www.apache.org/licenses/LICENSE-2.0
|
||||
*
|
||||
* Unless required by applicable law or agreed to in writing, software
|
||||
* distributed under the License is distributed on an "AS IS" BASIS,
|
||||
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
||||
* See the License for the specific language governing permissions and
|
||||
* limitations under the License.
|
||||
*/
|
||||
package org.thingsboard.server.msa.cf;
|
||||
|
||||
import com.fasterxml.jackson.databind.JsonNode;
|
||||
import org.testcontainers.shaded.org.apache.commons.lang3.RandomStringUtils;
|
||||
import org.testng.annotations.AfterClass;
|
||||
import org.testng.annotations.BeforeClass;
|
||||
import org.testng.annotations.BeforeMethod;
|
||||
import org.testng.annotations.Test;
|
||||
import org.thingsboard.common.util.JacksonUtil;
|
||||
import org.thingsboard.server.common.data.AttributeScope;
|
||||
import org.thingsboard.server.common.data.DataConstants;
|
||||
import org.thingsboard.server.common.data.Device;
|
||||
import org.thingsboard.server.common.data.DeviceProfile;
|
||||
import org.thingsboard.server.common.data.asset.Asset;
|
||||
import org.thingsboard.server.common.data.cf.CalculatedField;
|
||||
import org.thingsboard.server.common.data.cf.CalculatedFieldType;
|
||||
import org.thingsboard.server.common.data.cf.configuration.Argument;
|
||||
import org.thingsboard.server.common.data.cf.configuration.ArgumentType;
|
||||
import org.thingsboard.server.common.data.cf.configuration.Output;
|
||||
import org.thingsboard.server.common.data.cf.configuration.OutputType;
|
||||
import org.thingsboard.server.common.data.cf.configuration.ReferencedEntityKey;
|
||||
import org.thingsboard.server.common.data.cf.configuration.SimpleCalculatedFieldConfiguration;
|
||||
import org.thingsboard.server.common.data.debug.DebugSettings;
|
||||
import org.thingsboard.server.common.data.device.data.DefaultDeviceConfiguration;
|
||||
import org.thingsboard.server.common.data.device.data.DefaultDeviceTransportConfiguration;
|
||||
import org.thingsboard.server.common.data.device.data.DeviceData;
|
||||
import org.thingsboard.server.common.data.id.AssetProfileId;
|
||||
import org.thingsboard.server.common.data.id.DeviceProfileId;
|
||||
import org.thingsboard.server.common.data.id.EntityId;
|
||||
import org.thingsboard.server.common.data.id.TenantId;
|
||||
import org.thingsboard.server.common.data.id.UserId;
|
||||
import org.thingsboard.server.msa.AbstractContainerTest;
|
||||
import org.thingsboard.server.msa.ui.utils.EntityPrototypes;
|
||||
|
||||
import java.util.Map;
|
||||
import java.util.concurrent.TimeUnit;
|
||||
|
||||
import static org.assertj.core.api.Assertions.assertThat;
|
||||
import static org.awaitility.Awaitility.await;
|
||||
import static org.thingsboard.server.msa.ui.utils.EntityPrototypes.defaultAssetProfile;
|
||||
import static org.thingsboard.server.msa.ui.utils.EntityPrototypes.defaultDeviceProfile;
|
||||
import static org.thingsboard.server.msa.ui.utils.EntityPrototypes.defaultTenantAdmin;
|
||||
|
||||
public class CalculatedFieldTest extends AbstractContainerTest {
|
||||
|
||||
public final int TIMEOUT = 60;
|
||||
public final int POLL_INTERVAL = 1;
|
||||
|
||||
private final String deviceToken = "zmzURIVRsq3lvnTP2XBE";
|
||||
|
||||
private final String exampleScript = "var avgTemperature = temperature.mean(); // Get average temperature\n" +
|
||||
" var temperatureK = (avgTemperature - 32) * (5 / 9) + 273.15; // Convert Fahrenheit to Kelvin\n" +
|
||||
"\n" +
|
||||
" // Estimate air pressure based on altitude\n" +
|
||||
" var pressure = 101325 * Math.pow((1 - 2.25577e-5 * altitude), 5.25588);\n" +
|
||||
"\n" +
|
||||
" // Air density formula\n" +
|
||||
" var airDensity = pressure / (287.05 * temperatureK);\n" +
|
||||
"\n" +
|
||||
" return {\n" +
|
||||
" \"airDensity\": airDensity\n" +
|
||||
" };";
|
||||
|
||||
private TenantId tenantId;
|
||||
private UserId tenantAdminId;
|
||||
private DeviceProfileId deviceProfileId;
|
||||
private AssetProfileId assetProfileId;
|
||||
private Device device;
|
||||
private Asset asset;
|
||||
|
||||
@BeforeClass
|
||||
public void beforeClass() {
|
||||
testRestClient.login("sysadmin@thingsboard.org", "sysadmin");
|
||||
|
||||
tenantId = testRestClient.postTenant(EntityPrototypes.defaultTenantPrototype("Tenant")).getId();
|
||||
tenantAdminId = testRestClient.createUserAndLogin(defaultTenantAdmin(tenantId, "tenantAdmin@thingsboard.org"), "tenant");
|
||||
|
||||
deviceProfileId = testRestClient.postDeviceProfile(defaultDeviceProfile("Device Profile 1")).getId();
|
||||
device = testRestClient.postDevice(deviceToken, createDevice("Device 1", deviceProfileId));
|
||||
|
||||
assetProfileId = testRestClient.postAssetProfile(defaultAssetProfile("Asset Profile 1")).getId();
|
||||
asset = testRestClient.postAsset(createAsset("Asset 1", assetProfileId));
|
||||
|
||||
testRestClient.postTelemetry(deviceToken, JacksonUtil.toJsonNode("{\"temperature\":25}"));
|
||||
testRestClient.postTelemetryAttribute(device.getId(), DataConstants.SERVER_SCOPE, JacksonUtil.toJsonNode("{\"deviceTemperature\":40}"));
|
||||
|
||||
testRestClient.postTelemetry(deviceToken, JacksonUtil.toJsonNode("{\"temperatureInF\":72.32}"));
|
||||
testRestClient.postTelemetry(deviceToken, JacksonUtil.toJsonNode("{\"temperatureInF\":72.86}"));
|
||||
testRestClient.postTelemetry(deviceToken, JacksonUtil.toJsonNode("{\"temperatureInF\":73.58}"));
|
||||
|
||||
testRestClient.postTelemetryAttribute(asset.getId(), DataConstants.SERVER_SCOPE, JacksonUtil.toJsonNode("{\"altitude\":1035}"));
|
||||
}
|
||||
|
||||
@BeforeMethod
|
||||
public void beforeMethod() {
|
||||
testRestClient.login("sysadmin@thingsboard.org", "sysadmin");
|
||||
}
|
||||
|
||||
@AfterClass
|
||||
public void afterClass() {
|
||||
testRestClient.resetToken();
|
||||
testRestClient.login("sysadmin@thingsboard.org", "sysadmin");
|
||||
testRestClient.deleteTenant(tenantId);
|
||||
}
|
||||
|
||||
@Test
|
||||
public void testPerformInitialCalculationForSimpleType() {
|
||||
// login tenant admin
|
||||
testRestClient.getAndSetUserToken(tenantAdminId);
|
||||
|
||||
CalculatedField savedCalculatedField = createSimpleCalculatedField();
|
||||
|
||||
testRestClient.postTelemetry(deviceToken, JacksonUtil.toJsonNode("{\"temperature\":25}"));
|
||||
|
||||
await().alias("create CF -> perform initial calculation").atMost(TIMEOUT, TimeUnit.SECONDS)
|
||||
.pollInterval(POLL_INTERVAL, TimeUnit.SECONDS)
|
||||
.untilAsserted(() -> {
|
||||
JsonNode fahrenheitTemp = testRestClient.getLatestTelemetry(device.getId());
|
||||
assertThat(fahrenheitTemp).isNotNull();
|
||||
assertThat(fahrenheitTemp.get("fahrenheitTemp").get(0).get("value").asText()).isEqualTo("77.0");
|
||||
});
|
||||
|
||||
testRestClient.deleteCalculatedFieldIfExists(savedCalculatedField.getId());
|
||||
}
|
||||
|
||||
@Test
|
||||
public void testChangeConfigArgument() {
|
||||
// login tenant admin
|
||||
testRestClient.getAndSetUserToken(tenantAdminId);
|
||||
|
||||
CalculatedField savedCalculatedField = createSimpleCalculatedField();
|
||||
|
||||
Argument savedArgument = savedCalculatedField.getConfiguration().getArguments().get("T");
|
||||
savedArgument.setRefEntityKey(new ReferencedEntityKey("deviceTemperature", ArgumentType.ATTRIBUTE, AttributeScope.SERVER_SCOPE));
|
||||
testRestClient.postCalculatedField(savedCalculatedField);
|
||||
|
||||
await().alias("update CF argument -> perform calculation with new argument").atMost(TIMEOUT, TimeUnit.SECONDS)
|
||||
.pollInterval(POLL_INTERVAL, TimeUnit.SECONDS)
|
||||
.untilAsserted(() -> {
|
||||
JsonNode fahrenheitTemp = testRestClient.getLatestTelemetry(device.getId());
|
||||
assertThat(fahrenheitTemp).isNotNull();
|
||||
assertThat(fahrenheitTemp.get("fahrenheitTemp").get(0).get("value").asText()).isEqualTo("104.0");
|
||||
});
|
||||
|
||||
testRestClient.deleteCalculatedFieldIfExists(savedCalculatedField.getId());
|
||||
}
|
||||
|
||||
@Test
|
||||
public void testChangeConfigOutput() {
|
||||
// login tenant admin
|
||||
testRestClient.getAndSetUserToken(tenantAdminId);
|
||||
|
||||
CalculatedField savedCalculatedField = createSimpleCalculatedField();
|
||||
|
||||
Output savedOutput = savedCalculatedField.getConfiguration().getOutput();
|
||||
savedOutput.setType(OutputType.ATTRIBUTES);
|
||||
savedOutput.setScope(AttributeScope.SERVER_SCOPE);
|
||||
savedOutput.setName("temperatureF");
|
||||
testRestClient.postCalculatedField(savedCalculatedField);
|
||||
|
||||
await().alias("update CF output -> perform calculation with updated output").atMost(TIMEOUT, TimeUnit.SECONDS)
|
||||
.pollInterval(POLL_INTERVAL, TimeUnit.SECONDS)
|
||||
.untilAsserted(() -> {
|
||||
JsonNode temperatureF = testRestClient.getAttributes(device.getId(), AttributeScope.SERVER_SCOPE, "temperatureF");
|
||||
assertThat(temperatureF).isNotNull();
|
||||
assertThat(temperatureF.get(0).get("value").asText()).isEqualTo("77.0");
|
||||
});
|
||||
|
||||
testRestClient.deleteCalculatedFieldIfExists(savedCalculatedField.getId());
|
||||
}
|
||||
|
||||
@Test
|
||||
public void testChangeConfigExpression() {
|
||||
// login tenant admin
|
||||
testRestClient.getAndSetUserToken(tenantAdminId);
|
||||
|
||||
CalculatedField savedCalculatedField = createSimpleCalculatedField();
|
||||
|
||||
savedCalculatedField.setName("F to C");
|
||||
savedCalculatedField.getConfiguration().setExpression("(T - 32) / 1.8");
|
||||
testRestClient.postCalculatedField(savedCalculatedField);
|
||||
|
||||
await().alias("update CF expression -> perform calculation with new expression").atMost(TIMEOUT, TimeUnit.SECONDS)
|
||||
.pollInterval(POLL_INTERVAL, TimeUnit.SECONDS)
|
||||
.untilAsserted(() -> {
|
||||
JsonNode fahrenheitTemp = testRestClient.getLatestTelemetry(device.getId());
|
||||
assertThat(fahrenheitTemp).isNotNull();
|
||||
assertThat(fahrenheitTemp.get("fahrenheitTemp").get(0).get("value").asText()).isEqualTo("-3.89");
|
||||
});
|
||||
|
||||
testRestClient.deleteCalculatedFieldIfExists(savedCalculatedField.getId());
|
||||
}
|
||||
|
||||
@Test
|
||||
public void testTelemetryUpdated() {
|
||||
// login tenant admin
|
||||
testRestClient.getAndSetUserToken(tenantAdminId);
|
||||
|
||||
CalculatedField savedCalculatedField = createSimpleCalculatedField();
|
||||
|
||||
testRestClient.postTelemetry(deviceToken, JacksonUtil.toJsonNode("{\"temperature\":30}"));
|
||||
|
||||
await().alias("update telemetry -> recalculate state").atMost(TIMEOUT, TimeUnit.SECONDS)
|
||||
.pollInterval(POLL_INTERVAL, TimeUnit.SECONDS)
|
||||
.untilAsserted(() -> {
|
||||
JsonNode fahrenheitTemp = testRestClient.getLatestTelemetry(device.getId());
|
||||
assertThat(fahrenheitTemp).isNotNull();
|
||||
assertThat(fahrenheitTemp.get("fahrenheitTemp").get(0).get("value").asText()).isEqualTo("86.0");
|
||||
});
|
||||
|
||||
testRestClient.deleteCalculatedFieldIfExists(savedCalculatedField.getId());
|
||||
}
|
||||
|
||||
@Test
|
||||
public void testEntityIdIsProfile() {
|
||||
// login tenant admin
|
||||
testRestClient.getAndSetUserToken(tenantAdminId);
|
||||
|
||||
CalculatedField savedCalculatedField = createSimpleCalculatedField(deviceProfileId);
|
||||
|
||||
await().alias("create CF -> perform initial calculation for device by profile").atMost(TIMEOUT, TimeUnit.SECONDS)
|
||||
.pollInterval(POLL_INTERVAL, TimeUnit.SECONDS)
|
||||
.untilAsserted(() -> {
|
||||
JsonNode fahrenheitTemp = testRestClient.getLatestTelemetry(device.getId());
|
||||
assertThat(fahrenheitTemp).isNotNull();
|
||||
assertThat(fahrenheitTemp.get("fahrenheitTemp").get(0).get("value").asText()).isEqualTo("77.0");
|
||||
});
|
||||
|
||||
testRestClient.deleteCalculatedFieldIfExists(savedCalculatedField.getId());
|
||||
}
|
||||
|
||||
@Test
|
||||
public void testEntityAddedAndDeleted() {
|
||||
// login tenant admin
|
||||
testRestClient.getAndSetUserToken(tenantAdminId);
|
||||
|
||||
CalculatedField savedCalculatedField = createSimpleCalculatedField(deviceProfileId);
|
||||
|
||||
String newDeviceToken = "mmmXRIVRsq9lbnTP2XBE";
|
||||
Device newDevice = testRestClient.postDevice(newDeviceToken, createDevice("Device 2", deviceProfileId));
|
||||
|
||||
await().alias("create device by profile -> perform initial calculation for new device by profile").atMost(TIMEOUT, TimeUnit.SECONDS)
|
||||
.pollInterval(POLL_INTERVAL, TimeUnit.SECONDS)
|
||||
.untilAsserted(() -> {
|
||||
// used default value since telemetry is not present
|
||||
JsonNode fahrenheitTemp = testRestClient.getLatestTelemetry(newDevice.getId());
|
||||
assertThat(fahrenheitTemp).isNotNull();
|
||||
assertThat(fahrenheitTemp.get("fahrenheitTemp").get(0).get("value").asText()).isEqualTo("53.6");
|
||||
});
|
||||
|
||||
DeviceProfile newDeviceProfile = testRestClient.postDeviceProfile(defaultDeviceProfile("Test Profile"));
|
||||
newDevice.setDeviceProfileId(newDeviceProfile.getId());
|
||||
testRestClient.postDevice(newDeviceToken, newDevice);
|
||||
|
||||
testRestClient.postTelemetry(newDeviceToken, JacksonUtil.toJsonNode("{\"temperature\":25}"));
|
||||
|
||||
await().alias("update telemetry -> no updates").atMost(TIMEOUT, TimeUnit.SECONDS)
|
||||
.pollInterval(POLL_INTERVAL, TimeUnit.SECONDS)
|
||||
.untilAsserted(() -> {
|
||||
JsonNode fahrenheitTemp = testRestClient.getLatestTelemetry(newDevice.getId());
|
||||
assertThat(fahrenheitTemp).isNotNull();
|
||||
assertThat(fahrenheitTemp.get("fahrenheitTemp").get(0).get("value").asText()).isEqualTo("53.6");
|
||||
});
|
||||
|
||||
testRestClient.deleteCalculatedFieldIfExists(savedCalculatedField.getId());
|
||||
}
|
||||
|
||||
private CalculatedField createSimpleCalculatedField() {
|
||||
return createSimpleCalculatedField(device.getId());
|
||||
}
|
||||
|
||||
private CalculatedField createSimpleCalculatedField(EntityId entityId) {
|
||||
CalculatedField calculatedField = new CalculatedField();
|
||||
calculatedField.setEntityId(entityId);
|
||||
calculatedField.setType(CalculatedFieldType.SIMPLE);
|
||||
calculatedField.setName("C to F" + RandomStringUtils.randomAlphabetic(5));
|
||||
calculatedField.setDebugSettings(DebugSettings.all());
|
||||
|
||||
SimpleCalculatedFieldConfiguration config = new SimpleCalculatedFieldConfiguration();
|
||||
|
||||
Argument argument = new Argument();
|
||||
ReferencedEntityKey refEntityKey = new ReferencedEntityKey("temperature", ArgumentType.TS_LATEST, null);
|
||||
argument.setRefEntityKey(refEntityKey);
|
||||
argument.setDefaultValue("12"); // not used because real telemetry value in db is present
|
||||
config.setArguments(Map.of("T", argument));
|
||||
|
||||
config.setExpression("(T * 9/5) + 32");
|
||||
|
||||
Output output = new Output();
|
||||
output.setName("fahrenheitTemp");
|
||||
output.setType(OutputType.TIME_SERIES);
|
||||
output.setDecimalsByDefault(2);
|
||||
config.setOutput(output);
|
||||
|
||||
calculatedField.setConfiguration(config);
|
||||
|
||||
return testRestClient.postCalculatedField(calculatedField);
|
||||
}
|
||||
|
||||
private CalculatedField createScriptCalculatedField() {
|
||||
return createScriptCalculatedField(device.getId());
|
||||
}
|
||||
|
||||
private CalculatedField createScriptCalculatedField(EntityId entityId) {
|
||||
CalculatedField calculatedField = new CalculatedField();
|
||||
calculatedField.setEntityId(entityId);
|
||||
calculatedField.setType(CalculatedFieldType.SCRIPT);
|
||||
calculatedField.setName("Air density" + RandomStringUtils.randomAlphabetic(5));
|
||||
calculatedField.setDebugSettings(DebugSettings.all());
|
||||
|
||||
SimpleCalculatedFieldConfiguration config = new SimpleCalculatedFieldConfiguration();
|
||||
|
||||
Argument argument1 = new Argument();
|
||||
argument1.setRefEntityId(asset.getId());
|
||||
ReferencedEntityKey refEntityKey1 = new ReferencedEntityKey("altitude", ArgumentType.ATTRIBUTE, AttributeScope.SERVER_SCOPE);
|
||||
argument1.setRefEntityKey(refEntityKey1);
|
||||
config.setArguments(Map.of("altitude", argument1));
|
||||
Argument argument2 = new Argument();
|
||||
ReferencedEntityKey refEntityKey2 = new ReferencedEntityKey("temperatureInF", ArgumentType.TS_ROLLING, null);
|
||||
argument2.setRefEntityKey(refEntityKey2);
|
||||
config.setArguments(Map.of("temperature", argument2));
|
||||
|
||||
config.setExpression("return {\"airDensity\": 5};");
|
||||
|
||||
Output output = new Output();
|
||||
output.setType(OutputType.TIME_SERIES);
|
||||
config.setOutput(output);
|
||||
|
||||
calculatedField.setConfiguration(config);
|
||||
|
||||
return testRestClient.postCalculatedField(calculatedField);
|
||||
}
|
||||
|
||||
private Device createDevice(String name, DeviceProfileId deviceProfileId) {
|
||||
Device device = new Device();
|
||||
device.setName(name);
|
||||
device.setType("default");
|
||||
device.setDeviceProfileId(deviceProfileId);
|
||||
DeviceData deviceData = new DeviceData();
|
||||
deviceData.setTransportConfiguration(new DefaultDeviceTransportConfiguration());
|
||||
deviceData.setConfiguration(new DefaultDeviceConfiguration());
|
||||
device.setDeviceData(deviceData);
|
||||
return device;
|
||||
}
|
||||
|
||||
private Asset createAsset(String name, AssetProfileId assetProfileId) {
|
||||
Asset asset = new Asset();
|
||||
asset.setName(name);
|
||||
asset.setAssetProfileId(assetProfileId);
|
||||
return asset;
|
||||
}
|
||||
|
||||
}
|
||||
@ -77,7 +77,7 @@ public class HttpClientTest extends AbstractContainerTest {
|
||||
assertThat(accessToken).isNotNull();
|
||||
|
||||
JsonNode sharedAttribute = mapper.readTree(createPayload().toString());
|
||||
testRestClient.postTelemetryAttribute(DEVICE, device.getId(), SHARED_SCOPE, sharedAttribute);
|
||||
testRestClient.postTelemetryAttribute(device.getId(), SHARED_SCOPE, sharedAttribute);
|
||||
|
||||
JsonNode clientAttribute = mapper.readTree(createPayload().toString());
|
||||
testRestClient.postAttribute(accessToken, clientAttribute);
|
||||
|
||||
@ -212,7 +212,7 @@ public class MqttClientTest extends AbstractContainerTest {
|
||||
String sharedAttributeValue = StringUtils.randomAlphanumeric(8);
|
||||
sharedAttributes.addProperty("sharedAttr", sharedAttributeValue);
|
||||
JsonNode sharedAttribute = mapper.readTree(sharedAttributes.toString());
|
||||
testRestClient.postTelemetryAttribute(DEVICE, device.getId(), SHARED_SCOPE, sharedAttribute);
|
||||
testRestClient.postTelemetryAttribute(device.getId(), SHARED_SCOPE, sharedAttribute);
|
||||
|
||||
// Subscribe to attributes response
|
||||
mqttClient.on("v1/devices/me/attributes/response/+", listener, MqttQoS.AT_LEAST_ONCE).get();
|
||||
@ -255,7 +255,7 @@ public class MqttClientTest extends AbstractContainerTest {
|
||||
sharedAttributes.addProperty(sharedAttributeName, sharedAttributeValue);
|
||||
JsonNode sharedAttribute = mapper.readTree(sharedAttributes.toString());
|
||||
|
||||
testRestClient.postTelemetryAttribute(DataConstants.DEVICE, device.getId(), SHARED_SCOPE, sharedAttribute);
|
||||
testRestClient.postTelemetryAttribute(device.getId(), SHARED_SCOPE, sharedAttribute);
|
||||
|
||||
MqttEvent event = listener.getEvents().poll(10 * timeoutMultiplier, TimeUnit.SECONDS);
|
||||
assertThat(mapper.readValue(Objects.requireNonNull(event).getMessage(), JsonNode.class).get(sharedAttributeName).asText())
|
||||
@ -265,7 +265,7 @@ public class MqttClientTest extends AbstractContainerTest {
|
||||
JsonObject updatedSharedAttributes = new JsonObject();
|
||||
String updatedSharedAttributeValue = StringUtils.randomAlphanumeric(8);
|
||||
updatedSharedAttributes.addProperty(sharedAttributeName, updatedSharedAttributeValue);
|
||||
testRestClient.postTelemetryAttribute(DEVICE, device.getId(), SHARED_SCOPE, mapper.readTree(updatedSharedAttributes.toString()));
|
||||
testRestClient.postTelemetryAttribute(device.getId(), SHARED_SCOPE, mapper.readTree(updatedSharedAttributes.toString()));
|
||||
|
||||
event = listener.getEvents().poll(10 * timeoutMultiplier, TimeUnit.SECONDS);
|
||||
assertThat(mapper.readValue(Objects.requireNonNull(event).getMessage(), JsonNode.class).get(sharedAttributeName).asText())
|
||||
|
||||
@ -184,7 +184,7 @@ public class MqttGatewayClientTest extends AbstractContainerTest {
|
||||
|
||||
mqttClient.on("v1/gateway/attributes/response", listener, MqttQoS.AT_LEAST_ONCE).get();
|
||||
|
||||
testRestClient.postTelemetryAttribute(DataConstants.DEVICE, createdDevice.getId(), SHARED_SCOPE, mapper.readTree(sharedAttributes.toString()));
|
||||
testRestClient.postTelemetryAttribute(createdDevice.getId(), SHARED_SCOPE, mapper.readTree(sharedAttributes.toString()));
|
||||
var event = listener.getEvents().poll(10 * timeoutMultiplier, TimeUnit.SECONDS);
|
||||
|
||||
JsonObject requestData = new JsonObject();
|
||||
@ -266,7 +266,7 @@ public class MqttGatewayClientTest extends AbstractContainerTest {
|
||||
// Subscribe for attribute update event
|
||||
mqttClient.on("v1/gateway/attributes", listener, MqttQoS.AT_LEAST_ONCE).get();
|
||||
|
||||
testRestClient.postTelemetryAttribute(DEVICE, createdDevice.getId(), SHARED_SCOPE, mapper.readTree(sharedAttributes.toString()));
|
||||
testRestClient.postTelemetryAttribute(createdDevice.getId(), SHARED_SCOPE, mapper.readTree(sharedAttributes.toString()));
|
||||
MqttEvent sharedAttributeEvent = listener.getEvents().poll(10 * timeoutMultiplier, TimeUnit.SECONDS);
|
||||
|
||||
// Catch attribute update event
|
||||
@ -299,7 +299,7 @@ public class MqttGatewayClientTest extends AbstractContainerTest {
|
||||
gatewaySharedAttributeValue.addProperty("device", createdDevice.getName());
|
||||
gatewaySharedAttributeValue.add("data", sharedAttributes);
|
||||
|
||||
testRestClient.postTelemetryAttribute(DEVICE, createdDevice.getId(), SHARED_SCOPE, mapper.readTree(sharedAttributes.toString()));
|
||||
testRestClient.postTelemetryAttribute(createdDevice.getId(), SHARED_SCOPE, mapper.readTree(sharedAttributes.toString()));
|
||||
|
||||
MqttEvent event = listener.getEvents().poll(10 * timeoutMultiplier, TimeUnit.SECONDS);
|
||||
assertThat(mapper.readValue(Objects.requireNonNull(event).getMessage(), JsonNode.class).get("data").get(sharedAttributeName).asText())
|
||||
@ -314,7 +314,7 @@ public class MqttGatewayClientTest extends AbstractContainerTest {
|
||||
gatewayUpdatedSharedAttributeValue.addProperty("device", createdDevice.getName());
|
||||
gatewayUpdatedSharedAttributeValue.add("data", updatedSharedAttributes);
|
||||
|
||||
testRestClient.postTelemetryAttribute(DEVICE, createdDevice.getId(), SHARED_SCOPE, mapper.readTree(updatedSharedAttributes.toString()));
|
||||
testRestClient.postTelemetryAttribute(createdDevice.getId(), SHARED_SCOPE, mapper.readTree(updatedSharedAttributes.toString()));
|
||||
event = listener.getEvents().poll(10 * timeoutMultiplier, TimeUnit.SECONDS);
|
||||
assertThat(mapper.readValue(Objects.requireNonNull(event).getMessage(), JsonNode.class).get("data").get(sharedAttributeName).asText())
|
||||
.isEqualTo(updatedSharedAttributeValue);
|
||||
|
||||
Loading…
x
Reference in New Issue
Block a user