From 80df02b122c0d1ca158d6077aabbab7c0e1fd199 Mon Sep 17 00:00:00 2001
From: Michal Sokolowski <0michalsokolowski0@gmail.com>
Date: Sun, 24 Jul 2022 02:37:49 +0200
Subject: [PATCH] Add logfmt file extension (#286)

* Fix

* Add .logfmt to supported file extensions

* Add .logfmt to supported file extensions

* Add missing case in TransformReader
---
 runner/file.go | 2 ++
 runner/http.go | 2 ++
 2 files changed, 4 insertions(+)

diff --git a/runner/file.go b/runner/file.go
index 9bfa52a97..a69cae75f 100644
--- 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
index 4a7dc48ba..b5a71e811 100644
--- 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 {