diff --git a/awx/ui/client/features/output/index.controller.js b/awx/ui/client/features/output/index.controller.js index a0e9b6bd1d..bad00f5542 100644 --- a/awx/ui/client/features/output/index.controller.js +++ b/awx/ui/client/features/output/index.controller.js @@ -119,6 +119,7 @@ function clear () { function processWebSocketEvents (scope, data) { meta.scroll.inProgress = true; + console.log(data); append([data]) .then(() => { container[0].scrollTop = container[0].scrollHeight; diff --git a/awx/ui/client/features/output/index.js b/awx/ui/client/features/output/index.js index 927217f350..c67122d148 100644 --- a/awx/ui/client/features/output/index.js +++ b/awx/ui/client/features/output/index.js @@ -47,33 +47,45 @@ function resolveResource (Job, ProjectUpdate, AdHocCommand, SystemJob, WorkflowJ page_size: 100, order_by: 'start_line' } - })) - .catch(err => { - console.error(err); - }); + })); } function resolveWebSocket (SocketService, $stateParams) { + const { type, id } = $stateParams; const prefix = 'ws'; - const { id } = $stateParams; - const { type } = $stateParams; let name; + let events; switch (type) { - case 'playbook': - name = 'job_events'; + case 'system': + name = 'system_jobs'; + events = 'system_job_events'; + break; + case 'project': + name = 'project_updates'; + events = 'project_update_events'; + break; + case 'command': + name = 'ad_hoc_commands'; + events = 'ad_hoc_command_events'; + break; + case 'inventory': + name = 'inventory_updates'; + events = 'inventory_update_events'; + break; + case 'playbook': + name = 'jobs'; + events = 'job_events'; break; - default: - name = 'events'; } const state = { data: { socket: { groups: { - jobs: ['status_changed', 'summary'], - [name]: [] + [name]: ['status_changed', 'summary'], + [events]: [] } } } @@ -81,7 +93,7 @@ function resolveWebSocket (SocketService, $stateParams) { SocketService.addStateResolve(state, id); - return `${prefix}-${name}-${id}`; + return `${prefix}-${events}-${id}`; } function resolveBreadcrumb (strings) { diff --git a/awx/ui/client/src/shared/socket/socket.service.js b/awx/ui/client/src/shared/socket/socket.service.js index 7c390d0cba..b26dae58d7 100644 --- a/awx/ui/client/src/shared/socket/socket.service.js +++ b/awx/ui/client/src/shared/socket/socket.service.js @@ -90,12 +90,18 @@ export default // ex: 'ws-jobs-' str = `ws-${data.group_name}-${data.job}`; } + else if(data.group_name==="project_update_events"){ + str = `ws-${data.group_name}-${data.project_update}`; + } else if(data.group_name==="ad_hoc_command_events"){ - // The naming scheme is "ws" then a - // dash (-) and the group_name, then the job ID - // ex: 'ws-jobs-' str = `ws-${data.group_name}-${data.ad_hoc_command}`; } + else if(data.group_name==="system_job_events"){ + str = `ws-${data.group_name}-${data.system_job}`; + } + else if(data.group_name==="inventory_update_events"){ + str = `ws-${data.group_name}-${data.inventory_update}`; + } else if(data.group_name==="control"){ // As of v. 3.1.0, there is only 1 "control" // message, which is for expiring the session if the