Add log function #319

metafacture · Sep 18, 2024 · f1405ea · f1405ea
1 parent 19bbe2c
commit f1405ea
Showing 1 changed file with 22 additions and 0 deletions.
diff --git a/metafix/src/main/java/org/metafacture/metafix/FixMethod.java b/metafix/src/main/java/org/metafacture/metafix/FixMethod.java
@@ -43,6 +43,9 @@
 import java.util.regex.Pattern;
 import java.util.stream.Collectors;
 
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
 public enum FixMethod implements FixFunction { // checkstyle-disable-line ClassDataAbstractionCoupling|ClassFanOutComplexity
 
     // SCRIPT-LEVEL METHODS:
@@ -62,6 +65,23 @@ public void apply(final Metafix metafix, final Record record, final List<String>
             metafix.getRecordTransformer(includePath).transform(record, options);
         }
     },
+    log {
+        @Override
+        public void apply(final Metafix metafix, final Record record, final List<String> params, final Map<String, String> options) {
+            final String logMessage = params.get(0);
+            final String logLevel = options.get("level"); // does not support Catmandu lop level option FATAL
+
+            if (logLevel.equals("WARN")) {
+                LOG.warn(logMessage);
+            }
+            else if (logLevel.equals("ERROR")) {
+                LOG.error(logMessage);
+            }
+            else {
+                LOG.info(logMessage);
+            }
+        }
+    },
     nothing {
         @Override
         public void apply(final Metafix metafix, final Record record, final List<String> params, final Map<String, String> options) {
@@ -691,4 +711,6 @@ public void apply(final Metafix metafix, final Record record, final List<String>
 
     private static final Random RANDOM = new Random();
 
+    private static final Logger LOG = LoggerFactory.getLogger(FixMethod.class);
+
 }