TaskMigration.java

Go to the documentation of this file.

/*
 * Turró i Cutiller Foundation. License notice.
 * Copyright (C) 2022 Lluis Turró Cutiller <http://www.turro.org/>
 *
 * This program is free software: you can redistribute it and/or modify
 * it under the terms of the GNU Affero General Public License as published by
 * the Free Software Foundation, either version 3 of the License, or
 * (at your option) any later version.
 *
 * This program is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 * GNU Affero General Public License for more details.
 *
 * You should have received a copy of the GNU Affero General Public License
 * along with this program.  If not, see <http://www.gnu.org/licenses/>.
 */
 
package org.turro.scheduler.task.migration;
 
import java.io.IOException;
import java.util.Set;
import org.turro.elephant.context.IConstructor;
import org.turro.log.WebLoggers;
import org.turro.scheduler.motor.Constraints;
import org.turro.scheduler.motor.DefaultTask;
import org.turro.scheduler.motor.ScheduledSet;
import org.turro.scheduler.task.constraints.Month;
import org.turro.scheduler.task.constraints.TaskConstraints;
import org.turro.scheduler.task.constraints.WeekDay;
import org.turro.scheduler.task.settings.TaskSettings;
import org.turro.scheduler.task.settings.TaskSettingsSet;
 
public class TaskMigration {
 
  
  public static TaskSettingsSet migrate(IConstructor constructor) {
    if(TaskSettingsSet.noTasks()) {
      return doMigrate(constructor);
    }
    return new TaskSettingsSet();
  }
  
  private static TaskSettingsSet doMigrate(IConstructor constructor) {
    Set defs = new ScheduledSet();
    ScheduledSet.loadSet(constructor, defs);
    TaskSettingsSet set = new TaskSettingsSet();
    for(DefaultTask def : (Set<DefaultTask>) defs) {
      if(!"IScheduledTask_QueueSender".equals(def.getImplementation())) {
        TaskSettings settings = new TaskSettings();
        settings.setActive(def.isActive());
        settings.setImplementation(def.getClass().getName() + "Task");
        settings.setDescription(def.getDescription());
        settings.setStartDate(def.getStartDate());
        settings.setEndDate(def.getEndDate());
        settings.setData(def.getData());
        TaskConstraints cons = settings.getConstraints();
        Constraints dcons = def.getConstraints();
        for(Integer i : dcons.getDaysOfMonth()) {
          cons.getDaysOfMonth().add(i);
        }
        for(Integer i : dcons.getHours()) {
          cons.getHours().add(i);
        }
        for(Integer i : dcons.getMinutes()) {
          cons.getMinutes().add(i);
        }
        for(org.turro.scheduler.constraints.Month i : dcons.getMonths()) {
          cons.getMonths().add(Month.valueOf(i.name()));
        }
        for(org.turro.scheduler.constraints.WeekDay i : dcons.getWeekDays()) {
          cons.getWeekDays().add(WeekDay.valueOf(i.name()));
        }
        set.add(settings);
      }
    }
    try {
      set.save();
    } catch (IOException ex) {
      WebLoggers.severe(TaskMigration.class).exception(ex).log();
    }
    return set;
  }
  
}