.

src/hos_cosgi_testwebapp/webroot/libs/hos/DeviceRepo.js

@@ -0,0 +1,42 @@
+define([
+	"dojo/_base/config",
+	"dojo/store/JsonRest",
+	'dojo/store/Observable',
+	"dojox/socket",
+	"dojo/_base/xhr"
+], function(config, JsonRest, Observable, Socket, xhr){
+	var _store = new Observable(new JsonRest({
+		target: config.hos.deviceRepoUrl
+	}));
+	var _updateSocketOpened = false;
+	var _updateSocket = new Socket({ 
+			url: config.hos.deviceRepoUrl,
+			headers: {
+				"On-Event": "changes",
+				"Connection-Timeout": 60000,
+				"Client-Id": 1234
+			},
+			transport: xhr.get });
+	_updateSocket.on("open", function(event){
+			_socketOpened = true;
+			console.log("Socket Opened ", event.message);
+		});
+	_updateSocket.on("close", function(event){
+			_socketOpened = false;
+			console.log("Socket Closed ", event.message);
+		});
+	_updateSocket.on("error", function(event){
+			_socketOpened = false;
+			console.log("Socket Error ", event.message);
+		});
+	_updateSocket.on("message", function(event) {
+			var data = JSON.parse(event.data);
+			switch (data['eventtype']) {
+			  case "statechanged":
+			    _store.notify(data['device'], data['deviceid']);
+			    break;
+			}
+			console.log("Message: " + data);
+		});
+	return _store;
+});