app

Documentation

Index

• Variables
• func GetBlockchainConfig(ctx context.Context, api ton.APIClientWrapped) (*cell.Cell, error)
• func TimeTrack(start time.Time, fun string, args ...any)
• type FetcherConfig
• type FetcherService
• type IndexerConfig
• type IndexerService
• type ParserConfig
• type ParserService
• type QueryConfig
• type QueryService
• type RescanConfig
• type RescanService

Variables

var (
	ErrImpossibleParsing          = errors.New("parsing is impossible")
	ErrUnmatchedContractInterface = errors.New("account state does not match the contract interface description")
)

Functions

func GetBlockchainConfig

func GetBlockchainConfig(ctx context.Context, api ton.APIClientWrapped) (*cell.Cell, error)

func TimeTrack

func TimeTrack(start time.Time, fun string, args ...any)

Types

type FetcherConfig

type FetcherConfig struct {
	API ton.APIClientWrapped

	AccountRepo filter.AccountRepository

	Parser ParserService
}

type FetcherService

type FetcherService interface {
	LookupMaster(ctx context.Context, api ton.APIClientWrapped, seqNo uint32) (*ton.BlockIDExt, error)
	UnseenBlocks(ctx context.Context, masterSeqNo uint32) (master *ton.BlockIDExt, shards []*ton.BlockIDExt, err error)
	UnseenShards(ctx context.Context, master *ton.BlockIDExt) (shards []*ton.BlockIDExt, err error)
	BlockTransactions(ctx context.Context, master, b *ton.BlockIDExt) ([]*core.Transaction, error)
}

type IndexerConfig

type IndexerConfig struct {
	DB *repository.DB

	API ton.APIClientWrapped

	Fetcher FetcherService
	Parser  ParserService

	FromBlock uint32
	Workers   int
}

type IndexerService

type IndexerService interface {
	Start() error
	Stop()
}

type ParserConfig

type ParserConfig struct {
	BlockchainConfig *cell.Cell
	ContractRepo     core.ContractRepository
}

type ParserService

type ParserService interface {
	ParseAccountData(
		ctx context.Context,
		acc *core.AccountState,
		others func(context.Context, addr.Address) (*core.AccountState, error),
	) error

	ParseAccountContractData(
		ctx context.Context,
		contractDesc *core.ContractInterface,
		acc *core.AccountState,
		others func(context.Context, addr.Address) (*core.AccountState, error),
	) error

	ExecuteAccountGetMethod(
		ctx context.Context,
		contract abi.ContractName,
		getMethod string,
		acc *core.AccountState,
		others func(context.Context, addr.Address) (*core.AccountState, error),
	) error

	ParseMessagePayload(
		ctx context.Context,
		message *core.Message,
	) error
}

type QueryConfig

type QueryConfig struct {
	DB *repository.DB

	API ton.APIClientWrapped
}

type QueryService

type QueryService interface {
	GetStatistics(ctx context.Context) (*aggregate.Statistics, error)

	GetDefinitions(context.Context) (map[abi.TLBType]abi.TLBFieldsDesc, error)
	GetInterfaces(ctx context.Context) ([]*core.ContractInterface, error)
	GetOperations(ctx context.Context) ([]*core.ContractOperation, error)

	filter.BlockRepository

	GetLabelCategories(context.Context) ([]core.LabelCategory, error)

	filter.AccountRepository
	filter.TransactionRepository
	filter.MessageRepository

	aggregate.AccountRepository
	aggregate.MessageRepository

	history.AccountRepository
	history.TransactionRepository
	history.MessageRepository
}

type RescanConfig

type RescanConfig struct {
	ContractRepo core.ContractRepository
	RescanRepo   core.RescanRepository
	BlockRepo    repository.Block
	AccountRepo  repository.Account
	MessageRepo  repository.Message

	Parser ParserService

	Workers int

	SelectLimit int
}

type RescanService

type RescanService interface {
	Start() error
	Stop()
}