chore: bump to rc.4.

Signed-off-by: mikeee <[email protected]>

client/subscribe.go

@@ -104,23 +104,23 @@ func (s *Subscription) Receive() (*SubscriptionMessage, error) {
 		return nil, err
 	}
 
-	data := any(event.GetData())
-	if len(event.GetData()) > 0 {
-		mediaType, _, err := mime.ParseMediaType(event.GetDataContentType())
+	data := any(event.GetEventMessage().GetData())
+	if len(event.GetEventMessage().GetData()) > 0 {
+		mediaType, _, err := mime.ParseMediaType(event.GetEventMessage().GetDataContentType())
 		if err == nil {
 			var v interface{}
 			switch mediaType {
 			case "application/json":
-				if err := json.Unmarshal(event.GetData(), &v); err == nil {
+				if err := json.Unmarshal(event.GetEventMessage().GetData(), &v); err == nil {
 					data = v
 				}
 			case "text/plain":
 				// Assume UTF-8 encoded string.
-				data = string(event.GetData())
+				data = string(event.GetEventMessage().GetData())
 			default:
 				if strings.HasPrefix(mediaType, "application/") &&
 					strings.HasSuffix(mediaType, "+json") {
-					if err := json.Unmarshal(event.GetData(), &v); err == nil {
+					if err := json.Unmarshal(event.GetEventMessage().GetData(), &v); err == nil {
 						data = v
 					}
 				}
@@ -129,15 +129,15 @@ func (s *Subscription) Receive() (*SubscriptionMessage, error) {
 	}
 
 	topicEvent := &common.TopicEvent{
-		ID:              event.GetId(),
-		Source:          event.GetSource(),
-		Type:            event.GetType(),
-		SpecVersion:     event.GetSpecVersion(),
-		DataContentType: event.GetDataContentType(),
+		ID:              event.GetEventMessage().GetId(),
+		Source:          event.GetEventMessage().GetSource(),
+		Type:            event.GetEventMessage().GetType(),
+		SpecVersion:     event.GetEventMessage().GetSpecVersion(),
+		DataContentType: event.GetEventMessage().GetDataContentType(),
 		Data:            data,
-		RawData:         event.GetData(),
-		Topic:           event.GetTopic(),
-		PubsubName:      event.GetPubsubName(),
+		RawData:         event.GetEventMessage().GetData(),
+		Topic:           event.GetEventMessage().GetTopic(),
+		PubsubName:      event.GetEventMessage().GetPubsubName(),
 	}
 
 	return &SubscriptionMessage{
@@ -181,8 +181,8 @@ func (s *SubscriptionMessage) respond(status pb.TopicEventResponse_TopicEventRes
 	defer s.sub.lock.Unlock()
 
 	return s.sub.stream.Send(&pb.SubscribeTopicEventsRequestAlpha1{
-		SubscribeTopicEventsRequestType: &pb.SubscribeTopicEventsRequestAlpha1_EventResponse{
-			EventResponse: &pb.SubscribeTopicEventsResponseAlpha1{
+		SubscribeTopicEventsRequestType: &pb.SubscribeTopicEventsRequestAlpha1_EventProcessed{
+			EventProcessed: &pb.SubscribeTopicEventsRequestProcessedAlpha1{
 				Id:     s.ID,
 				Status: &pb.TopicEventResponse{Status: status},
 			},
@@ -206,7 +206,7 @@ func (c *GRPCClient) subscribeInitialRequest(ctx context.Context, opts Subscript
 
 	err = stream.Send(&pb.SubscribeTopicEventsRequestAlpha1{
 		SubscribeTopicEventsRequestType: &pb.SubscribeTopicEventsRequestAlpha1_InitialRequest{
-			InitialRequest: &pb.SubscribeTopicEventsInitialRequestAlpha1{
+			InitialRequest: &pb.SubscribeTopicEventsRequestInitialAlpha1{
 				PubsubName: opts.PubsubName, Topic: opts.Topic,
 				Metadata: opts.Metadata, DeadLetterTopic: opts.DeadLetterTopic,
 			},

examples/go.mod

@@ -18,7 +18,7 @@ require (
 	github.com/alecthomas/units v0.0.0-20211218093645-b94a6e3cc137 // indirect
 	github.com/cenkalti/backoff/v4 v4.3.0 // indirect
 	github.com/cespare/xxhash/v2 v2.3.0 // indirect
-	github.com/dapr/dapr v1.14.0-rc.2 // indirect
+	github.com/dapr/dapr v1.14.0-rc.4 // indirect
 	github.com/dgryski/go-rendezvous v0.0.0-20200823014737-9f7001d12a5f // indirect
 	github.com/go-chi/chi/v5 v5.1.0 // indirect
 	github.com/go-logr/logr v1.4.2 // indirect

examples/go.sum

@@ -7,8 +7,8 @@ github.com/cenkalti/backoff/v4 v4.3.0/go.mod h1:Y3VNntkOUPxTVeUxJ/G5vcM//AlwfmyY
 github.com/cespare/xxhash/v2 v2.3.0 h1:UL815xU9SqsFlibzuggzjXhog7bL6oX9BbNZnL2UFvs=
 github.com/cespare/xxhash/v2 v2.3.0/go.mod h1:VGX0DQ3Q6kWi7AoAeZDth3/j3BFtOZR5XLFGgcrjCOs=
 github.com/creack/pty v1.1.9/go.mod h1:oKZEueFk5CKHvIhNR5MUki03XCEU+Q6VDXinZuGJ33E=
-github.com/dapr/dapr v1.14.0-rc.2 h1:wuXninZLTyokeztCinVIVAc9mpVYJS8QyxecPCLdlY8=
-github.com/dapr/dapr v1.14.0-rc.2/go.mod h1:uZMuD9K7y+LKSsQUoSAvv1Yn8Cim9X/9ZQ9XuTobyP8=
+github.com/dapr/dapr v1.14.0-rc.4 h1:yyP3tzojgFgfwnJvEt4AQMWyJh9V0xzs4Cm0JXFE8dc=
+github.com/dapr/dapr v1.14.0-rc.4/go.mod h1:ahF4VpMDVCPQ7sWQYztE6JlOaBrAhRn/99Uh5JyTWX4=
 github.com/davecgh/go-spew v1.1.0/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
 github.com/davecgh/go-spew v1.1.2-0.20180830191138-d8f796af33cc h1:U9qPSI2PIWSS1VwoXQT9A3Wy9MM3WgvqSxFWenqJduM=
 github.com/davecgh/go-spew v1.1.2-0.20180830191138-d8f796af33cc/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=

go.mod

@@ -3,7 +3,7 @@ module github.com/dapr/go-sdk
 go 1.22.5
 
 require (
-	github.com/dapr/dapr v1.14.0-rc.2
+	github.com/dapr/dapr v1.14.0-rc.4
 	github.com/go-chi/chi/v5 v5.1.0
 	github.com/golang/mock v1.6.0
 	github.com/google/uuid v1.6.0

go.sum

@@ -1,8 +1,8 @@
 github.com/cenkalti/backoff/v4 v4.3.0 h1:MyRJ/UdXutAwSAT+s3wNd7MfTIcy71VQueUuFK343L8=
 github.com/cenkalti/backoff/v4 v4.3.0/go.mod h1:Y3VNntkOUPxTVeUxJ/G5vcM//AlwfmyYozVcomhLiZE=
 github.com/creack/pty v1.1.9/go.mod h1:oKZEueFk5CKHvIhNR5MUki03XCEU+Q6VDXinZuGJ33E=
-github.com/dapr/dapr v1.14.0-rc.2 h1:wuXninZLTyokeztCinVIVAc9mpVYJS8QyxecPCLdlY8=
-github.com/dapr/dapr v1.14.0-rc.2/go.mod h1:uZMuD9K7y+LKSsQUoSAvv1Yn8Cim9X/9ZQ9XuTobyP8=
+github.com/dapr/dapr v1.14.0-rc.4 h1:yyP3tzojgFgfwnJvEt4AQMWyJh9V0xzs4Cm0JXFE8dc=
+github.com/dapr/dapr v1.14.0-rc.4/go.mod h1:ahF4VpMDVCPQ7sWQYztE6JlOaBrAhRn/99Uh5JyTWX4=
 github.com/davecgh/go-spew v1.1.2-0.20180830191138-d8f796af33cc h1:U9qPSI2PIWSS1VwoXQT9A3Wy9MM3WgvqSxFWenqJduM=
 github.com/davecgh/go-spew v1.1.2-0.20180830191138-d8f796af33cc/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
 github.com/go-chi/chi/v5 v5.1.0 h1:acVI1TYaD+hhedDJ3r54HyA6sExp3HfXq7QWEEY/xMw=