<%
var user = session.get('user');
var streamId;

var log = new Log();

var JaggeryWebSocketHelper = Packages.org.wso2.carbon.event.output.adapter.ui.JaggeryWebSocketHelper;

webSocket.onopen = function () {
    var ws = this;
	var user = session.get('user');
    if (user != null) {
        log.info('Tenant : ' + user.tenantId);
        this.send("message from server");
//        this.onclose();
    }

	if (user == null) {
		ws.close();
		log.info('User is null. closing the connection');
	}
};

webSocket.ontext = function (data) {
    log.info("subscribed. data: " + data);
	streamId = data;
	JaggeryWebSocketHelper.subscribeWebSocket(data.split(":")[0], data.split(":")[1],session.getId(), this, user.tenantId);
};

//webSocket.onbinary = function (stream) {
//    log.info('Client Streamed : ' + stream.toString());
//};

webSocket.onclose = function () {
//    log.info('Closed connection with Websocket client. Stream ID: ' + streamId + ', Tenant ID: ' + user.tenantId + ', Session ID: ' + session.getId());
    JaggeryWebSocketHelper.unsubscribeWebsocket(streamId.split(":")[0], streamId.split(":")[1],session.getId(), user.tenantId);
};

webSocket.onerror = function () {
//    log.info('Error occured in the connection with Websocket client. Stream ID: ' + streamId + ', Tenant ID: ' + user.tenantId + ', Session ID: ' + session.getId());
    JaggeryWebSocketHelper.unsubscribeWebsocket(streamId.split(":")[0], streamId.split(":")[1],session.getId(), user.tenantId);
};

%>