From 2fcf5fd7c61f3d4d38b64a51278d0bc74cd72fc3 Mon Sep 17 00:00:00 2001 From: nickAS21 Date: Mon, 29 Mar 2021 12:50:50 +0300 Subject: [PATCH] lwm2m: front/back fix bug update profile --- .../transport/lwm2m/server/LwM2mTransportRequest.java | 9 +++++---- .../lwm2m/server/LwM2mTransportServiceImpl.java | 11 +++++------ 2 files changed, 10 insertions(+), 10 deletions(-) diff --git a/common/transport/lwm2m/src/main/java/org/thingsboard/server/transport/lwm2m/server/LwM2mTransportRequest.java b/common/transport/lwm2m/src/main/java/org/thingsboard/server/transport/lwm2m/server/LwM2mTransportRequest.java index 217d829c6a..9c415ee322 100644 --- a/common/transport/lwm2m/src/main/java/org/thingsboard/server/transport/lwm2m/server/LwM2mTransportRequest.java +++ b/common/transport/lwm2m/src/main/java/org/thingsboard/server/transport/lwm2m/server/LwM2mTransportRequest.java @@ -109,14 +109,15 @@ public class LwM2mTransportRequest { * Device management and service enablement, including Read, Write, Execute, Discover, Create, Delete and Write-Attributes * * @param registration - - * @param target - + * @param targetIdVer - * @param typeOper - * @param contentFormatParam - * @param observation - */ - public void sendAllRequest(Registration registration, String target, String typeOper, + public void sendAllRequest(Registration registration, String targetIdVer, String typeOper, String contentFormatParam, Observation observation, Object params, long timeoutInMs) { - LwM2mPath resultIds = new LwM2mPath(convertToObjectIdFromIdVer(target)); + String target = convertToObjectIdFromIdVer(targetIdVer); + LwM2mPath resultIds = new LwM2mPath(target); if (registration != null && resultIds.getObjectId() >= 0) { DownlinkRequest request = null; ContentFormat contentFormat = contentFormatParam != null ? ContentFormat.fromName(contentFormatParam.toUpperCase()) : null; @@ -221,7 +222,7 @@ public class LwM2mTransportRequest { this.sendRequest(registration, lwM2MClient, request, timeoutInMs); } else { - log.error("[{}], [{}] - [{}] error SendRequest", registration.getEndpoint(), typeOper, target); + log.error("[{}], [{}] - [{}] error SendRequest", registration.getEndpoint(), typeOper, targetIdVer); } } } diff --git a/common/transport/lwm2m/src/main/java/org/thingsboard/server/transport/lwm2m/server/LwM2mTransportServiceImpl.java b/common/transport/lwm2m/src/main/java/org/thingsboard/server/transport/lwm2m/server/LwM2mTransportServiceImpl.java index 8d43b76446..3c09c0ebf3 100644 --- a/common/transport/lwm2m/src/main/java/org/thingsboard/server/transport/lwm2m/server/LwM2mTransportServiceImpl.java +++ b/common/transport/lwm2m/src/main/java/org/thingsboard/server/transport/lwm2m/server/LwM2mTransportServiceImpl.java @@ -360,7 +360,7 @@ public class LwM2mTransportServiceImpl implements LwM2mTransportService { */ @Override public void onResourceUpdate (Optional resourceUpdateMsgOpt) { - String idVer = resourceUpdateMsgOpt.get().getResourceKey(); // 19_1.0 + String idVer = resourceUpdateMsgOpt.get().getResourceKey(); lwM2mClientContext.getLwM2mClients().values().stream().forEach(e -> e.updateResourceModel(idVer, this.lwM2mTransportContextServer.getLwM2MTransportConfigServer().getModelProvider())); } @@ -370,7 +370,7 @@ public class LwM2mTransportServiceImpl implements LwM2mTransportService { */ @Override public void onResourceDelete(Optional resourceDeleteMsgOpt) { - String pathIdVer = resourceDeleteMsgOpt.get().getResourceKey(); // 19_1.0 + String pathIdVer = resourceDeleteMsgOpt.get().getResourceKey(); lwM2mClientContext.getLwM2mClients().values().stream().forEach(e -> e.deleteResources(pathIdVer, this.lwM2mTransportContextServer.getLwM2MTransportConfigServer().getModelProvider())); } @@ -537,8 +537,7 @@ public class LwM2mTransportServiceImpl implements LwM2mTransportService { Set paths = new HashSet<>(); paths.add(path); this.updateAttrTelemetry(registration, paths); - } - else { + } else { log.error("Fail update Resource [{}]", lwM2mResource); } } @@ -574,7 +573,8 @@ public class LwM2mTransportServiceImpl implements LwM2mTransportService { private boolean validatePathInAttrProfile(LwM2mClientProfile clientProfile, String path) { try { List attributesSet = new Gson().fromJson(clientProfile.getPostAttributeProfile(), - new TypeToken>() {}.getType()); + new TypeToken>() { + }.getType()); return attributesSet.stream().anyMatch(p -> p.equals(path)); } catch (Exception e) { log.error("Fail Validate Path [{}] ClientProfile.Attribute", path, e); @@ -830,7 +830,6 @@ public class LwM2mTransportServiceImpl implements LwM2mTransportService { if (sendAttrToThingsboard.getPathPostParametersAdd().size() > 0) { // update value in Resources registrationIds.forEach(registrationId -> { -// LeshanServer lwServer = leshanServer; Registration registration = lwM2mClientContext.getRegistration(registrationId); this.readResourceValueObserve(registration, sendAttrToThingsboard.getPathPostParametersAdd(), GET_TYPE_OPER_READ); // send attr/telemetry to tingsboard for new path