private static final String DEVICE_NAME = "name";
private static final String DEVICE_TYPE = "type";
private static final String DEVICE_MODEL = "model";
+ private static final String DEVICE_MODE = "mode";
private static final String POLICY = "policy";
/**
* @return boolean boolean
*/
public static boolean deviceRegistrationInDSM(String duid, String uuid, String name, String type, String model,
- String parentUuid) {
+ String parentUuid, String mode) {
Map<String, String> messageMap = new HashMap<>();
Cbor<HashMap<String, String>> cbor = new Cbor<>();
messageMap.put(DUID, duid);
messageMap.put(DEVICE_TYPE, type);
messageMap.put(DEVICE_MODEL, model);
messageMap.put(DEVICE_PARENT_UUID, parentUuid);
+ messageMap.put(DEVICE_MODE, mode);
LOG.info("Device registration: " + messageMap);
byte[] data = cbor.encodingPayloadToCbor(messageMap);
return publishMessage(REG_TOPIC, data);
private static final String DEVICE_DUID_HUB = "hub-000000-1111-2222-3333-4444444444444";
private static final String DEVICE_NAME = "TV";
private static final String DEVICE_TYPE = "tv";
- private static final String KIND = "standard";
- private static final String KIND_HUB = "hub";
+ private static final String DEVICE_MODE1 = "standard";
+ private static final String DEVICE_MODE2 = "hub";
private static final String DEVICE_MODEL = "UE32M5500AUXUA";
private static final String DEVICE_PARENT_DUID = "55555555-6666-7777-8888-999999999999";
private static final String DEVICE_UNREGISTER_ACTION = "unregister";
private void registerDevice(String uuid) {
log("Device registration");
assertTrue(MQPublisherAPI
- .deviceRegistrationInDSM(DEVICE_DUID, uuid, DEVICE_NAME, DEVICE_TYPE, KIND+":"+DEVICE_MODEL, DEVICE_PARENT_DUID));
+ .deviceRegistrationInDSM(DEVICE_DUID, uuid, DEVICE_NAME, DEVICE_TYPE,DEVICE_MODEL, DEVICE_PARENT_DUID, DEVICE_MODE1));
}
private void registerHubDevice(String uuid) {
log("Device registration");
assertTrue(MQPublisherAPI
- .deviceRegistrationInDSM(DEVICE_DUID_HUB, uuid, DEVICE_NAME, DEVICE_TYPE, KIND_HUB+":"+DEVICE_MODEL, DEVICE_PARENT_DUID));
+ .deviceRegistrationInDSM(DEVICE_DUID_HUB, uuid, DEVICE_NAME, DEVICE_TYPE, DEVICE_MODEL, DEVICE_PARENT_DUID, DEVICE_MODE2));
}
private void checkDevice() {
private static final String DEVICE_TYPE = "tv";
private static final String DEVICE_PHONE_NAME = "Phone";
private static final String DEVICE_PHONE_TYPE = "phone";
- private static final String DEVICE_MODEL = "standard:UE32M5500AUXUA";
+ private static final String DEVICE_MODEL = "UE32M5500AUXUA";
+ private static final String DEVICE_MODE = "standard";
private static final String DEVICE_PARENT_DUID = "55555555-6666-7777-8888-999999999999";
private static final String DEVICE_UNREGISTER_ACTION = "unregister";
private static final String MAIN_TOPIC = ".oic.ps.";
private void registerDevice(String uuid) {
log("Device registration");
assertTrue(MQPublisherAPI
- .deviceRegistrationInDSM(DEVICE_DUID, uuid, DEVICE_NAME, DEVICE_TYPE, DEVICE_MODEL, DEVICE_PARENT_DUID));
+ .deviceRegistrationInDSM(DEVICE_DUID, uuid, DEVICE_NAME, DEVICE_TYPE, DEVICE_MODEL, DEVICE_PARENT_DUID, DEVICE_MODE));
}
private void registerPhoneDevice(String uuid) {
log("Device registration");
assertTrue(MQPublisherAPI
- .deviceRegistrationInDSM(DEVICE_DUID, uuid, DEVICE_PHONE_NAME, DEVICE_PHONE_TYPE, DEVICE_MODEL, DEVICE_PARENT_DUID));
+ .deviceRegistrationInDSM(DEVICE_DUID, uuid, DEVICE_PHONE_NAME, DEVICE_PHONE_TYPE, DEVICE_MODEL, DEVICE_PARENT_DUID, DEVICE_MODE));
}
private String readChangedPolicy() throws IOException {
private static final String DEVICE_DUID = "00000000-1111-2222-3333-4444444444444";
private static final String DEVICE_NAME = "TV";
private static final String DEVICE_TYPE = "tv";
- private static final String DEVICE_MODEL = "standard:UE32M5500AUXUA";
+ private static final String DEVICE_MODEL = "UE32M5500AUXUA";
+ private static final String DEVICE_MODE = "standard";
private static final String DEVICE_PARENT_DUID = "55555555-6666-7777-8888-999999999999";
private static final String DEVICE_UNREGISTER_ACTION = "unregister";
private static final String MAIN_TOPIC = ".oic.ps.";
private void registerDevice(String uuid) {
log("Device registration");
assertTrue(MQPublisherAPI
- .deviceRegistrationInDSM(DEVICE_DUID, uuid, DEVICE_NAME, DEVICE_TYPE, DEVICE_MODEL, DEVICE_PARENT_DUID));
+ .deviceRegistrationInDSM(DEVICE_DUID, uuid, DEVICE_NAME, DEVICE_TYPE, DEVICE_MODEL, DEVICE_PARENT_DUID, DEVICE_MODE));
}
private void checkReports() {
private static final String DEVICE_DUID = "00000000-1111-2222-3333-4444444444444";
private static final String DEVICE_NAME = "TV";
private static final String DEVICE_TYPE = "tv";
- private static final String DEVICE_MODEL = "standard:UE32M5500AUXUA";
+ private static final String DEVICE_MODEL = "UE32M5500AUXUA";
+ private static final String DEVICE_MODE = "standard";
private static final String DEVICE_PARENT_DUID = "55555555-6666-7777-8888-999999999999";
private static final String DEVICE_UNREGISTER_ACTION = "unregister";
private static final String MAIN_TOPIC = ".oic.ps.";
private void registerDevice(String uuid) {
log("Device registration");
assertTrue(MQPublisherAPI
- .deviceRegistrationInDSM(DEVICE_DUID, uuid, DEVICE_NAME, DEVICE_TYPE, DEVICE_MODEL, DEVICE_PARENT_DUID));
+ .deviceRegistrationInDSM(DEVICE_DUID, uuid, DEVICE_NAME, DEVICE_TYPE, DEVICE_MODEL, DEVICE_PARENT_DUID, DEVICE_MODE));
}
private void checkReports() {
private static final String DEVICE_NAME = "TV";
private static final String DEVICE_TYPE = "tv";
- private static final String DEVICE_MODEL = "standard:UE32M5500AUXUA";
+ private static final String DEVICE_MODEL = "UE32M5500AUXUA";
+ private static final String DEVICE_MODE = "standard";
private static final String DEVICE_PARENT_DUID = "TIA-55555555-6666-7777-8888-999999999999";
/**
private void registerDevice(String uuid) {
log("Device registration");
assertTrue(MQPublisherAPI
- .deviceRegistrationInDSM(DEVICE_DUID, uuid, DEVICE_NAME, DEVICE_TYPE, DEVICE_MODEL, DEVICE_PARENT_DUID));
+ .deviceRegistrationInDSM(DEVICE_DUID, uuid, DEVICE_NAME, DEVICE_TYPE, DEVICE_MODEL, DEVICE_PARENT_DUID, DEVICE_MODE));
}
private void checkReportSize(Response resp, int size) {
private static final String DEVICE_UNREGISTER_ACTION = "unregister";
private static final String DEVICE_NAME = "TV";
private static final String DEVICE_TYPE = "tv";
- private static final String DEVICE_MODEL1 = "standard:old";
- private static final String DEVICE_MODEL2 = "hub:new";
+ private static final String DEVICE_MODEL1 = "old";
+ private static final String DEVICE_MODEL2 = "new";
+ private static final String DEVICE_MODE1 = "standard";
+ private static final String DEVICE_MODE2 = "hub";
private static final String DEVICE_PARENT_DUID = "D-55555555-6666-7777-8888-999999999999";
@BeforeAll
private void registerDevices(String uuid) {
log("Device registration");
assertTrue(MQPublisherAPI
- .deviceRegistrationInDSM(DEVICE_DUID1, uuid, DEVICE_NAME, DEVICE_TYPE, DEVICE_MODEL1, DEVICE_PARENT_DUID));
+ .deviceRegistrationInDSM(DEVICE_DUID1, uuid, DEVICE_NAME, DEVICE_TYPE, DEVICE_MODEL1, DEVICE_PARENT_DUID, DEVICE_MODE1));
assertTrue(MQPublisherAPI
- .deviceRegistrationInDSM(DEVICE_DUID2, uuid, DEVICE_NAME, DEVICE_TYPE, DEVICE_MODEL2, DEVICE_PARENT_DUID));
+ .deviceRegistrationInDSM(DEVICE_DUID2, uuid, DEVICE_NAME, DEVICE_TYPE, DEVICE_MODEL2, DEVICE_PARENT_DUID, DEVICE_MODE2));
}
private void unregisterDevices() {
"1": {
"date": "12:25 PM; May 08, 2017",
"syscall": "5",
- "gid": "100",
- "fsgid": "100",
- "pid": "1005",
- "suid": "5001",
"type": "dac",
- "uid": "5001",
- "egid": "100",
- "exe": "/usr/bin/ls",
- "sgid": "100",
"per": "800000",
- "subj": "User::Shell",
- "ses": "4294967295",
- "auid": "4294967295",
- "comm": "ls",
- "euid": "5001",
"a0": "b7e3c6a0",
- "ppid": "1001",
- "a1": "a4800",
- "fsuid": "5001",
"exit": "-13",
- "a2": "b6ef84d0",
- "a3": "2f",
"success": "no",
- "tty": "pts1",
- "arch": "40000028",
- "items": "1"
+ "arch": "40000028"
}
}
\ No newline at end of file
String uid = MessageQueueUtils.extractDataFromPayload(data, MessageQueueKeys.UUID.getKey());
String name = MessageQueueUtils.extractDataFromPayload(data, MessageQueueKeys.DEVICE_NAME.getKey());
String type = MessageQueueUtils.extractDataFromPayload(data, MessageQueueKeys.DEVICE_TYPE.getKey());
- String str = MessageQueueUtils.extractDataFromPayload(data, MessageQueueKeys.DEVICE_MODEL.getKey());
+ String model = MessageQueueUtils.extractDataFromPayload(data, MessageQueueKeys.DEVICE_MODEL.getKey());
+ String mode = MessageQueueUtils.extractDataFromPayload(data, MessageQueueKeys.DEVICE_MODE.getKey());
String parentUuid = MessageQueueUtils
.extractDataFromPayload(data, MessageQueueKeys.DEVICE_PARENT_UUID.getKey());
- String model;
- String kind;
- int hasParts = str.indexOf(":");
- if (hasParts > -1) {
- String[] parts = str.split(":");
- model = parts[1];
- kind = parts[0];
- }
- else {
- model = str;
- kind ="";
- }
LOG.debug("New device with params : did = " + did + ", uid = " + uid + ", device type = " + name
- + ", model = " + model + ", parentUuid = " + parentUuid);
+ + ", model = " + model
+ + ", mode = " + mode
+ + ", parentUuid = " + parentUuid);
User user = iotCloudService.findAssociatedUserByUuid(uid);
- Device device = deviceService.init(did, name, type, model, 1, user, parentUuid, kind);
+ Device device = deviceService.init(did, name, type, model, 1, user, parentUuid, mode);
// TODO: remove or update after Agent functionality implementation
// TODO: test Agent registration for all new devices
String testAgentUuid = did + name.hashCode();
* Device model message queue keys.
*/
DEVICE_MODEL("model"),
+
+ DEVICE_MODE("mode"),
+
/**
* Policy message queue keys.
*/