import org.codelibs.fess.exception.JobNotFoundException;
import org.codelibs.fess.opensearch.config.bsentity.BsScheduledJob;
import org.codelibs.fess.util.ComponentUtil;
import org.lastaflute.job.LaScheduledJob;
import org.lastaflute.job.key.LaJobUnique;

/**
 * @author FreeGen
 */
public class ScheduledJob extends BsScheduledJob {

    private static final long serialVersionUID = 1L;

    @Override

    private ScheduledJob createTestScheduledJob(final String id, final boolean loggingEnabled) {
        final ScheduledJob scheduledJob = new ScheduledJob();
        scheduledJob.setId(id);
        scheduledJob.setName("Test Job");
        scheduledJob.setScriptType("groovy");
        scheduledJob.setScriptData("println 'test'");
        scheduledJob.setJobLogging(loggingEnabled ? Constants.T : Constants.F);

            }
        };

        scheduledJobs.add(job1);
        scheduledJobs.add(job2);
        scheduledJobs.add(job3);

        ComponentUtil.register(new ScheduledJobBhv() {
            @Override
            public void selectCursor(CBCall<ScheduledJobCB> cbLambda, EntityRowHandler<ScheduledJob> entityLambda) {
                for (ScheduledJob job : scheduledJobs) {
                    entityLambda.handle(job);

            logger.warn("Scheduled job is empty: key={}", Constants.SCHEDULED_JOB);
            return;
        }
        runtime.stopIfNeeds();

        final SystemHelper systemHelper = ComponentUtil.getSystemHelper();
        final JobManager jobManager = ComponentUtil.getJobManager();

        scheduledJob.setScriptType("groovy");
        scheduledJob.setScriptData("println 'hello'");
        scheduledJob.setJobLogging(Constants.T);
        scheduledJob.setAvailable(Constants.T);
        scheduledJob.setCrawler(Constants.F);
        scheduledJob.setTarget("all");
        return scheduledJob;
    }

        final ScheduledJob job = new ScheduledJob();
        assertFalse(job.isLoggingEnabled());
    }

    @Test
    public void test_isEnabled_true() {
        final ScheduledJob job = new ScheduledJob();
        job.setAvailable(Constants.T);
        assertTrue(job.isEnabled());
    }

    @Test
    public void test_isEnabled_false() {
        final ScheduledJob job = new ScheduledJob();

        // Setup: job with logging disabled
        final ScheduledJob scheduledJob = createScheduledJob("job-2", "Test Job No Log", false, true);

        registerMockJobManager("job-2", null, () -> {});

        final ApiAdminSchedulerAction action = createActionWithMockService(scheduledJob);

        // Execute the real put$start() method

    }

    @Test
    public void test_register_with_null_scheduledJob() {
        try {
            jobHelper.register((ScheduledJob) null);
            fail("Should throw ScheduledJobException");
        } catch (ScheduledJobException e) {
            assertEquals("scheduledJob parameter is null. Cannot register a null job.", e.getMessage());
        } catch (Exception e) {

            if (runtime != null) {
                final Object job = runtime.getParameterMap().get(Constants.SCHEDULED_JOB);
                if (job instanceof ScheduledJob) {
                    return (ScheduledJob) job;
                }
            }
        } catch (final Exception e) {
            if (logger.isDebugEnabled()) {
                logger.debug("Failed to get scheduled job from thread local", e);
            }

    // Job and Process Constants
    // ============================================================

    /** Scheduled job identifier. */
    public static final String SCHEDULED_JOB = "scheduledJob";

    /** Job log ID parameter key for passing pre-generated ID to job execution. */
    public static final String JOB_LOG_ID = "jobLogId";

    /** Default job target value (all configurations). */