2021-05-22 10:00:13 +00:00
|
|
|
package services
|
|
|
|
|
|
|
|
import (
|
|
|
|
"context"
|
|
|
|
"fmt"
|
|
|
|
|
2021-07-01 21:31:14 +00:00
|
|
|
"github.com/ledgerwatch/erigon-lib/gointerfaces"
|
|
|
|
"github.com/ledgerwatch/erigon-lib/gointerfaces/txpool"
|
2021-07-28 02:47:38 +00:00
|
|
|
"github.com/ledgerwatch/erigon/ethdb/privateapi"
|
2021-07-29 10:23:23 +00:00
|
|
|
"github.com/ledgerwatch/log/v3"
|
2021-05-22 10:00:13 +00:00
|
|
|
"google.golang.org/grpc"
|
|
|
|
"google.golang.org/protobuf/types/known/emptypb"
|
|
|
|
)
|
|
|
|
|
|
|
|
type TxPoolService struct {
|
|
|
|
txpool.TxpoolClient
|
|
|
|
log log.Logger
|
|
|
|
version gointerfaces.Version
|
|
|
|
}
|
|
|
|
|
2022-02-11 10:11:59 +00:00
|
|
|
func NewTxPoolService(client txpool.TxpoolClient) *TxPoolService {
|
2021-05-22 10:00:13 +00:00
|
|
|
return &TxPoolService{
|
2022-02-11 10:11:59 +00:00
|
|
|
TxpoolClient: client,
|
2021-07-28 02:47:38 +00:00
|
|
|
version: gointerfaces.VersionFromProto(privateapi.TxPoolAPIVersion),
|
2021-05-22 10:00:13 +00:00
|
|
|
log: log.New("remote_service", "tx_pool"),
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
func (s *TxPoolService) EnsureVersionCompatibility() bool {
|
|
|
|
versionReply, err := s.Version(context.Background(), &emptypb.Empty{}, grpc.WaitForReady(true))
|
|
|
|
if err != nil {
|
|
|
|
s.log.Error("ensure version", "error", err)
|
|
|
|
return false
|
|
|
|
}
|
|
|
|
if !gointerfaces.EnsureVersion(s.version, versionReply) {
|
|
|
|
s.log.Error("incompatible interface versions", "client", s.version.String(),
|
|
|
|
"server", fmt.Sprintf("%d.%d.%d", versionReply.Major, versionReply.Minor, versionReply.Patch))
|
|
|
|
return false
|
|
|
|
}
|
|
|
|
s.log.Info("interfaces compatible", "client", s.version.String(),
|
|
|
|
"server", fmt.Sprintf("%d.%d.%d", versionReply.Major, versionReply.Minor, versionReply.Patch))
|
|
|
|
return true
|
|
|
|
}
|