Add logfmt file extension (#286)

* Fix * Add .logfmt to supported file extensions * Add .logfmt to supported file extensions * Add missing case in TransformReader
multiprocessio · Jul 24, 2022 · 80df02b · 80df02b
1 parent 3362433
commit 80df02b
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 0 deletions.
diff --git a/runner/file.go b/runner/file.go
@@ -631,6 +631,8 @@ func GetMimeType(fileName string, ct ContentTypeInfo) MimeType {
 		return AvroMimeType
 	case ".yaml", ".yml":
 		return YAMLMimeType
+	case ".logfmt":
+		return LogFmtMimeType
 	}
 
 	return UnknownMimeType

diff --git a/runner/http.go b/runner/http.go
@@ -318,6 +318,8 @@ func TransformReader(r *bufio.Reader, fileName string, cti ContentTypeInfo, out
 			return edse(err)
 		}
 		return transformOpenOfficeSheet(oor, out)
+	case LogFmtMimeType:
+		return transformLogFmtFile(fileName, out)
 	}
 
 	if re, ok := BUILTIN_REGEX[assumedType]; ok {