Add protocol version in response

cmd/soroban-rpc/internal/jsonrpc.go

@@ -173,7 +173,7 @@ func NewJSONRPCHandler(cfg *config.Config, params HandlerParams) Handler {
 		},
 		{
 			methodName:           "getVersionInfo",
-			underlyingHandler:    methods.NewGetVersionInfoHandler(params.Logger, params.Daemon),
+			underlyingHandler:    methods.NewGetVersionInfoHandler(params.Logger, params.LedgerEntryReader, params.LedgerReader, params.Daemon),
 			longName:             "get_version_info",
 			queueLimit:           cfg.RequestBacklogGetVersionInfoQueueLimit,
 			requestDurationLimit: cfg.MaxGetVersionInfoExecutionDuration,

cmd/soroban-rpc/internal/methods/get_version_info.go

@@ -7,6 +7,7 @@ import (
 	"github.com/stellar/go/support/log"
 	"github.com/stellar/soroban-rpc/cmd/soroban-rpc/internal/config"
 	"github.com/stellar/soroban-rpc/cmd/soroban-rpc/internal/daemon/interfaces"
+	"github.com/stellar/soroban-rpc/cmd/soroban-rpc/internal/db"
 )
 
 type GetVersionInfoRequest struct {
@@ -17,25 +18,51 @@ type GetVersionInfoResponse struct {
 	CommitHash         string `json:"commit_hash"`
 	BuildTimestamp     string `json:"build_time_stamp"`
 	CaptiveCoreVersion string `json:"captive_core_version"`
+	ProtocolVersion    uint32 `json:"protocol_version"`
 }
 
-func NewGetVersionInfoHandler(logger *log.Entry, daemon interfaces.Daemon) jrpc2.Handler {
+func NewGetVersionInfoHandler(logger *log.Entry, ledgerEntryReader db.LedgerEntryReader, ledgerReader db.LedgerReader, daemon interfaces.Daemon) jrpc2.Handler {
 	coreClient := daemon.CoreClient()
 	return handler.New(func(ctx context.Context, request GetVersionInfoRequest) (GetVersionInfoResponse, error) {
-		info, err := coreClient.Info(ctx)
+
 		var captiveCoreVersion string
+		info, err := coreClient.Info(ctx)
 		if err != nil {
 			logger.WithError(err).WithField("request", request).
-				Infof("error occurred while calling Info endpoint of core")
+				Info("error occurred while calling Info endpoint of core")
 		} else {
 			captiveCoreVersion = info.Info.Build
 		}
 
+		// Fetch Protocol version
+		var protocolVersion uint32
+		readTx, err := ledgerEntryReader.NewCachedTx(ctx)
+		if err != nil {
+			logger.WithError(err).WithField("request", request).
+				Info("Cannot create read transaction")
+		}
+		defer func() {
+			_ = readTx.Done()
+		}()
+
+		latestLedger, err := readTx.GetLatestLedgerSequence()
+		if err != nil {
+			logger.WithError(err).WithField("request", request).
+				Info("error occurred while getting latest ledger")
+		}
+
+		_, protocolVersion, err = getBucketListSizeAndProtocolVersion(ctx, ledgerReader, latestLedger)
+		if err != nil {
+			logger.WithError(err).WithField("request", request).
+				Info("error occurred while fetching protocol version")
+		}
+
 		return GetVersionInfoResponse{
 			Version:            config.Version,
 			CommitHash:         config.CommitHash,
 			BuildTimestamp:     config.BuildTimestamp,
 			CaptiveCoreVersion: captiveCoreVersion,
+			ProtocolVersion:    protocolVersion,
 		}, nil
 	})
 }

cmd/soroban-rpc/internal/test/get_version_info_test.go

@@ -26,4 +26,5 @@ func TestGetVersionInfoSucceeds(t *testing.T) {
 	assert.NotEmpty(t, result.BuildTimestamp)
 	assert.NotEmpty(t, result.CommitHash)
 	assert.NotEmpty(t, result.CaptiveCoreVersion)
+	assert.NotEmpty(t, result.ProtocolVersion)
 }