a6f8b283e0
deleted: dump.rdb modified: config/socket.io.js new file: dump.rdb modified: package.json modified: public/dist/application.js modified: public/dist/application.min.js modified: public/modules/core/services/socket.io.client.service.js modified: public/modules/forms/directives/analytics-service.client.directive.js deleted: dump.rdb
55 lines
1.1 KiB
JavaScript
55 lines
1.1 KiB
JavaScript
(function () {
|
|
'use strict';
|
|
|
|
// Create the Socket.io wrapper service
|
|
angular
|
|
.module('core')
|
|
.factory('Socket', Socket);
|
|
|
|
Socket.$inject = ['$timeout', '$window'];
|
|
|
|
function Socket($timeout, $window) {
|
|
var service = {
|
|
connect: connect,
|
|
emit: emit,
|
|
on: on,
|
|
removeListener: removeListener,
|
|
socket: null
|
|
};
|
|
|
|
connect(window.location.protocol+'//'+window.location.hostname+':'+$window.socketPort);
|
|
|
|
return service;
|
|
|
|
// Connect to Socket.io server
|
|
function connect(url) {
|
|
service.socket = io(url, {'transports': ['websocket', 'polling']});
|
|
}
|
|
|
|
// Wrap the Socket.io 'emit' method
|
|
function emit(eventName, data) {
|
|
if (service.socket) {
|
|
service.socket.emit(eventName, data);
|
|
}
|
|
}
|
|
|
|
// Wrap the Socket.io 'on' method
|
|
function on(eventName, callback) {
|
|
if (service.socket) {
|
|
service.socket.on(eventName, function (data) {
|
|
$timeout(function () {
|
|
callback(data);
|
|
});
|
|
});
|
|
}
|
|
}
|
|
|
|
// Wrap the Socket.io 'removeListener' method
|
|
function removeListener(eventName) {
|
|
if (service.socket) {
|
|
service.socket.removeListener(eventName);
|
|
}
|
|
}
|
|
}
|
|
}());
|