@ -15,9 +15,8 @@
* /
package org.thingsboard.server.transport.lwm2m.server.store.util ;
import com.eclipsesource.json.Json ;
import com.eclipsesource.json.JsonObject ;
import com.eclipsesource.json.JsonValue ;
import com.fasterxml.jackson.annotation.JsonValue ;
import com.google.gson.JsonObject ;
import com.google.protobuf.util.JsonFormat ;
import lombok.SneakyThrows ;
import org.eclipse.leshan.core.model.ResourceModel ;
@ -26,113 +25,107 @@ import org.eclipse.leshan.core.node.LwM2mNodeException;
import org.eclipse.leshan.core.node.LwM2mResource ;
import org.eclipse.leshan.core.node.LwM2mSingleResource ;
import org.eclipse.leshan.core.node.ObjectLink ;
import org.eclipse.leshan.core.util.datatype.ULong ;
import org.eclipse.leshan.server.redis.serialization.RegistrationSerDes ;
import org.thingsboard.server.common.data.device.data.PowerMode ;
import org.thingsboard.server.common.data.id.TenantId ;
import org.thingsboard.server.gen.transport.TransportProtos ;
import org.thingsboard.server.transport.lwm2m.server.client.LwM2MClientState ;
import org.thingsboard.server.transport.lwm2m.server.client.LwM2mClient ;
import org.thingsboard.server.transport.lwm2m.server.client.ResourceValue ;
import java.lang.reflect.Field ;
import java.util.Base64 ;
import java.util.Date ;
import java.util.HashMap ;
import java.util.Map ;
import java.util.UUID ;
import java.util.concurrent.atomic.AtomicLong ;
public class LwM2MClientSerDes {
public static final String VALUE = "value" ;
@SneakyThrows
public static byte [ ] serialize ( LwM2mClient client ) {
JsonObject o = Json . o bject( ) ;
o . add ( "nodeId" , client . getNodeId ( ) ) ;
o . add ( "endpoint" , client . getEndpoint ( ) ) ;
JsonObject o = new JsonO bject ( ) ;
o . addProperty ( "nodeId" , "client.getNodeId()" ) ;
o . addProperty ( "endpoint" , client . getEndpoint ( ) ) ;
JsonObject resources = Json . o bject( ) ;
JsonObject resources = new JsonO bject( ) ;
client . getResources ( ) . forEach ( ( k , v ) - > {
JsonObject resourceValue = Json . o bject( ) ;
JsonObject resourceValue = new JsonO bject( ) ;
resourceValue . add ( "lwM2mResource" , serialize ( v . getLwM2mResource ( ) ) ) ;
resourceValue . add ( "resourceModel" , serialize ( v . getResourceModel ( ) ) ) ;
resources . add ( k , resourceValue ) ;
} ) ;
o . add ( "resources" , resources ) ;
JsonObject sharedAttributes = Json . o bject( ) ;
JsonObject sharedAttributes = new JsonO bject( ) ;
for ( Map . Entry < String , TransportProtos . TsKvProto > entry : client . getSharedAttributes ( ) . entrySet ( ) ) {
sharedAttributes . add ( entry . getKey ( ) , JsonFormat . printer ( ) . print ( entry . getValue ( ) ) ) ;
sharedAttributes . addProperty ( entry . getKey ( ) , JsonFormat . printer ( ) . print ( entry . getValue ( ) ) ) ;
}
o . add ( "sharedAttributes" , sharedAttributes ) ;
JsonObject keyTsLatestMap = Json . o bject( ) ;
JsonObject keyTsLatestMap = new JsonO bject( ) ;
client . getKeyTsLatestMap ( ) . forEach ( ( k , v ) - > {
keyTsLatestMap . add ( k , v . get ( ) ) ;
keyTsLatestMap . addProperty ( k , v . get ( ) ) ;
} ) ;
o . add ( "keyTsLatestMap" , keyTsLatestMap ) ;
o . add ( "state" , client . getState ( ) . toString ( ) ) ;
o . addProperty ( "state" , client . getState ( ) . toString ( ) ) ;
if ( client . getSession ( ) ! = null ) {
o . add ( "session" , JsonFormat . printer ( ) . print ( client . getSession ( ) ) ) ;
o . addProperty ( "session" , JsonFormat . printer ( ) . print ( client . getSession ( ) ) ) ;
}
if ( client . getTenantId ( ) ! = null ) {
o . add ( "tenantId" , client . getTenantId ( ) . toString ( ) ) ;
o . addProperty ( "tenantId" , client . getTenantId ( ) . toString ( ) ) ;
}
if ( client . getDeviceId ( ) ! = null ) {
o . add ( "deviceId" , client . getDeviceId ( ) . toString ( ) ) ;
o . addProperty ( "deviceId" , client . getDeviceId ( ) . toString ( ) ) ;
}
if ( client . getProfileId ( ) ! = null ) {
o . add ( "profileId" , client . getProfileId ( ) . toString ( ) ) ;
o . addProperty ( "profileId" , client . getProfileId ( ) . toString ( ) ) ;
}
if ( client . getPowerMode ( ) ! = null ) {
o . add ( "powerMode" , client . getPowerMode ( ) . toString ( ) ) ;
o . addProperty ( "powerMode" , client . getPowerMode ( ) . toString ( ) ) ;
}
if ( client . getEdrxCycle ( ) ! = null ) {
o . add ( "edrxCycle" , client . getEdrxCycle ( ) ) ;
o . addProperty ( "edrxCycle" , client . getEdrxCycle ( ) ) ;
}
if ( client . getPsmActivityTimer ( ) ! = null ) {
o . add ( "psmActivityTimer" , client . getPsmActivityTimer ( ) ) ;
o . addProperty ( "psmActivityTimer" , client . getPsmActivityTimer ( ) ) ;
}
if ( client . getPagingTransmissionWindow ( ) ! = null ) {
o . add ( "pagingTransmissionWindow" , client . getPagingTransmissionWindow ( ) ) ;
o . addProperty ( "pagingTransmissionWindow" , client . getPagingTransmissionWindow ( ) ) ;
}
if ( client . getRegistration ( ) ! = null ) {
o . add ( "registration" , RegistrationSerDes . jSerialize ( client . getRegistration ( ) ) ) ;
RegistrationSerDes regDez = new RegistrationSerDes ( ) ;
o . addProperty ( "registration" , regDez . jSerialize ( client . getRegistration ( ) ) . toString ( ) ) ;
}
o . add ( "asleep" , client . isAsleep ( ) ) ;
o . add ( "lastUplinkTime" , client . getLastUplinkTime ( ) ) ;
o . addProperty ( "asleep" , client . isAsleep ( ) ) ;
o . addProperty ( "lastUplinkTime" , client . getLastUplinkTime ( ) ) ;
Field firstEdrxDownlink = LwM2mClient . class . getDeclaredField ( "firstEdrxDownlink" ) ;
firstEdrxDownlink . setAccessible ( true ) ;
o . add ( "firstEdrxDownlink" , ( boolean ) firstEdrxDownlink . get ( client ) ) ;
o . add ( "retryAttempts" , client . getRetryAttempts ( ) . get ( ) ) ;
o . addProperty ( "firstEdrxDownlink" , ( boolean ) firstEdrxDownlink . get ( client ) ) ;
o . addProperty ( "retryAttempts" , client . getRetryAttempts ( ) . get ( ) ) ;
if ( client . getLastSentRpcId ( ) ! = null ) {
o . add ( "lastSentRpcId" , client . getLastSentRpcId ( ) . toString ( ) ) ;
o . addProperty ( "lastSentRpcId" , client . getLastSentRpcId ( ) . toString ( ) ) ;
}
return o . toString ( ) . getBytes ( ) ;
}
private static JsonObject serialize ( LwM2mResource resource ) {
JsonObject o = Json . o bject( ) ;
o . add ( "id" , resource . getId ( ) ) ;
o . add ( "type" , resource . getType ( ) . toString ( ) ) ;
JsonObject o = new JsonO bject( ) ;
o . addProperty ( "id" , resource . getId ( ) ) ;
o . addProperty ( "type" , resource . getType ( ) . toString ( ) ) ;
if ( resource . isMultiInstances ( ) ) {
o . add ( "multiInstances" , true ) ;
JsonObject instances = Json . o bject( ) ;
o . addProperty ( "multiInstances" , true ) ;
JsonObject instances = new JsonO bject( ) ;
resource . getInstances ( ) . forEach ( ( id , in ) - > {
JsonObject instance = Json . o bject( ) ;
instance . add ( "id" , in . getId ( ) ) ;
JsonObject instance = new JsonO bject( ) ;
instance . addProperty ( "id" , in . getId ( ) ) ;
addValue ( instance , in . getType ( ) , in . getValue ( ) ) ;
instances . add ( id . toString ( ) , instance ) ;
} ) ;
o . add ( "instances" , instances ) ;
} else {
o . add ( "multiInstances" , false ) ;
o . addProperty ( "multiInstances" , false ) ;
addValue ( o , resource . getType ( ) , resource . getValue ( ) ) ;
}
@ -140,95 +133,95 @@ public class LwM2MClientSerDes {
}
private static LwM2mResource parseLwM2mResource ( JsonObject o ) {
boolean multiInstances = o . get ( "multiInstances" ) . a sBoolean( ) ;
int id = o . get ( "id" ) . a sInt( ) ;
ResourceModel . Type type = ResourceModel . Type . valueOf ( o . get ( "type" ) . a sString( ) ) ;
boolean multiInstances = o . get ( "multiInstances" ) . getA sBoolean( ) ;
int id = o . get ( "id" ) . getA sInt( ) ;
ResourceModel . Type type = ResourceModel . Type . valueOf ( o . get ( "type" ) . getA sString( ) ) ;
if ( multiInstances ) {
Map < Integer , Object > instances = new HashMap < > ( ) ;
o . get ( "instances" ) . asObject ( ) . forEach ( entry - > {
instances . put ( Integer . valueOf ( entry . getName ( ) ) , parseValue ( type , entry . getValue ( ) ) ) ;
o . get ( "instances" ) . getAsJsonArray ( ) . forEach ( entry - > {
// instances.put(Integer.valueOf(entry.getAsJsonObject().), parseValue(type, entry.getValue()));
} ) ;
return LwM2mMultipleResource . newResource ( id , instances , type ) ;
} else {
return LwM2mSingleResource . newResource ( id , parseValue ( type , o . get ( VALUE ) ) ) ;
return LwM2mSingleResource . newResource ( id , parseValue ( type , ( JsonValue ) o . get ( VALUE ) ) ) ;
}
}
private static Object parseValue ( ResourceModel . Type type , JsonValue value ) {
switch ( type ) {
case INTEGER :
return value . asLong ( ) ;
case FLOAT :
return value . asDouble ( ) ;
case BOOLEAN :
return value . asBoolean ( ) ;
case OPAQUE :
return Base64 . getDecoder ( ) . decode ( value . asString ( ) ) ;
case STRING :
return value . asString ( ) ;
case TIME :
return new Date ( value . asLong ( ) ) ;
case OBJLNK :
return ObjectLink . decodeFromString ( value . asString ( ) ) ;
case UNSIGNED_INTEGER :
return ULong . valueOf ( value . asString ( ) ) ;
return value . value ( ) ;
// case FLOAT:
// return value.value();
// case BOOLEAN:
// return value.asBoolean();
// case OPAQUE:
// return Base64.getDecoder().decode(value.asString());
// case STRING:
// return value.asString();
// case TIME:
// return new Date(value.asLong());
// case OBJLNK:
// return ObjectLink.decodeFromString(value.asString());
// case UNSIGNED_INTEGER:
// return ULong.valueOf(value.asString());
default :
throw new LwM2mNodeException ( String . format ( "Type %s is not supported" , type . name ( ) ) ) ;
}
}
private static JsonObject serialize ( ResourceModel resourceModel ) {
JsonObject o = Json . o bject( ) ;
o . add ( "id" , resourceModel . id ) ;
o . add ( "name" , resourceModel . name ) ;
o . add ( "operations" , resourceModel . operations . toString ( ) ) ;
o . add ( "multiple" , resourceModel . multiple ) ;
o . add ( "mandatory" , resourceModel . mandatory ) ;
o . add ( "type" , resourceModel . type . toString ( ) ) ;
o . add ( "rangeEnumeration" , resourceModel . rangeEnumeration ) ;
o . add ( "units" , resourceModel . units ) ;
o . add ( "description" , resourceModel . description ) ;
JsonObject o = new JsonO bject( ) ;
o . addProperty ( "id" , resourceModel . id ) ;
o . addProperty ( "name" , resourceModel . name ) ;
o . addProperty ( "operations" , resourceModel . operations . toString ( ) ) ;
o . addProperty ( "multiple" , resourceModel . multiple ) ;
o . addProperty ( "mandatory" , resourceModel . mandatory ) ;
o . addProperty ( "type" , resourceModel . type . toString ( ) ) ;
o . addProperty ( "rangeEnumeration" , resourceModel . rangeEnumeration ) ;
o . addProperty ( "units" , resourceModel . units ) ;
o . addProperty ( "description" , resourceModel . description ) ;
return o ;
}
private static ResourceModel parseResourceModel ( JsonObject o ) {
Integer id = o . get ( "id" ) . a sInt( ) ;
String name = o . get ( "name" ) . a sString( ) ;
ResourceModel . Operations operations = ResourceModel . Operations . valueOf ( o . get ( "operations" ) . a sString( ) ) ;
Boolean multiple = o . get ( "multiple" ) . a sBoolean( ) ;
Boolean mandatory = o . get ( "mandatory" ) . a sBoolean( ) ;
ResourceModel . Type type = ResourceModel . Type . valueOf ( o . get ( "type" ) . a sString( ) ) ;
String rangeEnumeration = o . get ( "rangeEnumeration" ) . a sString( ) ;
String units = o . get ( "units" ) . a sString( ) ;
String description = o . get ( "description" ) . a sString( ) ;
Integer id = o . get ( "id" ) . getA sInt( ) ;
String name = o . get ( "name" ) . getA sString( ) ;
ResourceModel . Operations operations = ResourceModel . Operations . valueOf ( o . get ( "operations" ) . getA sString( ) ) ;
Boolean multiple = o . get ( "multiple" ) . getA sBoolean( ) ;
Boolean mandatory = o . get ( "mandatory" ) . getA sBoolean( ) ;
ResourceModel . Type type = ResourceModel . Type . valueOf ( o . get ( "type" ) . getA sString( ) ) ;
String rangeEnumeration = o . get ( "rangeEnumeration" ) . getA sString( ) ;
String units = o . get ( "units" ) . getA sString( ) ;
String description = o . get ( "description" ) . getA sString( ) ;
return new ResourceModel ( id , name , operations , multiple , mandatory , type , rangeEnumeration , units , description ) ;
}
private static void addValue ( JsonObject o , ResourceModel . Type type , Object value ) {
switch ( type ) {
case INTEGER :
o . add ( VALUE , ( Long ) value ) ;
o . addProperty ( VALUE , ( Long ) value ) ;
break ;
case FLOAT :
o . add ( VALUE , ( Double ) value ) ;
o . addProperty ( VALUE , ( Double ) value ) ;
break ;
case BOOLEAN :
o . add ( VALUE , ( Boolean ) value ) ;
o . addProperty ( VALUE , ( Boolean ) value ) ;
break ;
case OPAQUE :
o . add ( VALUE , Base64 . getEncoder ( ) . encodeToString ( ( byte [ ] ) value ) ) ;
o . addProperty ( VALUE , Base64 . getEncoder ( ) . encodeToString ( ( byte [ ] ) value ) ) ;
break ;
case STRING :
o . add ( VALUE , ( String ) value ) ;
o . addProperty ( VALUE , ( String ) value ) ;
break ;
case TIME :
o . add ( VALUE , ( ( Date ) value ) . getTime ( ) ) ;
o . addProperty ( VALUE , ( ( Date ) value ) . getTime ( ) ) ;
break ;
case OBJLNK :
o . add ( VALUE , ( ( ObjectLink ) value ) . encodeToString ( ) ) ;
o . addProperty ( VALUE , ( ( ObjectLink ) value ) . encodeToString ( ) ) ;
break ;
case UNSIGNED_INTEGER :
o . add ( VALUE , value . toString ( ) ) ;
o . addProperty ( VALUE , value . toString ( ) ) ;
break ;
default :
throw new LwM2mNodeException ( String . format ( "Type %s is not supported" , type . name ( ) ) ) ;
@ -237,111 +230,111 @@ public class LwM2MClientSerDes {
@SneakyThrows
public static LwM2mClient deserialize ( byte [ ] data ) {
JsonObject o = Json . parse ( new String ( data ) ) . asObject ( ) ;
LwM2mClient lwM2mClient = new LwM2mClient ( o . get ( "nodeId" ) . asString ( ) , o . get ( "endpoint" ) . asString ( ) ) ;
o . get ( "resources" ) . asObject ( ) . forEach ( entry - > {
JsonObject resource = entry . getValue ( ) . asObject ( ) ;
LwM2mResource lwM2mResource = parseLwM2mResource ( resource . get ( "lwM2mResource" ) . asObject ( ) ) ;
ResourceModel resourceModel = parseResourceModel ( resource . get ( "resourceModel" ) . asObject ( ) ) ;
ResourceValue resourceValue = new ResourceValue ( lwM2mResource , resourceModel ) ;
lwM2mClient . getResources ( ) . put ( entry . getName ( ) , resourceValue ) ;
} ) ;
for ( JsonObject . Member entry : o . get ( "sharedAttributes" ) . asObject ( ) ) {
TransportProtos . TsKvProto . Builder builder = TransportProtos . TsKvProto . newBuilder ( ) ;
JsonFormat . parser ( ) . merge ( entry . getValue ( ) . asString ( ) , builder ) ;
lwM2mClient . getSharedAttributes ( ) . put ( entry . getName ( ) , builder . build ( ) ) ;
}
o . get ( "keyTsLatestMap" ) . asObject ( ) . forEach ( entry - > {
lwM2mClient . getKeyTsLatestMap ( ) . put ( entry . getName ( ) , new AtomicLong ( entry . getValue ( ) . asLong ( ) ) ) ;
} ) ;
lwM2mClient . setState ( LwM2MClientState . valueOf ( o . get ( "state" ) . asString ( ) ) ) ;
Class < LwM2mClient > lwM2mClientClass = LwM2mClient . class ;
JsonValue session = o . get ( "session" ) ;
if ( session ! = null ) {
TransportProtos . SessionInfoProto . Builder builder = TransportProtos . SessionInfoProto . newBuilder ( ) ;
JsonFormat . parser ( ) . merge ( session . asString ( ) , builder ) ;
Field sessionField = lwM2mClientClass . getDeclaredField ( "session" ) ;
sessionField . setAccessible ( true ) ;
sessionField . set ( lwM2mClient , builder . build ( ) ) ;
}
JsonValue tenantId = o . get ( "tenantId" ) ;
if ( tenantId ! = null ) {
Field tenantIdField = lwM2mClientClass . getDeclaredField ( "tenantId" ) ;
tenantIdField . setAccessible ( true ) ;
tenantIdField . set ( lwM2mClient , new TenantId ( UUID . fromString ( tenantId . asString ( ) ) ) ) ;
}
JsonValue deviceId = o . get ( "deviceId" ) ;
if ( tenantId ! = null ) {
Field deviceIdField = lwM2mClientClass . getDeclaredField ( "deviceId" ) ;
deviceIdField . setAccessible ( true ) ;
deviceIdField . set ( lwM2mClient , UUID . fromString ( deviceId . asString ( ) ) ) ;
}
JsonValue profileId = o . get ( "profileId" ) ;
if ( tenantId ! = null ) {
Field profileIdField = lwM2mClientClass . getDeclaredField ( "profileId" ) ;
profileIdField . setAccessible ( true ) ;
profileIdField . set ( lwM2mClient , UUID . fromString ( profileId . asString ( ) ) ) ;
}
JsonValue powerMode = o . get ( "powerMode" ) ;
if ( powerMode ! = null ) {
Field powerModeField = lwM2mClientClass . getDeclaredField ( "powerMode" ) ;
powerModeField . setAccessible ( true ) ;
powerModeField . set ( lwM2mClient , PowerMode . valueOf ( powerMode . asString ( ) ) ) ;
}
JsonValue edrxCycle = o . get ( "edrxCycle" ) ;
if ( edrxCycle ! = null ) {
Field edrxCycleField = lwM2mClientClass . getDeclaredField ( "edrxCycle" ) ;
edrxCycleField . setAccessible ( true ) ;
edrxCycleField . set ( lwM2mClient , edrxCycle . asLong ( ) ) ;
}
JsonValue psmActivityTimer = o . get ( "psmActivityTimer" ) ;
if ( psmActivityTimer ! = null ) {
Field psmActivityTimerField = lwM2mClientClass . getDeclaredField ( "psmActivityTimer" ) ;
psmActivityTimerField . setAccessible ( true ) ;
psmActivityTimerField . set ( lwM2mClient , psmActivityTimer . asLong ( ) ) ;
}
JsonValue pagingTransmissionWindow = o . get ( "pagingTransmissionWindow" ) ;
if ( pagingTransmissionWindow ! = null ) {
Field pagingTransmissionWindowField = lwM2mClientClass . getDeclaredField ( "pagingTransmissionWindow" ) ;
pagingTransmissionWindowField . setAccessible ( true ) ;
pagingTransmissionWindowField . set ( lwM2mClient , pagingTransmissionWindow . asLong ( ) ) ;
}
JsonValue registration = o . get ( "registration" ) ;
if ( registration ! = null ) {
lwM2mClient . setRegistration ( RegistrationSerDes . deserialize ( registration . asObject ( ) ) ) ;
}
lwM2mClient . setAsleep ( o . get ( "asleep" ) . asBoolean ( ) ) ;
Field lastUplinkTimeField = lwM2mClientClass . getDeclaredField ( "lastUplinkTime" ) ;
lastUplinkTimeField . setAccessible ( true ) ;
lastUplinkTimeField . setLong ( lwM2mClient , o . get ( "lastUplinkTime" ) . asLong ( ) ) ;
Field firstEdrxDownlinkField = lwM2mClientClass . getDeclaredField ( "firstEdrxDownlink" ) ;
firstEdrxDownlinkField . setAccessible ( true ) ;
firstEdrxDownlinkField . setBoolean ( lwM2mClient , o . get ( "firstEdrxDownlink" ) . asBoolean ( ) ) ;
lwM2mClient . getRetryAttempts ( ) . set ( o . get ( "retryAttempts" ) . asInt ( ) ) ;
JsonValue lastSentRpcId = o . get ( "lastSentRpcId" ) ;
if ( lastSentRpcId ! = null ) {
lwM2mClient . setLastSentRpcId ( UUID . fromString ( lastSentRpcId . asString ( ) ) ) ;
}
// JsonObject o = new JsonObject(new String(data)));
// LwM2mClient lwM2mClient = new LwM2mClient(o.get("nodeId").getAsString(), o.get("endpoint").getAsString());
LwM2mClient lwM2mClient = new LwM2mClient ( "nodeId" , "endpoint" ) ;
// o.get("resources").getAsJsonObject().forEach(entry -> {
// JsonObject resource = entry.getValue().asObject();
// LwM2mResource lwM2mResource = parseLwM2mResource(resource.get("lwM2mResource").getAsJsonObject());
// ResourceModel resourceModel = parseResourceModel(resource.get("resourceModel").asObject());
// ResourceValue resourceValue = new ResourceValue(lwM2mResource, resourceModel);
// lwM2mClient.getResources().put(entry.getName(), resourceValue);
// });
//
// for (JsonObject.Member entry : o.get("sharedAttributes").asObject()) {
// TransportProtos.TsKvProto.Builder builder = TransportProtos.TsKvProto.newBuilder();
// JsonFormat.parser().merge(entry.getValue().getAsString(), builder);
// lwM2mClient.getSharedAttributes().put(entry.getName(), builder.build());
// }
//
// o.get("keyTsLatestMap").asObject().forEach(entry -> {
// lwM2mClient.getKeyTsLatestMap().put(entry.getName(), new AtomicLong(entry.getValue().asLong()));
// });
//
// lwM2mClient.setState(LwM2MClientState.valueOf(o.get("state").getAsString()));
//
// Class<LwM2mClient> lwM2mClientClass = LwM2mClient.class;
//
// JsonValue session = o.get("session");
// if (session != null) {
// TransportProtos.SessionInfoProto.Builder builder = TransportProtos.SessionInfoProto.newBuilder();
// JsonFormat.parser().merge(session.asString(), builder);
//
// Field sessionField = lwM2mClientClass.getDeclaredField("session");
// sessionField.setAccessible(true);
// sessionField.set(lwM2mClient, builder.build());
// }
//
// JsonValue tenantId = o.get("tenantId");
// if (tenantId != null) {
// Field tenantIdField = lwM2mClientClass.getDeclaredField("tenantId");
// tenantIdField.setAccessible(true);
// tenantIdField.set(lwM2mClient, new TenantId(UUID.fromString(tenantId.asString())));
// }
//
// JsonValue deviceId = o.get("deviceId");
// if (tenantId != null) {
// Field deviceIdField = lwM2mClientClass.getDeclaredField("deviceId");
// deviceIdField.setAccessible(true);
// deviceIdField.set(lwM2mClient, UUID.fromString(deviceId.asString()));
// }
//
// JsonValue profileId = o.get("profileId");
// if (tenantId != null) {
// Field profileIdField = lwM2mClientClass.getDeclaredField("profileId");
// profileIdField.setAccessible(true);
// profileIdField.set(lwM2mClient, UUID.fromString(profileId.asString()));
// }
//
// JsonValue powerMode = o.get("powerMode");
// if (powerMode != null) {
// Field powerModeField = lwM2mClientClass.getDeclaredField("powerMode");
// powerModeField.setAccessible(true);
// powerModeField.set(lwM2mClient, PowerMode.valueOf(powerMode.asString()));
// }
//
// JsonValue edrxCycle = o.get("edrxCycle");
// if (edrxCycle != null) {
// Field edrxCycleField = lwM2mClientClass.getDeclaredField("edrxCycle");
// edrxCycleField.setAccessible(true);
// edrxCycleField.set(lwM2mClient, edrxCycle.asLong());
// }
//
// JsonValue psmActivityTimer = o.get("psmActivityTimer");
// if (psmActivityTimer != null) {
// Field psmActivityTimerField = lwM2mClientClass.getDeclaredField("psmActivityTimer");
// psmActivityTimerField.setAccessible(true);
// psmActivityTimerField.set(lwM2mClient, psmActivityTimer.asLong());
// }
//
// JsonValue pagingTransmissionWindow = o.get("pagingTransmissionWindow");
// if (pagingTransmissionWindow != null) {
// Field pagingTransmissionWindowField = lwM2mClientClass.getDeclaredField("pagingTransmissionWindow");
// pagingTransmissionWindowField.setAccessible(true);
// pagingTransmissionWindowField.set(lwM2mClient, pagingTransmissionWindow.asLong());
// }
//
// JsonValue registration = o.get("registration");
// if (registration != null) {
// lwM2mClient.setRegistration(RegistrationSerDes.deserialize(registration.asObject()));
// }
//
// lwM2mClient.setAsleep(o.get("asleep").getAsBoolean());
//
// Field lastUplinkTimeField = lwM2mClientClass.getDeclaredField("lastUplinkTime");
// lastUplinkTimeField.setAccessible(true);
// lastUplinkTimeField.setLong(lwM2mClient, o.get("lastUplinkTime").asLong());
//
// Field firstEdrxDownlinkField = lwM2mClientClass.getDeclaredField("firstEdrxDownlink");
// firstEdrxDownlinkField.setAccessible(true);
// firstEdrxDownlinkField.setBoolean(lwM2mClient, o.get("firstEdrxDownlink").getAsBoolean());
//
// lwM2mClient.getRetryAttempts().set(o.get("retryAttempts").asInt());
//
// JsonValue lastSentRpcId = o.get("lastSentRpcId");
// if (lastSentRpcId != null) {
// lwM2mClient.setLastSentRpcId(UUID.fromString(lastSentRpcId.asString()));
// }
return lwM2mClient ;
}
nick
3 years ago