External-Mirrors/awx
2
0
Fork 0
mirror of https://github.com/ansible/awx.git synced 2026-05-06 17:07:36 -02:30
Code Issues Packages Projects Releases Wiki Activity

Job events subscription form- subscribe to events for a specific job.

Browse Source
This commit is contained in:
Chris Houseknecht
2014-04-18 13:52:06 -04:00
parent 210b1dce2e
commit af830ee50d
1 changed files with 26 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

26
awx/ui/static/js/controllers/Sockets.js
View File

@@ -38,6 +38,23 @@ function SocketsController ($scope, $compile, ClearScope, Socket) {
e = angular.element(document.getElementById('jobs-container')); e = angular.element(document.getElementById('jobs-container'));
e.append(html); e.append(html);
$compile(e)(jobs_scope); $compile(e)(jobs_scope);
html = "<div class=\"alert alert-info\"><strong>Socket url</strong>: {{ socket_url }} &nbsp;<strong>Status:</strong> {{ socket_status }} {{ socket_reason }}</div>\n" +
"<form class=\"form-inline\">\n" +
"<div class=\"form-group\">\n" +
"<label for=\"job_id\">Job Id</label>\n" +
"<input type=\"text\" name=\"job_id\" id=\"job_id\" ng-model=\"job_id\" class=\"input-sm form-control\">\n" +
"</div>\n" +
"<button type=\"submit\" ng-disabled=\"!job_id\" ng-click=\"subscribeToJobEvent()\" class=\"btn btn-sm btn-primary\"><i class=\"fa fa-check\"></i> Subscribe</button>\n" +
"</form>\n" +
"<div style=\"margin-top: 15px;\" class=\"well\">\n" +
"<p>Subscribed to events for job: {{ jobs_list }}</p>\n" +
"<h5>Received Messages:</h5>\n" +
"<ul>\n" +
"<li ng-repeat=\"message in messages\">{{ message }} </li>\n" +
"</ul>\n" +
"</div>\n";
e = angular.element(document.getElementById('job-events-container')); e = angular.element(document.getElementById('job-events-container'));
e.append(html); e.append(html);
$compile(e)(job_events_scope); $compile(e)(job_events_scope);
@@ -55,6 +72,15 @@ function SocketsController ($scope, $compile, ClearScope, Socket) {
jobs_socket.on("status_changed", function(data) { jobs_socket.on("status_changed", function(data) {
jobs_scope.messages.push(data); jobs_scope.messages.push(data);
}); });
job_events_scope.jobs_list = [];
job_events_scope.subscribeToJobEvent = function() {
job_events_scope.jobs_list.push(job_events_scope.job_id);
job_events_socket.on("job_events-" + job_events_scope.job_id, function(data) {
jobs_scope.messages.push(data);
});
};
} }
SocketsController.$inject = [ '$scope', '$compile', 'ClearScope', 'Socket']; SocketsController.$inject = [ '$scope', '$compile', 'ClearScope', 'Socket'];