Linter fixes

Signed-off-by: Tiago Scolari <[email protected]>

Author: tscolari

client/crypto.go

@@ -93,7 +93,6 @@ func performCryptoOperation[T runtimev1pb.DecryptRequest | runtimev1pb.EncryptRe
 	reqProto *T,
 	resProto *Y,
 ) (io.Reader, error) {
-
 	var err error
 	// Pipe for writing the response
 	pr, pw := io.Pipe()

client/crypto_test.go

@@ -297,9 +297,9 @@ func hasOptions[T runtimev1pb.DecryptRequest | runtimev1pb.EncryptRequest](msg *
 
 	switch r := any(msg).(type) {
 	case *runtimev1pb.EncryptRequest:
-		return r.Options != nil
+		return r.GetOptions() != nil
 	case *runtimev1pb.DecryptRequest:
-		return r.Options != nil
+		return r.GetOptions() != nil
 	}
 
 	return false

client/internal/crypto/helpers.go

@@ -1,9 +1,10 @@
 package crypto
 
 import (
+	"google.golang.org/protobuf/proto"
+
 	commonv1pb "github.com/dapr/go-sdk/internal/proto/dapr/proto/common/v1"
 	runtimev1 "github.com/dapr/go-sdk/internal/proto/dapr/proto/runtime/v1"
-	"google.golang.org/protobuf/proto"
 )
 
 func GetPayload[T runtimev1.DecryptRequest | runtimev1.EncryptRequest | runtimev1.DecryptResponse | runtimev1.EncryptResponse](req *T) *commonv1pb.StreamPayload {
@@ -13,13 +14,13 @@ func GetPayload[T runtimev1.DecryptRequest | runtimev1.EncryptRequest | runtimev
 
 	switch r := any(req).(type) {
 	case *runtimev1.EncryptRequest:
-		return r.Payload
+		return r.GetPayload()
 	case *runtimev1.DecryptRequest:
-		return r.Payload
+		return r.GetPayload()
 	case *runtimev1.EncryptResponse:
-		return r.Payload
+		return r.GetPayload()
 	case *runtimev1.DecryptResponse:
-		return r.Payload
+		return r.GetPayload()
 	}
 
 	return nil

client/internal/crypto/helpers_test.go

@@ -4,11 +4,12 @@ import (
 	"testing"
 
 	"github.com/dapr/go-sdk/client/internal/crypto"
-	commonv1 "github.com/dapr/go-sdk/internal/proto/dapr/proto/common/v1"
-	runtimev1 "github.com/dapr/go-sdk/internal/proto/dapr/proto/runtime/v1"
 	"github.com/stretchr/testify/assert"
 	"github.com/stretchr/testify/require"
 	"google.golang.org/protobuf/proto"
+
+	commonv1 "github.com/dapr/go-sdk/internal/proto/dapr/proto/common/v1"
+	runtimev1 "github.com/dapr/go-sdk/internal/proto/dapr/proto/runtime/v1"
 )
 
 func TestPayloadMethods(t *testing.T) {
@@ -56,7 +57,7 @@ func TestPayloadMethods(t *testing.T) {
 				require.Failf(t, "unsupported proto message type", "the type was %T", r)
 			}
 
-			assert.Equal(t, tc.inputData, outputPayload.Data, "payload should match the input")
+			assert.Equal(t, tc.inputData, outputPayload.GetData(), "payload should match the input")
 		})
 	}
 }
@@ -87,10 +88,10 @@ func TestSetOptions(t *testing.T) {
 			switch r := tc.protoMsg.(type) {
 			case *runtimev1.EncryptRequest:
 				crypto.SetOptions(r, tc.options)
-				outputOptions = r.Options
+				outputOptions = r.GetOptions()
 			case *runtimev1.DecryptRequest:
 				crypto.SetOptions(r, tc.options)
-				outputOptions = r.Options
+				outputOptions = r.GetOptions()
 			default:
 				require.Failf(t, "unsupported proto message type", "the type was %T", r)
 			}