chore: use waku-org/waku-proto repository for protobuffer definitions

.gitmodules

@@ -1,3 +1,6 @@
 [submodule "libs/waku-rln-contract"]
 	path = libs/waku-rln-contract
 	url = https://github.com/waku-org/waku-rln-contract.git
+[submodule "waku/v2/protocol/waku-proto"]
+	path = waku/v2/protocol/waku-proto
+	url = git@github.com:waku-org/waku-proto.git

waku/v2/protocol/filter/client.go

@@ -118,7 +118,7 @@ func (wf *WakuFilterLightNode) onRequest(ctx context.Context) func(s network.Str
 
 		reader := pbio.NewDelimitedReader(s, math.MaxInt32)
 
-		messagePush := &pb.MessagePushV2{}
+		messagePush := &pb.MessagePush{}
 		err := reader.ReadMsg(messagePush)
 		if err != nil {
 			logger.Error("reading message push", zap.Error(err))
@@ -207,7 +207,11 @@ func (wf *WakuFilterLightNode) request(ctx context.Context, params *FilterSubscr
 
 	if filterSubscribeResponse.StatusCode != http.StatusOK {
 		wf.metrics.RecordError(errorResponse)
-		err := NewFilterError(int(filterSubscribeResponse.StatusCode), filterSubscribeResponse.StatusDesc)
+		errMessage := ""
+		if filterSubscribeResponse.StatusDesc != nil {
+			errMessage = *filterSubscribeResponse.StatusDesc
+		}
+		err := NewFilterError(int(filterSubscribeResponse.StatusCode), errMessage)
 		return &err
 	}
 

waku/v2/protocol/filter/pb/generate.go

@@ -1,3 +1,3 @@
 package pb
 
-//go:generate protoc -I./../../pb/. -I. --go_opt=paths=source_relative --go_opt=Mwaku_filter_v2.proto=github.com/waku-org/go-waku/waku/v2/protocol/filter/pb --go_opt=Mwaku_message.proto=github.com/waku-org/go-waku/waku/v2/protocol/pb  --go_out=. ./waku_filter_v2.proto
+//go:generate protoc -I./../../waku-proto/waku/filter/v2/. -I./../../waku-proto/ --go_opt=paths=source_relative --go_opt=Mfilter.proto=github.com/waku-org/go-waku/waku/v2/protocol/filter/pb --go_opt=Mwaku/message/v1/message.proto=github.com/waku-org/go-waku/waku/v2/protocol/pb --go_out=. ./../../waku-proto/waku/filter/v2/filter.proto

waku/v2/protocol/filter/server.go

@@ -126,9 +126,10 @@ func (wf *WakuFilterFullNode) reply(ctx context.Context, s network.Stream, reque
 	}
 
 	if len(description) != 0 {
-		response.StatusDesc = description[0]
+		response.StatusDesc = &description[0]
 	} else {
-		response.StatusDesc = http.StatusText(statusCode)
+		desc := http.StatusText(statusCode)
+		response.StatusDesc = &desc
 	}
 
 	writer := pbio.NewDelimitedWriter(s)
@@ -271,7 +272,7 @@ func (wf *WakuFilterFullNode) pushMessage(ctx context.Context, peerID peer.ID, e
 		zap.String("contentTopic", env.Message().ContentTopic),
 	)
 	pubSubTopic := env.PubsubTopic()
-	messagePush := &pb.MessagePushV2{
+	messagePush := &pb.MessagePush{
 		PubsubTopic: &pubSubTopic,
 		WakuMessage: env.Message(),
 	}