Make JSON key for the record ID value configurable (#443)

Author: fsteeg

metafacture-json/src/main/java/org/metafacture/json/JsonValidator.java

@@ -45,21 +45,24 @@
  */
 @Description("Validate JSON against a given schema, send only valid input to the receiver. Pass the schema location to validate against. " +
         "Set 'schemaRoot' for resolving sub-schemas referenced in '$id' or '$ref' (defaults to the classpath root: '/'). " +
-        "Write valid and/or invalid output to locations specified with 'writeValid' and 'writeInvalid'.")
+        "Write valid and/or invalid output to locations specified with 'writeValid' and 'writeInvalid'." +
+        "Set the JSON key for the record ID value with 'idKey' (for logging output, defaults to 'id').")
 @In(String.class)
 @Out(String.class)
 @FluxCommand("validate-json")
 public final class JsonValidator extends DefaultObjectPipe<String, ObjectReceiver<String>> {
 
     private static final Logger LOG = LoggerFactory.getLogger(JsonValidator.class);
     private static final String DEFAULT_SCHEMA_ROOT = "/";
+    private static final String DEFAULT_ID_KEY = "id";
     private String schemaUrl;
     private Schema schema;
     private long fail;
     private long success;
     private FileWriter writeInvalid;
     private FileWriter writeValid;
     private String schemaRoot = DEFAULT_SCHEMA_ROOT;
+    private String idKey = DEFAULT_ID_KEY;
 
     /**
      * @param url The URL of the schema to validate against.
@@ -89,6 +92,13 @@ public void setWriteInvalid(final String writeInvalid) {
         this.writeInvalid = fileWriter(writeInvalid);
     }
 
+    /**
+     * @param idKey The JSON key for the record ID value.
+     */
+    public void setIdKey(final String idKey) {
+        this.idKey = idKey;
+    }
+
     @Override
     public void process(final String json) {
         final JSONObject object;
@@ -149,7 +159,7 @@ private FileWriter fileWriter(final String fileLocation) {
 
     private void handleInvalid(final String json, final JSONObject object,
             final String errorMessage) {
-        LOG.info("Invalid JSON: {} in {}", errorMessage, object != null ? object.opt("id") : json);
+        LOG.info("Invalid JSON: {} in {}", errorMessage, object != null ? object.opt(idKey) : json);
         ++fail;
         write(json, writeInvalid);
     }