Fix timestampz parsing

Author: ihippik

listener/wal_transaction.go

@@ -79,7 +79,10 @@ func (c *Column) AssertValue(src []byte) {
 
 	strSrc := string(src)
 
-	const timestampLayout = "2006-01-02 15:04:05"
+	const (
+		timestampLayout       = "2006-01-02 15:04:05"
+		timestampWithTZLayout = "2006-01-02 15:04:05.999999999+00"
+	)
 
 	switch c.valueType {
 	case BoolOID:
@@ -93,7 +96,7 @@ func (c *Column) AssertValue(src []byte) {
 	case TimestampOID:
 		val, err = time.Parse(timestampLayout, strSrc)
 	case TimestamptzOID:
-		val, err = time.Parse(time.RFC3339, strSrc)
+		val, err = time.ParseInLocation(timestampWithTZLayout, strSrc, time.UTC)
 	case DateOID, TimeOID:
 		val = strSrc
 	case UUIDOID:

listener/wal_transaction_test.go

@@ -236,11 +236,11 @@ func TestColumn_AssertValue(t *testing.T) {
 				isKey:     false,
 			},
 			args: args{
-				src: []byte("2022-08-27T17:44:01.041007Z"),
+				src: []byte("2022-08-27 17:44:58.083316+00"),
 			},
 			want: &Column{
 				name:      "created",
-				value:     time.Date(2022, 8, 27, 17, 44, 1, 41007000, time.UTC),
+				value:     time.Date(2022, 8, 27, 17, 44, 58, 83316000, time.UTC),
 				valueType: 1184,
 				isKey:     false,
 			},