@ -54,6 +54,7 @@ import org.thingsboard.server.gen.transport.TransportProtos.AttributeUpdateNotif
import org.thingsboard.server.gen.transport.TransportProtos.SessionEvent ;
import org.thingsboard.server.gen.transport.TransportProtos.SessionEvent ;
import org.thingsboard.server.gen.transport.TransportProtos.SessionInfoProto ;
import org.thingsboard.server.gen.transport.TransportProtos.SessionInfoProto ;
import org.thingsboard.server.queue.util.TbLwM2mTransportComponent ;
import org.thingsboard.server.queue.util.TbLwM2mTransportComponent ;
import org.thingsboard.server.transport.lwm2m.config.LwM2MTransportServerConfig ;
import org.thingsboard.server.transport.lwm2m.server.client.LwM2mClient ;
import org.thingsboard.server.transport.lwm2m.server.client.LwM2mClient ;
import org.thingsboard.server.transport.lwm2m.server.client.LwM2mClientContext ;
import org.thingsboard.server.transport.lwm2m.server.client.LwM2mClientContext ;
import org.thingsboard.server.transport.lwm2m.server.client.LwM2mClientProfile ;
import org.thingsboard.server.transport.lwm2m.server.client.LwM2mClientProfile ;
@ -84,71 +85,71 @@ import static org.eclipse.californium.core.coap.CoAP.ResponseCode.BAD_REQUEST;
import static org.eclipse.leshan.core.attributes.Attribute.OBJECT_VERSION ;
import static org.eclipse.leshan.core.attributes.Attribute.OBJECT_VERSION ;
import static org.thingsboard.server.common.data.lwm2m.LwM2mConstants.LWM2M_SEPARATOR_KEY ;
import static org.thingsboard.server.common.data.lwm2m.LwM2mConstants.LWM2M_SEPARATOR_KEY ;
import static org.thingsboard.server.common.data.lwm2m.LwM2mConstants.LWM2M_SEPARATOR_PATH ;
import static org.thingsboard.server.common.data.lwm2m.LwM2mConstants.LWM2M_SEPARATOR_PATH ;
import static org.thingsboard.server.transport.lwm2m.server.LwM2mTransportHandler.CLIENT_NOT_AUTHORIZED ;
import static org.thingsboard.server.transport.lwm2m.server.LwM2mTransportHandlerUtil.CLIENT_NOT_AUTHORIZED ;
import static org.thingsboard.server.transport.lwm2m.server.LwM2mTransportHandler.DEVICE_ATTRIBUTES_REQUEST ;
import static org.thingsboard.server.transport.lwm2m.server.LwM2mTransportHandlerUtil.DEVICE_ATTRIBUTES_REQUEST ;
import static org.thingsboard.server.transport.lwm2m.server.LwM2mTransportHandler.FR_PATH_RESOURCE_VER_ID ;
import static org.thingsboard.server.transport.lwm2m.server.LwM2mTransportHandlerUtil.FR_OBJECT_ID ;
import static org.thingsboard.server.transport.lwm2m.server.LwM2mTransportHandler.LOG_LW2M_ERROR ;
import static org.thingsboard.server.transport.lwm2m.server.LwM2mTransportHandlerUtil.FR_PATH_RESOURCE_VER_ID ;
import static org.thingsboard.server.transport.lwm2m.server.LwM2mTransportHandler.LOG_LW2M_INFO ;
import static org.thingsboard.server.transport.lwm2m.server.LwM2mTransportHandlerUtil.LOG_LW2M_ERROR ;
import static org.thingsboard.server.transport.lwm2m.server.LwM2mTransportHandler.LOG_LW2M_VALUE ;
import static org.thingsboard.server.transport.lwm2m.server.LwM2mTransportHandlerUtil.LOG_LW2M_INFO ;
import static org.thingsboard.server.transport.lwm2m.server.LwM2mTransportHandler.LWM2M_STRATEGY_2 ;
import static org.thingsboard.server.transport.lwm2m.server.LwM2mTransportHandlerUtil.LOG_LW2M_VALUE ;
import static org.thingsboard.server.transport.lwm2m.server.LwM2mTransportHandler.LwM2mTypeOper ;
import static org.thingsboard.server.transport.lwm2m.server.LwM2mTransportHandlerUtil.LWM2M_STRATEGY_2 ;
import static org.thingsboard.server.transport.lwm2m.server.LwM2mTransportHandler.LwM2mTypeOper.DISCOVER ;
import static org.thingsboard.server.transport.lwm2m.server.LwM2mTransportHandlerUtil.LwM2mTypeOper ;
import static org.thingsboard.server.transport.lwm2m.server.LwM2mTransportHandler.LwM2mTypeOper.EXECUTE ;
import static org.thingsboard.server.transport.lwm2m.server.LwM2mTransportHandlerUtil.LwM2mTypeOper.DISCOVER ;
import static org.thingsboard.server.transport.lwm2m.server.LwM2mTransportHandler.LwM2mTypeOper.OBSERVE ;
import static org.thingsboard.server.transport.lwm2m.server.LwM2mTransportHandlerUtil.LwM2mTypeOper.EXECUTE ;
import static org.thingsboard.server.transport.lwm2m.server.LwM2mTransportHandler.LwM2mTypeOper.OBSERVE_CANCEL ;
import static org.thingsboard.server.transport.lwm2m.server.LwM2mTransportHandlerUtil.LwM2mTypeOper.OBSERVE ;
import static org.thingsboard.server.transport.lwm2m.server.LwM2mTransportHandler.LwM2mTypeOper.OBSERVE_READ_ALL ;
import static org.thingsboard.server.transport.lwm2m.server.LwM2mTransportHandlerUtil.LwM2mTypeOper.OBSERVE_CANCEL ;
import static org.thingsboard.server.transport.lwm2m.server.LwM2mTransportHandler.LwM2mTypeOper.READ ;
import static org.thingsboard.server.transport.lwm2m.server.LwM2mTransportHandlerUtil.LwM2mTypeOper.OBSERVE_READ_ALL ;
import static org.thingsboard.server.transport.lwm2m.server.LwM2mTransportHandler.LwM2mTypeOper.WRITE_ATTRIBUTES ;
import static org.thingsboard.server.transport.lwm2m.server.LwM2mTransportHandlerUtil.LwM2mTypeOper.READ ;
import static org.thingsboard.server.transport.lwm2m.server.LwM2mTransportHandler.LwM2mTypeOper.WRITE_REPLACE ;
import static org.thingsboard.server.transport.lwm2m.server.LwM2mTransportHandlerUtil.LwM2mTypeOper.WRITE_ATTRIBUTES ;
import static org.thingsboard.server.transport.lwm2m.server.LwM2mTransportHandler.LwM2mTypeOper.WRITE_UPDATE ;
import static org.thingsboard.server.transport.lwm2m.server.LwM2mTransportHandlerUtil.LwM2mTypeOper.WRITE_REPLACE ;
import static org.thingsboard.server.transport.lwm2m.server.LwM2mTransportHandler.SERVICE_CHANNEL ;
import static org.thingsboard.server.transport.lwm2m.server.LwM2mTransportHandlerUtil.LwM2mTypeOper.WRITE_UPDATE ;
import static org.thingsboard.server.transport.lwm2m.server.LwM2mTransportHandler.convertJsonArrayToSet ;
import static org.thingsboard.server.transport.lwm2m.server.LwM2mTransportHandlerUtil.SERVICE_CHANNEL ;
import static org.thingsboard.server.transport.lwm2m.server.LwM2mTransportHandler.convertPathFromIdVerToObjectId ;
import static org.thingsboard.server.transport.lwm2m.server.LwM2mTransportHandlerUtil.convertJsonArrayToSet ;
import static org.thingsboard.server.transport.lwm2m.server.LwM2mTransportHandler.convertPathFromObjectIdToIdVer ;
import static org.thingsboard.server.transport.lwm2m.server.LwM2mTransportHandlerUtil.convertPathFromIdVerToObjectId ;
import static org.thingsboard.server.transport.lwm2m.server.LwM2mTransportHandler.getAckCallback ;
import static org.thingsboard.server.transport.lwm2m.server.LwM2mTransportHandlerUtil.convertPathFromObjectIdToIdVer ;
import static org.thingsboard.server.transport.lwm2m.server.LwM2mTransportHandler.validateObjectVerFromKey ;
import static org.thingsboard.server.transport.lwm2m.server.LwM2mTransportHandlerUtil.getAckCallback ;
import static org.thingsboard.server.transport.lwm2m.server.LwM2mTransportHandlerUtil.validateObjectVerFromKey ;
@Slf4j
@Slf4j
@Service
@Service
@TbLwM2mTransportComponent
@TbLwM2mTransportComponent
public class LwM2mTransportServiceImpl implements LwM2mTransportService {
public class DefaultLwM2MTransportMsgHandler implements LwM2mTransportMsgHandler {
private ExecutorService executorRegistered ;
private ExecutorService executorRegistered ;
private ExecutorService executorUpdateRegistered ;
private ExecutorService executorUpdateRegistered ;
private ExecutorService executorUnRegistered ;
private ExecutorService executorUnRegistered ;
private LwM2mValueConverterImpl converter ;
private LwM2mValueConverterImpl converter ;
private FirmwareDataCache firmwareDataCache ;
private final TransportService transportService ;
private final TransportService transportService ;
private final LwM2mTransportContext context ;
public final LwM2mTransportContextServer lwM2mTransportContextServer ;
private final LwM2MTransportServerConfig config ;
private final FirmwareDataCache firmwareDataCache ;
private final LwM2mTransportServerHelper helper ;
private final LwM2mClientContext lwM2mClientContext ;
private final LwM2mClientContext lwM2mClientContext ;
private final LeshanServer leshanServer ;
private final LwM2mTransportRequest lwM2mTransportRequest ;
private final LwM2mTransportRequest lwM2mTransportRequest ;
public LwM2mTransportServiceImpl ( TransportService transportService , LwM2mTransportContextServer lwM2mTransportContextServer ,
public DefaultLwM2MTransportMsgHandler ( TransportService transportService , LwM2MTransportServerConfig config , LwM2mTransportServerHelper helper ,
LwM2mClientContext lwM2mClientContext , LeshanServer leshanServer ,
LwM2mClientContext lwM2mClientContext ,
@Lazy LwM2mTransportRequest lwM2mTransportRequest , FirmwareDataCache firmwareDataCache ) {
@Lazy LwM2mTransportRequest lwM2mTransportRequest ,
FirmwareDataCache firmwareDataCache ,
LwM2mTransportContext context ) {
this . transportService = transportService ;
this . transportService = transportService ;
this . lwM2mTransportContextServer = lwM2mTransportContextServer ;
this . config = config ;
this . helper = helper ;
this . lwM2mClientContext = lwM2mClientContext ;
this . lwM2mClientContext = lwM2mClientContext ;
this . leshanServer = leshanServer ;
this . lwM2mTransportRequest = lwM2mTransportRequest ;
this . lwM2mTransportRequest = lwM2mTransportRequest ;
this . firmwareDataCache = firmwareDataCache ;
this . firmwareDataCache = firmwareDataCache ;
this . context = context ;
}
}
@PostConstruct
@PostConstruct
public void init ( ) {
public void init ( ) {
this . lwM2mTransportContextServer . getScheduler ( ) . scheduleAtFixedRate ( this : : checkInactivityAndReportActivity , new Random ( ) . nextInt ( ( int ) lwM2mTransportContextServer . getLwM2MTransportC onfigServer ( ) . getSessionReportTimeout ( ) ) , lwM2mTransportContextServer . getLwM2MTransportC onfigServer ( ) . getSessionReportTimeout ( ) , TimeUnit . MILLISECONDS ) ;
this . context . getScheduler ( ) . scheduleAtFixedRate ( this : : checkInactivityAndReportActivity , new Random ( ) . nextInt ( ( int ) c onfig. getSessionReportTimeout ( ) ) , c onfig. getSessionReportTimeout ( ) , TimeUnit . MILLISECONDS ) ;
this . executorRegistered = Executors . newFixedThreadPool ( this . lwM2mTransportContextServer . getLwM2MTransportC onfigServer ( ) . getRegisteredPoolSize ( ) ,
this . executorRegistered = Executors . newFixedThreadPool ( this . c onfig. getRegisteredPoolSize ( ) ,
new NamedThreadFactory ( String . format ( "LwM2M %s channel registered" , SERVICE_CHANNEL ) ) ) ;
new NamedThreadFactory ( String . format ( "LwM2M %s channel registered" , SERVICE_CHANNEL ) ) ) ;
this . executorUpdateRegistered = Executors . newFixedThreadPool ( this . lwM2mTransportContextServer . getLwM2MTransportC onfigServer ( ) . getUpdateRegisteredPoolSize ( ) ,
this . executorUpdateRegistered = Executors . newFixedThreadPool ( this . c onfig. getUpdateRegisteredPoolSize ( ) ,
new NamedThreadFactory ( String . format ( "LwM2M %s channel update registered" , SERVICE_CHANNEL ) ) ) ;
new NamedThreadFactory ( String . format ( "LwM2M %s channel update registered" , SERVICE_CHANNEL ) ) ) ;
this . executorUnRegistered = Executors . newFixedThreadPool ( this . lwM2mTransportContextServer . getLwM2MTransportC onfigServer ( ) . getUnRegisteredPoolSize ( ) ,
this . executorUnRegistered = Executors . newFixedThreadPool ( this . c onfig. getUnRegisteredPoolSize ( ) ,
new NamedThreadFactory ( String . format ( "LwM2M %s channel un registered" , SERVICE_CHANNEL ) ) ) ;
new NamedThreadFactory ( String . format ( "LwM2M %s channel un registered" , SERVICE_CHANNEL ) ) ) ;
this . converter = LwM2mValueConverterImpl . getInstance ( ) ;
this . converter = LwM2mValueConverterImpl . getInstance ( ) ;
}
}
@ -278,10 +279,10 @@ public class LwM2mTransportServiceImpl implements LwM2mTransportService {
@Override
@Override
public void setCancelObservations ( Registration registration ) {
public void setCancelObservations ( Registration registration ) {
if ( registration ! = null ) {
if ( registration ! = null ) {
Set < Observation > observations = leshanServer . getObservationService ( ) . getObservations ( registration ) ;
Set < Observation > observations = context . getServer ( ) . getObservationService ( ) . getObservations ( registration ) ;
observations . forEach ( observation - > lwM2mTransportRequest . sendAllRequest ( registration ,
observations . forEach ( observation - > lwM2mTransportRequest . sendAllRequest ( registration ,
convertPathFromObjectIdToIdVer ( observation . getPath ( ) . toString ( ) , registration ) , OBSERVE_CANCEL ,
convertPathFromObjectIdToIdVer ( observation . getPath ( ) . toString ( ) , registration ) , OBSERVE_CANCEL ,
null , null , this . lwM2mTransportContextServer . getLwM2MTransportC onfigServer ( ) . getTimeout ( ) , null ) ) ;
null , null , this . c onfig. getTimeout ( ) , null ) ) ;
}
}
}
}
@ -333,12 +334,13 @@ public class LwM2mTransportServiceImpl implements LwM2mTransportService {
msg . getSharedUpdatedList ( ) . forEach ( tsKvProto - > {
msg . getSharedUpdatedList ( ) . forEach ( tsKvProto - > {
String pathName = tsKvProto . getKv ( ) . getKey ( ) ;
String pathName = tsKvProto . getKv ( ) . getKey ( ) ;
String pathIdVer = this . getPresentPathIntoProfile ( sessionInfo , pathName ) ;
String pathIdVer = this . getPresentPathIntoProfile ( sessionInfo , pathName ) ;
Object valueNew = this . lwM2mTransportContextServer . getValueFromKvProto ( tsKvProto . getKv ( ) ) ;
Object valueNew = this . helper . getValueFromKvProto ( tsKvProto . getKv ( ) ) ;
//TODO: react on change of the firmware name.
if ( FirmwareUtil . getAttributeKey ( FirmwareType . FIRMWARE , FirmwareKey . VERSION ) . equals ( pathName ) & & ! valueNew . equals ( lwM2MClient . getFrUpdate ( ) . getCurrentFwVersion ( ) ) ) {
if ( FirmwareUtil . getAttributeKey ( FirmwareType . FIRMWARE , FirmwareKey . VERSION ) . equals ( pathName ) & & ! valueNew . equals ( lwM2MClient . getFrUpdate ( ) . getCurrentFwVersion ( ) ) ) {
this . getInfoFirmwareUpdate ( lwM2MClient ) ;
this . getInfoFirmwareUpdate ( lwM2MClient ) ;
}
}
if ( pathIdVer ! = null ) {
if ( pathIdVer ! = null ) {
ResourceModel resourceModel = lwM2MClient . getResourceModel ( pathIdVer , this . lwM2mTransportContextServer . getLwM2MTransportC onfigServer ( )
ResourceModel resourceModel = lwM2MClient . getResourceModel ( pathIdVer , this . c onfig
. getModelProvider ( ) ) ;
. getModelProvider ( ) ) ;
if ( resourceModel ! = null & & resourceModel . operations . isWritable ( ) ) {
if ( resourceModel ! = null & & resourceModel . operations . isWritable ( ) ) {
this . updateResourcesValueToClient ( lwM2MClient , this . getResourceValueFormatKv ( lwM2MClient , pathIdVer ) , valueNew , pathIdVer ) ;
this . updateResourcesValueToClient ( lwM2MClient , this . getResourceValueFormatKv ( lwM2MClient , pathIdVer ) , valueNew , pathIdVer ) ;
@ -359,7 +361,7 @@ public class LwM2mTransportServiceImpl implements LwM2mTransportService {
} else if ( msg . getSharedDeletedCount ( ) > 0 ) {
} else if ( msg . getSharedDeletedCount ( ) > 0 ) {
msg . getSharedUpdatedList ( ) . forEach ( tsKvProto - > {
msg . getSharedUpdatedList ( ) . forEach ( tsKvProto - > {
String pathName = tsKvProto . getKv ( ) . getKey ( ) ;
String pathName = tsKvProto . getKv ( ) . getKey ( ) ;
Object valueNew = this . lwM2mTrans portContextServ er . getValueFromKvProto ( tsKvProto . getKv ( ) ) ;
Object valueNew = this . he lper. getValueFromKvProto ( tsKvProto . getKv ( ) ) ;
if ( FirmwareUtil . getAttributeKey ( FirmwareType . FIRMWARE , FirmwareKey . VERSION ) . equals ( pathName ) & & ! valueNew . equals ( lwM2MClient . getFrUpdate ( ) . getCurrentFwVersion ( ) ) ) {
if ( FirmwareUtil . getAttributeKey ( FirmwareType . FIRMWARE , FirmwareKey . VERSION ) . equals ( pathName ) & & ! valueNew . equals ( lwM2MClient . getFrUpdate ( ) . getCurrentFwVersion ( ) ) ) {
lwM2MClient . getFrUpdate ( ) . setCurrentFwVersion ( ( String ) valueNew ) ;
lwM2MClient . getFrUpdate ( ) . setCurrentFwVersion ( ( String ) valueNew ) ;
}
}
@ -403,7 +405,7 @@ public class LwM2mTransportServiceImpl implements LwM2mTransportService {
@Override
@Override
public void onResourceUpdate ( Optional < TransportProtos . ResourceUpdateMsg > resourceUpdateMsgOpt ) {
public void onResourceUpdate ( Optional < TransportProtos . ResourceUpdateMsg > resourceUpdateMsgOpt ) {
String idVer = resourceUpdateMsgOpt . get ( ) . getResourceKey ( ) ;
String idVer = resourceUpdateMsgOpt . get ( ) . getResourceKey ( ) ;
lwM2mClientContext . getLwM2mClients ( ) . values ( ) . stream ( ) . forEach ( e - > e . updateResourceModel ( idVer , this . lwM2mTransportContextServer . getLwM2MTransportC onfigServer ( ) . getModelProvider ( ) ) ) ;
lwM2mClientContext . getLwM2mClients ( ) . values ( ) . stream ( ) . forEach ( e - > e . updateResourceModel ( idVer , this . c onfig. getModelProvider ( ) ) ) ;
}
}
/ * *
/ * *
@ -412,7 +414,7 @@ public class LwM2mTransportServiceImpl implements LwM2mTransportService {
@Override
@Override
public void onResourceDelete ( Optional < TransportProtos . ResourceDeleteMsg > resourceDeleteMsgOpt ) {
public void onResourceDelete ( Optional < TransportProtos . ResourceDeleteMsg > resourceDeleteMsgOpt ) {
String pathIdVer = resourceDeleteMsgOpt . get ( ) . getResourceKey ( ) ;
String pathIdVer = resourceDeleteMsgOpt . get ( ) . getResourceKey ( ) ;
lwM2mClientContext . getLwM2mClients ( ) . values ( ) . stream ( ) . forEach ( e - > e . deleteResources ( pathIdVer , this . lwM2mTransportContextServer . getLwM2MTransportC onfigServer ( ) . getModelProvider ( ) ) ) ;
lwM2mClientContext . getLwM2mClients ( ) . values ( ) . stream ( ) . forEach ( e - > e . deleteResources ( pathIdVer , this . c onfig. getModelProvider ( ) ) ) ;
}
}
@Override
@Override
@ -428,7 +430,7 @@ public class LwM2mTransportServiceImpl implements LwM2mTransportService {
} else {
} else {
lwM2mTransportRequest . sendAllRequest ( registration , lwm2mClientRpcRequest . getTargetIdVer ( ) , lwm2mClientRpcRequest . getTypeOper ( ) , lwm2mClientRpcRequest . getContentFormatName ( ) ,
lwM2mTransportRequest . sendAllRequest ( registration , lwm2mClientRpcRequest . getTargetIdVer ( ) , lwm2mClientRpcRequest . getTypeOper ( ) , lwm2mClientRpcRequest . getContentFormatName ( ) ,
lwm2mClientRpcRequest . getValue ( ) = = null ? lwm2mClientRpcRequest . getParams ( ) : lwm2mClientRpcRequest . getValue ( ) ,
lwm2mClientRpcRequest . getValue ( ) = = null ? lwm2mClientRpcRequest . getParams ( ) : lwm2mClientRpcRequest . getValue ( ) ,
this . lwM2mTransportContextServer . getLwM2MTransportC onfigServer ( ) . getTimeout ( ) , lwm2mClientRpcRequest ) ;
this . c onfig. getTimeout ( ) , lwm2mClientRpcRequest ) ;
}
}
} catch ( Exception e ) {
} catch ( Exception e ) {
if ( lwm2mClientRpcRequest = = null ) {
if ( lwm2mClientRpcRequest = = null ) {
@ -456,7 +458,7 @@ public class LwM2mTransportServiceImpl implements LwM2mTransportService {
lwm2mClientRpcRequest . setRequestId ( toDeviceRequest . getRequestId ( ) ) ;
lwm2mClientRpcRequest . setRequestId ( toDeviceRequest . getRequestId ( ) ) ;
lwm2mClientRpcRequest . setSessionInfo ( sessionInfo ) ;
lwm2mClientRpcRequest . setSessionInfo ( sessionInfo ) ;
lwm2mClientRpcRequest . setValidTypeOper ( toDeviceRequest . getMethodName ( ) ) ;
lwm2mClientRpcRequest . setValidTypeOper ( toDeviceRequest . getMethodName ( ) ) ;
JsonObject rpcRequest = LwM2mTransportHandler . validateJson ( toDeviceRequest . getParams ( ) ) ;
JsonObject rpcRequest = LwM2mTransportHandlerUtil . validateJson ( toDeviceRequest . getParams ( ) ) ;
if ( rpcRequest ! = null ) {
if ( rpcRequest ! = null ) {
if ( rpcRequest . has ( lwm2mClientRpcRequest . keyNameKey ) ) {
if ( rpcRequest . has ( lwm2mClientRpcRequest . keyNameKey ) ) {
String targetIdVer = this . getPresentPathIntoProfile ( sessionInfo ,
String targetIdVer = this . getPresentPathIntoProfile ( sessionInfo ,
@ -545,7 +547,7 @@ public class LwM2mTransportServiceImpl implements LwM2mTransportService {
@Override
@Override
public void doTrigger ( Registration registration , String path ) {
public void doTrigger ( Registration registration , String path ) {
lwM2mTransportRequest . sendAllRequest ( registration , path , EXECUTE ,
lwM2mTransportRequest . sendAllRequest ( registration , path , EXECUTE ,
ContentFormat . TLV . getName ( ) , null , this . lwM2mTransportContextServer . getLwM2MTransportC onfigServer ( ) . getTimeout ( ) , null ) ;
ContentFormat . TLV . getName ( ) , null , this . c onfig. getTimeout ( ) , null ) ;
}
}
/ * *
/ * *
@ -578,7 +580,8 @@ public class LwM2mTransportServiceImpl implements LwM2mTransportService {
*
*
* @param registration -
* @param registration -
* /
* /
protected void onAwakeDev ( Registration registration ) {
@Override
public void onAwakeDev ( Registration registration ) {
log . info ( "[{}] [{}] Received endpoint Awake version event" , registration . getId ( ) , registration . getEndpoint ( ) ) ;
log . info ( "[{}] [{}] Received endpoint Awake version event" , registration . getId ( ) , registration . getEndpoint ( ) ) ;
this . sendLogsToThingsboard ( LOG_LW2M_INFO + ": Client is awake!" , registration . getId ( ) ) ;
this . sendLogsToThingsboard ( LOG_LW2M_INFO + ": Client is awake!" , registration . getId ( ) ) ;
//TODO: associate endpointId with device information.
//TODO: associate endpointId with device information.
@ -609,10 +612,14 @@ public class LwM2mTransportServiceImpl implements LwM2mTransportService {
* @param logMsg - text msg
* @param logMsg - text msg
* @param registrationId - Id of Registration LwM2M Client
* @param registrationId - Id of Registration LwM2M Client
* /
* /
@Override
public void sendLogsToThingsboard ( String logMsg , String registrationId ) {
public void sendLogsToThingsboard ( String logMsg , String registrationId ) {
SessionInfoProto sessionInfo = this . getValidateSessionInfo ( registrationId ) ;
SessionInfoProto sessionInfo = this . getValidateSessionInfo ( registrationId ) ;
if ( logMsg ! = null & & sessionInfo ! = null ) {
if ( logMsg ! = null & & sessionInfo ! = null ) {
this . lwM2mTransportContextServer . sendParametersOnThingsboardTelemetry ( this . lwM2mTransportContextServer . getKvLogyToThingsboard ( logMsg ) , sessionInfo ) ;
if ( logMsg . length ( ) > 1024 ) {
logMsg = logMsg . substring ( 0 , 1024 ) ;
}
this . helper . sendParametersOnThingsboardTelemetry ( this . helper . getKvLogyToThingsboard ( logMsg ) , sessionInfo ) ;
}
}
}
}
@ -632,11 +639,11 @@ public class LwM2mTransportServiceImpl implements LwM2mTransportService {
LwM2mClientProfile lwM2MClientProfile = lwM2mClientContext . getProfile ( registration ) ;
LwM2mClientProfile lwM2MClientProfile = lwM2mClientContext . getProfile ( registration ) ;
Set < String > clientObjects = lwM2mClientContext . getSupportedIdVerInClient ( registration ) ;
Set < String > clientObjects = lwM2mClientContext . getSupportedIdVerInClient ( registration ) ;
if ( clientObjects ! = null & & clientObjects . size ( ) > 0 ) {
if ( clientObjects ! = null & & clientObjects . size ( ) > 0 ) {
if ( LWM2M_STRATEGY_2 = = LwM2mTransportHandler . getClientOnlyObserveAfterConnect ( lwM2MClientProfile ) ) {
if ( LWM2M_STRATEGY_2 = = LwM2mTransportHandlerUtil . getClientOnlyObserveAfterConnect ( lwM2MClientProfile ) ) {
// #2
// #2
lwM2MClient . getPendingReadRequests ( ) . addAll ( clientObjects ) ;
lwM2MClient . getPendingReadRequests ( ) . addAll ( clientObjects ) ;
clientObjects . forEach ( path - > lwM2mTransportRequest . sendAllRequest ( registration , path , READ , ContentFormat . TLV . getName ( ) ,
clientObjects . forEach ( path - > lwM2mTransportRequest . sendAllRequest ( registration , path , READ , ContentFormat . TLV . getName ( ) ,
null , this . lwM2mTransportContextServer . getLwM2MTransportC onfigServer ( ) . getTimeout ( ) , null ) ) ;
null , this . c onfig. getTimeout ( ) , null ) ) ;
}
}
// #1
// #1
this . initReadAttrTelemetryObserveToClient ( registration , lwM2MClient , READ , clientObjects ) ;
this . initReadAttrTelemetryObserveToClient ( registration , lwM2MClient , READ , clientObjects ) ;
@ -685,7 +692,7 @@ public class LwM2mTransportServiceImpl implements LwM2mTransportService {
* /
* /
private void updateResourcesValue ( Registration registration , LwM2mResource lwM2mResource , String path ) {
private void updateResourcesValue ( Registration registration , LwM2mResource lwM2mResource , String path ) {
LwM2mClient lwM2MClient = lwM2mClientContext . getLwM2mClientWithReg ( registration , null ) ;
LwM2mClient lwM2MClient = lwM2mClientContext . getLwM2mClientWithReg ( registration , null ) ;
if ( lwM2MClient . saveResourceValue ( path , lwM2mResource , this . lwM2mTransportContextServer . getLwM2MTransportC onfigServer ( )
if ( lwM2MClient . saveResourceValue ( path , lwM2mResource , this . c onfig
. getModelProvider ( ) ) ) {
. getModelProvider ( ) ) ) {
if ( FR_PATH_RESOURCE_VER_ID . equals ( convertPathFromIdVerToObjectId ( path ) ) & &
if ( FR_PATH_RESOURCE_VER_ID . equals ( convertPathFromIdVerToObjectId ( path ) ) & &
lwM2MClient . getFrUpdate ( ) . getCurrentFwVersion ( ) ! = null
lwM2MClient . getFrUpdate ( ) . getCurrentFwVersion ( ) ! = null
@ -724,10 +731,10 @@ public class LwM2mTransportServiceImpl implements LwM2mTransportService {
SessionInfoProto sessionInfo = this . getValidateSessionInfo ( registration ) ;
SessionInfoProto sessionInfo = this . getValidateSessionInfo ( registration ) ;
if ( results ! = null & & sessionInfo ! = null ) {
if ( results ! = null & & sessionInfo ! = null ) {
if ( results . getResultAttributes ( ) . size ( ) > 0 ) {
if ( results . getResultAttributes ( ) . size ( ) > 0 ) {
this . lwM2mTrans portContextServ er . sendParametersOnThingsboardAttribute ( results . getResultAttributes ( ) , sessionInfo ) ;
this . he lper. sendParametersOnThingsboardAttribute ( results . getResultAttributes ( ) , sessionInfo ) ;
}
}
if ( results . getResultTelemetries ( ) . size ( ) > 0 ) {
if ( results . getResultTelemetries ( ) . size ( ) > 0 ) {
this . lwM2mTrans portContextServ er . sendParametersOnThingsboardTelemetry ( results . getResultTelemetries ( ) , sessionInfo ) ;
this . he lper. sendParametersOnThingsboardTelemetry ( results . getResultTelemetries ( ) , sessionInfo ) ;
}
}
}
}
} catch ( Exception e ) {
} catch ( Exception e ) {
@ -776,7 +783,7 @@ public class LwM2mTransportServiceImpl implements LwM2mTransportService {
ConcurrentHashMap < String , Object > finalParams = params ;
ConcurrentHashMap < String , Object > finalParams = params ;
pathSend . forEach ( target - > {
pathSend . forEach ( target - > {
lwM2mTransportRequest . sendAllRequest ( registration , target , typeOper , ContentFormat . TLV . getName ( ) ,
lwM2mTransportRequest . sendAllRequest ( registration , target , typeOper , ContentFormat . TLV . getName ( ) ,
finalParams ! = null ? finalParams . get ( target ) : null , this . lwM2mTransportContextServer . getLwM2MTransportC onfigServer ( ) . getTimeout ( ) , null ) ;
finalParams ! = null ? finalParams . get ( target ) : null , this . c onfig. getTimeout ( ) , null ) ;
} ) ;
} ) ;
if ( OBSERVE . equals ( typeOper ) ) {
if ( OBSERVE . equals ( typeOper ) ) {
lwM2MClient . initReadValue ( this , null ) ;
lwM2MClient . initReadValue ( this , null ) ;
@ -861,7 +868,7 @@ public class LwM2mTransportServiceImpl implements LwM2mTransportService {
LwM2mResource resourceValue = lwM2MClient ! = null ? getResourceValueFromLwM2MClient ( lwM2MClient , pathIdVer ) : null ;
LwM2mResource resourceValue = lwM2MClient ! = null ? getResourceValueFromLwM2MClient ( lwM2MClient , pathIdVer ) : null ;
if ( resourceValue ! = null ) {
if ( resourceValue ! = null ) {
ResourceModel . Type currentType = resourceValue . getType ( ) ;
ResourceModel . Type currentType = resourceValue . getType ( ) ;
ResourceModel . Type expectedType = this . lwM2mTrans portContextServ er . getResourceModelTypeEqualsKvProtoValueType ( currentType , pathIdVer ) ;
ResourceModel . Type expectedType = this . he lper. getResourceModelTypeEqualsKvProtoValueType ( currentType , pathIdVer ) ;
Object valueKvProto = null ;
Object valueKvProto = null ;
if ( resourceValue . isMultiInstances ( ) ) {
if ( resourceValue . isMultiInstances ( ) ) {
valueKvProto = new JsonObject ( ) ;
valueKvProto = new JsonObject ( ) ;
@ -878,7 +885,7 @@ public class LwM2mTransportServiceImpl implements LwM2mTransportService {
valueKvProto = this . converter . convertValue ( resourceValue . getValue ( ) , currentType , expectedType ,
valueKvProto = this . converter . convertValue ( resourceValue . getValue ( ) , currentType , expectedType ,
new LwM2mPath ( convertPathFromIdVerToObjectId ( pathIdVer ) ) ) ;
new LwM2mPath ( convertPathFromIdVerToObjectId ( pathIdVer ) ) ) ;
}
}
return valueKvProto ! = null ? this . lwM2mTrans portContextServ er . getKvAttrTelemetryToThingsboard ( currentType , resourceName , valueKvProto , resourceValue . isMultiInstances ( ) ) : null ;
return valueKvProto ! = null ? this . he lper. getKvAttrTelemetryToThingsboard ( currentType , resourceName , valueKvProto , resourceValue . isMultiInstances ( ) ) : null ;
}
}
} catch ( Exception e ) {
} catch ( Exception e ) {
log . error ( "Failed to add parameters." , e ) ;
log . error ( "Failed to add parameters." , e ) ;
@ -897,7 +904,7 @@ public class LwM2mTransportServiceImpl implements LwM2mTransportService {
private Object getResourceValueFormatKv ( LwM2mClient lwM2MClient , String pathIdVer ) {
private Object getResourceValueFormatKv ( LwM2mClient lwM2MClient , String pathIdVer ) {
LwM2mResource resourceValue = this . getResourceValueFromLwM2MClient ( lwM2MClient , pathIdVer ) ;
LwM2mResource resourceValue = this . getResourceValueFromLwM2MClient ( lwM2MClient , pathIdVer ) ;
ResourceModel . Type currentType = resourceValue . getType ( ) ;
ResourceModel . Type currentType = resourceValue . getType ( ) ;
ResourceModel . Type expectedType = this . lwM2mTrans portContextServ er . getResourceModelTypeEqualsKvProtoValueType ( currentType , pathIdVer ) ;
ResourceModel . Type expectedType = this . he lper. getResourceModelTypeEqualsKvProtoValueType ( currentType , pathIdVer ) ;
return this . converter . convertValue ( resourceValue . getValue ( ) , currentType , expectedType ,
return this . converter . convertValue ( resourceValue . getValue ( ) , currentType , expectedType ,
new LwM2mPath ( convertPathFromIdVerToObjectId ( pathIdVer ) ) ) ;
new LwM2mPath ( convertPathFromIdVerToObjectId ( pathIdVer ) ) ) ;
}
}
@ -1090,10 +1097,10 @@ public class LwM2mTransportServiceImpl implements LwM2mTransportService {
if ( pathIds . isResource ( ) ) {
if ( pathIds . isResource ( ) ) {
if ( READ . equals ( typeOper ) ) {
if ( READ . equals ( typeOper ) ) {
lwM2mTransportRequest . sendAllRequest ( registration , target , typeOper ,
lwM2mTransportRequest . sendAllRequest ( registration , target , typeOper ,
ContentFormat . TLV . getName ( ) , null , this . lwM2mTransportContextServer . getLwM2MTransportC onfigServer ( ) . getTimeout ( ) , null ) ;
ContentFormat . TLV . getName ( ) , null , this . c onfig. getTimeout ( ) , null ) ;
} else if ( OBSERVE . equals ( typeOper ) ) {
} else if ( OBSERVE . equals ( typeOper ) ) {
lwM2mTransportRequest . sendAllRequest ( registration , target , typeOper ,
lwM2mTransportRequest . sendAllRequest ( registration , target , typeOper ,
null , null , this . lwM2mTransportContextServer . getLwM2MTransportC onfigServer ( ) . getTimeout ( ) , null ) ;
null , null , this . c onfig. getTimeout ( ) , null ) ;
}
}
}
}
} ) ;
} ) ;
@ -1149,7 +1156,7 @@ public class LwM2mTransportServiceImpl implements LwM2mTransportService {
if ( ! pathSend . isEmpty ( ) ) {
if ( ! pathSend . isEmpty ( ) ) {
ConcurrentHashMap < String , Object > finalParams = lwm2mAttributesNew ;
ConcurrentHashMap < String , Object > finalParams = lwm2mAttributesNew ;
pathSend . forEach ( target - > lwM2mTransportRequest . sendAllRequest ( registration , target , WRITE_ATTRIBUTES , ContentFormat . TLV . getName ( ) ,
pathSend . forEach ( target - > lwM2mTransportRequest . sendAllRequest ( registration , target , WRITE_ATTRIBUTES , ContentFormat . TLV . getName ( ) ,
finalParams . get ( target ) , this . lwM2mTransportContextServer . getLwM2MTransportC onfigServer ( ) . getTimeout ( ) , null ) ) ;
finalParams . get ( target ) , this . c onfig. getTimeout ( ) , null ) ) ;
}
}
} ) ;
} ) ;
}
}
@ -1166,7 +1173,7 @@ public class LwM2mTransportServiceImpl implements LwM2mTransportService {
params . clear ( ) ;
params . clear ( ) ;
params . put ( OBJECT_VERSION , "" ) ;
params . put ( OBJECT_VERSION , "" ) ;
lwM2mTransportRequest . sendAllRequest ( registration , target , WRITE_ATTRIBUTES , ContentFormat . TLV . getName ( ) ,
lwM2mTransportRequest . sendAllRequest ( registration , target , WRITE_ATTRIBUTES , ContentFormat . TLV . getName ( ) ,
params , this . lwM2mTransportContextServer . getLwM2MTransportC onfigServer ( ) . getTimeout ( ) , null ) ;
params , this . c onfig. getTimeout ( ) , null ) ;
} ) ;
} ) ;
}
}
} ) ;
} ) ;
@ -1179,7 +1186,7 @@ public class LwM2mTransportServiceImpl implements LwM2mTransportService {
paramAnallyzer . forEach ( pathIdVer - > {
paramAnallyzer . forEach ( pathIdVer - > {
if ( this . getResourceValueFromLwM2MClient ( lwM2MClient , pathIdVer ) ! = null ) {
if ( this . getResourceValueFromLwM2MClient ( lwM2MClient , pathIdVer ) ! = null ) {
lwM2mTransportRequest . sendAllRequest ( registration , pathIdVer , OBSERVE_CANCEL , null ,
lwM2mTransportRequest . sendAllRequest ( registration , pathIdVer , OBSERVE_CANCEL , null ,
null , this . lwM2mTransportContextServer . getLwM2MTransportC onfigServer ( ) . getTimeout ( ) , null ) ;
null , this . c onfig. getTimeout ( ) , null ) ;
}
}
}
}
) ;
) ;
@ -1189,7 +1196,7 @@ public class LwM2mTransportServiceImpl implements LwM2mTransportService {
if ( valueNew ! = null & & ( valueOld = = null | | ! valueNew . toString ( ) . equals ( valueOld . toString ( ) ) ) ) {
if ( valueNew ! = null & & ( valueOld = = null | | ! valueNew . toString ( ) . equals ( valueOld . toString ( ) ) ) ) {
lwM2mTransportRequest . sendAllRequest ( lwM2MClient . getRegistration ( ) , path , WRITE_REPLACE ,
lwM2mTransportRequest . sendAllRequest ( lwM2MClient . getRegistration ( ) , path , WRITE_REPLACE ,
ContentFormat . TLV . getName ( ) , valueNew ,
ContentFormat . TLV . getName ( ) , valueNew ,
this . lwM2mTransportContextServer . getLwM2MTransportC onfigServer ( ) . getTimeout ( ) , null ) ;
this . c onfig. getTimeout ( ) , null ) ;
} else {
} else {
log . error ( "Failed update resource [{}] [{}]" , path , valueNew ) ;
log . error ( "Failed update resource [{}] [{}]" , path , valueNew ) ;
String logMsg = String . format ( "%s: Failed update resource path - %s value - %s. Value is not changed or bad" ,
String logMsg = String . format ( "%s: Failed update resource path - %s value - %s. Value is not changed or bad" ,
@ -1267,7 +1274,7 @@ public class LwM2mTransportServiceImpl implements LwM2mTransportService {
// #2.1
// #2.1
lwM2MClient . getDelayedRequests ( ) . forEach ( ( pathIdVer , tsKvProto ) - > {
lwM2MClient . getDelayedRequests ( ) . forEach ( ( pathIdVer , tsKvProto ) - > {
this . updateResourcesValueToClient ( lwM2MClient , this . getResourceValueFormatKv ( lwM2MClient , pathIdVer ) ,
this . updateResourcesValueToClient ( lwM2MClient , this . getResourceValueFormatKv ( lwM2MClient , pathIdVer ) ,
this . lwM2mTrans portContextServ er . getValueFromKvProto ( tsKvProto . getKv ( ) ) , pathIdVer ) ;
this . he lper. getValueFromKvProto ( tsKvProto . getKv ( ) ) , pathIdVer ) ;
} ) ;
} ) ;
}
}
@ -1284,7 +1291,7 @@ public class LwM2mTransportServiceImpl implements LwM2mTransportService {
return null ;
return null ;
} else {
} else {
return SessionInfoProto . newBuilder ( )
return SessionInfoProto . newBuilder ( )
. setNodeId ( this . lwM2mTransportContextServer . getNodeId ( ) )
. setNodeId ( this . context . getNodeId ( ) )
. setSessionIdMSB ( lwM2MClient . getSessionId ( ) . getMostSignificantBits ( ) )
. setSessionIdMSB ( lwM2MClient . getSessionId ( ) . getMostSignificantBits ( ) )
. setSessionIdLSB ( lwM2MClient . getSessionId ( ) . getLeastSignificantBits ( ) )
. setSessionIdLSB ( lwM2MClient . getSessionId ( ) . getLeastSignificantBits ( ) )
. setDeviceIdMSB ( msg . getDeviceInfo ( ) . getDeviceIdMSB ( ) )
. setDeviceIdMSB ( msg . getDeviceInfo ( ) . getDeviceIdMSB ( ) )
@ -1354,7 +1361,7 @@ public class LwM2mTransportServiceImpl implements LwM2mTransportService {
if ( keyNamesMap . values ( ) . size ( ) > 0 ) {
if ( keyNamesMap . values ( ) . size ( ) > 0 ) {
try {
try {
//#1.2
//#1.2
TransportProtos . GetAttributeRequestMsg getAttributeMsg = lwM2mTrans portContextServ er . getAdaptor ( ) . convertToGetAttributes ( null , keyNamesMap . values ( ) ) ;
TransportProtos . GetAttributeRequestMsg getAttributeMsg = he lper. getAdaptor ( ) . convertToGetAttributes ( null , keyNamesMap . values ( ) ) ;
transportService . process ( sessionInfo , getAttributeMsg , getAckCallback ( lwM2MClient , getAttributeMsg . getRequestId ( ) , DEVICE_ATTRIBUTES_REQUEST ) ) ;
transportService . process ( sessionInfo , getAttributeMsg , getAckCallback ( lwM2MClient , getAttributeMsg . getRequestId ( ) , DEVICE_ATTRIBUTES_REQUEST ) ) ;
} catch ( AdaptorException e ) {
} catch ( AdaptorException e ) {
log . warn ( "Failed to decode get attributes request" , e ) ;
log . warn ( "Failed to decode get attributes request" , e ) ;
@ -1372,6 +1379,7 @@ public class LwM2mTransportServiceImpl implements LwM2mTransportService {
. setDeviceIdLSB ( sessionInfo . getDeviceIdLSB ( ) )
. setDeviceIdLSB ( sessionInfo . getDeviceIdLSB ( ) )
. setTenantIdMSB ( sessionInfo . getTenantIdMSB ( ) )
. setTenantIdMSB ( sessionInfo . getTenantIdMSB ( ) )
. setTenantIdLSB ( sessionInfo . getTenantIdLSB ( ) )
. setTenantIdLSB ( sessionInfo . getTenantIdLSB ( ) )
. setType ( FirmwareType . FIRMWARE . name ( ) )
. build ( ) ;
. build ( ) ;
transportService . process ( sessionInfo , getFirmwareRequestMsg ,
transportService . process ( sessionInfo , getFirmwareRequestMsg ,
new TransportServiceCallback < > ( ) {
new TransportServiceCallback < > ( ) {
@ -1401,7 +1409,7 @@ public class LwM2mTransportServiceImpl implements LwM2mTransportService {
public void readRequestToClientFirmwareVer ( Registration registration ) {
public void readRequestToClientFirmwareVer ( Registration registration ) {
String pathIdVer = convertPathFromObjectIdToIdVer ( FR_PATH_RESOURCE_VER_ID , registration ) ;
String pathIdVer = convertPathFromObjectIdToIdVer ( FR_PATH_RESOURCE_VER_ID , registration ) ;
lwM2mTransportRequest . sendAllRequest ( registration , pathIdVer , READ , ContentFormat . TLV . getName ( ) ,
lwM2mTransportRequest . sendAllRequest ( registration , pathIdVer , READ , ContentFormat . TLV . getName ( ) ,
null , lwM2mTransportContextServer . getLwM2MTransportC onfigServer ( ) . getTimeout ( ) , null ) ;
null , c onfig. getTimeout ( ) , null ) ;
}
}
/ * *
/ * *
@ -1413,11 +1421,10 @@ public class LwM2mTransportServiceImpl implements LwM2mTransportService {
int chunkSize = 0 ;
int chunkSize = 0 ;
int chunk = 0 ;
int chunk = 0 ;
byte [ ] firmwareChunk = firmwareDataCache . get ( lwM2MClient . getFrUpdate ( ) . getCurrentFwId ( ) . toString ( ) , chunkSize , chunk ) ;
byte [ ] firmwareChunk = firmwareDataCache . get ( lwM2MClient . getFrUpdate ( ) . getCurrentFwId ( ) . toString ( ) , chunkSize , chunk ) ;
Integer objectId = 5 ;
String verSupportedObject = lwM2MClient . getRegistration ( ) . getSupportedObject ( ) . get ( FR_OBJECT_ID ) ;
String verSupportedObject = lwM2MClient . getRegistration ( ) . getSupportedObject ( ) . get ( objectId ) ;
String targetIdVer = LWM2M_SEPARATOR_PATH + FR_OBJECT_ID + LWM2M_SEPARATOR_KEY + verSupportedObject + LWM2M_SEPARATOR_PATH + 0 + LWM2M_SEPARATOR_PATH + 0 ;
String targetIdVer = LWM2M_SEPARATOR_PATH + objectId + LWM2M_SEPARATOR_KEY + verSupportedObject + LWM2M_SEPARATOR_PATH + 0 + LWM2M_SEPARATOR_PATH + 0 ;
lwM2mTransportRequest . sendAllRequest ( lwM2MClient . getRegistration ( ) , targetIdVer , WRITE_REPLACE , ContentFormat . OPAQUE . getName ( ) ,
lwM2mTransportRequest . sendAllRequest ( lwM2MClient . getRegistration ( ) , targetIdVer , WRITE_REPLACE , ContentFormat . TLV . getName ( ) ,
firmwareChunk , config . getTimeout ( ) , null ) ;
firmwareChunk , lwM2mTransportContextServer . getLwM2MTransportConfigServer ( ) . getTimeout ( ) , null ) ;
log . warn ( "updateFirmwareClient [{}] [{}]" , lwM2MClient . getFrUpdate ( ) . getCurrentFwVersion ( ) , lwM2MClient . getFrUpdate ( ) . getClientFwVersion ( ) ) ;
log . warn ( "updateFirmwareClient [{}] [{}]" , lwM2MClient . getFrUpdate ( ) . getCurrentFwVersion ( ) , lwM2MClient . getFrUpdate ( ) . getClientFwVersion ( ) ) ;
}
}
}
}
@ -1439,7 +1446,7 @@ public class LwM2mTransportServiceImpl implements LwM2mTransportService {
}
}
private boolean validateResourceInModel ( LwM2mClient lwM2mClient , String pathIdVer , boolean isWritableNotOptional ) {
private boolean validateResourceInModel ( LwM2mClient lwM2mClient , String pathIdVer , boolean isWritableNotOptional ) {
ResourceModel resourceModel = lwM2mClient . getResourceModel ( pathIdVer , this . lwM2mTransportContextServer . getLwM2MTransportC onfigServer ( )
ResourceModel resourceModel = lwM2mClient . getResourceModel ( pathIdVer , this . c onfig
. getModelProvider ( ) ) ;
. getModelProvider ( ) ) ;
Integer objectId = new LwM2mPath ( convertPathFromIdVerToObjectId ( pathIdVer ) ) . getObjectId ( ) ;
Integer objectId = new LwM2mPath ( convertPathFromIdVerToObjectId ( pathIdVer ) ) . getObjectId ( ) ;
String objectVer = validateObjectVerFromKey ( pathIdVer ) ;
String objectVer = validateObjectVerFromKey ( pathIdVer ) ;
@ -1448,9 +1455,4 @@ public class LwM2mTransportServiceImpl implements LwM2mTransportService {
objectId ! = null & & objectVer ! = null & & objectVer . equals ( lwM2mClient . getRegistration ( ) . getSupportedVersion ( objectId ) ) ) ;
objectId ! = null & & objectVer ! = null & & objectVer . equals ( lwM2mClient . getRegistration ( ) . getSupportedVersion ( objectId ) ) ) ;
}
}
@Override
public String getName ( ) {
return "LWM2M" ;
}
}
}