Grok/Match: provide option to completely disable automatic conversion (#71)

Author: retoo

src/main/java/io/thekraken/grok/api/Grok.java

@@ -86,6 +86,12 @@ public class Grok implements Serializable {
   /** only use in grok discovery. */
   private String savedPattern;
 
+
+  /**
+   * automatic conversion of values
+   */
+  private boolean automaticConversionEnabled = true;
+
   /**
    * Create Empty {@code Grok}.
    */
@@ -260,7 +266,17 @@ public void addPatternFromReader(Reader r) throws GrokException {
     } catch (GrokException e) {
       throw new GrokException(e.getMessage());
     }
+  }
+
+  /**
+   * Disable automatic conversion of values
+   */
+  public void disableAutomaticConversion() {
+    this.automaticConversionEnabled = false;
+  }
 
+  public boolean isAutomaticConversionEnabled() {
+    return automaticConversionEnabled;
   }
 
   /**

src/main/java/io/thekraken/grok/api/Match.java

@@ -175,6 +175,8 @@ private void captures(boolean flattened ) {
       return;
     }
     capture.clear();
+    boolean automaticConversionEnabled = grok.isAutomaticConversionEnabled();
+
 
     // _capture.put("LINE", this.line);
     // _capture.put("LENGTH", this.line.length() +"");
@@ -195,21 +197,24 @@ private void captures(boolean flattened ) {
       if (pairs.getValue() != null) {
         value = pairs.getValue().toString();
 
-        KeyValue keyValue = Converter.convert(key, value);
 
-        // get validated key
-        key = keyValue.getKey();
+        if (automaticConversionEnabled) {
+          KeyValue keyValue = Converter.convert(key, value);
 
-        // resolve value
-        if (keyValue.getValue() instanceof String) {
-          value = cleanString((String) keyValue.getValue());
-        } else {
-          value = keyValue.getValue();
-        }
+          // get validated key
+          key = keyValue.getKey();
 
-        // set if grok failure
-        if (keyValue.hasGrokFailure()) {
-          capture.put(key + "_grokfailure", keyValue.getGrokFailure());
+          // resolve value
+          if (keyValue.getValue() instanceof String) {
+            value = cleanString((String) keyValue.getValue());
+          } else {
+            value = keyValue.getValue();
+          }
+
+          // set if grok failure
+          if (keyValue.hasGrokFailure()) {
+            capture.put(key + "_grokfailure", keyValue.getGrokFailure());
+          }
         }
       }
 

src/test/java/io/thekraken/grok/api/GrokTest.java

@@ -522,4 +522,17 @@ public void test017_nonMachingList() throws GrokException {
         assertEquals(i, 4);
     }
 
+    /* see: https://github.com/thekrakken/java-grok/issues/64 */
+    @Test
+    public void testDisablingAutomaticConversion() throws GrokException {
+        String input = "client id: \"foo\" \"bar\"";
+        String pattern = "(?<message>client id): (?<clientid>.*)";
+
+        Grok grok = new Grok();
+        grok.disableAutomaticConversion();
+        grok.compile(pattern, false);
+        Match gm = grok.match(input);
+        gm.captures();
+        assertEquals("\"foo\" \"bar\"", gm.toMap().get("clientid"));
+    }
 }