spectra-gnoland-indexer/api/handlers/interface.go at 5a964128af4d84b3ad9e18e4da3598616d919c2e · nman98/spectra-gnoland-indexer · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
package handlers

import (
	"context"
	"time"

	"github.com/Cogwheel-Validator/spectra-gnoland-indexer/pkgs/database"
	"github.com/Cogwheel-Validator/spectra-gnoland-indexer/pkgs/date"
)

type AddressDbHandler interface {
	GetAddressTxs(
		ctx context.Context,
		address string,
		chainName string,
		fromTimestamp *time.Time,
		toTimestamp *time.Time,
		limit *uint64,
		cursor *string,
		direction database.Direction,
	) (*[]database.AddressTx, bool, error)
	GetDailyActiveAccount(
		ctx context.Context,
		chainName string,
		dateFrom date.Date,
		dateTo date.Date,
		sortOrder database.SortOrder,
	) ([]*database.DailyActiveAccount, error)
}

type ValidatorDbHandler interface {
	GetValidatorSigning24h(
		ctx context.Context,
		validatorAddress string,
		chainName string,
	) (*database.ValidatorSigning, error)
	GetValidatorSigningByHour(
		ctx context.Context,
		validatorAddress string,
		chainName string,
		fromTimestamp time.Time,
		toTimestamp time.Time,
		sortOrder database.SortOrder,
	) ([]*database.ValidatorSigning, error)
	GetAllValidators(ctx context.Context, chainName string) (*database.ValidatorList, error)
	GetAllValidatorSigning24h(ctx context.Context, chainName string) (database.AllValidatorSignings, error)
}

type BlockDbHandler interface {
	GetBlock(ctx context.Context, height uint64, chainName string) (*database.BlockData, error)
	GetFromToBlocks(ctx context.Context, fromHeight uint64, toHeight uint64, chainName string) ([]*database.BlockData, error)
	GetAllBlockSigners(ctx context.Context, chainName string, blockHeight uint64) (*database.BlockSigners, error)
	GetLatestBlock(ctx context.Context, chainName string) (*database.BlockData, error)
	GetLastXBlocks(ctx context.Context, chainName string, x uint64) ([]*database.BlockData, error)
	GetBlockCount24h(ctx context.Context, chainName string) (int64, error)
	GetBlockCountByDate(
		ctx context.Context,
		chainName string,
		dateFrom date.Date,
		dateTo date.Date,
		sortOrder database.SortOrder,
	) ([]*database.BlockCountByDate, error)
}

type TransactionDbHandler interface {
	GetTransaction(ctx context.Context, txHash string, chainName string) (*database.Transaction, error)
	GetLastXTransactions(ctx context.Context, chainName string, x uint64, sortOrder *database.SortOrder,
	) ([]*database.Transaction, error)
	GetMsgTypes(ctx context.Context, txHash string, chainName string) ([]string, error)
	GetBankSend(ctx context.Context, txHash string, chainName string) ([]*database.BankSend, error)
	GetBankMultiSend(ctx context.Context, txHash string, chainName string) ([]*database.BankMultiSendRow, error)
	GetMsgCall(ctx context.Context, txHash string, chainName string) ([]*database.MsgCall, error)
	GetMsgAddPackage(ctx context.Context, txHash string, chainName string) ([]*database.MsgAddPackage, error)
	GetMsgRun(ctx context.Context, txHash string, chainName string) ([]*database.MsgRun, error)
	GetMsgAuthCrSession(ctx context.Context, txHash string, chainName string) ([]*database.MsgAuthCrSession, error)
	GetMsgAuthRvSession(ctx context.Context, txHash string, chainName string) ([]*database.MsgAuthRvSession, error)
	GetMsgAuthRvAllSessions(ctx context.Context, txHash string, chainName string) ([]*database.MsgAuthRvAllSessions, error)
	GetTransactionsByRange(
		ctx context.Context, chainName string, cursor string, limit uint64, direction database.Direction,
	) ([]*database.Transaction, bool, error)
	GetTotalTxCount24h(ctx context.Context, chainName string) (int64, error)
	GetTotalTxCountByDate(ctx context.Context, chainName string, dateFrom date.Date, dateTo date.Date, sortOrder database.SortOrder) ([]*database.TxCountDateRange, error)
	GetTotalTxCountByHour(ctx context.Context, chainName string, fromTimestamp time.Time, toTimestamp time.Time, sortOrder database.SortOrder) ([]*database.TxCountTimeRange, error)
	GetVolumeByDate(ctx context.Context, chainName string, dateFrom date.Date, dateTo date.Date, sortOrder database.SortOrder) (database.VolumeByDenomDaily, error)
	GetVolumeByHour(ctx context.Context, chainName string, fromTimestamp time.Time, toTimestamp time.Time, sortOrder database.SortOrder) (database.VolumeByDenomHourly, error)
}

type InMemoryDbHandler interface {
	GetTotalAddressesCount(ctx context.Context, chainName string) (int32, error)
	GetAvgBlockProdTime(ctx context.Context, chainName string) (float64, error)
}