Introduce v2beta1 and migrate v2alpha1 POST API calls to GET (#6636)

Author: kacpersaw

api/grpcserver/config.go

@@ -53,6 +53,21 @@ const (
 	AccountV2Alpha1           Service = "account_v2alpha1"
 	MalfeasanceV2Alpha1       Service = "malfeasance_v2alpha1"
 	MalfeasanceStreamV2Alpha1 Service = "malfeasance_stream_v2alpha1"
+
+	// v2beta1.
+	ActivationV2Beta1        Service = "activation_v2beta1"
+	ActivationStreamV2Beta1  Service = "activation_stream_v2beta1"
+	RewardV2Beta1            Service = "reward_v2beta1"
+	RewardStreamV2Beta1      Service = "reward_stream_v2beta1"
+	NetworkV2Beta1           Service = "network_v2beta1"
+	NodeV2Beta1              Service = "node_v2beta1"
+	LayerV2Beta1             Service = "layer_v2beta1"
+	LayerStreamV2Beta1       Service = "layer_stream_v2beta1"
+	TransactionV2Beta1       Service = "transaction_v2beta1"
+	TransactionStreamV2Beta1 Service = "transaction_stream_v2beta1"
+	AccountV2Beta1           Service = "account_v2beta1"
+	MalfeasanceV2Beta1       Service = "malfeasance_v2beta1"
+	MalfeasanceStreamV2Beta1 Service = "malfeasance_stream_v2beta1"
 )
 
 // DefaultConfig defines the default configuration options for api.
@@ -62,12 +77,20 @@ func DefaultConfig() Config {
 			GlobalState, Mesh, Transaction, Node, Activation, ActivationV2Alpha1,
 			RewardV2Alpha1, NetworkV2Alpha1, NodeV2Alpha1, LayerV2Alpha1, TransactionV2Alpha1,
 			AccountV2Alpha1, MalfeasanceV2Alpha1,
+
+			// v2beta1
+			ActivationV2Beta1, RewardV2Beta1, NetworkV2Beta1, NodeV2Beta1,
+			LayerV2Beta1, TransactionV2Beta1, AccountV2Beta1, MalfeasanceV2Beta1,
 		},
 		PublicListener: "0.0.0.0:9092",
 		PrivateServices: []Service{
 			Admin, Smesher, Debug, ActivationStreamV2Alpha1,
 			RewardStreamV2Alpha1, LayerStreamV2Alpha1, TransactionStreamV2Alpha1,
 			MalfeasanceStreamV2Alpha1,
+
+			// v2beta1
+			ActivationStreamV2Beta1, RewardStreamV2Beta1, LayerStreamV2Beta1,
+			TransactionStreamV2Beta1, MalfeasanceStreamV2Beta1,
 		},
 		PrivateListener:        "127.0.0.1:9093",
 		PostServices:           []Service{Post, PostInfo},

api/grpcserver/v2beta1/account.go

@@ -0,0 +1,141 @@
+package v2beta1
+
+import (
+	"context"
+
+	"github.com/grpc-ecosystem/grpc-gateway/v2/runtime"
+	spacemeshv2beta1 "github.com/spacemeshos/api/release/go/spacemesh/v2beta1"
+	"google.golang.org/grpc"
+	"google.golang.org/grpc/codes"
+	"google.golang.org/grpc/status"
+
+	"github.com/spacemeshos/go-spacemesh/common/types"
+	"github.com/spacemeshos/go-spacemesh/sql"
+	"github.com/spacemeshos/go-spacemesh/sql/accounts"
+	"github.com/spacemeshos/go-spacemesh/sql/builder"
+)
+
+const (
+	Account = "account_v2beta1"
+)
+
+type accountConState interface {
+	GetProjection(types.Address) (uint64, uint64)
+}
+
+func NewAccountService(db sql.Executor, conState accountConState) *AccountService {
+	return &AccountService{
+		db:       db,
+		conState: conState,
+	}
+}
+
+type AccountService struct {
+	db       sql.Executor
+	conState accountConState
+}
+
+func (s *AccountService) RegisterService(server *grpc.Server) {
+	spacemeshv2beta1.RegisterAccountServiceServer(server, s)
+}
+
+func (s *AccountService) RegisterHandlerService(mux *runtime.ServeMux) error {
+	return spacemeshv2beta1.RegisterAccountServiceHandlerServer(context.Background(), mux, s)
+}
+
+// String returns the service name.
+func (s *AccountService) String() string {
+	return "AccountService"
+}
+
+func (s *AccountService) List(
+	_ context.Context,
+	request *spacemeshv2beta1.AccountRequest,
+) (*spacemeshv2beta1.AccountList, error) {
+	switch {
+	case request.Limit > 100:
+		return nil, status.Error(codes.InvalidArgument, "limit is capped at 100")
+	case request.Limit == 0:
+		return nil, status.Error(codes.InvalidArgument, "limit must be set to <= 100")
+	}
+
+	ops, err := toAccountOperations(request)
+	if err != nil {
+		return nil, status.Error(codes.InvalidArgument, err.Error())
+	}
+
+	rst := make([]*spacemeshv2beta1.Account, 0, request.Limit)
+	if err := accounts.IterateAccountsOps(s.db, ops, func(account *types.Account) bool {
+		counterProjected, balanceProjected := s.conState.GetProjection(account.Address)
+		item := &spacemeshv2beta1.Account{
+			Address: account.Address.String(),
+			Current: &spacemeshv2beta1.AccountState{
+				Counter: account.NextNonce,
+				Balance: account.Balance,
+				Layer:   account.Layer.Uint32(),
+			},
+			Projected: &spacemeshv2beta1.AccountState{
+				Counter: counterProjected,
+				Balance: balanceProjected,
+			},
+		}
+		if account.TemplateAddress != nil {
+			item.Template = account.TemplateAddress.String()
+		}
+		rst = append(rst, item)
+		return true
+	}); err != nil {
+		return nil, status.Error(codes.Internal, err.Error())
+	}
+
+	return &spacemeshv2beta1.AccountList{Accounts: rst}, nil
+}
+
+func toAccountOperations(filter *spacemeshv2beta1.AccountRequest) (builder.Operations, error) {
+	ops := builder.Operations{}
+	if filter == nil {
+		return ops, nil
+	}
+
+	if len(filter.Addresses) > 0 {
+		var addrs [][]byte
+		for _, address := range filter.Addresses {
+			addr, err := types.StringToAddress(address)
+			if err != nil {
+				return builder.Operations{}, err
+			}
+			addrs = append(addrs, addr.Bytes())
+		}
+
+		ops.Filter = append(ops.Filter, builder.Op{
+			Field: builder.Address,
+			Token: builder.In,
+			Value: addrs,
+		})
+	}
+
+	ops.Modifiers = append(ops.Modifiers, builder.Modifier{
+		Key:   builder.GroupBy,
+		Value: "address",
+	})
+
+	ops.Modifiers = append(ops.Modifiers, builder.Modifier{
+		Key:   builder.OrderBy,
+		Value: "layer_updated desc",
+	})
+
+	if filter.Limit != 0 {
+		ops.Modifiers = append(ops.Modifiers, builder.Modifier{
+			Key:   builder.Limit,
+			Value: int64(filter.Limit),
+		})
+	}
+	if filter.Offset != 0 {
+		ops.Modifiers = append(ops.Modifiers, builder.Modifier{
+			Key:   builder.Offset,
+			Value: int64(filter.Offset),
+		})
+	}
+
+	return ops, nil
+}