diff --git a/src/main/java/org/caosdb/server/database/proto/Rule.java b/src/main/java/org/caosdb/server/database/proto/Rule.java index 0aa848bbd08b4ff8728785dc24a7ac014f7c1a29..cf0a899577c1014d6e5a011059e3e72c40d517d0 100644 --- a/src/main/java/org/caosdb/server/database/proto/Rule.java +++ b/src/main/java/org/caosdb/server/database/proto/Rule.java @@ -1,37 +1,37 @@ -/* - * ** header v3.0 - * This file is a part of the CaosDB Project. - * - * Copyright (C) 2018 Research Group Biomedical Physics, - * Max-Planck-Institute for Dynamics and Self-Organization Göttingen - * - * 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 <https://www.gnu.org/licenses/>. - * - * ** end header - */ -package org.caosdb.server.database.proto; - -import java.io.Serializable; -import org.caosdb.server.jobs.core.JobFailureSeverity; - -public class Rule implements Serializable { - - private static final long serialVersionUID = 1122097540596265945L; - - public int domain = 0; - public int entity = 0; - public String job = null; - public String transaction = null; - public JobFailureSeverity mode = null; -} +///* +// * ** header v3.0 +// * This file is a part of the CaosDB Project. +// * +// * Copyright (C) 2018 Research Group Biomedical Physics, +// * Max-Planck-Institute for Dynamics and Self-Organization Göttingen +// * +// * 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 <https://www.gnu.org/licenses/>. +// * +// * ** end header +// */ +//package org.caosdb.server.database.proto; +// +//import java.io.Serializable; +//import org.caosdb.server.jobs.core.JobFailureSeverity; +/ +//public class Rule implements Serializable { +// +// private static final long serialVersionUID = 1122097540596265945L; +// +// public int domain = 0; +// public int entity = 0; +// public String job = null; +// public String transaction = null; +// public JobFailureSeverity severity = null; +//} diff --git a/src/main/java/org/caosdb/server/jobs/Job.java b/src/main/java/org/caosdb/server/jobs/Job.java index 2954f533f832feadcfd8bbf011167b632d76166a..6617d2aa5f8fc60f1b789d258fb7ffcf73446c5d 100644 --- a/src/main/java/org/caosdb/server/jobs/Job.java +++ b/src/main/java/org/caosdb/server/jobs/Job.java @@ -70,7 +70,7 @@ public abstract class Job { private static List<Class<? extends Job>> loadAlways; private Transaction<? extends TransactionContainer> transaction = null; - private JobFailureSeverity mode = null; + private JobFailureSeverity failureSeverity = null; private final TransactionStage stage; private EntityInterface entity = null; @@ -99,7 +99,7 @@ public abstract class Job { protected ScheduledJob appendJob(final EntityInterface entity, final Class<? extends Job> clazz) { try { final Job job = clazz.getDeclaredConstructor().newInstance(); - job.init(getMode(), entity, getTransaction()); + job.init(getFailureSeverity(), entity, getTransaction()); return getTransaction().getSchedule().add(job); } catch (InstantiationException | IllegalAccessException @@ -128,10 +128,10 @@ public abstract class Job { } public final Job init( - final JobFailureSeverity mode, + final JobFailureSeverity severity, final EntityInterface entity, final Transaction<? extends TransactionContainer> transaction) { - this.mode = mode; + this.failureSeverity = severity; this.entity = entity; this.transaction = transaction; return this; @@ -149,12 +149,12 @@ public abstract class Job { return this.entity; } - protected final JobFailureSeverity getMode() { - return this.mode; + protected final JobFailureSeverity getFailureSeverity() { + return this.failureSeverity; } - protected final void setMode(final JobFailureSeverity mode) { - this.mode = mode; + protected final void setFailureSeverity(final JobFailureSeverity severiy) { + this.failureSeverity = severiy; } TransactionContainer getContainer() { @@ -307,7 +307,7 @@ public abstract class Job { */ public static Job getJob( final String job, - final JobFailureSeverity mode, + final JobFailureSeverity severiy, final EntityInterface entity, final Transaction<? extends TransactionContainer> transaction) { // Fill `allClasses` with available subclasses @@ -315,7 +315,7 @@ public abstract class Job { // Get matching class for Job and generate it. final Class<? extends Job> jobClass = allClasses.get(job.toLowerCase()); - return getJob(jobClass, mode, entity, transaction); + return getJob(jobClass, severiy, entity, transaction); } /** @@ -427,7 +427,7 @@ public abstract class Job { private static Job getJob( final Class<? extends Job> jobClass, - final JobFailureSeverity mode, + final JobFailureSeverity severity, final EntityInterface entity, final Transaction<? extends TransactionContainer> transaction) { Job ret; @@ -435,7 +435,7 @@ public abstract class Job { if (jobClass != null) { ret = jobClass.getDeclaredConstructor().newInstance(); - ret.init(mode, entity, transaction); + ret.init(severity, entity, transaction); return ret; } return null; @@ -526,7 +526,7 @@ public abstract class Job { + "-" + (getEntity() != null ? getEntity().toString() : "NOENTITY") + " #" - + getMode().toString() + + getFailureSeverity().toString() + "]"; } diff --git a/src/main/java/org/caosdb/server/jobs/JobConfig.java b/src/main/java/org/caosdb/server/jobs/JobConfig.java index cbbe93f127602ac12749644f64edf5d498b88b7a..43a53a99080631710a44f9ae994e7cfddf098af8 100644 --- a/src/main/java/org/caosdb/server/jobs/JobConfig.java +++ b/src/main/java/org/caosdb/server/jobs/JobConfig.java @@ -87,12 +87,12 @@ public class JobConfig { final Integer entity = Integer.parseInt(row[1]); final String transaction = row[2]; final String job = row[3]; - final JobFailureSeverity mode = JobFailureSeverity.valueOf(row[4]); + final JobFailureSeverity severiy = JobFailureSeverity.valueOf(row[4]); final String key = getKey(domain, entity, transaction); if (!result.containsKey(key)) { result.put(key, new ArrayList<>()); } - result.get(key).add(new Object[] {job, mode}); + result.get(key).add(new Object[] {job, severiy}); } catch (final Exception e) { throw new ConfigurationException("Could not parse the job rules.", e); diff --git a/src/main/java/org/caosdb/server/jobs/core/CheckDescPresent.java b/src/main/java/org/caosdb/server/jobs/core/CheckDescPresent.java index d94e61f26b7140fa468778ca853ed68726582a77..e430a0817e9083013330bc4d59d8f7377d10d62a 100644 --- a/src/main/java/org/caosdb/server/jobs/core/CheckDescPresent.java +++ b/src/main/java/org/caosdb/server/jobs/core/CheckDescPresent.java @@ -35,7 +35,7 @@ public class CheckDescPresent extends EntityJob { @Override public final void run() { if (!getEntity().hasDescription()) { - switch (getMode()) { + switch (getFailureSeverity()) { case ERROR: getEntity().addError(ServerMessages.ENTITY_HAS_NO_DESCRIPTION); getEntity().setEntityStatus(EntityStatus.UNQUALIFIED); diff --git a/src/main/java/org/caosdb/server/jobs/core/CheckNamePresent.java b/src/main/java/org/caosdb/server/jobs/core/CheckNamePresent.java index 4f0e5f324391ccb873ffafc31a789f0e3edd2768..3166057c95671273efe27357ce11b2ffe10e2c78 100644 --- a/src/main/java/org/caosdb/server/jobs/core/CheckNamePresent.java +++ b/src/main/java/org/caosdb/server/jobs/core/CheckNamePresent.java @@ -35,7 +35,7 @@ public class CheckNamePresent extends EntityJob { @Override public final void run() { if (!getEntity().hasName()) { - switch (getMode()) { + switch (getFailureSeverity()) { case ERROR: getEntity().addError(ServerMessages.ENTITY_HAS_NO_NAME); getEntity().setEntityStatus(EntityStatus.UNQUALIFIED); diff --git a/src/main/java/org/caosdb/server/jobs/core/CheckNoAdditionalPropertiesPresent.java b/src/main/java/org/caosdb/server/jobs/core/CheckNoAdditionalPropertiesPresent.java index 9ff3b127a8226b2d3a5cba1e2dcf2421c9d82eec..fb6919649242a906b36526e3725fc25e710c9d60 100644 --- a/src/main/java/org/caosdb/server/jobs/core/CheckNoAdditionalPropertiesPresent.java +++ b/src/main/java/org/caosdb/server/jobs/core/CheckNoAdditionalPropertiesPresent.java @@ -45,7 +45,7 @@ public class CheckNoAdditionalPropertiesPresent extends EntityJob { } private void addMessage(EntityInterface property, Message message) { - if (getMode() == JobFailureSeverity.ERROR) { + if (getFailureSeverity() == JobFailureSeverity.ERROR) { property.addError(message); } else { property.addWarning(message); diff --git a/src/main/java/org/caosdb/server/jobs/core/CheckNoOverridesPresent.java b/src/main/java/org/caosdb/server/jobs/core/CheckNoOverridesPresent.java index e0eca6b76a07e71794288340b3456187475c0edf..d6cae3ee40222d3b3d6eb89e1b2d0c8bce1da0e5 100644 --- a/src/main/java/org/caosdb/server/jobs/core/CheckNoOverridesPresent.java +++ b/src/main/java/org/caosdb/server/jobs/core/CheckNoOverridesPresent.java @@ -28,7 +28,7 @@ public class CheckNoOverridesPresent extends EntityJob { } private void addMessage(Property p, Message message) { - if (getMode() == JobFailureSeverity.ERROR) { + if (getFailureSeverity() == JobFailureSeverity.ERROR) { p.addError(message); } else { p.addWarning(message); diff --git a/src/main/java/org/caosdb/server/jobs/core/CheckParOblPropPresent.java b/src/main/java/org/caosdb/server/jobs/core/CheckParOblPropPresent.java index ffd0431bd72eabc2231c11e2d4af3aa6205a8ed8..6899373af3fbe4647800ee0f042adbb6efaca122 100644 --- a/src/main/java/org/caosdb/server/jobs/core/CheckParOblPropPresent.java +++ b/src/main/java/org/caosdb/server/jobs/core/CheckParOblPropPresent.java @@ -53,7 +53,7 @@ public class CheckParOblPropPresent extends EntityJob { if (getEntity().hasParents()) { handleImportanceFlags(); - if (getMode() == JobFailureSeverity.IGNORE) { + if (getFailureSeverity() == JobFailureSeverity.IGNORE) { // importance is to be ignored return; } @@ -105,7 +105,7 @@ public class CheckParOblPropPresent extends EntityJob { // No entityProperty has been found which // implements this parentProperty. Add the // respective messages. - switch (getMode()) { + switch (getFailureSeverity()) { case ERROR: // TODO add information WHICH property is // missing. @@ -133,13 +133,13 @@ public class CheckParOblPropPresent extends EntityJob { if (entityFlag != null) { switch (entityFlag) { case "error": - setMode(JobFailureSeverity.ERROR); + setFailureSeverity(JobFailureSeverity.ERROR); break; case "warn": - setMode(JobFailureSeverity.WARN); + setFailureSeverity(JobFailureSeverity.WARN); break; case "ignore": - setMode(JobFailureSeverity.IGNORE); + setFailureSeverity(JobFailureSeverity.IGNORE); break; default: // do nothing diff --git a/src/main/java/org/caosdb/server/jobs/core/CheckParPresent.java b/src/main/java/org/caosdb/server/jobs/core/CheckParPresent.java index 3ab63fb1468f67399d47a7a737217c06d5faac3e..058710c6bbbf5c2bbd3f95f7ae70a243d3bfcd20 100644 --- a/src/main/java/org/caosdb/server/jobs/core/CheckParPresent.java +++ b/src/main/java/org/caosdb/server/jobs/core/CheckParPresent.java @@ -35,7 +35,7 @@ public class CheckParPresent extends EntityJob { @Override public final void run() { if (!getEntity().hasParents() || getEntity().getParents().isEmpty()) { - switch (getMode()) { + switch (getFailureSeverity()) { case ERROR: getEntity().addError(ServerMessages.ENTITY_HAS_NO_PARENTS); getEntity().setEntityStatus(EntityStatus.UNQUALIFIED); diff --git a/src/main/java/org/caosdb/server/jobs/core/CheckPropPresent.java b/src/main/java/org/caosdb/server/jobs/core/CheckPropPresent.java index cbb8661049cf86792834f7adb89de08906e9753e..cc23d980152c44cfdbf88500e9041044a0418034 100644 --- a/src/main/java/org/caosdb/server/jobs/core/CheckPropPresent.java +++ b/src/main/java/org/caosdb/server/jobs/core/CheckPropPresent.java @@ -35,7 +35,7 @@ public class CheckPropPresent extends EntityJob { @Override public final void run() { if (getEntity().getProperties().isEmpty()) { - switch (getMode()) { + switch (getFailureSeverity()) { case ERROR: getEntity().addError(ServerMessages.ENTITY_HAS_NO_PROPERTIES); getEntity().setEntityStatus(EntityStatus.UNQUALIFIED); diff --git a/src/main/java/org/caosdb/server/jobs/core/CheckUnitPresent.java b/src/main/java/org/caosdb/server/jobs/core/CheckUnitPresent.java index 1688ab7f2a32eb6f088f24bc1d8c5945b46f49ca..5e3e6120fadef8f4b519ec694ebbf7588d7c2488 100644 --- a/src/main/java/org/caosdb/server/jobs/core/CheckUnitPresent.java +++ b/src/main/java/org/caosdb/server/jobs/core/CheckUnitPresent.java @@ -40,7 +40,7 @@ public class CheckUnitPresent extends EntityJob { runJobFromSchedule(getEntity(), Inheritance.class); if (!hasUnit(getEntity())) { - switch (getMode()) { + switch (getFailureSeverity()) { case ERROR: getEntity().addError(ServerMessages.ENTITY_HAS_NO_UNIT); getEntity().setEntityStatus(EntityStatus.UNQUALIFIED);