WIP

Author: dr0i

metafix/src/main/java/org/metafacture/metafix/Metafix.java

@@ -602,6 +602,25 @@ public boolean getStrictnessHandlesProcessExceptions() {
         return strictnessHandlesProcessExceptions;
     }
 
+    /**
+     * Sets the global error limit.
+     * The default is {@link Strictness#DEFAULT_ERROR_LIMIT}.
+     *
+     * @param errorLimit the limit of allowed errors
+     */
+    public void setErrorLimit(final int errorLimit) {
+        this.strictness.setErrorLimit(errorLimit);
+    }
+
+    /**
+     * Gets the error limit.
+     *
+     * @return the error limit
+     */
+    public int getErrorLimit() {
+        return this.strictness.errorLimit;
+    }
+
     /**
      * Flags whether repeated fields should always be emitted as array entities.
      *
@@ -660,7 +679,7 @@ protected void handleInternal(final MetafactureException exception, final Record
          */
         RECORD {
             @Override
-            protected void handleInternal(final MetafactureException exception, final Record record) {
+            protected void handleInternal(final MetafactureException exception, final Record record) {;
                 log(exception, LOG::error);
                 record.setReject(true); // TODO: Skip remaining expressions?
             }
@@ -676,18 +695,28 @@ protected void handleInternal(final MetafactureException exception, final Record
             }
         };
 
+        public static final int DEFAULT_ERROR_LIMIT = Integer.MAX_VALUE;
+        private static int errorLimit = DEFAULT_ERROR_LIMIT;
+        private int errorCnt = 0;
         /**
          * Handles the exception based on the selected strictness level.
          *
          * @param exception the exception to be handled
          * @param record    the current record
          */
         public void handle(final MetafactureException exception, final Record record) {
+            errorCnt++;
+            if ( errorCnt > errorLimit){
+                throw new MetafactureException("Too many errors (as defined in errorLimit) - exiting");
+            }
             LOG.info("Current record: {}", record);
             handleInternal(exception, record);
         }
 
         protected abstract void handleInternal(MetafactureException exception, Record record);
+        public void setErrorLimit(int errorLimit){
+this.errorLimit=errorLimit;
+        }
 
         protected void log(final MetafactureException exception, final BiConsumer<String, Throwable> logger) {
             logger.accept(exception.getMessage(), exception.getCause());

metafix/src/test/java/org/metafacture/metafix/MetafixLookupTest.java

@@ -46,7 +46,7 @@
  */
 @ExtendWith(MockitoExtension.class)
 public class MetafixLookupTest {
-    private static final String CSV_MAP = "src/test/resources/org/metafacture/metafix/maps/test.csv";
+    private static final String CSV_MAP = "FUTSCHsrc/test/resources/org/metafacture/metafix/maps/test.csv";
     private static final String CSV_PATH = "/maps/test.csv";
     private static final String CSV_URL = "%s" + CSV_PATH;
     private static final String RDF_MAP = "src/test/resources/org/metafacture/metafix/maps/test.ttl";
@@ -469,6 +469,14 @@ public void shouldLookupInSeparateExternalFileMap() {
         );
     }
 
+    @Test
+    public void shouldLogWhenExternalFileMapMissing() {
+        assertMap(
+            "put_filemap('" + CSV_MAP + "')",
+            LOOKUP + " '" + CSV_MAP + "')"
+        );
+    }
+
     @Test
     public void shouldNotLookupInRelativeExternalFileMapFromInlineScript() {
         final String mapFile = "../maps/test.csv";

metafix/src/test/java/org/metafacture/metafix/MetafixScriptTest.java

@@ -584,6 +584,29 @@ public void shouldOptionallySkipExpressionOnProcessException() {
         });
     }
 
+    @Test
+    public void shouldExitingOnProcessExceptionWhenErrorLimitIsOne() {
+        assertStrictness(Metafix.Strictness.EXPRESSION, "upcase()", true, i -> {i.setStrictnessHandlesProcessExceptions(true); i.setErrorLimit(1);}, o -> {
+            o.get().startRecord("1");
+            o.get().literal("data", "foo");
+            o.get().literal("before", "");
+            o.get().literal("after", "");
+            o.get().endRecord();
+
+            o.get().startRecord("2");
+            o.get().literal("data", "foo");
+            o.get().literal("data", "bar");
+            o.get().literal("before", "");
+            o.get().literal("after", "");
+            o.get().endRecord();
+
+            o.get().startRecord("3");
+            o.get().literal("data", "bar");
+            o.get().literal("before", "");
+            o.get().literal("after", "");
+            o.get().endRecord();
+        });
+    }
     private void assertVar(final String fixDef, final Map<String, String> vars, final Map<String, String> result) {
         assertFix(fixDef, vars, f -> result.forEach((k, v) -> Assertions.assertEquals(v, f.getVars().get(k))));
     }