ROX-22019: Protobuf v2 migration (#1500)

Makefile

@@ -383,7 +383,7 @@ generate-junit-reports: $(GO_JUNIT_REPORT_BIN)
 ## Generated Srcs ##
 ####################
 
-PROTO_GENERATED_SRCS = $(GENERATED_PB_SRCS) $(GENERATED_API_GW_SRCS)
+PROTO_GENERATED_SRCS = $(GENERATED_PB_SRCS) $(GENERATED_VT_SRCS) $(GENERATED_API_SRCS) $(GENERATED_API_GW_SRCS)
 
 include make/protogen.mk
 
@@ -525,7 +525,7 @@ local-nodescanner:
 	$(BUILD_FLAGS) $(NODESCAN_BUILD_CMD)
 
 .PHONY: local-nodescanner-build-dockerized
-local-nodescanner-build-dockerized: 
+local-nodescanner-build-dockerized:
 	@echo "+ $@"
 ifdef CI
 	docker container create --name builder $(BUILD_IMAGE) $(NODESCAN_BUILD_CMD)

api/grpc/grpc.go

@@ -11,7 +11,7 @@ import (
 
 	"github.com/NYTimes/gziphandler"
 	grpcprometheus "github.com/grpc-ecosystem/go-grpc-prometheus"
-	"github.com/grpc-ecosystem/grpc-gateway/runtime"
+	"github.com/grpc-ecosystem/grpc-gateway/v2/runtime"
 	log "github.com/sirupsen/logrus"
 	"github.com/stackrox/scanner/pkg/env"
 	"github.com/stackrox/scanner/pkg/mtls"
@@ -190,7 +190,7 @@ func (a *apiImpl) muxer(localConn *grpc.ClientConn) http.Handler {
 		mux.Handle(route, handler)
 	}
 
-	gwMux := runtime.NewServeMux(runtime.WithMarshalerOption(runtime.MIMEWildcard, &runtime.JSONPb{EmitDefaults: true}))
+	gwMux := runtime.NewServeMux(runtime.WithMarshalerOption(runtime.MIMEWildcard, &runtime.JSONPb{}))
 	for _, service := range a.apiServices {
 		if err := service.RegisterServiceHandler(context.Background(), gwMux, localConn); err != nil {
 			log.Panicf("failed to register API service: %v", err)

api/v1/imagescan/service.go

@@ -3,7 +3,7 @@ package imagescan
 import (
 	"context"
 
-	"github.com/grpc-ecosystem/grpc-gateway/runtime"
+	"github.com/grpc-ecosystem/grpc-gateway/v2/runtime"
 	"github.com/sirupsen/logrus"
 	"github.com/stackrox/rox/pkg/stringutils"
 	apiGRPC "github.com/stackrox/scanner/api/grpc"

api/v1/nodeinventory/service.go

@@ -4,7 +4,7 @@ import (
 	"context"
 	"time"
 
-	"github.com/grpc-ecosystem/grpc-gateway/runtime"
+	"github.com/grpc-ecosystem/grpc-gateway/v2/runtime"
 	"github.com/pkg/errors"
 	log "github.com/sirupsen/logrus"
 	apiGRPC "github.com/stackrox/scanner/api/grpc"

api/v1/nodescan/service.go

@@ -5,7 +5,7 @@ import (
 	"sort"
 	"strings"
 
-	"github.com/grpc-ecosystem/grpc-gateway/runtime"
+	"github.com/grpc-ecosystem/grpc-gateway/v2/runtime"
 	"github.com/pkg/errors"
 	log "github.com/sirupsen/logrus"
 	"github.com/stackrox/rox/pkg/stringutils"

api/v1/orchestratorscan/service.go

@@ -3,7 +3,7 @@ package orchestratorscan
 import (
 	"context"
 
-	"github.com/grpc-ecosystem/grpc-gateway/runtime"
+	"github.com/grpc-ecosystem/grpc-gateway/v2/runtime"
 	rpmVersion "github.com/knqyf263/go-rpm-version"
 	"github.com/pkg/errors"
 	log "github.com/sirupsen/logrus"

api/v1/ping/service.go

@@ -3,7 +3,7 @@ package ping
 import (
 	"context"
 
-	"github.com/grpc-ecosystem/grpc-gateway/runtime"
+	"github.com/grpc-ecosystem/grpc-gateway/v2/runtime"
 	apiGRPC "github.com/stackrox/scanner/api/grpc"
 	v1 "github.com/stackrox/scanner/generated/scanner/api/v1"
 	"github.com/stackrox/scanner/pkg/version"

api/v1/vulndefs/service.go

@@ -3,15 +3,15 @@ package vulndefs
 import (
 	"context"
 
-	"github.com/gogo/protobuf/types"
-	"github.com/grpc-ecosystem/grpc-gateway/runtime"
+	"github.com/grpc-ecosystem/grpc-gateway/v2/runtime"
 	apiGRPC "github.com/stackrox/scanner/api/grpc"
 	"github.com/stackrox/scanner/database"
 	v1 "github.com/stackrox/scanner/generated/scanner/api/v1"
 	"github.com/stackrox/scanner/pkg/updater"
 	"google.golang.org/grpc"
 	"google.golang.org/grpc/codes"
 	"google.golang.org/grpc/status"
+	"google.golang.org/protobuf/types/known/timestamppb"
 )
 
 // Service defines a vulnerability definitions service.
@@ -50,8 +50,8 @@ func (s *serviceImpl) GetVulnDefsMetadata(context.Context, *v1.Empty) (*v1.VulnD
 		return nil, status.Errorf(codes.Internal, "failed to obtain vulnerability definitions update timestamp: %v", err)
 	}
 
-	ts, err := types.TimestampProto(t)
-	if err != nil {
+	ts := timestamppb.New(t)
+	if err = ts.CheckValid(); err != nil {
 		return nil, status.Errorf(codes.Internal, "failed to obtain vulnerability definitions update timestamp: %v", err)
 	}