Update logging of empty 200 response for pub/sub messages to indicate…

… success (dapr#7620)

Signed-off-by: Kun Chang <curtis@mail.ustc.edu.cn>

pkg/runtime/processor/pubsub/publish.go

@@ -19,6 +19,7 @@ import (
 	"encoding/json"
 	"errors"
 	"fmt"
+	"io"
 	"net/http"
 	"strings"
 	"time"
@@ -139,7 +140,11 @@ func (p *pubsub) publishMessageHTTP(ctx context.Context, msg *subscribedMessage)
 		var appResponse contribpubsub.AppResponse
 		err := json.NewDecoder(resp.RawData()).Decode(&appResponse)
 		if err != nil {
-			log.Debugf("skipping status check due to error parsing result from pub/sub event %v: %s", cloudEvent[contribpubsub.IDField], err)
+			if errors.Is(err, io.EOF) {
+				log.Debugf("skipping status check due to empty response body from pub/sub event %v", cloudEvent[contribpubsub.IDField])
+			} else {
+				log.Debugf("skipping status check due to error parsing result from pub/sub event %v: %s", cloudEvent[contribpubsub.IDField], err)
+			}
 			diag.DefaultComponentMonitoring.PubsubIngressEvent(ctx, msg.pubsub, strings.ToLower(string(contribpubsub.Success)), msg.topic, elapsed)
 			return nil
 		}

pkg/runtime/processor/pubsub/publish_test.go

@@ -108,6 +108,25 @@ func TestErrorPublishedNonCloudEventHTTP(t *testing.T) {
 		require.NoError(t, err)
 	})
 
+	t.Run("ok with empty body", func(t *testing.T) {
+		log.SetOutputLevel(logger.DebugLevel)
+		defer log.SetOutputLevel(logger.InfoLevel)
+
+		mockAppChannel := new(channelt.MockAppChannel)
+		ps.channels = new(channels.Channels).WithAppChannel(mockAppChannel)
+
+		fakeResp := invokev1.NewInvokeMethodResponse(200, "OK", nil).WithRawData(nil)
+		defer fakeResp.Close()
+
+		mockAppChannel.On("InvokeMethod", mock.Anything, fakeReq).Return(fakeResp, nil)
+
+		// act
+		err := ps.publishMessageHTTP(context.Background(), testPubSubMessage)
+
+		// assert
+		require.NoError(t, err)
+	})
+
 	t.Run("ok with retry", func(t *testing.T) {
 		mockAppChannel := new(channelt.MockAppChannel)
 		ps.channels = new(channels.Channels).WithAppChannel(mockAppChannel)