v1 Scheduled Jobs / Third Party Sync Migration

webapp/src/main/java/com/box/l10n/mojito/entity/ScheduledJob.java

@@ -0,0 +1,175 @@
+package com.box.l10n.mojito.entity;
+
+import com.box.l10n.mojito.json.ObjectMapper;
+import com.box.l10n.mojito.service.scheduledjob.ScheduledJobProperties;
+import jakarta.persistence.Basic;
+import jakarta.persistence.Column;
+import jakarta.persistence.Entity;
+import jakarta.persistence.ForeignKey;
+import jakarta.persistence.GeneratedValue;
+import jakarta.persistence.GenerationType;
+import jakarta.persistence.Id;
+import jakarta.persistence.JoinColumn;
+import jakarta.persistence.ManyToOne;
+import jakarta.persistence.PostLoad;
+import jakarta.persistence.Table;
+import jakarta.persistence.Transient;
+import java.time.ZonedDateTime;
+import org.hibernate.envers.Audited;
+
+@Audited
+@Entity
+@Table(name = "scheduled_job")
+public class ScheduledJob {
+  @Id
+  @GeneratedValue(strategy = GenerationType.IDENTITY)
+  private Long id;
+
+  @Basic(optional = false)
+  @Column(name = "uuid")
+  private String uuid;
+
+  @ManyToOne
+  @JoinColumn(
+      name = "repository_id",
+      foreignKey = @ForeignKey(name = "FK__SCHEDULED_JOB__IMPORT_REPOSITORY__ID"))
+  private Repository repository;
+
+  @ManyToOne
+  @JoinColumn(name = "job_type", foreignKey = @ForeignKey(name = "FK__JOB_TYPE__JOB_TYPE_ID"))
+  private ScheduledJobType jobType;
+
+  @Column(name = "cron")
+  private String cron;
+
+  @Transient private ScheduledJobProperties properties;
+
+  @Basic(optional = false)
+  @Column(name = "properties")
+  private String propertiesString;
+
+  @ManyToOne
+  @JoinColumn(name = "job_status", foreignKey = @ForeignKey(name = "FK__JOB_STATUS__JOB_STATUS_ID"))
+  private ScheduledJobStatus jobStatus;
+
+  @Column(name = "start_date")
+  private ZonedDateTime startDate;
+
+  @Column(name = "end_date")
+  private ZonedDateTime endDate;
+
+  @Basic(optional = false)
+  @Column(name = "enabled")
+  private Boolean enabled = true;
+
+  @PostLoad
+  public void deserializeProperties() {
+    ObjectMapper objectMapper = new ObjectMapper();
+    try {
+      this.properties =
+          objectMapper.readValue(propertiesString, jobType.getEnum().getPropertiesClass());
+    } catch (Exception e) {
+      throw new RuntimeException(
+          "Failed to deserialize properties '"
+              + propertiesString
+              + "' for class: "
+              + jobType.getEnum().getPropertiesClass().getName(),
+          e);
+    }
+  }
+
+  public Long getId() {
+    return id;
+  }
+
+  public void setId(Long id) {
+    this.id = id;
+  }
+
+  public String getUuid() {
+    return uuid;
+  }
+
+  public void setUuid(String uuid) {
+    this.uuid = uuid;
+  }
+
+  public Repository getRepository() {
+    return repository;
+  }
+
+  public void setRepository(Repository repository) {
+    this.repository = repository;
+  }
+
+  public ScheduledJobType getJobType() {
+    return jobType;
+  }
+
+  public void setJobType(ScheduledJobType jobType) {
+    this.jobType = jobType;
+  }
+
+  public String getCron() {
+    return cron;
+  }
+
+  public void setCron(String cron) {
+    this.cron = cron;
+  }
+
+  public ScheduledJobProperties getProperties() {
+    return properties;
+  }
+
+  public void setProperties(ScheduledJobProperties properties) {
+    this.properties = properties;
+
+    ObjectMapper objectMapper = new ObjectMapper();
+    try {
+      this.propertiesString = objectMapper.writeValueAsString(this.properties);
+    } catch (Exception e) {
+      throw new RuntimeException("Failed to serialize properties", e);
+    }
+  }
+
+  public String getPropertiesString() {
+    return propertiesString;
+  }
+
+  public void setPropertiesString(String properties) {
+    this.propertiesString = properties;
+  }
+
+  public ScheduledJobStatus getJobStatus() {
+    return jobStatus;
+  }
+
+  public void setJobStatus(ScheduledJobStatus jobStatus) {
+    this.jobStatus = jobStatus;
+  }
+
+  public ZonedDateTime getStartDate() {
+    return startDate;
+  }
+
+  public void setStartDate(ZonedDateTime startDate) {
+    this.startDate = startDate;
+  }
+
+  public ZonedDateTime getEndDate() {
+    return endDate;
+  }
+
+  public void setEndDate(ZonedDateTime endDate) {
+    this.endDate = endDate;
+  }
+
+  public Boolean getEnabled() {
+    return enabled;
+  }
+
+  public void setEnabled(Boolean enabled) {
+    this.enabled = enabled;
+  }
+}

webapp/src/main/java/com/box/l10n/mojito/entity/ScheduledJobStatus.java

@@ -0,0 +1,35 @@
+package com.box.l10n.mojito.entity;
+
+import static org.hibernate.envers.RelationTargetAuditMode.NOT_AUDITED;
+
+import com.box.l10n.mojito.rest.View;
+import com.fasterxml.jackson.annotation.JsonView;
+import jakarta.persistence.Basic;
+import jakarta.persistence.Column;
+import jakarta.persistence.Entity;
+import jakarta.persistence.EnumType;
+import jakarta.persistence.Enumerated;
+import jakarta.persistence.Id;
+import jakarta.persistence.Table;
+import org.hibernate.envers.Audited;
+
+@Entity
+@Table(name = "scheduled_job_status_type")
+@Audited(targetAuditMode = NOT_AUDITED)
+public class ScheduledJobStatus extends BaseEntity {
+  @Id private Long id;
+
+  @Basic(optional = false)
+  @Column(name = "name")
+  @Enumerated(EnumType.STRING)
+  @JsonView(View.Repository.class)
+  private com.box.l10n.mojito.service.scheduledjob.ScheduledJobStatus jobStatus;
+
+  public com.box.l10n.mojito.service.scheduledjob.ScheduledJobStatus getEnum() {
+    return jobStatus;
+  }
+
+  public void setJobStatus(com.box.l10n.mojito.service.scheduledjob.ScheduledJobStatus jobStatus) {
+    this.jobStatus = jobStatus;
+  }
+}

webapp/src/main/java/com/box/l10n/mojito/entity/ScheduledJobType.java

@@ -0,0 +1,45 @@
+package com.box.l10n.mojito.entity;
+
+import static org.hibernate.envers.RelationTargetAuditMode.NOT_AUDITED;
+
+import com.box.l10n.mojito.rest.View;
+import com.fasterxml.jackson.annotation.JsonView;
+import jakarta.persistence.Basic;
+import jakarta.persistence.Column;
+import jakarta.persistence.Entity;
+import jakarta.persistence.EnumType;
+import jakarta.persistence.Enumerated;
+import jakarta.persistence.Id;
+import jakarta.persistence.Table;
+import org.hibernate.envers.Audited;
+
+@Entity
+@Table(name = "scheduled_job_type")
+@Audited(targetAuditMode = NOT_AUDITED)
+public class ScheduledJobType extends BaseEntity {
+  @Id private Long id;
+
+  @Basic(optional = false)
+  @Column(name = "name")
+  @Enumerated(EnumType.STRING)
+  @JsonView(View.Repository.class)
+  private com.box.l10n.mojito.service.scheduledjob.ScheduledJobType jobType;
+
+  @Override
+  public Long getId() {
+    return id;
+  }
+
+  @Override
+  public void setId(Long id) {
+    this.id = id;
+  }
+
+  public com.box.l10n.mojito.service.scheduledjob.ScheduledJobType getEnum() {
+    return jobType;
+  }
+
+  public void setEnum(com.box.l10n.mojito.service.scheduledjob.ScheduledJobType jobType) {
+    this.jobType = jobType;
+  }
+}