Adds support for restarting and stopping jobs.

resolves #577

Author: cppwfs

ui/src/app/jobs/jobs.component.ts

@@ -64,11 +64,27 @@ export class JobsComponent implements OnInit {
   }
 
   restartJob(item: JobExecution) {
-    console.log('Restart Job');
+    console.log('Restart Job ' + item.jobExecutionId);
+    this.jobsService.restartJob(item).subscribe(
+      data => {
+        this.toastyService.success('Successfully restarted job "' + item.name + '"');
+      },
+      error => {
+        this.toastyService.error(error);
+      }
+    );
   }
 
   stopJob(item: JobExecution) {
-    console.log('Stop Job');
+    console.log('Stop Job' + item.jobExecutionId);
+    this.jobsService.stopJob(item).subscribe(
+      data => {
+        this.toastyService.success('Successfully stopped job "' + item.name + '"');
+      },
+      error => {
+        this.toastyService.error(error);
+      }
+    );
   }
 
   viewJobExecutionDetails(item: JobExecution) {

ui/src/app/jobs/jobs.service.spec.ts

@@ -9,6 +9,7 @@ import {
 } from '../tests/mocks/mock-data';
 import {Page} from '../shared/model/page';
 import {JobExecution} from './model/job-execution.model';
+import {RequestOptionsArgs} from '@angular/http';
 
 export class MockResponse {
 
@@ -30,7 +31,7 @@ export class MockResponse {
 describe('JobsService', () => {
 
   beforeEach(() => {
-    this.mockHttp = jasmine.createSpyObj('mockHttp', ['get']);
+    this.mockHttp = jasmine.createSpyObj('mockHttp', ['get', 'put']);
     this.jsonData = { };
     const errorHandler = new ErrorHandler();
     this.jobsService = new JobsService(this.mockHttp, errorHandler);
@@ -96,6 +97,30 @@ describe('JobsService', () => {
     });
   });
 
+  describe('restartJobExecution', () => {
+    it('should execute a PUT command to restart a job', () => {
+      const jobExecution: JobExecution = new JobExecution();
+      jobExecution.jobExecutionId = 1;
+      jobExecution.name = 'foo';
+      this.mockHttp.put.and.returnValue(Observable.of(this.jsonData));
+      this.jobsService.restartJob(jobExecution);
+      const options: RequestOptionsArgs = HttpUtils.getDefaultRequestOptions();
+      expect(this.mockHttp.put).toHaveBeenCalledWith('/jobs/executions/1?restart=true', options);
+    });
+  });
+
+  describe('stopJobExecution', () => {
+    it('should execute a PUT command to stop a job', () => {
+      const jobExecution: JobExecution = new JobExecution();
+      jobExecution.jobExecutionId = 1;
+      jobExecution.name = 'foo';
+      this.mockHttp.put.and.returnValue(Observable.of(this.jsonData));
+      this.jobsService.stopJob(jobExecution);
+      const options: RequestOptionsArgs = HttpUtils.getDefaultRequestOptions();
+      expect(this.mockHttp.put).toHaveBeenCalledWith('/jobs/executions/1?stop=true', options);
+    });
+  });
+
   describe('extractData', () => {
     it('should call the jobs service to extract data from json', () => {
       const response = new MockResponse();

ui/src/app/jobs/jobs.service.ts

@@ -1,5 +1,5 @@
 import { Injectable } from '@angular/core';
-import { Http, Response } from '@angular/http';
+import { Http, Response, RequestOptionsArgs } from '@angular/http';
 
 import { Observable } from 'rxjs/Observable';
 import 'rxjs/add/operator/catch';
@@ -347,4 +347,28 @@ export class JobsService {
     this.jobExecutions.update(page);
     return this.jobExecutions;
   }
+
+  /**
+   * Restarts a job if the job failed.
+   * @param {JobExecution} item JobExecution to restart.
+   * @returns {Observable<any | any>} with the state of the restart.
+   */
+  restartJob(item: JobExecution) {
+    const options: RequestOptionsArgs = HttpUtils.getDefaultRequestOptions();
+
+    return this.http.put(this.jobExecutionsUrl + '/' + item.jobExecutionId + '?restart=true', options)
+      .catch(this.errorHandler.handleError);
+  }
+
+  /**
+   * Stops a running JobExecution.
+   * @param {JobExecution} item the JobExecution to stop
+   * @returns {Observable<any | any>} state of the job execution stop event.
+   */
+  stopJob(item: JobExecution) {
+    const options: RequestOptionsArgs = HttpUtils.getDefaultRequestOptions();
+
+    return this.http.put(this.jobExecutionsUrl + '/' + item.jobExecutionId + '?stop=true', options)
+      .catch(this.errorHandler.handleError);
+  }
 }