Add isbn() Fix function. (#231)

Author: blackwinter

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

@@ -18,6 +18,7 @@
 
 import org.metafacture.metafix.api.FixFunction;
 import org.metafacture.metamorph.api.Maps;
+import org.metafacture.metamorph.functions.ISBN;
 import org.metafacture.metamorph.functions.Timestamp;
 import org.metafacture.metamorph.maps.FileMap;
 
@@ -359,6 +360,18 @@ public void apply(final Metafix metafix, final Record record, final List<String>
             record.transform(params.get(0), s -> String.valueOf(s.indexOf(search))); // TODO: multiple
         }
     },
+    isbn {
+        @Override
+        public void apply(final Metafix metafix, final Record record, final List<String> params, final Map<String, String> options) {
+            final ISBN isbn = new ISBN();
+
+            withOption(options, "error_string", isbn::setErrorString);
+            withOption(options, "to", isbn::setTo);
+            withOption(options, "verify_check_digit", isbn::setVerifyCheckDigit);
+
+            record.transform(params.get(0), isbn::process);
+        }
+    },
     join_field {
         @Override
         public void apply(final Metafix metafix, final Record record, final List<String> params, final Map<String, String> options) {

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

@@ -1145,6 +1145,95 @@ public void shouldGetIndexOfSubstring() {
         );
     }
 
+    @Test
+    public void shouldCleanseISBN10() {
+        MetafixTestHelpers.assertFix(streamReceiver, Arrays.asList(
+                "isbn(test)"
+            ),
+            i -> {
+                i.startRecord("1");
+                i.literal("test", "ISBN: 1-.93.3-988-31-2 EUro 17.70");
+                i.endRecord();
+            },
+            o -> {
+                o.get().startRecord("1");
+                o.get().literal("test", "1933988312");
+                o.get().endRecord();
+            }
+        );
+    }
+
+    @Test
+    public void shouldConvertISBN10ToISBN13() {
+        MetafixTestHelpers.assertFix(streamReceiver, Arrays.asList(
+                "isbn(test, to: 'isbn13')"
+            ),
+            i -> {
+                i.startRecord("1");
+                i.literal("test", "1933988312");
+                i.endRecord();
+            },
+            o -> {
+                o.get().startRecord("1");
+                o.get().literal("test", "9781933988313");
+                o.get().endRecord();
+            }
+        );
+    }
+
+    @Test
+    public void shouldConvertISBN13ToISBN10() {
+        MetafixTestHelpers.assertFix(streamReceiver, Arrays.asList(
+                "isbn(test, to: 'isbn10')"
+            ),
+            i -> {
+                i.startRecord("1");
+                i.literal("test", "9781933988313");
+                i.endRecord();
+            },
+            o -> {
+                o.get().startRecord("1");
+                o.get().literal("test", "1933988312");
+                o.get().endRecord();
+            }
+        );
+    }
+
+    @Test
+    public void shouldNotProcessInvalidISBN10() {
+        MetafixTestHelpers.assertFix(streamReceiver, Arrays.asList(
+                "isbn(test, verify_check_digit: 'true')"
+            ),
+            i -> {
+                i.startRecord("1");
+                i.literal("test", "1933988313");
+                i.endRecord();
+            },
+            o -> {
+                o.get().startRecord("1");
+                o.get().endRecord();
+            }
+        );
+    }
+
+    @Test
+    public void shouldSetInvalidISBN10ToErrorString() {
+        MetafixTestHelpers.assertFix(streamReceiver, Arrays.asList(
+                "isbn(test, verify_check_digit: 'true', error_string: 'invalid')"
+            ),
+            i -> {
+                i.startRecord("1");
+                i.literal("test", "1933988313");
+                i.endRecord();
+            },
+            o -> {
+                o.get().startRecord("1");
+                o.get().literal("test", "invalid");
+                o.get().endRecord();
+            }
+        );
+    }
+
     @Test
     public void shouldJoinArrayField() {
         MetafixTestHelpers.assertFix(streamReceiver, Arrays.asList(