JobService.java

package edu.ucsb.cs156.frontiers.services.jobs;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.context.annotation.Lazy;

import org.springframework.scheduling.annotation.Async;

import org.springframework.stereotype.Service;

import edu.ucsb.cs156.frontiers.entities.Job;

import edu.ucsb.cs156.frontiers.repositories.JobsRepository;

import edu.ucsb.cs156.frontiers.services.CurrentUserService;

@Service

public class JobService {

  @Autowired private JobsRepository jobsRepository;

  @Autowired private CurrentUserService currentUserService;

  @Lazy @Autowired private JobService self;

  public Job runAsJob(JobContextConsumer jobFunction) {

    Job job = Job.builder().createdBy(currentUserService.getUser()).status("running").build();

    jobsRepository.save(job);

    self.runJobAsync(job, jobFunction);

    return job;

  }

  @Async

  public void runJobAsync(Job job, JobContextConsumer jobFunction) {

    JobContext context = new JobContext(jobsRepository, job);

    try {

      jobFunction.accept(context);

    } catch (Exception e) {

      job.setStatus("error");

      context.log(e.getMessage());

      return;

    }

    job.setStatus("complete");

    jobsRepository.save(job);

  }

  public String getJobLogs(Long jobId) {

    Job job =

        jobsRepository

            .findById(jobId)

            .orElseThrow(() -> new IllegalArgumentException("Job not found"));

    String log = job.getLog();

    return log != null ? log : "";

  }

}

Active mutators

• CONDITIONALS_BOUNDARY
• EMPTY_RETURNS
• FALSE_RETURNS
• INCREMENTS
• INVERT_NEGS
• MATH
• NEGATE_CONDITIONALS
• NULL_RETURNS
• PRIMITIVE_RETURNS
• TRUE_RETURNS
• VOID_METHOD_CALLS

Tests examined

• edu.ucsb.cs156.frontiers.controllers.JobsControllerDetailedTests.[engine:junit-jupiter]/[class:edu.ucsb.cs156.frontiers.controllers.JobsControllerDetailedTests]/[method:admin_can_launch_updateAll_job()] (10 ms)
• edu.ucsb.cs156.frontiers.controllers.JobsControllerDetailedTests.[engine:junit-jupiter]/[class:edu.ucsb.cs156.frontiers.controllers.JobsControllerDetailedTests]/[method:admin_can_launch_test_job()] (2029 ms)
• edu.ucsb.cs156.frontiers.controllers.JobsControllerDetailedTests.[engine:junit-jupiter]/[class:edu.ucsb.cs156.frontiers.controllers.JobsControllerDetailedTests]/[method:admin_can_launch_test_job_that_fails()] (4122 ms)
• edu.ucsb.cs156.frontiers.services.JobLogsServiceTests.[engine:junit-jupiter]/[class:edu.ucsb.cs156.frontiers.services.JobLogsServiceTests]/[method:test_getJobLogs_with_null_log()] (2 ms)
• edu.ucsb.cs156.frontiers.controllers.JobsControllerDetailedTests.[engine:junit-jupiter]/[class:edu.ucsb.cs156.frontiers.controllers.JobsControllerDetailedTests]/[method:test_getJobLogs_admin_can_get_empty_log()] (5 ms)
• edu.ucsb.cs156.frontiers.services.JobLogsServiceTests.[engine:junit-jupiter]/[class:edu.ucsb.cs156.frontiers.services.JobLogsServiceTests]/[method:test_getJobLogs_with_log()] (11 ms)
• edu.ucsb.cs156.frontiers.controllers.JobsControllerDetailedTests.[engine:junit-jupiter]/[class:edu.ucsb.cs156.frontiers.controllers.JobsControllerDetailedTests]/[method:test_getJobLogs_admin_can_get_job_log()] (38 ms)
• edu.ucsb.cs156.frontiers.services.JobLogsServiceTests.[engine:junit-jupiter]/[class:edu.ucsb.cs156.frontiers.services.JobLogsServiceTests]/[method:test_getJobLogs_job_not_found()] (3 ms)