Register custom Fix commands. (metafacture/metafacture-core#706)

blackwinter · blackwinter · commit bed69402ca8c · 2025-10-14T10:10:58.000+02:00
diff --git a/src/main/java/hbz/limetrans/function/Dedup.java b/src/main/java/hbz/limetrans/function/Dedup.java
@@ -1,5 +1,6 @@
 package hbz.limetrans.function;
 
+import org.metafacture.metafix.FixCommand;
 import org.metafacture.metafix.Metafix;
 import org.metafacture.metafix.Record;
 import org.metafacture.metafix.api.FixFunction;
@@ -9,6 +10,7 @@
 import java.util.Map;
 import java.util.Set;
 
+@FixCommand("dedup")
 public class Dedup implements FixFunction {
 
     public Dedup() {
diff --git a/src/main/java/hbz/limetrans/function/DropLocal.java b/src/main/java/hbz/limetrans/function/DropLocal.java
@@ -1,5 +1,6 @@
 package hbz.limetrans.function;
 
+import org.metafacture.metafix.FixCommand;
 import org.metafacture.metafix.Metafix;
 import org.metafacture.metafix.Record;
 import org.metafacture.metafix.Value;
@@ -14,6 +15,7 @@
 import java.util.regex.Matcher;
 import java.util.regex.Pattern;
 
+@FixCommand("drop_local")
 public class DropLocal implements FixFunction {
 
     private static final String LOCAL = "LOCAL";
diff --git a/src/main/java/hbz/limetrans/function/DropRepeated.java b/src/main/java/hbz/limetrans/function/DropRepeated.java
@@ -1,5 +1,6 @@
 package hbz.limetrans.function;
 
+import org.metafacture.metafix.FixCommand;
 import org.metafacture.metafix.Metafix;
 import org.metafacture.metafix.Record;
 import org.metafacture.metafix.Value;
@@ -8,6 +9,7 @@
 import java.util.List;
 import java.util.Map;
 
+@FixCommand("drop_repeated")
 public class DropRepeated implements FixFunction {
 
     public DropRepeated() {
diff --git a/src/main/java/hbz/limetrans/function/MemberLocal.java b/src/main/java/hbz/limetrans/function/MemberLocal.java
@@ -1,5 +1,6 @@
 package hbz.limetrans.function;
 
+import org.metafacture.metafix.FixCommand;
 import org.metafacture.metafix.Metafix;
 import org.metafacture.metafix.Record;
 import org.metafacture.metafix.api.FixPredicate;
@@ -10,6 +11,7 @@
 import java.util.List;
 import java.util.Map;
 
+@FixCommand("member_local")
 public class MemberLocal implements FixPredicate {
 
     private static final String SUBFIELD = "M";
diff --git a/src/main/java/hbz/limetrans/function/PutLmdbMap.java b/src/main/java/hbz/limetrans/function/PutLmdbMap.java
@@ -2,13 +2,15 @@
 
 import hbz.limetrans.util.LMDB;
 
+import org.metafacture.metafix.FixCommand;
 import org.metafacture.metafix.Metafix;
 import org.metafacture.metafix.Record;
 import org.metafacture.metafix.api.FixFunction;
 
 import java.util.List;
 import java.util.Map;
 
+@FixCommand("put_lmdbmap")
 public class PutLmdbMap implements FixFunction {
 
     public PutLmdbMap() {
diff --git a/src/main/java/hbz/limetrans/function/StandardNumber.java b/src/main/java/hbz/limetrans/function/StandardNumber.java
@@ -1,5 +1,6 @@
 package hbz.limetrans.function;
 
+import org.metafacture.metafix.FixCommand;
 import org.metafacture.metafix.Metafix;
 import org.metafacture.metafix.Record;
 import org.metafacture.metafix.Value;
@@ -19,6 +20,7 @@
 import java.util.regex.Pattern;
 import java.util.stream.IntStream;
 
+@FixCommand("standard_number")
 public class StandardNumber implements FixFunction {
 
     private static final String IDENTIFIER_FORMAT = "identifier%s";
diff --git a/src/main/java/hbz/limetrans/function/VerifyLinks.java b/src/main/java/hbz/limetrans/function/VerifyLinks.java
@@ -4,6 +4,7 @@
 
 import org.apache.logging.log4j.LogManager;
 import org.apache.logging.log4j.Logger;
+import org.metafacture.metafix.FixCommand;
 import org.metafacture.metafix.Metafix;
 import org.metafacture.metafix.Record;
 import org.metafacture.metafix.Value;
@@ -20,6 +21,7 @@
 import java.util.function.Consumer;
 import java.util.function.Predicate;
 
+@FixCommand("verify_links")
 public class VerifyLinks implements FixFunction {
 
     private static final Logger LOGGER = LogManager.getLogger();
diff --git a/src/main/resources/fix-commands.properties b/src/main/resources/fix-commands.properties
@@ -0,0 +1 @@
+hbz.limetrans.function
diff --git a/src/main/resources/transformation/DE-107-bridge-supplement-sisis.fix b/src/main/resources/transformation/DE-107-bridge-supplement-sisis.fix
@@ -194,7 +194,7 @@ do list_as("$t": "0451.*", "$d": "0453.*", "$v": "0455.*")
     end
   end
 end
-hbz.limetrans.function.Dedup("SeriesStatement[].*.title")
+dedup("SeriesStatement[].*.title")
 
 # SISIS/0501
 add_array("Description[]")
@@ -212,11 +212,11 @@ end
 add_array("IdentifierISBN[]")
 do list(path: "0540.*", "var": "$i")
   copy_field("$i", "IdentifierISBN[].$append.identifierISBN")
-  hbz.limetrans.function.StandardNumber("ISBN", "IdentifierISBN[].$last", source: "$i")
+  standard_number("ISBN", "IdentifierISBN[].$last", source: "$i")
 end
 do list(path: "0541.*", "var": "$i")
   copy_field("$i", "IdentifierISBN[].$append.identifierISBN")
-  hbz.limetrans.function.StandardNumber("ISBN", "IdentifierISBN[].$last", source: "$i")
+  standard_number("ISBN", "IdentifierISBN[].$last", source: "$i")
 end
 
 # SISIS/0600
diff --git a/src/main/resources/transformation/DE-708-deposit.fix b/src/main/resources/transformation/DE-708-deposit.fix
@@ -105,7 +105,7 @@ include("./marc/titleOther.fix")
 include("./marc/rswk.fix")
 include("./marc/translatedTitle.fix")
 
-hbz.limetrans.function.Dedup("OnlineAccess[].*.uri")
+dedup("OnlineAccess[].*.uri")
 
 retain(
   "AbbreviatedTitle[]",
diff --git a/src/main/resources/transformation/alma.fix b/src/main/resources/transformation/alma.fix
@@ -15,13 +15,13 @@ do once("setup")
   put_filemap("$[external-maps]/lookup-tables/data/almaSublibraryCode2Isil/generated/generatedAlmaSublibraryCode2Isil.tsv", "alma-library-to-isil", sep_char: "\t")
   put_filemap("$[external-maps]/lookup-tables/data/almaSuppressedLocations/generated/generatedAlmaSuppressedLocations.tsv", "alma-suppressed-location", sep_char: "\t")
 
-  hbz.limetrans.function.PutLmdbMap("$[external-maps]/lobid-gnd.lmdb", "lobid-gnd")
-  hbz.limetrans.function.PutLmdbMap("$[external-maps]/lobid-organisations.lmdb", "lobid-organisations")
-  hbz.limetrans.function.PutLmdbMap("$[external-maps]/rvk.lmdb", "rvk")
+  put_lmdbmap("$[external-maps]/lobid-gnd.lmdb", "lobid-gnd")
+  put_lmdbmap("$[external-maps]/lobid-organisations.lmdb", "lobid-organisations")
+  put_lmdbmap("$[external-maps]/rvk.lmdb", "rvk")
 end
 
-hbz.limetrans.function.DropLocal()
-hbz.limetrans.function.DropRepeated("008")
+drop_local()
+drop_repeated("008")
 
 # MARC/leader, MARC/006, MARC/007, MARC/008
 include("./marc/fixedLengthDataElements.fix")
@@ -409,7 +409,7 @@ include("./marc/introx_carrier.fix")
 # MARC/983
 add_array("@SubjectGHBLocal")
 do list(path: "983  ", "var": "$i")
-  if hbz.limetrans.function.MemberLocal("$i")
+  if member_local("$i")
     copy_field("$i.[ab]", "@SubjectGHBLocal.$append")
   end
 end
@@ -488,7 +488,7 @@ do list(path: "0167?", "var": "$i")
   if any_equal("$i.2", "DE-600")
     add_hash("IdentifierZDB[].$append")
     copy_field("$i.a", "IdentifierZDB[].$last.identifierZDB")
-    hbz.limetrans.function.StandardNumber("ZDB", "IdentifierZDB[].$last")
+    standard_number("ZDB", "IdentifierZDB[].$last")
     if exists("IdentifierZDB[].$last.preferredZDB")
       paste("@zdbids.$append", "~(", "$i.2", "~)", "$i.a", join_char: "")
     end
@@ -523,7 +523,7 @@ do list(path: "029[ab]?", "var": "$i")
   do list(path: "$i.a", "var": "$j")
     add_hash("IdentifierSerial[].$append")
     copy_field("$j", "IdentifierSerial[].$last.identifierISSN")
-    hbz.limetrans.function.StandardNumber("ISSN", "IdentifierSerial[].$last")
+    standard_number("ISSN", "IdentifierSerial[].$last")
   end
 end
 
@@ -639,13 +639,13 @@ add_array("@description")
 add_array("DescriptionOfProvenance[]")
 add_array("introx.provenance[]")
 do list(path: "985  ", "var": "$i")
-  if hbz.limetrans.function.MemberLocal("$i")
+  if member_local("$i")
     copy_field("$i.a", "DescriptionOfProvenance[].$append.description")
     copy_field("$i.a", "introx.provenance[].$append")
   end
 end
 do list(path: "989  ", "var": "$i")
-  if hbz.limetrans.function.MemberLocal("$i")
+  if member_local("$i")
     copy_field("$i.a", "@description.$append")
     copy_field("$i.a", "introx.provenance[].$append")
   end
@@ -802,7 +802,7 @@ do list(path: "9640s", "var": "$i")
     add_hash("IdentifierISBNParallel[].$append")
     add_array("IdentifierISBNParallel[].$last.identifierISBN[]")
     copy_field("$i.[abcdehnpqs]", "IdentifierISBNParallel[].$last.identifierISBN[].$append")
-    hbz.limetrans.function.StandardNumber("ISBN", "IdentifierISBNParallel[].$last", source: "IdentifierISBNParallel[].$last.identifierISBN[].1")
+    standard_number("ISBN", "IdentifierISBNParallel[].$last", source: "IdentifierISBNParallel[].$last.identifierISBN[].1")
   end
 end
 
@@ -816,7 +816,7 @@ include("./marc/seriesAddedEntryUniformTitle.fix")
 include("./marc/onlineAccess.fix")
 # MARC/998
 do list(path: "9984?", "var": "$i")
-  if hbz.limetrans.function.MemberLocal("$i")
+  if member_local("$i")
     call_macro("online-access")
     add_field("OnlineAccess[].$last.isInternalLinkFor", "$[isil]")
   end
@@ -888,7 +888,7 @@ do list(path: "@sisis_supplement-2662", "var": "$i")
   copy_field("$i", "OnlineAccess[].$last.uri")
   add_field("OnlineAccess[].$last.isInternalLinkFor", "$[isil]")
 end
-hbz.limetrans.function.Dedup("OnlineAccess[].*.uri")
+dedup("OnlineAccess[].*.uri")
 
 # MARC/962
 add_array("ClassifierDigitization[]")
@@ -903,15 +903,15 @@ end
 # MARC/980
 add_array("ClassifierLocal.classifier[]")
 do list(path: "9801 ", "var": "$i")
-  if hbz.limetrans.function.MemberLocal("$i")
+  if member_local("$i")
     do list(path: "$i.a", "var": "$j")
       copy_field("$j", "ClassifierLocal.classifier[].$append")
     end
   end
 end
 add_array("ClassifierLocal.collection[]")
 do list(path: "980  ", "var": "$i")
-  if hbz.limetrans.function.MemberLocal("$i")
+  if member_local("$i")
     do list(path: "$i.s", "var": "$j")
       copy_field("$j", "ClassifierLocal.collection[].$append")
     end
@@ -921,7 +921,7 @@ end
 # MARC/982
 add_array("@subjectHeadings")
 do list(path: "982  ", "var": "$i")
-  if hbz.limetrans.function.MemberLocal("$i")
+  if member_local("$i")
     copy_field("$i.b", "@subjectHeadings.$append")
     copy_field("$i.a", "@subjectTopicName")
     split_field("@subjectTopicName", ";|\\*")
@@ -1004,7 +1004,7 @@ do list(path: "H52??", "var": "$i")
 end
 # MARC/992
 do list(path: "992??", "var": "$i")
-  if hbz.limetrans.function.MemberLocal("$i")
+  if member_local("$i")
     copy_field("$i.a", "introx.localCallNumber[].$append")
   end
 end
@@ -1076,7 +1076,7 @@ include("./marc/translatedTitle.fix")
 # MARC/880
 add_array("AlternateGraphicRepresentation[]")
 do list(path: "880??", "var": "$i")
-  if hbz.limetrans.function.MemberLocal("$i")
+  if member_local("$i")
     add_hash("AlternateGraphicRepresentation[].$append")
 
     copy_field("$i.6", "@linkage")
@@ -1288,4 +1288,4 @@ retain(
 
 vacuum()
 
-hbz.limetrans.function.VerifyLinks()
+verify_links()
diff --git a/src/main/resources/transformation/marc/_linkingEntry.fix b/src/main/resources/transformation/marc/_linkingEntry.fix
@@ -13,9 +13,9 @@ do list(path: "$[source][ 0]?", "var": "$i")
   call_macro("remove-nonsort", source: "$i.t")
   call_macro("copy-first-item", source: "$i.t", target: "$[target][].$last.title")
   call_macro("copy-first-item", source: "$i.x", target: "$[target][].$last.identifierISSN")
-  hbz.limetrans.function.StandardNumber("ISSN", "$[target][].$last")
+  standard_number("ISSN", "$[target][].$last")
   call_macro("copy-all-items", source: "$i.z", target: "$[target][].$last.identifierISBN")
-  hbz.limetrans.function.StandardNumber("ISBN", "$[target][].$last", source: "$[target][].$last.identifierISBN[].1") # TODO: multiple ISBNs?
+  standard_number("ISBN", "$[target][].$last", source: "$[target][].$last.identifierISBN[].1") # TODO: multiple ISBNs?
   call_macro("copy-all-items", source: "$i.w", target: "$[target][].$last.controlNumber")
   call_macro("alma-mms-with-isil", source: "$i.w", target: "$[target][].$last.identifierForLinkingEntry")
 end
diff --git a/src/main/resources/transformation/marc/_person.fix b/src/main/resources/transformation/marc/_person.fix
@@ -18,7 +18,7 @@ do list(path: "$i.c", "var": "$j")
   copy_field("$j", "@person.$last.personTitle[].$append")
   paste("@combined_label", "@combined_label", "~, ", "$j", join_char: "")
 end
-hbz.limetrans.function.DropRepeated("$i.d", index: "2")
+drop_repeated("$i.d", index: "2")
 replace_all("$i.d", "[.]$", "")
 copy_field("$i.d", "@person.$last.personBio")
 if exists("$i.d")
diff --git a/src/main/resources/transformation/marc/identifierISBN.fix b/src/main/resources/transformation/marc/identifierISBN.fix
@@ -11,7 +11,7 @@ do list(path: "020??", "var": "$i")
       copy_field("$j", "IdentifierISBN[].$last.identifierISBN[].$append")
     end
     call_macro("copy-first-item", source: "$i.a", target: "$i.@isbn")
-    hbz.limetrans.function.StandardNumber("ISBN", "IdentifierISBN[].$last", source: "$i.@isbn")
+    standard_number("ISBN", "IdentifierISBN[].$last", source: "$i.@isbn")
   end
   add_array("IdentifierISBN[].$last.invalidISBN[]")
   do list(path: "$i.z", "var": "$j")
diff --git a/src/main/resources/transformation/marc/identifierISSN.fix b/src/main/resources/transformation/marc/identifierISSN.fix
@@ -4,6 +4,6 @@ do list(path: "022? ", "var": "$i")
   do list(path: "$i.a", "var": "$j")
     add_hash("IdentifierISSN[].$append")
     copy_field("$j", "IdentifierISSN[].$last.identifierISSN")
-    hbz.limetrans.function.StandardNumber("ISSN", "IdentifierISSN[].$last")
+    standard_number("ISSN", "IdentifierISSN[].$last")
   end
 end
diff --git a/src/main/resources/transformation/marc/onlineAccess.fix b/src/main/resources/transformation/marc/onlineAccess.fix
@@ -1,7 +1,7 @@
 # MARC/856
 add_array("OnlineAccess[]")
 do list(path: "856??", "var": "$i")
-  if hbz.limetrans.function.MemberLocal("$i")
+  if member_local("$i")
     call_macro("online-access")
   end
 end
