Browse Source

Replaced 5 deprecated APIs with non-deprecated variants

pull/15663/head
Oleksandra Matviienko 1 month ago
parent
commit
97dfd557cf
  1. 2
      application/src/main/java/org/thingsboard/server/service/security/model/token/JwtTokenFactory.java
  2. 2
      application/src/test/java/org/thingsboard/server/service/sync/vc/VersionControlTest.java
  3. 2
      application/src/test/java/org/thingsboard/server/transport/lwm2m/AbstractLwM2MIntegrationTest.java
  4. 7
      common/transport/http/src/test/java/org/thingsboard/server/transport/http/DeviceApiControllerTest.java
  5. 7
      common/util/src/main/java/org/thingsboard/common/util/JacksonUtil.java
  6. 6
      common/util/src/main/java/org/thingsboard/common/util/TbStopWatch.java
  7. 2
      rule-engine/rule-engine-components/src/main/java/org/thingsboard/rule/engine/ai/Langchain4jJsonSchemaAdapter.java
  8. 5
      rule-engine/rule-engine-components/src/main/java/org/thingsboard/rule/engine/transform/TbCopyKeysNode.java
  9. 9
      tools/src/main/java/org/thingsboard/client/tools/i18n/TranslationPruner.java

2
application/src/main/java/org/thingsboard/server/service/security/model/token/JwtTokenFactory.java

@ -23,9 +23,9 @@ import io.jsonwebtoken.JwtBuilder;
import io.jsonwebtoken.JwtParser;
import io.jsonwebtoken.Jwts;
import io.jsonwebtoken.MalformedJwtException;
import io.jsonwebtoken.SignatureException;
import io.jsonwebtoken.UnsupportedJwtException;
import io.jsonwebtoken.security.Keys;
import io.jsonwebtoken.security.SignatureException;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.springframework.context.annotation.Lazy;

2
application/src/test/java/org/thingsboard/server/service/sync/vc/VersionControlTest.java

@ -477,7 +477,7 @@ public class VersionControlTest extends AbstractControllerTest {
Dashboard importedOtherDashboard = findDashboard(otherDashboard.getName());
Dashboard importedDashboard = findDashboard(dashboard.getName());
Map.Entry<String, JsonNode> entityAlias = importedDashboard.getConfiguration().get("entityAliases").fields().next();
Map.Entry<String, JsonNode> entityAlias = importedDashboard.getConfiguration().get("entityAliases").properties().iterator().next();
assertThat(entityAlias.getKey()).isEqualTo(aliasId);
assertThat(entityAlias.getValue().get("id").asText()).isEqualTo(aliasId);

2
application/src/test/java/org/thingsboard/server/transport/lwm2m/AbstractLwM2MIntegrationTest.java

@ -102,10 +102,10 @@ import java.util.concurrent.atomic.AtomicLong;
import static org.awaitility.Awaitility.await;
import static org.eclipse.leshan.client.object.Security.noSec;
import static org.hamcrest.MatcherAssert.assertThat;
import static org.hamcrest.core.IsInstanceOf.instanceOf;
import static org.junit.Assert.assertEquals;
import static org.junit.Assert.assertNotNull;
import static org.junit.Assert.assertThat;
import static org.junit.Assert.assertTrue;
import static org.mockito.ArgumentMatchers.eq;
import static org.mockito.Mockito.timeout;

7
common/transport/http/src/test/java/org/thingsboard/server/transport/http/DeviceApiControllerTest.java

@ -18,6 +18,7 @@ package org.thingsboard.server.transport.http;
import com.google.gson.JsonParseException;
import org.junit.jupiter.api.Test;
import org.mockito.Mockito;
import org.springframework.http.HttpInputMessage;
import org.springframework.http.ResponseEntity;
import org.springframework.http.converter.HttpMessageNotReadableException;
import org.springframework.web.context.request.async.DeferredResult;
@ -37,7 +38,7 @@ class DeviceApiControllerTest {
};
var callback = new DeviceApiController.DeviceAuthCallback(transportContext, responseWriter, onSuccess);
callback.onError(new HttpMessageNotReadableException("JSON incorrect syntax"));
callback.onError(new HttpMessageNotReadableException("JSON incorrect syntax", (HttpInputMessage) null));
callback.onError(new JsonParseException("Json ; expected"));
@ -51,7 +52,7 @@ class DeviceApiControllerTest {
DeferredResult<ResponseEntity> responseWriter = Mockito.mock(DeferredResult.class);
var callback = new DeviceApiController.DeviceProvisionCallback(responseWriter);
callback.onError(new HttpMessageNotReadableException("JSON incorrect syntax"));
callback.onError(new HttpMessageNotReadableException("JSON incorrect syntax", (HttpInputMessage) null));
callback.onError(new JsonParseException("Json ; expected"));
@ -71,7 +72,7 @@ class DeviceApiControllerTest {
var callback = new DeviceApiController.GetOtaPackageCallback(transportContext, responseWriter, title, version, chunkSize, chunk);
callback.onError(new HttpMessageNotReadableException("JSON incorrect syntax"));
callback.onError(new HttpMessageNotReadableException("JSON incorrect syntax", (HttpInputMessage) null));
callback.onError(new JsonParseException("Json ; expected"));

7
common/util/src/main/java/org/thingsboard/common/util/JacksonUtil.java

@ -447,10 +447,8 @@ public class JacksonUtil {
private static void toFlatMap(JsonNode node, String currentPath, Map<String, String> map) {
if (node.isObject()) {
Iterator<Map.Entry<String, JsonNode>> fields = node.fields();
currentPath = currentPath.isEmpty() ? "" : currentPath + ".";
while (fields.hasNext()) {
Map.Entry<String, JsonNode> entry = fields.next();
for (Map.Entry<String, JsonNode> entry : node.properties()) {
toFlatMap(entry.getValue(), currentPath + entry.getKey(), map);
}
} else if (node.isValueNode()) {
@ -554,8 +552,7 @@ public class JacksonUtil {
}
} else if (node.isObject()) {
ObjectNode on = (ObjectNode) node;
for (Iterator<Map.Entry<String, JsonNode>> it = on.fields(); it.hasNext(); ) {
var kv = it.next();
for (Map.Entry<String, JsonNode> kv : on.properties()) {
if (variableName != null) {
tasks.add(task.next(kv.getValue(), variableName, kv.getKey()));
} else {

6
common/util/src/main/java/org/thingsboard/common/util/TbStopWatch.java

@ -52,17 +52,17 @@ public class TbStopWatch extends StopWatch {
public long stopAndGetTotalTimeNanos(){
stop();
return getLastTaskTimeNanos();
return lastTaskInfo().getTimeNanos();
}
public long stopAndGetLastTaskTimeMillis(){
stop();
return getLastTaskTimeMillis();
return lastTaskInfo().getTimeMillis();
}
public long stopAndGetLastTaskTimeNanos(){
stop();
return getLastTaskTimeNanos();
return lastTaskInfo().getTimeNanos();
}
}

2
rule-engine/rule-engine-components/src/main/java/org/thingsboard/rule/engine/ai/Langchain4jJsonSchemaAdapter.java

@ -94,7 +94,7 @@ final class Langchain4jJsonSchemaAdapter {
JsonNode propertiesNode = objectSchema.get("properties");
if (propertiesNode != null) {
propertiesNode.fields().forEachRemaining(entry -> {
propertiesNode.properties().forEach(entry -> {
String key = entry.getKey();
JsonNode value = entry.getValue();
builder.addProperty(key, parse(value));

5
rule-engine/rule-engine-components/src/main/java/org/thingsboard/rule/engine/transform/TbCopyKeysNode.java

@ -29,7 +29,6 @@ import org.thingsboard.server.common.data.plugin.ComponentType;
import org.thingsboard.server.common.msg.TbMsg;
import java.util.Arrays;
import java.util.Iterator;
import java.util.List;
import java.util.Map;
import java.util.concurrent.ExecutionException;
@ -87,9 +86,7 @@ public class TbCopyKeysNode extends TbAbstractTransformNodeWithTbMsgSource {
msgData = JacksonUtil.toString(msgDataNode);
break;
case DATA:
Iterator<Map.Entry<String, JsonNode>> iteratorNode = dataNode.fields();
while (iteratorNode.hasNext()) {
Map.Entry<String, JsonNode> entry = iteratorNode.next();
for (Map.Entry<String, JsonNode> entry : dataNode.properties()) {
String msgKey = entry.getKey();
JsonNode msgValue = entry.getValue();
if (matches(msgKey)) {

9
tools/src/main/java/org/thingsboard/client/tools/i18n/TranslationPruner.java

@ -25,7 +25,6 @@ import com.fasterxml.jackson.databind.node.ObjectNode;
import java.io.File;
import java.io.IOException;
import java.util.HashSet;
import java.util.Iterator;
import java.util.Map;
import java.util.Set;
@ -37,9 +36,7 @@ public class TranslationPruner {
*/
private static void collectKeys(JsonNode node, String prefix, Set<String> keys) {
if (!node.isObject()) return;
Iterator<Map.Entry<String, JsonNode>> fields = node.fields();
while (fields.hasNext()) {
Map.Entry<String, JsonNode> entry = fields.next();
for (Map.Entry<String, JsonNode> entry : node.properties()) {
String key = entry.getKey();
String fullKey = prefix.isEmpty() ? key : prefix + "." + key;
keys.add(fullKey);
@ -52,9 +49,7 @@ public class TranslationPruner {
*/
private static ObjectNode pruneNode(ObjectNode node, Set<String> keys, String prefix, ObjectMapper mapper) {
ObjectNode pruned = mapper.createObjectNode();
Iterator<Map.Entry<String, JsonNode>> fields = node.fields();
while (fields.hasNext()) {
Map.Entry<String, JsonNode> entry = fields.next();
for (Map.Entry<String, JsonNode> entry : node.properties()) {
String key = entry.getKey();
JsonNode value = entry.getValue();
String fullKey = prefix.isEmpty() ? key : prefix + "." + key;

Loading…
Cancel
Save