chore: upgrade to Go 1.25 (toolchain + tools + lint fixes)

go.mod

@@ -1,6 +1,6 @@
 module github.com/conduitio/conduit-processor-sdk
 
-go 1.24.2
+go 1.25.0
 
 require (
 	github.com/conduitio/conduit-commons v0.6.0

internal/reference/reference.go

@@ -21,6 +21,14 @@ import (
 	"github.com/conduitio/conduit-commons/opencdc"
 )
 
+const (
+	refKey           = ".Key"
+	refPosition      = ".Position"
+	refOperation     = ".Operation"
+	refPayloadBefore = ".Payload.Before"
+	refPayloadAfter  = ".Payload.After"
+)
+
 // Reference is an interface that represents a reference to a field in a record.
 // It can be used to get and set the value of the field dynamically using input
 // provided by the user.
@@ -120,15 +128,15 @@ func cleanInput(input string) string {
 	}
 	input = replacePrefix(input, map[string]string{
 		".payload":   ".Payload",
-		".key":       ".Key",
+		".key":       refKey,
 		".metadata":  ".Metadata",
-		".position":  ".Position",
-		".operation": ".Operation",
+		".position":  refPosition,  //nolint:goconst // canonicalization token, clearest inline
+		".operation": refOperation, //nolint:goconst // canonicalization token, clearest inline
 	})
 	if strings.HasPrefix(input, ".Payload") {
 		input = replacePrefix(input, map[string]string{
-			".Payload.before": ".Payload.Before",
-			".Payload.after":  ".Payload.After",
+			".Payload.before": refPayloadBefore,
+			".Payload.after":  refPayloadAfter,
 		})
 	}
 	return input
@@ -393,7 +401,7 @@ func (r keyReference) walk(field string) (Reference, error) {
 	return dataFieldReference{
 		data:  r.rec.Key.(opencdc.StructuredData), //nolint:forcetypeassert // we know it's the right type
 		field: field,
-		path:  ".Key",
+		path:  refKey,
 	}, nil
 }
 
@@ -483,7 +491,7 @@ func (r payloadBeforeReference) walk(field string) (Reference, error) {
 	return dataFieldReference{
 		data:  r.rec.Payload.Before.(opencdc.StructuredData), //nolint:forcetypeassert // we know it's the right type
 		field: field,
-		path:  ".Payload.Before",
+		path:  refPayloadBefore,
 	}, nil
 }
 
@@ -535,7 +543,7 @@ func (r payloadAfterReference) walk(field string) (Reference, error) {
 	return dataFieldReference{
 		data:  r.rec.Payload.After.(opencdc.StructuredData), //nolint:forcetypeassert // we know it's the right type
 		field: field,
-		path:  ".Payload.After",
+		path:  refPayloadAfter,
 	}, nil
 }
 

internal/reference/reference_test.go

@@ -65,14 +65,14 @@ func TestReference_Get_RawData(t *testing.T) {
 	}{
 		// uppercase
 		{".", rec},
-		{".Position", rec.Position},
-		{".Operation", rec.Operation},
+		{refPosition, rec.Position},
+		{refOperation, rec.Operation},
 		{".Metadata.foo", rec.Metadata["foo"]},
 		{".Metadata.bar", nil},
-		{".Key", rec.Key},
+		{refKey, rec.Key},
 		{".Payload", rec.Payload},
-		{".Payload.Before", rec.Payload.Before},
-		{".Payload.After", rec.Payload.After},
+		{refPayloadBefore, rec.Payload.Before},
+		{refPayloadAfter, rec.Payload.After},
 		// lowercase
 		{".position", rec.Position},
 		{".operation", rec.Operation},
@@ -164,8 +164,8 @@ func TestReference_Get_NoData(t *testing.T) {
 		want      any
 	}{
 		// uppercase
-		{".Position", nil},
-		{".Operation", opencdc.Operation(0)},
+		{refPosition, nil},
+		{refOperation, opencdc.Operation(0)},
 		{".Metadata.foo", nil},
 		{".Metadata.bar", nil},
 		{".Key.foo1", nil},
@@ -284,7 +284,7 @@ func TestReference_Position(t *testing.T) {
 
 	is := is.New(t)
 	resolvers := map[string]Resolver{
-		"uppercase": MustResolver(is)(NewResolver(".Position")),
+		"uppercase": MustResolver(is)(NewResolver(refPosition)),
 		"lowercase": MustResolver(is)(NewResolver(".position")),
 	}
 
@@ -341,7 +341,7 @@ func TestReference_Operation(t *testing.T) {
 
 	is := is.New(t)
 	resolvers := map[string]Resolver{
-		"uppercase": MustResolver(is)(NewResolver(".Operation")),
+		"uppercase": MustResolver(is)(NewResolver(refOperation)),
 		"lowercase": MustResolver(is)(NewResolver(".operation")),
 	}
 
@@ -531,7 +531,7 @@ func TestReference_Key(t *testing.T) {
 
 	is := is.New(t)
 	resolvers := map[string]Resolver{
-		"uppercase": MustResolver(is)(NewResolver(".Key")),
+		"uppercase": MustResolver(is)(NewResolver(refKey)),
 		"lowercase": MustResolver(is)(NewResolver(".key")),
 	}
 
@@ -673,7 +673,7 @@ func TestReference_PayloadBefore(t *testing.T) {
 	is := is.New(t)
 	resolvers := map[string]Resolver{
 		"uppercase1": MustResolver(is)(NewResolver(".payload.Before")),
-		"uppercase2": MustResolver(is)(NewResolver(".Payload.Before")),
+		"uppercase2": MustResolver(is)(NewResolver(refPayloadBefore)),
 		"lowercase1": MustResolver(is)(NewResolver(".payload.before")),
 		"lowercase2": MustResolver(is)(NewResolver(".Payload.before")),
 	}
@@ -820,7 +820,7 @@ func TestReference_PayloadAfter(t *testing.T) {
 	is := is.New(t)
 	resolvers := map[string]Resolver{
 		"uppercase1": MustResolver(is)(NewResolver(".payload.After")),
-		"uppercase2": MustResolver(is)(NewResolver(".Payload.After")),
+		"uppercase2": MustResolver(is)(NewResolver(refPayloadAfter)),
 		"lowercase1": MustResolver(is)(NewResolver(".payload.after")),
 		"lowercase2": MustResolver(is)(NewResolver(".Payload.after")),
 	}