From 804dedbc8a41de41f8164d39841adaa015e52517 Mon Sep 17 00:00:00 2001
From: armstrmi <mitchell.armstrong@bluemedora.com>
Date: Wed, 2 Mar 2022 14:57:40 -0500
Subject: [PATCH] allowed any int value for version and priority

---
 rfc5424/machine.go | 71 +++++++++++++++-------------------------------
 1 file changed, 23 insertions(+), 48 deletions(-)

diff --git a/rfc5424/machine.go b/rfc5424/machine.go
index 78bf991..0240b7e 100644
--- a/rfc5424/machine.go
+++ b/rfc5424/machine.go
@@ -2,6 +2,7 @@ package rfc5424
 
 import (
 	"fmt"
+	"math"
 	"time"
 
 	"github.com/observiq/go-syslog/v3"
@@ -13,11 +14,11 @@ var ColumnPositionTemplate = " [col %d]"
 
 const (
 	// ErrPrival represents an error in the priority value (PRIVAL) inside the PRI part of the RFC5424 syslog message.
-	ErrPrival = "expecting a priority value in the range 1-191 or equal to 0"
+	ErrPrival = "expecting a priority value in the range 1-255 or equal to 0"
 	// ErrPri represents an error in the PRI part of the RFC5424 syslog message.
 	ErrPri = "expecting a priority value within angle brackets"
 	// ErrVersion represents an error in the VERSION part of the RFC5424 syslog message.
-	ErrVersion = "expecting a version value in the range 1-999"
+	ErrVersion = "expecting a version value in the range 0-%d"
 	// ErrTimestamp represents an error in the TIMESTAMP part of the RFC5424 syslog message.
 	ErrTimestamp = "expecting a RFC3339MICRO timestamp or a nil value"
 	// ErrHostname represents an error in the HOSTNAME part of the RFC5424 syslog message.
@@ -111,6 +112,8 @@ func (m *machine) text() []byte {
 // It can also partially parse input messages returning a partially valid structured representation
 // and the error that stopped the parsing.
 func (m *machine) Parse(input []byte) (syslog.Message, error) {
+	test := math.MaxUint32
+
 	m.data = input
 	m.p = 0
 	m.pb = 0
@@ -1450,8 +1453,6 @@ func (m *machine) Parse(input []byte) (syslog.Message, error) {
 			goto stCase654
 		case 655:
 			goto stCase655
-		case 656:
-			goto stCase656
 		case 657:
 			goto stCase657
 		case 658:
@@ -1531,7 +1532,7 @@ func (m *machine) Parse(input []byte) (syslog.Message, error) {
 		goto st0
 	tr7:
 
-		m.err = fmt.Errorf(ErrVersion+ColumnPositionTemplate, m.p)
+		m.err = fmt.Errorf(ErrVersion+ColumnPositionTemplate, math.MaxUint16, m.p)
 		(m.p)--
 
 		{
@@ -1834,21 +1835,14 @@ func (m *machine) Parse(input []byte) (syslog.Message, error) {
 			goto _testEof2
 		}
 	stCase2:
-		switch (m.data)[(m.p)] {
-		case 48:
-			goto tr3
-		case 49:
-			goto tr4
+		if (m.data)[(m.p)] == 62 {
+			goto st4
 		}
-		if 50 <= (m.data)[(m.p)] && (m.data)[(m.p)] <= 57 {
+
+		if 48 <= (m.data)[(m.p)] && (m.data)[(m.p)] <= 57 {
 			goto tr5
 		}
 		goto tr2
-	tr3:
-
-		m.pb = m.p
-
-		goto st3
 	st3:
 		if (m.p)++; (m.p) == (m.pe) {
 			goto _testEof3
@@ -1867,7 +1861,7 @@ func (m *machine) Parse(input []byte) (syslog.Message, error) {
 			goto _testEof4
 		}
 	stCase4:
-		if 49 <= (m.data)[(m.p)] && (m.data)[(m.p)] <= 57 {
+		if 48 <= (m.data)[(m.p)] && (m.data)[(m.p)] <= 57 {
 			goto tr8
 		}
 		goto tr7
@@ -11053,37 +11047,20 @@ func (m *machine) Parse(input []byte) (syslog.Message, error) {
 			goto _testEof655
 		}
 	stCase655:
-
+		test = common.UnsafeUTF8DecimalCodePointsToInt(m.text())
 		output.version = uint16(common.UnsafeUTF8DecimalCodePointsToInt(m.text()))
 
-		if (m.data)[(m.p)] == 32 {
-			goto st6
-		}
-		if 48 <= (m.data)[(m.p)] && (m.data)[(m.p)] <= 57 {
-			goto st656
-		}
-		goto tr7
-	st656:
-		if (m.p)++; (m.p) == (m.pe) {
-			goto _testEof656
+		if test > math.MaxUint16 {
+			goto tr7
 		}
-	stCase656:
-
-		output.version = uint16(common.UnsafeUTF8DecimalCodePointsToInt(m.text()))
 
 		if (m.data)[(m.p)] == 32 {
 			goto st6
 		}
-		goto tr7
-	tr4:
-
-		m.pb = m.p
-
-		goto st657
-	st657:
-		if (m.p)++; (m.p) == (m.pe) {
-			goto _testEof657
+		if 48 <= (m.data)[(m.p)] && (m.data)[(m.p)] <= 57 {
+			goto st655
 		}
+		goto tr7
 	stCase657:
 
 		output.priority = uint8(common.UnsafeUTF8DecimalCodePointsToInt(m.text()))
@@ -11109,15 +11086,19 @@ func (m *machine) Parse(input []byte) (syslog.Message, error) {
 			goto _testEof658
 		}
 	stCase658:
-
+		test = common.UnsafeUTF8DecimalCodePointsToInt(m.text())
 		output.priority = uint8(common.UnsafeUTF8DecimalCodePointsToInt(m.text()))
 		output.prioritySet = true
 
+		if test > math.MaxUint8 {
+			goto tr2
+		}
+
 		if (m.data)[(m.p)] == 62 {
 			goto st4
 		}
 		if 48 <= (m.data)[(m.p)] && (m.data)[(m.p)] <= 57 {
-			goto st3
+			goto st658
 		}
 		goto tr2
 	st659:
@@ -13290,12 +13271,6 @@ func (m *machine) Parse(input []byte) (syslog.Message, error) {
 	_testEof655:
 		m.cs = 655
 		goto _testEof
-	_testEof656:
-		m.cs = 656
-		goto _testEof
-	_testEof657:
-		m.cs = 657
-		goto _testEof
 	_testEof658:
 		m.cs = 658
 		goto _testEof