#24958

Committed 10 Mar 2025 05:32PM CUT coverage: 22.614%. Remained the same

Build # #24958

Build Type

Pull #11325

github

Committed by

stevenwinship

Commit Message

extend size of deaccessionlink column

Pull Request Pull Request #11325: extend size of deaccessionlink column

Run Details

20033 of 88586 relevant lines covered (22.61%)

0.23 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

0.0

/src/main/java/edu/harvard/iq/dataverse/api/batchjob/BatchJobResource.java

package edu.harvard.iq.dataverse.api.batchjob;

import com.fasterxml.jackson.databind.ObjectMapper;
import edu.harvard.iq.dataverse.api.AbstractApiBean;
import edu.harvard.iq.dataverse.batch.entities.JobExecutionEntity;

import jakarta.batch.operations.JobOperator;
import jakarta.batch.runtime.BatchRuntime;
import jakarta.batch.runtime.JobExecution;
import jakarta.batch.runtime.JobInstance;
import jakarta.ejb.Stateless;
import jakarta.ws.rs.GET;
import jakarta.ws.rs.Path;
import jakarta.ws.rs.PathParam;
import jakarta.ws.rs.Produces;
import jakarta.ws.rs.core.MediaType;
import jakarta.ws.rs.core.Response;
import java.util.ArrayList;
import java.util.List;
import java.util.Set;


@Stateless
@Path("admin/batch")
public class BatchJobResource extends AbstractApiBean {

    private static String EMPTY_JSON_LIST = "[]";
    private static String EMPTY_JSON_OBJ = "{}";
    private static ObjectMapper mapper = new ObjectMapper();

    @GET
    @Path("/jobs")
    @Produces(MediaType.APPLICATION_JSON)
    public Response listBatchJobs() {
        try {
            final List<JobExecutionEntity> executionEntities = new ArrayList<>();
            final JobOperator jobOperator = BatchRuntime.getJobOperator();
            final Set<String> names = jobOperator.getJobNames();
            for (String name : names) {
                final int end = jobOperator.getJobInstanceCount(name);
                final List<JobInstance> jobInstances = jobOperator.getJobInstances(name, 0, end);
                for (JobInstance jobInstance : jobInstances) {
                    final List<JobExecution> executions = jobOperator.getJobExecutions(jobInstance);
                    for (JobExecution execution : executions) {
                        executionEntities.add(JobExecutionEntity.create(execution));
                    }
                }
            }
            return Response.ok("{ \"jobs\": \n" + mapper.writeValueAsString(executionEntities) + "\n}").build();
        } catch (Exception e) {
            return Response.ok(EMPTY_JSON_LIST).build();
        }
    }

    @GET
    @Path("/jobs/name/{jobName}")
    @Produces(MediaType.APPLICATION_JSON)
    public Response listBatchJobsByName( @PathParam("jobName") String jobName) {
        try {
            final List<JobExecutionEntity> executionEntities = new ArrayList<>();
            final JobOperator jobOperator = BatchRuntime.getJobOperator();
            final int end = jobOperator.getJobInstanceCount(jobName);
            final List<JobInstance> jobInstances = jobOperator.getJobInstances(jobName, 0, end);
            for (JobInstance jobInstance : jobInstances) {
                final List<JobExecution> executions = jobOperator.getJobExecutions(jobInstance);
                for (JobExecution execution : executions) {
                    executionEntities.add(JobExecutionEntity.create(execution));
                }
            }
            return Response.ok("{ \"jobs\": \n" + mapper.writeValueAsString(executionEntities) + "\n}").build();
        } catch (Exception e) {
            return Response.ok(EMPTY_JSON_LIST).build();
        }
    }


    @GET
    @Path("/jobs/{jobId}")
    @Produces(MediaType.APPLICATION_JSON)
    public Response listBatchJobById(@PathParam("jobId") String jobId) {
        try {
            JobExecution execution = BatchRuntime.getJobOperator().getJobExecution(Long.valueOf(jobId));
            return Response.ok(mapper.writeValueAsString(JobExecutionEntity.create(execution))).build();
        } catch (Exception e) {
            return Response.ok(EMPTY_JSON_OBJ).build();
        }
    }

}

1	package edu.harvard.iq.dataverse.api.batchjob;
2
3	import com.fasterxml.jackson.databind.ObjectMapper;
4	import edu.harvard.iq.dataverse.api.AbstractApiBean;
5	import edu.harvard.iq.dataverse.batch.entities.JobExecutionEntity;
6
7	import jakarta.batch.operations.JobOperator;
8	import jakarta.batch.runtime.BatchRuntime;
9	import jakarta.batch.runtime.JobExecution;
10	import jakarta.batch.runtime.JobInstance;
11	import jakarta.ejb.Stateless;
12	import jakarta.ws.rs.GET;
13	import jakarta.ws.rs.Path;
14	import jakarta.ws.rs.PathParam;
15	import jakarta.ws.rs.Produces;
16	import jakarta.ws.rs.core.MediaType;
17	import jakarta.ws.rs.core.Response;
18	import java.util.ArrayList;
19	import java.util.List;
20	import java.util.Set;
21
22
23	@Stateless
24	@Path("admin/batch")
25	public class BatchJobResource extends AbstractApiBean {	×
26
27	private static String EMPTY_JSON_LIST = "[]";	×
28	private static String EMPTY_JSON_OBJ = "{}";	×
29	private static ObjectMapper mapper = new ObjectMapper();	×
30
31	@GET
32	@Path("/jobs")
33	@Produces(MediaType.APPLICATION_JSON)
34	public Response listBatchJobs() {
35	try {
36	final List<JobExecutionEntity> executionEntities = new ArrayList<>();	×
37	final JobOperator jobOperator = BatchRuntime.getJobOperator();	×
38	final Set<String> names = jobOperator.getJobNames();	×
39	for (String name : names) {	×
40	final int end = jobOperator.getJobInstanceCount(name);	×
41	final List<JobInstance> jobInstances = jobOperator.getJobInstances(name, 0, end);	×
42	for (JobInstance jobInstance : jobInstances) {	×
43	final List<JobExecution> executions = jobOperator.getJobExecutions(jobInstance);	×
44	for (JobExecution execution : executions) {	×
45	executionEntities.add(JobExecutionEntity.create(execution));	×
46	}	×
47	}	×
48	}	×
49	return Response.ok("{ \"jobs\": \n" + mapper.writeValueAsString(executionEntities) + "\n}").build();	×
50	} catch (Exception e) {	×
51	return Response.ok(EMPTY_JSON_LIST).build();	×
52	}
53	}
54
55	@GET
56	@Path("/jobs/name/{jobName}")
57	@Produces(MediaType.APPLICATION_JSON)
58	public Response listBatchJobsByName( @PathParam("jobName") String jobName) {
59	try {
60	final List<JobExecutionEntity> executionEntities = new ArrayList<>();	×
61	final JobOperator jobOperator = BatchRuntime.getJobOperator();	×
62	final int end = jobOperator.getJobInstanceCount(jobName);	×
63	final List<JobInstance> jobInstances = jobOperator.getJobInstances(jobName, 0, end);	×
64	for (JobInstance jobInstance : jobInstances) {	×
65	final List<JobExecution> executions = jobOperator.getJobExecutions(jobInstance);	×
66	for (JobExecution execution : executions) {	×
67	executionEntities.add(JobExecutionEntity.create(execution));	×
68	}	×
69	}	×
70	return Response.ok("{ \"jobs\": \n" + mapper.writeValueAsString(executionEntities) + "\n}").build();	×
71	} catch (Exception e) {	×
72	return Response.ok(EMPTY_JSON_LIST).build();	×
73	}
74	}
75
76
77	@GET
78	@Path("/jobs/{jobId}")
79	@Produces(MediaType.APPLICATION_JSON)
80	public Response listBatchJobById(@PathParam("jobId") String jobId) {
81	try {
82	JobExecution execution = BatchRuntime.getJobOperator().getJobExecution(Long.valueOf(jobId));	×
83	return Response.ok(mapper.writeValueAsString(JobExecutionEntity.create(execution))).build();	×
84	} catch (Exception e) {	×
85	return Response.ok(EMPTY_JSON_OBJ).build();	×
86	}
87	}
88
89	}

IQSS / dataverse / #24958

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous