feat(job): restart job

src/api/db/job.ts

@@ -66,3 +66,22 @@ export function resetJobs(buildId: number): Promise<any> {
     });
   });
 }
+
+export function resetJob(jobId: number): Promise<any> {
+  return new Promise((resolve, reject) => {
+    const data = {
+      start_time: new Date(),
+      end_time: null,
+      status: 'queued',
+      log: ''
+    };
+
+    new Job({ id: jobId }).save(data, { method: 'update' }).then(job => {
+      if (!job) {
+        reject();
+      }
+
+      getJob(jobId).then(job => resolve(job));
+    });
+  });
+}

src/api/process-manager.ts

@@ -1,7 +1,7 @@
 import { startBuildJob, Job, startDockerImageSetupJob } from './process';
 import { Observable, Subject } from 'rxjs';
 import { insertBuild, updateBuild, getBuild } from './db/build';
-import { insertJob, resetJobs, updateJob } from './db/job';
+import { insertJob, resetJobs, updateJob, resetJob } from './db/job';
 import { getRepository } from './db/repository';
 import { getRepositoryDetails, generateCommands } from './config';
 import { killContainer } from './docker';
@@ -195,6 +195,30 @@ export function queueJob(buildId: number, jobId: number, commands: string[]): Su
   return Subject.create(jobObserver, jobOutput);
 }
 
+export function restartJob(jobId: number): Promise<Subject<JobMessage>> {
+  stopJob(jobId);
+
+  return resetJob(jobId)
+    .then(job => {
+      console.log(job);
+      const commands = JSON.parse(job.commands);
+      return queueJob(job.build_id, jobId, commands);
+    });
+}
+
+export function stopJob(jobId: number): void {
+  const jobIndex = jobProcesses.findIndex(jobProcess => jobProcess.job_id === jobId);
+  if (jobIndex !== -1) {
+    jobProcesses[jobIndex].job.next({ action: 'exit' });
+    jobProcesses = jobProcesses.filter(jobProcess => jobProcess.job_id === jobId);
+  }
+}
+
+export function getBuildJobsData(buildId: number): Observable<JobMessage> {
+  const jobs = getJobsForBuild(buildId);
+  return Observable.merge(...jobs.map(job => job.job));
+}
+
 export function findDockerImageBuildJob(name: string): JobProcess | null {
   const index = jobProcesses.findIndex(job => job.image_name && job.image_name === name);
   return jobProcesses[index] || null;

src/api/socket.ts

@@ -8,7 +8,8 @@ import {
   startBuild,
   startSetup,
   findDockerImageBuildJob,
-  getJobsForBuild
+  getJobsForBuild,
+  restartJob
 } from './process-manager';
 import { getBuild } from './db/build';
 
@@ -19,11 +20,9 @@ export interface ISocketServerOptions {
 export class SocketServer {
   options: ISocketServerOptions;
   connections: Observable<any>;
-  ptyProcesses: any[];
 
   constructor(options: ISocketServerOptions) {
     this.options = options;
-    this.ptyProcesses = [];
   }
 
   start(): Observable<string> {
@@ -61,6 +60,13 @@ export class SocketServer {
               case 'restartBuild':
 
               break;
+              case 'restartJob':
+                restartJob(event.data.jobId).then(subj => {
+                  subj.subscribe(event => {
+                    console.log(event);
+                  });
+                });
+              break;
             }
 
             // switch (event.type) {

src/app/components/app-build-details/app-build-details.component.html

@@ -100,7 +100,7 @@ <h3>#{{ build.id }}.{{ build.iteration }} ({{ build.uuid }})</h3>
                 <span>{{ job.status }}</span>
               </div>
               <div class="column is-1">
-                <button type="button" class="button green">
+                <button type="button" class="button green" (click)="restartJob($event, job.id)">
                   Restart
                 </button>
               </div>

src/app/components/app-build-details/app-build-details.component.ts

@@ -47,6 +47,13 @@ export class AppBuildDetailsComponent implements OnInit {
     this.socketService.emit({ type: 'restartBuild', data: buildId });
   }
 
+  restartJob(e: MouseEvent, jobId: number): void {
+    e.preventDefault();
+    e.stopPropagation();
+
+    this.socketService.emit({ type: 'restartJob', data: { jobId: jobId } });
+  }
+
   stopBuild(): void {
     this.socketService.emit({ type: 'stopBuild', data: this.id });
   }