value = listITF.get(0);
}
- for (String deviceId : deviceList) {
+ for (String deviceId : deviceList) {
if(key != null && value != null){
foundResList = DBManager.getInstance().findResourceAboutDiAndFilter(deviceId,
key, value);
- } else {
+ } else {
foundResList = DBManager.getInstance().findResourceAboutDi(deviceId);
}
-
+
if (foundResList != null) {
resourceList.add(makeDiscoveryPayloadSegment(foundResList));
}
ArrayList<HashMap<Object, Object>> responseMapList = new ArrayList<HashMap<Object, Object>>();
for (DiscoveryPayload discoveryPayload : discoveryPayloadList) {
- HashMap<Object, Object> responseSegment = null;
+
DiscoveryTags tags = discoveryPayload.getTags();
- responseSegment = mDiscoveryTagsTypeManager
+
+ HashMap<Object, Object> responseSegment = mDiscoveryTagsTypeManager
.convertObjectToMap(tags);
ArrayList<DiscoveryLinks> discoveryLinksList = discoveryPayload
break;
default:
- throw new BadRequestException(
- request.getMethod() + " request type is not supported");
+ throw new BadRequestException(request.getMethod()
+ + " request type is not supported");
}
srcDevice.sendResponse(response);
for (String deviceId : deviceList) {
HashMap<String, String> payloadSegment = new HashMap<String, String>();
payloadSegment.put(Constants.DEVICE_ID, deviceId);
- payloadSegment.put(Constants.PRESENCE_STATE,
- DBManager.getInstance().findDeviceState(deviceId));
+ payloadSegment.put(Constants.PRESENCE_STATE, DBManager
+ .getInstance().findDeviceState(deviceId));
getPayload.add(payloadSegment);
}
for (String deviceId : deviceList) {
HashMap<String, String> payloadSegment = new HashMap<String, String>();
payloadSegment.put(Constants.DEVICE_ID, deviceId);
- payloadSegment.put(Constants.PRESENCE_STATE,
- DBManager.getInstance().findDeviceState(deviceId));
+ payloadSegment.put(Constants.PRESENCE_STATE, DBManager
+ .getInstance().findDeviceState(deviceId));
getPayload.add(payloadSegment);
}
Log.i("Get observe response" + getPayload.toString());
mCbor.encodingPayloadToCbor(getPayload));
}
- public IResponse handlePostRequest(IRequest request)
- throws ServerException {
+ public IResponse handlePostRequest(IRequest request) throws ServerException {
// check payload
byte[] payload = request.getPayload();
- HashMap<String, Object> parsedPayload = mCbor
- .parsePayloadFromCbor(payload, HashMap.class);
+ if (payload == null) {
+ throw new PreconditionFailedException("payload is null");
+ }
+
+ HashMap<String, Object> parsedPayload = mCbor.parsePayloadFromCbor(
+ payload, HashMap.class);
+
+ checkPayloadException(
+ Arrays.asList(Constants.DEVICE_ID, Constants.PRESENCE_STATE),
+ parsedPayload);
+
String deviceId = parsedPayload.get(Constants.DEVICE_ID).toString();
String state = parsedPayload.get(Constants.PRESENCE_STATE).toString();
DeviceState deviceState = new DeviceState();
mDeviceSubscriber.put(deviceId, subscribers);
}
- subscribers.put(request.getRequestId(),
- new PresenceSubscriber(srcDevice, request));
+ subscribers.put(request.getRequestId(), new PresenceSubscriber(
+ srcDevice, request));
}
mSubscribedDevices.put(request.getRequestId(), deviceIdList);
private void removeObserver(IRequest request) {
- List<String> deviceIdList = mSubscribedDevices
- .get(request.getRequestId());
+ List<String> deviceIdList = mSubscribedDevices.get(request
+ .getRequestId());
if (deviceIdList == null) {
return;
if (tokenNSubscribers != null) {
for (PresenceSubscriber subscriber : tokenNSubscribers.values()) {
- subscriber.mSubscriber.sendResponse(
- MessageBuilder.createResponse(subscriber.mRequest,
+ subscriber.mSubscriber.sendResponse(MessageBuilder
+ .createResponse(subscriber.mRequest,
ResponseStatus.CONTENT,
ContentFormat.APPLICATION_CBOR,
mCbor.encodingPayloadToCbor(response)));