mirror of
https://github.com/ZwareBear/awx.git
synced 2026-04-15 12:31:48 -05:00
2961d5150f
Job submission now removes the spinner once the job is started. It is also 'socket aware'. In the event the socket connection is unavailable on SCM updates and inventory sync runs it prompts the user with a dialog letting them know to hit the refresh button. Came up with a way to 'monitor' socket connections. On the main connection and on the Jobs page connecgtions we now check the connection every 3 seconds. If the connection status is error, or if the status returns 'connnecting' 2x in a row, we kill and restart the connections.
167 lines
7.8 KiB
JavaScript
167 lines
7.8 KiB
JavaScript
/**************************************************
|
|
* Copyright (c) 2014 AnsibleWorks, Inc.
|
|
*
|
|
* Socket.js
|
|
*
|
|
* Wrapper for lib/socket.io-client/dist/socket.io.js.
|
|
*/
|
|
|
|
/* global io */
|
|
|
|
'use strict';
|
|
|
|
angular.module('SocketIO', ['AuthService', 'Utilities'])
|
|
|
|
.factory('Socket', ['$rootScope', '$location', '$log', 'Authorization', function ($rootScope, $location, $log, Authorization) {
|
|
return function(params) {
|
|
var scope = params.scope,
|
|
host = $location.host(),
|
|
endpoint = params.endpoint,
|
|
protocol = $location.protocol(),
|
|
url = protocol + '://' + host + ':' + $AnsibleConfig.websocket_port + '/socket.io/' + endpoint;
|
|
|
|
function getSocketTip(status) {
|
|
var result = '';
|
|
switch(status) {
|
|
case 'error':
|
|
result = "There was an error connecting to the websocket server. Click for troubleshooting help.";
|
|
break;
|
|
case 'connecting':
|
|
result = "Attempting to connect to the websocket server. Click for troubleshooting help.";
|
|
break;
|
|
case "ok":
|
|
result = "Connected to the websocket server. Pages containing job status information for playbook runs, SCM updates and inventory " +
|
|
"sync processes will automatically update in real-time.";
|
|
}
|
|
return result;
|
|
}
|
|
|
|
return {
|
|
scope: scope,
|
|
url: url,
|
|
socket: null,
|
|
init: function() {
|
|
var self = this,
|
|
token = Authorization.getToken();
|
|
if (!$rootScope.sessionTimer.isExpired()) {
|
|
// We have a valid session token, so attmempt socket connection
|
|
$log.debug('Socket connecting to: ' + url);
|
|
self.scope.socket_url = url;
|
|
self.socket = io.connect(url, { headers:
|
|
{
|
|
'Authorization': 'Token ' + token,
|
|
'X-Auth-Token': 'Token ' + token
|
|
},
|
|
'connect timeout': 3000,
|
|
'try multiple transports': false,
|
|
'max reconneciton attemps': 3,
|
|
'reconnection limit': 3000,
|
|
});
|
|
self.socket.on('connection', function() {
|
|
$log.debug('Socket connecting...');
|
|
self.scope.$apply(function () {
|
|
self.scope.socketStatus = 'connecting';
|
|
self.scope.socketTip = getSocketTip(self.scope.socketStatus);
|
|
});
|
|
});
|
|
self.socket.on('connect', function() {
|
|
$log.debug('Socket connection established');
|
|
self.scope.$apply(function () {
|
|
self.scope.socketStatus = 'ok';
|
|
self.scope.socketTip = getSocketTip(self.scope.socketStatus);
|
|
});
|
|
});
|
|
self.socket.on('connect_failed', function(reason) {
|
|
var r = reason || 'connection refused by host';
|
|
$log.error('Socket connection failed: ' + r);
|
|
self.scope.$apply(function () {
|
|
self.scope.socketStatus = 'error';
|
|
self.scope.socketTip = getSocketTip(self.scope.socketStatus);
|
|
});
|
|
|
|
});
|
|
self.socket.on('diconnect', function() {
|
|
$log.debug('Socket disconnected');
|
|
self.scope.$apply(function() {
|
|
self.socketStatus = 'error';
|
|
self.scope.socketTip = getSocketTip(self.scope.socketStatus);
|
|
});
|
|
});
|
|
self.socket.on('error', function(reason) {
|
|
var r = reason || 'connection refused by host';
|
|
$log.debug('Socket error: ' + r);
|
|
self.scope.$apply(function() {
|
|
self.scope.socketStatus = 'error';
|
|
self.scope.socketTip = getSocketTip(self.scope.socketStatus);
|
|
});
|
|
});
|
|
self.socket.on('reconnecting', function() {
|
|
$log.debug('Socket attempting reconnect...');
|
|
self.scope.$apply(function() {
|
|
self.scope.socketStatus = 'connecting';
|
|
self.scope.socketTip = getSocketTip(self.scope.socketStatus);
|
|
});
|
|
});
|
|
self.socket.on('reconnect', function() {
|
|
$log.debug('Socket reconnected');
|
|
self.scope.$apply(function() {
|
|
self.scope.socketStatus = 'ok';
|
|
self.scope.socketTip = getSocketTip(self.scope.socketStatus);
|
|
});
|
|
});
|
|
self.socket.on('reconnect_failed', function(reason) {
|
|
$log.error('Socket reconnect failed: ' + reason);
|
|
self.scope.$apply(function() {
|
|
self.scope.socketStatus = 'error';
|
|
self.scope.socketTip = getSocketTip(self.scope.socketStatus);
|
|
});
|
|
});
|
|
}
|
|
else {
|
|
// encountered expired token, redirect to login page
|
|
$rootScope.sessionTimer.expireSession();
|
|
$location.url('/login');
|
|
}
|
|
},
|
|
checkStatus: function() {
|
|
// Check connection status
|
|
var self = this;
|
|
if (self.socket.socket.connected) {
|
|
self.scope.socketStatus = 'ok';
|
|
}
|
|
else if (self.socket.socket.connecting || self.socket.socket.reconnecting) {
|
|
self.scope.socketStatus = 'connecting';
|
|
}
|
|
else {
|
|
self.scope.socketStatus = 'error';
|
|
}
|
|
self.scope.socketTip = getSocketTip(self.scope.socketStatus);
|
|
return self.scope.socketStatus;
|
|
},
|
|
on: function (eventName, callback) {
|
|
var self = this;
|
|
self.socket.on(eventName, function () {
|
|
var args = arguments;
|
|
self.scope.$apply(function () {
|
|
callback.apply(self.socket, args);
|
|
});
|
|
});
|
|
},
|
|
emit: function (eventName, data, callback) {
|
|
var self = this;
|
|
self.socket.emit(eventName, data, function () {
|
|
var args = arguments;
|
|
self.scope.$apply(function () {
|
|
if (callback) {
|
|
callback.apply(self.socket, args);
|
|
}
|
|
});
|
|
});
|
|
},
|
|
getUrl: function() {
|
|
return url;
|
|
}
|
|
};
|
|
};
|
|
}]);
|