app

Documentation

Index

• Variables
• func GetBlockchainConfig(ctx context.Context, api *ton.APIClient) (*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

Variables

var ErrImpossibleParsing = errors.New("parsing is impossible")

Functions

func GetBlockchainConfig

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

func TimeTrack

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

Types

type FetcherConfig

type FetcherConfig struct {
	API *ton.APIClient

	Parser ParserService
}

type FetcherService

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

type IndexerConfig

type IndexerConfig struct {
	DB *repository.DB

	API *ton.APIClient

	Fetcher FetcherService
	Parser  ParserService

	FromBlock        uint32
	Workers          int
	InsertBlockBatch 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

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

type QueryConfig

type QueryConfig struct {
	DB *repository.DB
}

type QueryService

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

	GetInterfaces(ctx context.Context) ([]*core.ContractInterface, error)
	GetOperations(ctx context.Context) ([]*core.ContractOperation, error)

	filter.BlockRepository
	filter.AccountRepository
	filter.TransactionRepository
	filter.MessageRepository

	aggregate.AccountRepository
	aggregate.MessageRepository

	history.AccountRepository
	history.TransactionRepository
	history.MessageRepository
}