| package org.eclipse.osee.ote.rest.internal; |
| |
| import java.io.IOException; |
| import java.util.concurrent.ExecutionException; |
| |
| import javax.ws.rs.DELETE; |
| import javax.ws.rs.PUT; |
| import javax.ws.rs.Produces; |
| import javax.ws.rs.core.MediaType; |
| import javax.ws.rs.core.Request; |
| import javax.ws.rs.core.UriInfo; |
| |
| import org.eclipse.osee.ote.core.ServiceUtility; |
| import org.eclipse.osee.ote.core.framework.command.RunTests; |
| import org.eclipse.osee.ote.rest.model.OTEJobStatus; |
| |
| public class OteRunTestResourceItem { |
| |
| @SuppressWarnings("unused") |
| private UriInfo uriInfo; |
| @SuppressWarnings("unused") |
| private Request request; |
| private String id; |
| |
| public OteRunTestResourceItem(UriInfo uriInfo, Request request, String id) { |
| this.uriInfo = uriInfo; |
| this.request = request; |
| this.id = id; |
| } |
| |
| @DELETE |
| @Produces({MediaType.APPLICATION_JSON, MediaType.APPLICATION_XML}) |
| public OTEJobStatus abortAll() throws IOException, InterruptedException, ExecutionException { |
| OteRunTestCommands commands = ServiceUtility.getService(OteRunTestCommands.class); |
| OTEJobStatus status = new OTEJobStatus(); |
| status.setSuccess(false); |
| if(commands != null){ |
| RunTests cmd = commands.getCommand(id); |
| if(cmd != null){ |
| cmd.cancel(); |
| status.setSuccess(true); |
| } |
| } |
| return status; |
| } |
| |
| @PUT |
| @Produces({MediaType.APPLICATION_JSON, MediaType.APPLICATION_XML}) |
| public OTEJobStatus abortSingle() { |
| OteRunTestCommands commands = ServiceUtility.getService(OteRunTestCommands.class); |
| OTEJobStatus status = new OTEJobStatus(); |
| status.setSuccess(false); |
| if(commands != null){ |
| RunTests cmd = commands.getCommand(id); |
| if(cmd != null){ |
| cmd.cancelSingle(); |
| status.setSuccess(true); |
| } |
| } |
| return status; |
| } |
| |
| } |