Skip to content

Commit acdb6a3

Browse files
catalyst17catalyst17
committed
feat: get blocks API handle
1 parent 0cad690 commit acdb6a3

File tree

4 files changed

+161
-49
lines changed

4 files changed

+161
-49
lines changed

‎cmd/api.go‎

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -73,6 +73,9 @@ func RunApi(cmd *cobra.Command, args []string) {
7373
// signature scoped queries
7474
root.GET("/transactions/:to/:signature", handlers.GetTransactionsByContractAndSignature)
7575
root.GET("/events/:contract/:signature", handlers.GetLogsByContractAndSignature)
76+
77+
// blocks table queries
78+
root.GET("/blocks", handlers.GetBlocks)
7679
}
7780

7881
r.GET("/health", func(c *gin.Context) {

‎internal/handlers/blocks_handlers.go‎

Lines changed: 126 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,126 @@
1+
package handlers
2+
3+
import (
4+
"github.com/gin-gonic/gin"
5+
"github.com/rs/zerolog/log"
6+
"github.com/thirdweb-dev/indexer/api"
7+
"github.com/thirdweb-dev/indexer/internal/storage"
8+
)
9+
10+
// BlockModel represents a simplified Block structure for Swagger documentation
11+
type BlockModel struct {
12+
ChainId string `json:"chain_id"`
13+
Number string `json:"number"`
14+
Hash string `json:"hash"`
15+
ParentHash string `json:"parent_hash"`
16+
Timestamp uint64 `json:"timestamp"`
17+
Nonce string `json:"nonce"`
18+
Sha3Uncles string `json:"sha3_uncles"`
19+
LogsBloom string `json:"logs_bloom"`
20+
ReceiptsRoot string `json:"receipts_root"`
21+
Difficulty string `json:"difficulty"`
22+
TotalDifficulty string `json:"total_difficulty"`
23+
Size uint64 `json:"size"`
24+
ExtraData string `json:"extra_data"`
25+
GasLimit uint64 `json:"gas_limit"`
26+
GasUsed uint64 `json:"gas_used"`
27+
BaseFeePerGas string `json:"base_fee_per_gas"`
28+
WithdrawalsRoot string `json:"withdrawals_root"`
29+
}
30+
31+
// @Summary Get all blocks
32+
// @Description Retrieve all blocks
33+
// @Tags blocks
34+
// @Accept json
35+
// @Produce json
36+
// @Security BasicAuth
37+
// @Param chainId path string true "Chain ID"
38+
// @Param filter query string false "Filter parameters"
39+
// @Param group_by query string false "Field to group results by"
40+
// @Param sort_by query string false "Field to sort results by"
41+
// @Param sort_order query string false "Sort order (asc or desc)"
42+
// @Param page query int false "Page number for pagination"
43+
// @Param limit query int false "Number of items per page" default(5)
44+
// @Param aggregate query []string false "List of aggregate functions to apply"
45+
// @Success 200 {object} api.QueryResponse{data=[]BlockModel}
46+
// @Failure 400 {object} api.Error
47+
// @Failure 401 {object} api.Error
48+
// @Failure 500 {object} api.Error
49+
// @Router /{chainId}/blocks [get]
50+
func GetBlocks(c *gin.Context) {
51+
handleBlocksRequest(c)
52+
}
53+
54+
func handleBlocksRequest(c *gin.Context) {
55+
chainId, err := api.GetChainId(c)
56+
if err != nil {
57+
api.BadRequestErrorHandler(c, err)
58+
return
59+
}
60+
61+
queryParams, err := api.ParseQueryParams(c.Request)
62+
if err != nil {
63+
api.BadRequestErrorHandler(c, err)
64+
return
65+
}
66+
67+
mainStorage, err := getMainStorage()
68+
if err != nil {
69+
log.Error().Err(err).Msg("Error getting main storage")
70+
api.InternalErrorHandler(c)
71+
return
72+
}
73+
74+
// Prepare the QueryFilter
75+
qf := storage.QueryFilter{
76+
FilterParams: queryParams.FilterParams,
77+
ChainId: chainId,
78+
SortBy: queryParams.SortBy,
79+
SortOrder: queryParams.SortOrder,
80+
Page: queryParams.Page,
81+
Limit: queryParams.Limit,
82+
}
83+
84+
// Initialize the QueryResult
85+
queryResult := api.QueryResponse{
86+
Meta: api.Meta{
87+
ChainId: chainId.Uint64(),
88+
Page: queryParams.Page,
89+
Limit: queryParams.Limit,
90+
TotalItems: 0,
91+
TotalPages: 0, // TODO: Implement total pages count
92+
},
93+
Data: nil,
94+
Aggregations: nil,
95+
}
96+
97+
// If aggregates or groupings are specified, retrieve them
98+
if len(queryParams.Aggregates) > 0 || len(queryParams.GroupBy) > 0 {
99+
qf.Aggregates = queryParams.Aggregates
100+
qf.GroupBy = queryParams.GroupBy
101+
102+
aggregatesResult, err := mainStorage.GetAggregations("blocks", qf)
103+
if err != nil {
104+
log.Error().Err(err).Msg("Error querying aggregates")
105+
// TODO: might want to choose BadRequestError if it's due to not-allowed functions
106+
api.InternalErrorHandler(c)
107+
return
108+
}
109+
queryResult.Aggregations = aggregatesResult.Aggregates
110+
queryResult.Meta.TotalItems = len(aggregatesResult.Aggregates)
111+
} else {
112+
// Retrieve blocks data
113+
blocksResult, err := mainStorage.GetBlocks(qf)
114+
if err != nil {
115+
log.Error().Err(err).Msg("Error querying blocks")
116+
// TODO: might want to choose BadRequestError if it's due to not-allowed functions
117+
api.InternalErrorHandler(c)
118+
return
119+
}
120+
121+
queryResult.Data = blocksResult.Data
122+
queryResult.Meta.TotalItems = len(blocksResult.Data)
123+
}
124+
125+
sendJSONResponse(c, queryResult)
126+
}

‎internal/storage/clickhouse.go‎

Lines changed: 31 additions & 48 deletions
Original file line numberDiff line numberDiff line change
@@ -291,55 +291,9 @@ func (c *ClickHouseConnector) StoreBlockFailures(failures []common.BlockFailure)
291291
return batch.Send()
292292
}
293293

294-
func (c *ClickHouseConnector) GetBlocks(qf QueryFilter) (blocks []common.Block, err error) {
294+
func (c *ClickHouseConnector) GetBlocks(qf QueryFilter) (QueryResult[common.Block], error) {
295295
columns := "chain_id, number, hash, parent_hash, timestamp, nonce, sha3_uncles, logs_bloom, receipts_root, difficulty, total_difficulty, size, extra_data, gas_limit, gas_used, transaction_count, base_fee_per_gas, withdrawals_root"
296-
query := fmt.Sprintf("SELECT %s FROM %s.blocks WHERE number IN (%s) AND is_deleted = 0",
297-
columns, c.cfg.Database, getBlockNumbersStringArray(qf.BlockNumbers))
298-
299-
if qf.ChainId.Sign() > 0 {
300-
query += fmt.Sprintf(" AND chain_id = %s", qf.ChainId.String())
301-
}
302-
303-
query += getLimitClause(int(qf.Limit))
304-
305-
if err := common.ValidateQuery(query); err != nil {
306-
return nil, err
307-
}
308-
rows, err := c.conn.Query(context.Background(), query)
309-
if err != nil {
310-
return nil, err
311-
}
312-
defer rows.Close()
313-
314-
for rows.Next() {
315-
var block common.Block
316-
err := rows.Scan(
317-
&block.ChainId,
318-
&block.Number,
319-
&block.Hash,
320-
&block.ParentHash,
321-
&block.Timestamp,
322-
&block.Nonce,
323-
&block.Sha3Uncles,
324-
&block.LogsBloom,
325-
&block.ReceiptsRoot,
326-
&block.Difficulty,
327-
&block.TotalDifficulty,
328-
&block.Size,
329-
&block.ExtraData,
330-
&block.GasLimit,
331-
&block.GasUsed,
332-
&block.TransactionCount,
333-
&block.BaseFeePerGas,
334-
&block.WithdrawalsRoot,
335-
)
336-
if err != nil {
337-
zLog.Error().Err(err).Msg("Error scanning block")
338-
return nil, err
339-
}
340-
blocks = append(blocks, block)
341-
}
342-
return blocks, nil
296+
return executeQuery[common.Block](c, "blocks", columns, qf, scanBlock)
343297
}
344298

345299
func (c *ClickHouseConnector) GetTransactions(qf QueryFilter) (QueryResult[common.Transaction], error) {
@@ -613,6 +567,35 @@ func scanLog(rows driver.Rows) (common.Log, error) {
613567
return log, nil
614568
}
615569

570+
func scanBlock(rows driver.Rows) (common.Block, error) {
571+
var block common.Block
572+
err := rows.Scan(
573+
&block.ChainId,
574+
&block.Number,
575+
&block.Hash,
576+
&block.ParentHash,
577+
&block.Timestamp,
578+
&block.Nonce,
579+
&block.Sha3Uncles,
580+
&block.LogsBloom,
581+
&block.ReceiptsRoot,
582+
&block.Difficulty,
583+
&block.TotalDifficulty,
584+
&block.Size,
585+
&block.ExtraData,
586+
&block.GasLimit,
587+
&block.GasUsed,
588+
&block.TransactionCount,
589+
&block.BaseFeePerGas,
590+
&block.WithdrawalsRoot,
591+
)
592+
if err != nil {
593+
return common.Block{}, fmt.Errorf("error scanning block: %w", err)
594+
}
595+
596+
return block, nil
597+
}
598+
616599
func (c *ClickHouseConnector) GetMaxBlockNumber(chainId *big.Int) (maxBlockNumber *big.Int, err error) {
617600
query := fmt.Sprintf("SELECT number FROM %s.blocks WHERE is_deleted = 0", c.cfg.Database)
618601
if chainId.Sign() > 0 {

‎internal/storage/connector.go‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -53,7 +53,7 @@ type IStagingStorage interface {
5353
type IMainStorage interface {
5454
InsertBlockData(data *[]common.BlockData) error
5555

56-
GetBlocks(qf QueryFilter) (blocks []common.Block, err error)
56+
GetBlocks(qf QueryFilter) (blocks QueryResult[common.Block], err error)
5757
GetTransactions(qf QueryFilter) (transactions QueryResult[common.Transaction], err error)
5858
GetLogs(qf QueryFilter) (logs QueryResult[common.Log], err error)
5959
GetAggregations(table string, qf QueryFilter) (QueryResult[interface{}], error)

0 commit comments

Comments
 (0)