shaba/awx
1
0
Fork 0
mirror of https://github.com/ansible/awx.git synced 2024-11-02 09:51:09 +03:00
Code Releases Activity

adding more console.logs for socket debugging

Browse Source
This commit is contained in:
Jared Tabor 2017-09-15 14:10:42 -07:00 committed by Jared Tabor
parent 50d6981695
commit b593adcf84
2 changed files with 11 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
awx/ui/client/src/app.js
View File

@ -146,7 +146,8 @@ var awApp = angular.module('awApp', [
.constant('AngularScheduler.showUTCField', true) .constant('AngularScheduler.showUTCField', true)
.constant('$timezones.definitions.location', urlPrefix + 'lib/angular-tz-extensions/tz/data') .constant('$timezones.definitions.location', urlPrefix + 'lib/angular-tz-extensions/tz/data')
.config(['$logProvider', function($logProvider) { .config(['$logProvider', function($logProvider) {
$logProvider.debugEnabled($ENV['ng-debug'] || false); // $logProvider.debugEnabled($ENV['ng-debug'] || false);
$logProvider.debugEnabled(true);
}]) }])
.config(['ngToastProvider', function(ngToastProvider) { .config(['ngToastProvider', function(ngToastProvider) {
ngToastProvider.configure({ ngToastProvider.configure({

12
awx/ui/client/src/shared/socket/socket.service.js
View File

@ -27,7 +27,7 @@ export default
if (!$rootScope.sessionTimer || ($rootScope.sessionTimer && !$rootScope.sessionTimer.isExpired())) { if (!$rootScope.sessionTimer || ($rootScope.sessionTimer && !$rootScope.sessionTimer.isExpired())) {
$log.debug('Socket connecting to: ' + url); $log.debug('Socket connecting to: ' + url);
console.log("prior to new ReconnectingWebSocket..., self.socket is: " + self.socket);
self.socket = new ReconnectingWebSocket(url, null, { self.socket = new ReconnectingWebSocket(url, null, {
timeoutInterval: 3000, timeoutInterval: 3000,
maxReconnectAttempts: 10 }); maxReconnectAttempts: 10 });
@ -77,6 +77,9 @@ export default
$log.debug('Received From Server: ' + e.data); $log.debug('Received From Server: ' + e.data);
var data = JSON.parse(e.data), str = ""; var data = JSON.parse(e.data), str = "";
if(_.has(data, "accept") && data.accept === true){
console.log('handshake message received from server. readyState: '+ this.readyState, data);
}
if(data.group_name==="jobs" && !('status' in data)){ if(data.group_name==="jobs" && !('status' in data)){
// we know that this must have been a // we know that this must have been a
// summary complete message b/c status is missing. // summary complete message b/c status is missing.
@ -126,8 +129,11 @@ export default
// listen for specific messages. A subscription object could // listen for specific messages. A subscription object could
// look like {"groups":{"jobs": ["status_changed", "summary"]}. // look like {"groups":{"jobs": ["status_changed", "summary"]}.
// This is used by all socket-enabled $states // This is used by all socket-enabled $states
this.emit(JSON.stringify(state.data.socket)); let self = this;
this.setLast(state); socketPromise.promise.then(function(){
self.emit(JSON.stringify(state.data.socket));
self.setLast(state);
});
}, },
unsubscribe: function(state){ unsubscribe: function(state){
// Unsubscribing tells the API that the user is no longer on // Unsubscribing tells the API that the user is no longer on