name: OSV-Scanner Scheduled Scan

on:
  schedule:
    - cron: 0 4 * * 1

permissions:
  # Require writing security events to upload SARIF file to security tab
  security-events: write
  # Only need to read contents
  contents: read

jobs:
  scan-scheduled:
    if: github.repository == 'tensorflow/tensorflow'

    /** Service for managing scheduled jobs */
    @Resource
    private ScheduledJobService scheduledJobService;
    /** Pager for paginating scheduled job results */
    @Resource
    private SchedulerPager schedulerPager;
    /** Helper for processing scheduled jobs. */
    @Resource
    protected ProcessHelper processHelper;

      object : Task("task one") {
        val schedules = mutableListOf(200.µs)

        override fun runOnce(): Long {
          if (schedules.isNotEmpty()) {
            redQueue.schedule(this, schedules.removeAt(0)) // Add it at the end also.
          }
          log += "scheduledTasks=${redQueue.scheduledTasks}"
          return -1L
        }
      }
    redQueue.schedule(task, 100.µs)

    /**
     * Registers a scheduled job with the job manager.
     *
     * @param scheduledJob the scheduled job to register
     */
    public void register(final ScheduledJob scheduledJob) {
        final JobManager jobManager = ComponentUtil.getJobManager();
        jobManager.schedule(cron -> register(cron, scheduledJob));
    }

    /**
     * Registers a scheduled job with the specified cron scheduler.
     *

    }

    /**
     * Gets a scheduled job by its ID.
     * @param id The ID of the scheduled job.
     * @return An optional entity of the scheduled job.
     */
    public OptionalEntity<ScheduledJob> getScheduledJob(final String id) {
        return scheduledJobBhv.selectByPK(id);
    }

    /**
     * Deletes a scheduled job.
     * @param scheduledJob The scheduled job to delete.
     */

    // If the task is already scheduled, take the earlier of the two times.
    val existingIndex = futureTasks.indexOf(task)
    if (existingIndex != -1) {
      if (task.nextExecuteNanoTime <= executeNanoTime) {
        taskRunner.logger.taskLog(task, this) { "already scheduled" }
        return false
      }
      futureTasks.removeAt(existingIndex) // Already scheduled later: reschedule below!
    }

    /**
     * The sort order for displaying this scheduled job.
     */
    @Required
    @Min(value = 0)
    @Max(value = 2147483647)
    @ValidateTypeFailure
    public Integer sortOrder;

    /**
     * The username of who created this scheduled job.
     */
    @Size(max = 1000)
    public String createdBy;

    /**
     * The timestamp when this scheduled job was created.
     */

    /**
     * Constructs a new JobNotFoundException with a message derived from the scheduled job.
     *
     * @param scheduledJob the scheduled job that was not found
     */
    public JobNotFoundException(final ScheduledJob scheduledJob) {
        super(scheduledJob.toString());
    }

    /**
     * Constructs a new JobNotFoundException with the specified detail message.
     *

     */
    public String scriptType;

    /**
     * Whether the scheduled job is a crawler job.
     */
    public String crawler;

    /**
     * Whether logging is enabled for the scheduled job.
     */
    public String jobLogging;

    /**
     * Whether the scheduled job is available.
     */
    public String available;

    /**
     * Sort order of the scheduled job.

    }

    /**
     * Retrieves scheduler settings with pagination.
     *
     * @param body the search parameters for filtering and pagination
     * @return JSON response containing scheduler settings list
     */
    // GET /api/admin/scheduler
    // PUT /api/admin/scheduler
    @Execute
    public JsonResponse<ApiResult> settings(final SearchBody body) {