From 8ce3b0f17ff33ed30e01d14998c7cb4d688d0163 Mon Sep 17 00:00:00 2001 From: cui fliter Date: Sun, 9 Mar 2025 13:18:08 +0800 Subject: [PATCH] fix: Fix problematic error returns (#1102) Signed-off-by: cuishuang --- pkg/grpc/dapr/dapr_api_pubsub.go | 2 +- pkg/grpc/default_api/api_pubsub.go | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/pkg/grpc/dapr/dapr_api_pubsub.go b/pkg/grpc/dapr/dapr_api_pubsub.go index a8c40cf113..72eb6eb9e7 100644 --- a/pkg/grpc/dapr/dapr_api_pubsub.go +++ b/pkg/grpc/dapr/dapr_api_pubsub.go @@ -242,7 +242,7 @@ func (d *daprGrpcAPI) publishMessageGRPC(ctx context.Context, msg *pubsub.NewMes decoded, decodeErr := base64.StdEncoding.DecodeString(data.(string)) if decodeErr != nil { log.DefaultLogger.Debugf("unable to base64 decode cloudEvent field data_base64: %s", decodeErr) - return err + return decodeErr } envelope.Data = decoded diff --git a/pkg/grpc/default_api/api_pubsub.go b/pkg/grpc/default_api/api_pubsub.go index 43c78216e6..9984e76610 100644 --- a/pkg/grpc/default_api/api_pubsub.go +++ b/pkg/grpc/default_api/api_pubsub.go @@ -245,7 +245,7 @@ func (a *api) envelopeFromSubscriptionMessage(ctx context.Context, msg *pubsub.N decoded, decodeErr := base64.StdEncoding.DecodeString(data.(string)) if decodeErr != nil { log.DefaultLogger.Debugf("unable to base64 decode cloudEvent field data_base64: %s", decodeErr) - return nil, cloudEvent, err + return nil, cloudEvent, decodeErr } envelope.Data = decoded