hermez-node/db/historydb/historydb.go
db/historydb/historydb.goRaw
1package historydb
2
3import (
4 "database/sql"
5 "errors"
6 "fmt"
7 "math"
8 "math/big"
9
10 ethCommon "github.com/ethereum/go-ethereum/common"
11 "github.com/hermeznetwork/hermez-node/common"
12 "github.com/hermeznetwork/hermez-node/db"
13 "github.com/hermeznetwork/tracerr"
14 "github.com/iden3/go-iden3-crypto/babyjub"
15 "github.com/jmoiron/sqlx"
16
17 //nolint:errcheck // driver for postgres DB
18 _ "github.com/lib/pq"
19 "github.com/russross/meddler"
20)
21
22const (
23 // OrderAsc indicates ascending order when using pagination
24 OrderAsc = "ASC"
25 // OrderDesc indicates descending order when using pagination
26 OrderDesc = "DESC"
27)
28
29// TODO(Edu): Document here how HistoryDB is kept consistent
30
31// HistoryDB persist the historic of the rollup
32type HistoryDB struct {
33 db *sqlx.DB
34}
35
36// NewHistoryDB initialize the DB
37func NewHistoryDB(db *sqlx.DB) *HistoryDB {
38 return &HistoryDB{db: db}
39}
40
41// DB returns a pointer to the L2DB.db. This method should be used only for
42// internal testing purposes.
43func (hdb *HistoryDB) DB() *sqlx.DB {
44 return hdb.db
45}
46
47// AddBlock insert a block into the DB
48func (hdb *HistoryDB) AddBlock(block *common.Block) error { return hdb.addBlock(hdb.db, block) }
49func (hdb *HistoryDB) addBlock(d meddler.DB, block *common.Block) error {
50 return tracerr.Wrap(meddler.Insert(d, "block", block))
51}
52
53// AddBlocks inserts blocks into the DB
54func (hdb *HistoryDB) AddBlocks(blocks []common.Block) error {
55 return tracerr.Wrap(hdb.addBlocks(hdb.db, blocks))
56}
57
58func (hdb *HistoryDB) addBlocks(d meddler.DB, blocks []common.Block) error {
59 return tracerr.Wrap(db.BulkInsert(
60 d,
61 `INSERT INTO block (
62 eth_block_num,
63 timestamp,
64 hash
65 ) VALUES %s;`,
66 blocks[:],
67 ))
68}
69
70// GetBlock retrieve a block from the DB, given a block number
71func (hdb *HistoryDB) GetBlock(blockNum int64) (*common.Block, error) {
72 block := &common.Block{}
73 err := meddler.QueryRow(
74 hdb.db, block,
75 "SELECT * FROM block WHERE eth_block_num = $1;", blockNum,
76 )
77 return block, tracerr.Wrap(err)
78}
79
80// GetAllBlocks retrieve all blocks from the DB
81func (hdb *HistoryDB) GetAllBlocks() ([]common.Block, error) {
82 var blocks []*common.Block
83 err := meddler.QueryAll(
84 hdb.db, &blocks,
85 "SELECT * FROM block;",
86 )
87 return db.SlicePtrsToSlice(blocks).([]common.Block), tracerr.Wrap(err)
88}
89
90// GetBlocks retrieve blocks from the DB, given a range of block numbers defined by from and to
91func (hdb *HistoryDB) GetBlocks(from, to int64) ([]common.Block, error) {
92 var blocks []*common.Block
93 err := meddler.QueryAll(
94 hdb.db, &blocks,
95 "SELECT * FROM block WHERE $1 <= eth_block_num AND eth_block_num < $2;",
96 from, to,
97 )
98 return db.SlicePtrsToSlice(blocks).([]common.Block), tracerr.Wrap(err)
99}
100
101// GetLastBlock retrieve the block with the highest block number from the DB
102func (hdb *HistoryDB) GetLastBlock() (*common.Block, error) {
103 block := &common.Block{}
104 err := meddler.QueryRow(
105 hdb.db, block, "SELECT * FROM block ORDER BY eth_block_num DESC LIMIT 1;",
106 )
107 return block, tracerr.Wrap(err)
108}
109
110// AddBatch insert a Batch into the DB
111func (hdb *HistoryDB) AddBatch(batch *common.Batch) error { return hdb.addBatch(hdb.db, batch) }
112func (hdb *HistoryDB) addBatch(d meddler.DB, batch *common.Batch) error {
113 // Calculate total collected fees in USD
114 // Get IDs of collected tokens for fees
115 tokenIDs := []common.TokenID{}
116 for id := range batch.CollectedFees {
117 tokenIDs = append(tokenIDs, id)
118 }
119 // Get USD value of the tokens
120 type tokenPrice struct {
121 ID common.TokenID `meddler:"token_id"`
122 USD *float64 `meddler:"usd"`
123 Decimals int `meddler:"decimals"`
124 }
125 var tokenPrices []*tokenPrice
126 if len(tokenIDs) > 0 {
127 query, args, err := sqlx.In(
128 "SELECT token_id, usd, decimals FROM token WHERE token_id IN (?);",
129 tokenIDs,
130 )
131 if err != nil {
132 return tracerr.Wrap(err)
133 }
134 query = hdb.db.Rebind(query)
135 if err := meddler.QueryAll(
136 hdb.db, &tokenPrices, query, args...,
137 ); err != nil {
138 return tracerr.Wrap(err)
139 }
140 }
141 // Calculate total collected
142 var total float64
143 for _, tokenPrice := range tokenPrices {
144 if tokenPrice.USD == nil {
145 continue
146 }
147 f := new(big.Float).SetInt(batch.CollectedFees[tokenPrice.ID])
148 amount, _ := f.Float64()
149 total += *tokenPrice.USD * (amount / math.Pow(10, float64(tokenPrice.Decimals))) //nolint decimals have to be ^10
150 }
151 batch.TotalFeesUSD = &total
152 // Insert to DB
153 return tracerr.Wrap(meddler.Insert(d, "batch", batch))
154}
155
156// AddBatches insert Bids into the DB
157func (hdb *HistoryDB) AddBatches(batches []common.Batch) error {
158 return tracerr.Wrap(hdb.addBatches(hdb.db, batches))
159}
160func (hdb *HistoryDB) addBatches(d meddler.DB, batches []common.Batch) error {
161 for i := 0; i < len(batches); i++ {
162 if err := hdb.addBatch(d, &batches[i]); err != nil {
163 return tracerr.Wrap(err)
164 }
165 }
166 return nil
167}
168
169// GetBatchAPI return the batch with the given batchNum
170func (hdb *HistoryDB) GetBatchAPI(batchNum common.BatchNum) (*BatchAPI, error) {
171 batch := &BatchAPI{}
172 return batch, tracerr.Wrap(meddler.QueryRow(
173 hdb.db, batch,
174 `SELECT batch.*, block.timestamp, block.hash
175 FROM batch INNER JOIN block ON batch.eth_block_num = block.eth_block_num
176 WHERE batch_num = $1;`, batchNum,
177 ))
178}
179
180// GetBatchesAPI return the batches applying the given filters
181func (hdb *HistoryDB) GetBatchesAPI(
182 minBatchNum, maxBatchNum, slotNum *uint,
183 forgerAddr *ethCommon.Address,
184 fromItem, limit *uint, order string,
185) ([]BatchAPI, uint64, error) {
186 var query string
187 var args []interface{}
188 queryStr := `SELECT batch.*, block.timestamp, block.hash,
189 count(*) OVER() AS total_items
190 FROM batch INNER JOIN block ON batch.eth_block_num = block.eth_block_num `
191 // Apply filters
192 nextIsAnd := false
193 // minBatchNum filter
194 if minBatchNum != nil {
195 if nextIsAnd {
196 queryStr += "AND "
197 } else {
198 queryStr += "WHERE "
199 }
200 queryStr += "batch.batch_num > ? "
201 args = append(args, minBatchNum)
202 nextIsAnd = true
203 }
204 // maxBatchNum filter
205 if maxBatchNum != nil {
206 if nextIsAnd {
207 queryStr += "AND "
208 } else {
209 queryStr += "WHERE "
210 }
211 queryStr += "batch.batch_num < ? "
212 args = append(args, maxBatchNum)
213 nextIsAnd = true
214 }
215 // slotNum filter
216 if slotNum != nil {
217 if nextIsAnd {
218 queryStr += "AND "
219 } else {
220 queryStr += "WHERE "
221 }
222 queryStr += "batch.slot_num = ? "
223 args = append(args, slotNum)
224 nextIsAnd = true
225 }
226 // forgerAddr filter
227 if forgerAddr != nil {
228 if nextIsAnd {
229 queryStr += "AND "
230 } else {
231 queryStr += "WHERE "
232 }
233 queryStr += "batch.forger_addr = ? "
234 args = append(args, forgerAddr)
235 nextIsAnd = true
236 }
237 // pagination
238 if fromItem != nil {
239 if nextIsAnd {
240 queryStr += "AND "
241 } else {
242 queryStr += "WHERE "
243 }
244 if order == OrderAsc {
245 queryStr += "batch.item_id >= ? "
246 } else {
247 queryStr += "batch.item_id <= ? "
248 }
249 args = append(args, fromItem)
250 }
251 queryStr += "ORDER BY batch.item_id "
252 if order == OrderAsc {
253 queryStr += " ASC "
254 } else {
255 queryStr += " DESC "
256 }
257 queryStr += fmt.Sprintf("LIMIT %d;", *limit)
258 query = hdb.db.Rebind(queryStr)
259 // log.Debug(query)
260 batchPtrs := []*BatchAPI{}
261 if err := meddler.QueryAll(hdb.db, &batchPtrs, query, args...); err != nil {
262 return nil, 0, tracerr.Wrap(err)
263 }
264 batches := db.SlicePtrsToSlice(batchPtrs).([]BatchAPI)
265 if len(batches) == 0 {
266 return nil, 0, tracerr.Wrap(sql.ErrNoRows)
267 }
268 return batches, batches[0].TotalItems - uint64(len(batches)), nil
269}
270
271// GetAllBatches retrieve all batches from the DB
272func (hdb *HistoryDB) GetAllBatches() ([]common.Batch, error) {
273 var batches []*common.Batch
274 err := meddler.QueryAll(
275 hdb.db, &batches,
276 `SELECT batch.batch_num, batch.eth_block_num, batch.forger_addr, batch.fees_collected,
277 batch.fee_idxs_coordinator, batch.state_root, batch.num_accounts, batch.last_idx, batch.exit_root,
278 batch.forge_l1_txs_num, batch.slot_num, batch.total_fees_usd FROM batch;`,
279 )
280 return db.SlicePtrsToSlice(batches).([]common.Batch), tracerr.Wrap(err)
281}
282
283// GetBatches retrieve batches from the DB, given a range of batch numbers defined by from and to
284func (hdb *HistoryDB) GetBatches(from, to common.BatchNum) ([]common.Batch, error) {
285 var batches []*common.Batch
286 err := meddler.QueryAll(
287 hdb.db, &batches,
288 "SELECT * FROM batch WHERE $1 <= batch_num AND batch_num < $2;",
289 from, to,
290 )
291 return db.SlicePtrsToSlice(batches).([]common.Batch), tracerr.Wrap(err)
292}
293
294// GetBatchesLen retrieve number of batches from the DB, given a slotNum
295func (hdb *HistoryDB) GetBatchesLen(slotNum int64) (int, error) {
296 row := hdb.db.QueryRow("SELECT COUNT(*) FROM batch WHERE slot_num = $1;", slotNum)
297 var batchesLen int
298 return batchesLen, tracerr.Wrap(row.Scan(&batchesLen))
299}
300
301// GetLastBatchNum returns the BatchNum of the latest forged batch
302func (hdb *HistoryDB) GetLastBatchNum() (common.BatchNum, error) {
303 row := hdb.db.QueryRow("SELECT batch_num FROM batch ORDER BY batch_num DESC LIMIT 1;")
304 var batchNum common.BatchNum
305 return batchNum, tracerr.Wrap(row.Scan(&batchNum))
306}
307
308// GetLastL1BatchBlockNum returns the blockNum of the latest forged l1Batch
309func (hdb *HistoryDB) GetLastL1BatchBlockNum() (int64, error) {
310 row := hdb.db.QueryRow(`SELECT eth_block_num FROM batch
311 WHERE forge_l1_txs_num IS NOT NULL
312 ORDER BY batch_num DESC LIMIT 1;`)
313 var blockNum int64
314 return blockNum, tracerr.Wrap(row.Scan(&blockNum))
315}
316
317// GetLastL1TxsNum returns the greatest ForgeL1TxsNum in the DB from forged
318// batches. If there's no batch in the DB (nil, nil) is returned.
319func (hdb *HistoryDB) GetLastL1TxsNum() (*int64, error) {
320 row := hdb.db.QueryRow("SELECT MAX(forge_l1_txs_num) FROM batch;")
321 lastL1TxsNum := new(int64)
322 return lastL1TxsNum, tracerr.Wrap(row.Scan(&lastL1TxsNum))
323}
324
325// Reorg deletes all the information that was added into the DB after the
326// lastValidBlock. If lastValidBlock is negative, all block information is
327// deleted.
328func (hdb *HistoryDB) Reorg(lastValidBlock int64) error {
329 var err error
330 if lastValidBlock < 0 {
331 _, err = hdb.db.Exec("DELETE FROM block;")
332 } else {
333 _, err = hdb.db.Exec("DELETE FROM block WHERE eth_block_num > $1;", lastValidBlock)
334 }
335 return tracerr.Wrap(err)
336}
337
338// AddBids insert Bids into the DB
339func (hdb *HistoryDB) AddBids(bids []common.Bid) error { return hdb.addBids(hdb.db, bids) }
340func (hdb *HistoryDB) addBids(d meddler.DB, bids []common.Bid) error {
341 if len(bids) == 0 {
342 return nil
343 }
344 // TODO: check the coordinator info
345 return tracerr.Wrap(db.BulkInsert(
346 d,
347 "INSERT INTO bid (slot_num, bid_value, eth_block_num, bidder_addr) VALUES %s;",
348 bids[:],
349 ))
350}
351
352// GetAllBids retrieve all bids from the DB
353func (hdb *HistoryDB) GetAllBids() ([]common.Bid, error) {
354 var bids []*common.Bid
355 err := meddler.QueryAll(
356 hdb.db, &bids,
357 `SELECT bid.slot_num, bid.bid_value, bid.eth_block_num, bid.bidder_addr FROM bid;`,
358 )
359 return db.SlicePtrsToSlice(bids).([]common.Bid), tracerr.Wrap(err)
360}
361
362// GetBestBidAPI returns the best bid in specific slot by slotNum
363func (hdb *HistoryDB) GetBestBidAPI(slotNum *int64) (BidAPI, error) {
364 bid := &BidAPI{}
365 err := meddler.QueryRow(
366 hdb.db, bid, `SELECT bid.*, block.timestamp, coordinator.forger_addr, coordinator.url
367 FROM bid INNER JOIN block ON bid.eth_block_num = block.eth_block_num
368 INNER JOIN coordinator ON bid.bidder_addr = coordinator.bidder_addr
369 WHERE slot_num = $1 ORDER BY item_id DESC LIMIT 1;`, slotNum,
370 )
371 return *bid, tracerr.Wrap(err)
372}
373
374// GetBestBidCoordinator returns the forger address of the highest bidder in a slot by slotNum
375func (hdb *HistoryDB) GetBestBidCoordinator(slotNum int64) (*common.BidCoordinator, error) {
376 bidCoord := &common.BidCoordinator{}
377 err := meddler.QueryRow(
378 hdb.db, bidCoord,
379 `SELECT (
380 SELECT default_slot_set_bid
381 FROM auction_vars
382 WHERE default_slot_set_bid_slot_num <= $1
383 ORDER BY eth_block_num DESC LIMIT 1
384 ),
385 bid.slot_num, bid.bid_value, bid.bidder_addr,
386 coordinator.forger_addr, coordinator.url
387 FROM bid
388 INNER JOIN coordinator ON bid.bidder_addr = coordinator.bidder_addr
389 WHERE bid.slot_num = $1 ORDER BY bid.item_id DESC LIMIT 1;`,
390 slotNum)
391
392 return bidCoord, tracerr.Wrap(err)
393}
394
395// GetBestBidsAPI returns the best bid in specific slot by slotNum
396func (hdb *HistoryDB) GetBestBidsAPI(
397 minSlotNum, maxSlotNum *int64,
398 bidderAddr *ethCommon.Address,
399 limit *uint, order string,
400) ([]BidAPI, uint64, error) {
401 var query string
402 var args []interface{}
403 queryStr := `SELECT b.*, block.timestamp, coordinator.forger_addr, coordinator.url,
404 COUNT(*) OVER() AS total_items FROM (
405 SELECT slot_num, MAX(item_id) as maxitem
406 FROM bid GROUP BY slot_num
407 )
408 AS x INNER JOIN bid AS b ON b.item_id = x.maxitem
409 INNER JOIN block ON b.eth_block_num = block.eth_block_num
410 INNER JOIN coordinator ON b.bidder_addr = coordinator.bidder_addr
411 WHERE (b.slot_num >= ? AND b.slot_num <= ?)`
412 args = append(args, minSlotNum)
413 args = append(args, maxSlotNum)
414 // Apply filters
415 if bidderAddr != nil {
416 queryStr += " AND b.bidder_addr = ? "
417 args = append(args, bidderAddr)
418 }
419 queryStr += " ORDER BY b.slot_num "
420 if order == OrderAsc {
421 queryStr += "ASC "
422 } else {
423 queryStr += "DESC "
424 }
425 if limit != nil {
426 queryStr += fmt.Sprintf("LIMIT %d;", *limit)
427 }
428 query = hdb.db.Rebind(queryStr)
429 bidPtrs := []*BidAPI{}
430 if err := meddler.QueryAll(hdb.db, &bidPtrs, query, args...); err != nil {
431 return nil, 0, tracerr.Wrap(err)
432 }
433 // log.Debug(query)
434 bids := db.SlicePtrsToSlice(bidPtrs).([]BidAPI)
435 if len(bids) == 0 {
436 return nil, 0, tracerr.Wrap(sql.ErrNoRows)
437 }
438 return bids, bids[0].TotalItems - uint64(len(bids)), nil
439}
440
441// GetBidsAPI return the bids applying the given filters
442func (hdb *HistoryDB) GetBidsAPI(
443 slotNum *int64, forgerAddr *ethCommon.Address,
444 fromItem, limit *uint, order string,
445) ([]BidAPI, uint64, error) {
446 var query string
447 var args []interface{}
448 queryStr := `SELECT bid.*, block.timestamp, coordinator.forger_addr, coordinator.url,
449 COUNT(*) OVER() AS total_items
450 FROM bid INNER JOIN block ON bid.eth_block_num = block.eth_block_num
451 INNER JOIN coordinator ON bid.bidder_addr = coordinator.bidder_addr `
452 // Apply filters
453 nextIsAnd := false
454 // slotNum filter
455 if slotNum != nil {
456 if nextIsAnd {
457 queryStr += "AND "
458 } else {
459 queryStr += "WHERE "
460 }
461 queryStr += "bid.slot_num = ? "
462 args = append(args, slotNum)
463 nextIsAnd = true
464 }
465 // slotNum filter
466 if forgerAddr != nil {
467 if nextIsAnd {
468 queryStr += "AND "
469 } else {
470 queryStr += "WHERE "
471 }
472 queryStr += "bid.bidder_addr = ? "
473 args = append(args, forgerAddr)
474 nextIsAnd = true
475 }
476 if fromItem != nil {
477 if nextIsAnd {
478 queryStr += "AND "
479 } else {
480 queryStr += "WHERE "
481 }
482 if order == OrderAsc {
483 queryStr += "bid.item_id >= ? "
484 } else {
485 queryStr += "bid.item_id <= ? "
486 }
487 args = append(args, fromItem)
488 }
489 // pagination
490 queryStr += "ORDER BY bid.item_id "
491 if order == OrderAsc {
492 queryStr += "ASC "
493 } else {
494 queryStr += "DESC "
495 }
496 queryStr += fmt.Sprintf("LIMIT %d;", *limit)
497 query, argsQ, err := sqlx.In(queryStr, args...)
498 if err != nil {
499 return nil, 0, tracerr.Wrap(err)
500 }
501 query = hdb.db.Rebind(query)
502 bids := []*BidAPI{}
503 if err := meddler.QueryAll(hdb.db, &bids, query, argsQ...); err != nil {
504 return nil, 0, tracerr.Wrap(err)
505 }
506 if len(bids) == 0 {
507 return nil, 0, tracerr.Wrap(sql.ErrNoRows)
508 }
509 return db.SlicePtrsToSlice(bids).([]BidAPI), bids[0].TotalItems - uint64(len(bids)), nil
510}
511
512// AddCoordinators insert Coordinators into the DB
513func (hdb *HistoryDB) AddCoordinators(coordinators []common.Coordinator) error {
514 return tracerr.Wrap(hdb.addCoordinators(hdb.db, coordinators))
515}
516func (hdb *HistoryDB) addCoordinators(d meddler.DB, coordinators []common.Coordinator) error {
517 if len(coordinators) == 0 {
518 return nil
519 }
520 return tracerr.Wrap(db.BulkInsert(
521 d,
522 "INSERT INTO coordinator (bidder_addr, forger_addr, eth_block_num, url) VALUES %s;",
523 coordinators[:],
524 ))
525}
526
527// AddExitTree insert Exit tree into the DB
528func (hdb *HistoryDB) AddExitTree(exitTree []common.ExitInfo) error {
529 return tracerr.Wrap(hdb.addExitTree(hdb.db, exitTree))
530}
531func (hdb *HistoryDB) addExitTree(d meddler.DB, exitTree []common.ExitInfo) error {
532 if len(exitTree) == 0 {
533 return nil
534 }
535 return tracerr.Wrap(db.BulkInsert(
536 d,
537 "INSERT INTO exit_tree (batch_num, account_idx, merkle_proof, balance, "+
538 "instant_withdrawn, delayed_withdraw_request, delayed_withdrawn) VALUES %s;",
539 exitTree[:],
540 ))
541}
542
543func (hdb *HistoryDB) updateExitTree(d sqlx.Ext, blockNum int64,
544 rollupWithdrawals []common.WithdrawInfo, wDelayerWithdrawals []common.WDelayerTransfer) error {
545 if len(rollupWithdrawals) == 0 && len(wDelayerWithdrawals) == 0 {
546 return nil
547 }
548 type withdrawal struct {
549 BatchNum int64 `db:"batch_num"`
550 AccountIdx int64 `db:"account_idx"`
551 InstantWithdrawn *int64 `db:"instant_withdrawn"`
552 DelayedWithdrawRequest *int64 `db:"delayed_withdraw_request"`
553 DelayedWithdrawn *int64 `db:"delayed_withdrawn"`
554 Owner *ethCommon.Address `db:"owner"`
555 Token *ethCommon.Address `db:"token"`
556 }
557 withdrawals := make([]withdrawal, len(rollupWithdrawals)+len(wDelayerWithdrawals))
558 for i := range rollupWithdrawals {
559 info := &rollupWithdrawals[i]
560 withdrawals[i] = withdrawal{
561 BatchNum: int64(info.NumExitRoot),
562 AccountIdx: int64(info.Idx),
563 }
564 if info.InstantWithdraw {
565 withdrawals[i].InstantWithdrawn = &blockNum
566 } else {
567 withdrawals[i].DelayedWithdrawRequest = &blockNum
568 withdrawals[i].Owner = &info.Owner
569 withdrawals[i].Token = &info.Token
570 }
571 }
572 for i := range wDelayerWithdrawals {
573 info := &wDelayerWithdrawals[i]
574 withdrawals[len(rollupWithdrawals)+i] = withdrawal{
575 DelayedWithdrawn: &blockNum,
576 Owner: &info.Owner,
577 Token: &info.Token,
578 }
579 }
580 // In VALUES we set an initial row of NULLs to set the types of each
581 // variable passed as argument
582 const query string = `
583 UPDATE exit_tree e SET
584 instant_withdrawn = d.instant_withdrawn,
585 delayed_withdraw_request = CASE
586 WHEN e.delayed_withdraw_request IS NOT NULL THEN e.delayed_withdraw_request
587 ELSE d.delayed_withdraw_request
588 END,
589 delayed_withdrawn = d.delayed_withdrawn,
590 owner = d.owner,
591 token = d.token
592 FROM (VALUES
593 (NULL::::BIGINT, NULL::::BIGINT, NULL::::BIGINT, NULL::::BIGINT, NULL::::BIGINT, NULL::::BYTEA, NULL::::BYTEA),
594 (:batch_num,
595 :account_idx,
596 :instant_withdrawn,
597 :delayed_withdraw_request,
598 :delayed_withdrawn,
599 :owner,
600 :token)
601 ) as d (batch_num, account_idx, instant_withdrawn, delayed_withdraw_request, delayed_withdrawn, owner, token)
602 WHERE
603 (d.batch_num IS NOT NULL AND e.batch_num = d.batch_num AND e.account_idx = d.account_idx) OR
604 (d.delayed_withdrawn IS NOT NULL AND e.delayed_withdrawn IS NULL AND e.owner = d.owner AND e.token = d.token);
605 `
606 if len(withdrawals) > 0 {
607 if _, err := sqlx.NamedExec(d, query, withdrawals); err != nil {
608 return tracerr.Wrap(err)
609 }
610 }
611
612 return nil
613}
614
615// AddToken insert a token into the DB
616func (hdb *HistoryDB) AddToken(token *common.Token) error {
617 return tracerr.Wrap(meddler.Insert(hdb.db, "token", token))
618}
619
620// AddTokens insert tokens into the DB
621func (hdb *HistoryDB) AddTokens(tokens []common.Token) error { return hdb.addTokens(hdb.db, tokens) }
622func (hdb *HistoryDB) addTokens(d meddler.DB, tokens []common.Token) error {
623 if len(tokens) == 0 {
624 return nil
625 }
626 return tracerr.Wrap(db.BulkInsert(
627 d,
628 `INSERT INTO token (
629 token_id,
630 eth_block_num,
631 eth_addr,
632 name,
633 symbol,
634 decimals
635 ) VALUES %s;`,
636 tokens[:],
637 ))
638}
639
640// UpdateTokenValue updates the USD value of a token
641func (hdb *HistoryDB) UpdateTokenValue(tokenSymbol string, value float64) error {
642 _, err := hdb.db.Exec(
643 "UPDATE token SET usd = $1 WHERE symbol = $2;",
644 value, tokenSymbol,
645 )
646 return tracerr.Wrap(err)
647}
648
649// GetToken returns a token from the DB given a TokenID
650func (hdb *HistoryDB) GetToken(tokenID common.TokenID) (*TokenWithUSD, error) {
651 token := &TokenWithUSD{}
652 err := meddler.QueryRow(
653 hdb.db, token, `SELECT * FROM token WHERE token_id = $1;`, tokenID,
654 )
655 return token, tracerr.Wrap(err)
656}
657
658// GetAllTokens returns all tokens from the DB
659func (hdb *HistoryDB) GetAllTokens() ([]TokenWithUSD, error) {
660 var tokens []*TokenWithUSD
661 err := meddler.QueryAll(
662 hdb.db, &tokens,
663 "SELECT * FROM token ORDER BY token_id;",
664 )
665 return db.SlicePtrsToSlice(tokens).([]TokenWithUSD), tracerr.Wrap(err)
666}
667
668// GetTokens returns a list of tokens from the DB
669func (hdb *HistoryDB) GetTokens(
670 ids []common.TokenID, symbols []string, name string, fromItem,
671 limit *uint, order string,
672) ([]TokenWithUSD, uint64, error) {
673 var query string
674 var args []interface{}
675 queryStr := `SELECT * , COUNT(*) OVER() AS total_items FROM token `
676 // Apply filters
677 nextIsAnd := false
678 if len(ids) > 0 {
679 queryStr += "WHERE token_id IN (?) "
680 nextIsAnd = true
681 args = append(args, ids)
682 }
683 if len(symbols) > 0 {
684 if nextIsAnd {
685 queryStr += "AND "
686 } else {
687 queryStr += "WHERE "
688 }
689 queryStr += "symbol IN (?) "
690 args = append(args, symbols)
691 nextIsAnd = true
692 }
693 if name != "" {
694 if nextIsAnd {
695 queryStr += "AND "
696 } else {
697 queryStr += "WHERE "
698 }
699 queryStr += "name ~ ? "
700 args = append(args, name)
701 nextIsAnd = true
702 }
703 if fromItem != nil {
704 if nextIsAnd {
705 queryStr += "AND "
706 } else {
707 queryStr += "WHERE "
708 }
709 if order == OrderAsc {
710 queryStr += "item_id >= ? "
711 } else {
712 queryStr += "item_id <= ? "
713 }
714 args = append(args, fromItem)
715 }
716 // pagination
717 queryStr += "ORDER BY item_id "
718 if order == OrderAsc {
719 queryStr += "ASC "
720 } else {
721 queryStr += "DESC "
722 }
723 queryStr += fmt.Sprintf("LIMIT %d;", *limit)
724 query, argsQ, err := sqlx.In(queryStr, args...)
725 if err != nil {
726 return nil, 0, tracerr.Wrap(err)
727 }
728 query = hdb.db.Rebind(query)
729 tokens := []*TokenWithUSD{}
730 if err := meddler.QueryAll(hdb.db, &tokens, query, argsQ...); err != nil {
731 return nil, 0, tracerr.Wrap(err)
732 }
733 if len(tokens) == 0 {
734 return nil, 0, tracerr.Wrap(sql.ErrNoRows)
735 }
736 return db.SlicePtrsToSlice(tokens).([]TokenWithUSD), uint64(len(tokens)) - tokens[0].TotalItems, nil
737}
738
739// GetTokenSymbols returns all the token symbols from the DB
740func (hdb *HistoryDB) GetTokenSymbols() ([]string, error) {
741 var tokenSymbols []string
742 rows, err := hdb.db.Query("SELECT symbol FROM token;")
743 if err != nil {
744 return nil, tracerr.Wrap(err)
745 }
746 defer db.RowsClose(rows)
747 sym := new(string)
748 for rows.Next() {
749 err = rows.Scan(sym)
750 if err != nil {
751 return nil, tracerr.Wrap(err)
752 }
753 tokenSymbols = append(tokenSymbols, *sym)
754 }
755 return tokenSymbols, nil
756}
757
758// AddAccounts insert accounts into the DB
759func (hdb *HistoryDB) AddAccounts(accounts []common.Account) error {
760 return tracerr.Wrap(hdb.addAccounts(hdb.db, accounts))
761}
762func (hdb *HistoryDB) addAccounts(d meddler.DB, accounts []common.Account) error {
763 if len(accounts) == 0 {
764 return nil
765 }
766 return tracerr.Wrap(db.BulkInsert(
767 d,
768 `INSERT INTO account (
769 idx,
770 token_id,
771 batch_num,
772 bjj,
773 eth_addr
774 ) VALUES %s;`,
775 accounts[:],
776 ))
777}
778
779// GetAllAccounts returns a list of accounts from the DB
780func (hdb *HistoryDB) GetAllAccounts() ([]common.Account, error) {
781 var accs []*common.Account
782 err := meddler.QueryAll(
783 hdb.db, &accs,
784 "SELECT * FROM account ORDER BY idx;",
785 )
786 return db.SlicePtrsToSlice(accs).([]common.Account), tracerr.Wrap(err)
787}
788
789// AddL1Txs inserts L1 txs to the DB. USD and DepositAmountUSD will be set automatically before storing the tx.
790// If the tx is originated by a coordinator, BatchNum must be provided. If it's originated by a user,
791// BatchNum should be null, and the value will be setted by a trigger when a batch forges the tx.
792// EffectiveAmount and EffectiveDepositAmount are seted with default values by the DB.
793func (hdb *HistoryDB) AddL1Txs(l1txs []common.L1Tx) error {
794 return tracerr.Wrap(hdb.addL1Txs(hdb.db, l1txs))
795}
796
797// addL1Txs inserts L1 txs to the DB. USD and DepositAmountUSD will be set automatically before storing the tx.
798// If the tx is originated by a coordinator, BatchNum must be provided. If it's originated by a user,
799// BatchNum should be null, and the value will be setted by a trigger when a batch forges the tx.
800// EffectiveAmount and EffectiveDepositAmount are seted with default values by the DB.
801func (hdb *HistoryDB) addL1Txs(d meddler.DB, l1txs []common.L1Tx) error {
802 txs := []txWrite{}
803 for i := 0; i < len(l1txs); i++ {
804 af := new(big.Float).SetInt(l1txs[i].Amount)
805 amountFloat, _ := af.Float64()
806 laf := new(big.Float).SetInt(l1txs[i].DepositAmount)
807 depositAmountFloat, _ := laf.Float64()
808 txs = append(txs, txWrite{
809 // Generic
810 IsL1: true,
811 TxID: l1txs[i].TxID,
812 Type: l1txs[i].Type,
813 Position: l1txs[i].Position,
814 FromIdx: &l1txs[i].FromIdx,
815 ToIdx: l1txs[i].ToIdx,
816 Amount: l1txs[i].Amount,
817 AmountFloat: amountFloat,
818 TokenID: l1txs[i].TokenID,
819 BatchNum: l1txs[i].BatchNum,
820 EthBlockNum: l1txs[i].EthBlockNum,
821 // L1
822 ToForgeL1TxsNum: l1txs[i].ToForgeL1TxsNum,
823 UserOrigin: &l1txs[i].UserOrigin,
824 FromEthAddr: &l1txs[i].FromEthAddr,
825 FromBJJ: l1txs[i].FromBJJ,
826 DepositAmount: l1txs[i].DepositAmount,
827 DepositAmountFloat: &depositAmountFloat,
828 })
829 }
830 return tracerr.Wrap(hdb.addTxs(d, txs))
831}
832
833// AddL2Txs inserts L2 txs to the DB. TokenID, USD and FeeUSD will be set automatically before storing the tx.
834func (hdb *HistoryDB) AddL2Txs(l2txs []common.L2Tx) error {
835 return tracerr.Wrap(hdb.addL2Txs(hdb.db, l2txs))
836}
837
838// addL2Txs inserts L2 txs to the DB. TokenID, USD and FeeUSD will be set automatically before storing the tx.
839func (hdb *HistoryDB) addL2Txs(d meddler.DB, l2txs []common.L2Tx) error {
840 txs := []txWrite{}
841 for i := 0; i < len(l2txs); i++ {
842 f := new(big.Float).SetInt(l2txs[i].Amount)
843 amountFloat, _ := f.Float64()
844 txs = append(txs, txWrite{
845 // Generic
846 IsL1: false,
847 TxID: l2txs[i].TxID,
848 Type: l2txs[i].Type,
849 Position: l2txs[i].Position,
850 FromIdx: &l2txs[i].FromIdx,
851 ToIdx: l2txs[i].ToIdx,
852 Amount: l2txs[i].Amount,
853 AmountFloat: amountFloat,
854 BatchNum: &l2txs[i].BatchNum,
855 EthBlockNum: l2txs[i].EthBlockNum,
856 // L2
857 Fee: &l2txs[i].Fee,
858 Nonce: &l2txs[i].Nonce,
859 })
860 }
861 return tracerr.Wrap(hdb.addTxs(d, txs))
862}
863
864func (hdb *HistoryDB) addTxs(d meddler.DB, txs []txWrite) error {
865 if len(txs) == 0 {
866 return nil
867 }
868 return tracerr.Wrap(db.BulkInsert(
869 d,
870 `INSERT INTO tx (
871 is_l1,
872 id,
873 type,
874 position,
875 from_idx,
876 to_idx,
877 amount,
878 amount_f,
879 token_id,
880 batch_num,
881 eth_block_num,
882 to_forge_l1_txs_num,
883 user_origin,
884 from_eth_addr,
885 from_bjj,
886 deposit_amount,
887 deposit_amount_f,
888 fee,
889 nonce
890 ) VALUES %s;`,
891 txs[:],
892 ))
893}
894
895// // GetTxs returns a list of txs from the DB
896// func (hdb *HistoryDB) GetTxs() ([]common.Tx, error) {
897// var txs []*common.Tx
898// err := meddler.QueryAll(
899// hdb.db, &txs,
900// `SELECT * FROM tx
901// ORDER BY (batch_num, position) ASC`,
902// )
903// return db.SlicePtrsToSlice(txs).([]common.Tx), err
904// }
905
906// GetHistoryTx returns a tx from the DB given a TxID
907func (hdb *HistoryDB) GetHistoryTx(txID common.TxID) (*TxAPI, error) {
908 // Warning: amount_success and deposit_amount_success have true as default for
909 // performance reasons. The expected default value is false (when txs are unforged)
910 // this case is handled at the function func (tx TxAPI) MarshalJSON() ([]byte, error)
911 tx := &TxAPI{}
912 err := meddler.QueryRow(
913 hdb.db, tx, `SELECT tx.item_id, tx.is_l1, tx.id, tx.type, tx.position,
914 hez_idx(tx.from_idx, token.symbol) AS from_idx, tx.from_eth_addr, tx.from_bjj,
915 hez_idx(tx.to_idx, token.symbol) AS to_idx, tx.to_eth_addr, tx.to_bjj,
916 tx.amount, tx.amount_success, tx.token_id, tx.amount_usd,
917 tx.batch_num, tx.eth_block_num, tx.to_forge_l1_txs_num, tx.user_origin,
918 tx.deposit_amount, tx.deposit_amount_usd, tx.deposit_amount_success, tx.fee, tx.fee_usd, tx.nonce,
919 token.token_id, token.item_id AS token_item_id, token.eth_block_num AS token_block,
920 token.eth_addr, token.name, token.symbol, token.decimals, token.usd,
921 token.usd_update, block.timestamp
922 FROM tx INNER JOIN token ON tx.token_id = token.token_id
923 INNER JOIN block ON tx.eth_block_num = block.eth_block_num
924 WHERE tx.id = $1;`, txID,
925 )
926 return tx, tracerr.Wrap(err)
927}
928
929// GetHistoryTxs returns a list of txs from the DB using the HistoryTx struct
930// and pagination info
931func (hdb *HistoryDB) GetHistoryTxs(
932 ethAddr *ethCommon.Address, bjj *babyjub.PublicKey,
933 tokenID *common.TokenID, idx *common.Idx, batchNum *uint, txType *common.TxType,
934 fromItem, limit *uint, order string,
935) ([]TxAPI, uint64, error) {
936 // Warning: amount_success and deposit_amount_success have true as default for
937 // performance reasons. The expected default value is false (when txs are unforged)
938 // this case is handled at the function func (tx TxAPI) MarshalJSON() ([]byte, error)
939 if ethAddr != nil && bjj != nil {
940 return nil, 0, tracerr.Wrap(errors.New("ethAddr and bjj are incompatible"))
941 }
942 var query string
943 var args []interface{}
944 queryStr := `SELECT tx.item_id, tx.is_l1, tx.id, tx.type, tx.position,
945 hez_idx(tx.from_idx, token.symbol) AS from_idx, tx.from_eth_addr, tx.from_bjj,
946 hez_idx(tx.to_idx, token.symbol) AS to_idx, tx.to_eth_addr, tx.to_bjj,
947 tx.amount, tx.amount_success, tx.token_id, tx.amount_usd,
948 tx.batch_num, tx.eth_block_num, tx.to_forge_l1_txs_num, tx.user_origin,
949 tx.deposit_amount, tx.deposit_amount_usd, tx.deposit_amount_success, tx.fee, tx.fee_usd, tx.nonce,
950 token.token_id, token.item_id AS token_item_id, token.eth_block_num AS token_block,
951 token.eth_addr, token.name, token.symbol, token.decimals, token.usd,
952 token.usd_update, block.timestamp, count(*) OVER() AS total_items
953 FROM tx INNER JOIN token ON tx.token_id = token.token_id
954 INNER JOIN block ON tx.eth_block_num = block.eth_block_num `
955 // Apply filters
956 nextIsAnd := false
957 // ethAddr filter
958 if ethAddr != nil {
959 queryStr += "WHERE (tx.from_eth_addr = ? OR tx.to_eth_addr = ?) "
960 nextIsAnd = true
961 args = append(args, ethAddr, ethAddr)
962 } else if bjj != nil { // bjj filter
963 queryStr += "WHERE (tx.from_bjj = ? OR tx.to_bjj = ?) "
964 nextIsAnd = true
965 args = append(args, bjj, bjj)
966 }
967 // tokenID filter
968 if tokenID != nil {
969 if nextIsAnd {
970 queryStr += "AND "
971 } else {
972 queryStr += "WHERE "
973 }
974 queryStr += "tx.token_id = ? "
975 args = append(args, tokenID)
976 nextIsAnd = true
977 }
978 // idx filter
979 if idx != nil {
980 if nextIsAnd {
981 queryStr += "AND "
982 } else {
983 queryStr += "WHERE "
984 }
985 queryStr += "(tx.from_idx = ? OR tx.to_idx = ?) "
986 args = append(args, idx, idx)
987 nextIsAnd = true
988 }
989 // batchNum filter
990 if batchNum != nil {
991 if nextIsAnd {
992 queryStr += "AND "
993 } else {
994 queryStr += "WHERE "
995 }
996 queryStr += "tx.batch_num = ? "
997 args = append(args, batchNum)
998 nextIsAnd = true
999 }
1000 // txType filter
1001 if txType != nil {
1002 if nextIsAnd {
1003 queryStr += "AND "
1004 } else {
1005 queryStr += "WHERE "
1006 }
1007 queryStr += "tx.type = ? "
1008 args = append(args, txType)
1009 nextIsAnd = true
1010 }
1011 if fromItem != nil {
1012 if nextIsAnd {
1013 queryStr += "AND "
1014 } else {
1015 queryStr += "WHERE "
1016 }
1017 if order == OrderAsc {
1018 queryStr += "tx.item_id >= ? "
1019 } else {
1020 queryStr += "tx.item_id <= ? "
1021 }
1022 args = append(args, fromItem)
1023 nextIsAnd = true
1024 }
1025 if nextIsAnd {
1026 queryStr += "AND "
1027 } else {
1028 queryStr += "WHERE "
1029 }
1030 queryStr += "tx.batch_num IS NOT NULL "
1031
1032 // pagination
1033 queryStr += "ORDER BY tx.item_id "
1034 if order == OrderAsc {
1035 queryStr += " ASC "
1036 } else {
1037 queryStr += " DESC "
1038 }
1039 queryStr += fmt.Sprintf("LIMIT %d;", *limit)
1040 query = hdb.db.Rebind(queryStr)
1041 // log.Debug(query)
1042 txsPtrs := []*TxAPI{}
1043 if err := meddler.QueryAll(hdb.db, &txsPtrs, query, args...); err != nil {
1044 return nil, 0, tracerr.Wrap(err)
1045 }
1046 txs := db.SlicePtrsToSlice(txsPtrs).([]TxAPI)
1047 if len(txs) == 0 {
1048 return nil, 0, tracerr.Wrap(sql.ErrNoRows)
1049 }
1050 return txs, txs[0].TotalItems - uint64(len(txs)), nil
1051}
1052
1053// GetAllExits returns all exit from the DB
1054func (hdb *HistoryDB) GetAllExits() ([]common.ExitInfo, error) {
1055 var exits []*common.ExitInfo
1056 err := meddler.QueryAll(
1057 hdb.db, &exits,
1058 `SELECT exit_tree.batch_num, exit_tree.account_idx, exit_tree.merkle_proof,
1059 exit_tree.balance, exit_tree.instant_withdrawn, exit_tree.delayed_withdraw_request,
1060 exit_tree.delayed_withdrawn FROM exit_tree;`,
1061 )
1062 return db.SlicePtrsToSlice(exits).([]common.ExitInfo), tracerr.Wrap(err)
1063}
1064
1065// GetExitAPI returns a exit from the DB
1066func (hdb *HistoryDB) GetExitAPI(batchNum *uint, idx *common.Idx) (*ExitAPI, error) {
1067 exit := &ExitAPI{}
1068 err := meddler.QueryRow(
1069 hdb.db, exit, `SELECT exit_tree.item_id, exit_tree.batch_num,
1070 hez_idx(exit_tree.account_idx, token.symbol) AS account_idx,
1071 exit_tree.merkle_proof, exit_tree.balance, exit_tree.instant_withdrawn,
1072 exit_tree.delayed_withdraw_request, exit_tree.delayed_withdrawn,
1073 token.token_id, token.item_id AS token_item_id,
1074 token.eth_block_num AS token_block, token.eth_addr, token.name, token.symbol,
1075 token.decimals, token.usd, token.usd_update
1076 FROM exit_tree INNER JOIN account ON exit_tree.account_idx = account.idx
1077 INNER JOIN token ON account.token_id = token.token_id
1078 WHERE exit_tree.batch_num = $1 AND exit_tree.account_idx = $2;`, batchNum, idx,
1079 )
1080 return exit, tracerr.Wrap(err)
1081}
1082
1083// GetExitsAPI returns a list of exits from the DB and pagination info
1084func (hdb *HistoryDB) GetExitsAPI(
1085 ethAddr *ethCommon.Address, bjj *babyjub.PublicKey, tokenID *common.TokenID,
1086 idx *common.Idx, batchNum *uint, onlyPendingWithdraws *bool,
1087 fromItem, limit *uint, order string,
1088) ([]ExitAPI, uint64, error) {
1089 if ethAddr != nil && bjj != nil {
1090 return nil, 0, tracerr.Wrap(errors.New("ethAddr and bjj are incompatible"))
1091 }
1092 var query string
1093 var args []interface{}
1094 queryStr := `SELECT exit_tree.item_id, exit_tree.batch_num,
1095 hez_idx(exit_tree.account_idx, token.symbol) AS account_idx,
1096 exit_tree.merkle_proof, exit_tree.balance, exit_tree.instant_withdrawn,
1097 exit_tree.delayed_withdraw_request, exit_tree.delayed_withdrawn,
1098 token.token_id, token.item_id AS token_item_id,
1099 token.eth_block_num AS token_block, token.eth_addr, token.name, token.symbol,
1100 token.decimals, token.usd, token.usd_update, COUNT(*) OVER() AS total_items
1101 FROM exit_tree INNER JOIN account ON exit_tree.account_idx = account.idx
1102 INNER JOIN token ON account.token_id = token.token_id `
1103 // Apply filters
1104 nextIsAnd := false
1105 // ethAddr filter
1106 if ethAddr != nil {
1107 queryStr += "WHERE account.eth_addr = ? "
1108 nextIsAnd = true
1109 args = append(args, ethAddr)
1110 } else if bjj != nil { // bjj filter
1111 queryStr += "WHERE account.bjj = ? "
1112 nextIsAnd = true
1113 args = append(args, bjj)
1114 }
1115 // tokenID filter
1116 if tokenID != nil {
1117 if nextIsAnd {
1118 queryStr += "AND "
1119 } else {
1120 queryStr += "WHERE "
1121 }
1122 queryStr += "account.token_id = ? "
1123 args = append(args, tokenID)
1124 nextIsAnd = true
1125 }
1126 // idx filter
1127 if idx != nil {
1128 if nextIsAnd {
1129 queryStr += "AND "
1130 } else {
1131 queryStr += "WHERE "
1132 }
1133 queryStr += "exit_tree.account_idx = ? "
1134 args = append(args, idx)
1135 nextIsAnd = true
1136 }
1137 // batchNum filter
1138 if batchNum != nil {
1139 if nextIsAnd {
1140 queryStr += "AND "
1141 } else {
1142 queryStr += "WHERE "
1143 }
1144 queryStr += "exit_tree.batch_num = ? "
1145 args = append(args, batchNum)
1146 nextIsAnd = true
1147 }
1148 // onlyPendingWithdraws
1149 if onlyPendingWithdraws != nil {
1150 if *onlyPendingWithdraws {
1151 if nextIsAnd {
1152 queryStr += "AND "
1153 } else {
1154 queryStr += "WHERE "
1155 }
1156 queryStr += "(exit_tree.instant_withdrawn IS NULL AND exit_tree.delayed_withdrawn IS NULL) "
1157 nextIsAnd = true
1158 }
1159 }
1160 if fromItem != nil {
1161 if nextIsAnd {
1162 queryStr += "AND "
1163 } else {
1164 queryStr += "WHERE "
1165 }
1166 if order == OrderAsc {
1167 queryStr += "exit_tree.item_id >= ? "
1168 } else {
1169 queryStr += "exit_tree.item_id <= ? "
1170 }
1171 args = append(args, fromItem)
1172 // nextIsAnd = true
1173 }
1174 // pagination
1175 queryStr += "ORDER BY exit_tree.item_id "
1176 if order == OrderAsc {
1177 queryStr += " ASC "
1178 } else {
1179 queryStr += " DESC "
1180 }
1181 queryStr += fmt.Sprintf("LIMIT %d;", *limit)
1182 query = hdb.db.Rebind(queryStr)
1183 // log.Debug(query)
1184 exits := []*ExitAPI{}
1185 if err := meddler.QueryAll(hdb.db, &exits, query, args...); err != nil {
1186 return nil, 0, tracerr.Wrap(err)
1187 }
1188 if len(exits) == 0 {
1189 return nil, 0, tracerr.Wrap(sql.ErrNoRows)
1190 }
1191 return db.SlicePtrsToSlice(exits).([]ExitAPI), exits[0].TotalItems - uint64(len(exits)), nil
1192}
1193
1194// GetAllL1UserTxs returns all L1UserTxs from the DB
1195func (hdb *HistoryDB) GetAllL1UserTxs() ([]common.L1Tx, error) {
1196 var txs []*common.L1Tx
1197 err := meddler.QueryAll(
1198 hdb.db, &txs, // Note that '\x' gets parsed as a big.Int with value = 0
1199 `SELECT tx.id, tx.to_forge_l1_txs_num, tx.position, tx.user_origin,
1200 tx.from_idx, tx.from_eth_addr, tx.from_bjj, tx.to_idx, tx.token_id,
1201 tx.amount, (CASE WHEN tx.batch_num IS NULL THEN NULL WHEN tx.amount_success THEN tx.amount ELSE '\x' END) AS effective_amount,
1202 tx.deposit_amount, (CASE WHEN tx.batch_num IS NULL THEN NULL WHEN tx.deposit_amount_success THEN tx.deposit_amount ELSE '\x' END) AS effective_deposit_amount,
1203 tx.eth_block_num, tx.type, tx.batch_num
1204 FROM tx WHERE is_l1 = TRUE AND user_origin = TRUE;`,
1205 )
1206 return db.SlicePtrsToSlice(txs).([]common.L1Tx), tracerr.Wrap(err)
1207}
1208
1209// GetAllL1CoordinatorTxs returns all L1CoordinatorTxs from the DB
1210func (hdb *HistoryDB) GetAllL1CoordinatorTxs() ([]common.L1Tx, error) {
1211 var txs []*common.L1Tx
1212 // Since the query specifies that only coordinator txs are returned, it's safe to assume
1213 // that returned txs will always have effective amounts
1214 err := meddler.QueryAll(
1215 hdb.db, &txs,
1216 `SELECT tx.id, tx.to_forge_l1_txs_num, tx.position, tx.user_origin,
1217 tx.from_idx, tx.from_eth_addr, tx.from_bjj, tx.to_idx, tx.token_id,
1218 tx.amount, tx.amount AS effective_amount,
1219 tx.deposit_amount, tx.deposit_amount AS effective_deposit_amount,
1220 tx.eth_block_num, tx.type, tx.batch_num
1221 FROM tx WHERE is_l1 = TRUE AND user_origin = FALSE;`,
1222 )
1223 return db.SlicePtrsToSlice(txs).([]common.L1Tx), tracerr.Wrap(err)
1224}
1225
1226// GetAllL2Txs returns all L2Txs from the DB
1227func (hdb *HistoryDB) GetAllL2Txs() ([]common.L2Tx, error) {
1228 var txs []*common.L2Tx
1229 err := meddler.QueryAll(
1230 hdb.db, &txs,
1231 `SELECT tx.id, tx.batch_num, tx.position,
1232 tx.from_idx, tx.to_idx, tx.amount, tx.fee, tx.nonce,
1233 tx.type, tx.eth_block_num
1234 FROM tx WHERE is_l1 = FALSE;`,
1235 )
1236 return db.SlicePtrsToSlice(txs).([]common.L2Tx), tracerr.Wrap(err)
1237}
1238
1239// GetUnforgedL1UserTxs gets L1 User Txs to be forged in the L1Batch with toForgeL1TxsNum.
1240func (hdb *HistoryDB) GetUnforgedL1UserTxs(toForgeL1TxsNum int64) ([]common.L1Tx, error) {
1241 var txs []*common.L1Tx
1242 err := meddler.QueryAll(
1243 hdb.db, &txs, // only L1 user txs can have batch_num set to null
1244 `SELECT tx.id, tx.to_forge_l1_txs_num, tx.position, tx.user_origin,
1245 tx.from_idx, tx.from_eth_addr, tx.from_bjj, tx.to_idx, tx.token_id,
1246 tx.amount, NULL AS effective_amount,
1247 tx.deposit_amount, NULL AS effective_deposit_amount,
1248 tx.eth_block_num, tx.type, tx.batch_num
1249 FROM tx WHERE batch_num IS NULL AND to_forge_l1_txs_num = $1
1250 ORDER BY position;`,
1251 toForgeL1TxsNum,
1252 )
1253 return db.SlicePtrsToSlice(txs).([]common.L1Tx), tracerr.Wrap(err)
1254}
1255
1256// TODO: Think about chaning all the queries that return a last value, to queries that return the next valid value.
1257
1258// GetLastTxsPosition for a given to_forge_l1_txs_num
1259func (hdb *HistoryDB) GetLastTxsPosition(toForgeL1TxsNum int64) (int, error) {
1260 row := hdb.db.QueryRow(
1261 "SELECT position FROM tx WHERE to_forge_l1_txs_num = $1 ORDER BY position DESC;",
1262 toForgeL1TxsNum,
1263 )
1264 var lastL1TxsPosition int
1265 return lastL1TxsPosition, tracerr.Wrap(row.Scan(&lastL1TxsPosition))
1266}
1267
1268// GetSCVars returns the rollup, auction and wdelayer smart contracts variables at their last update.
1269func (hdb *HistoryDB) GetSCVars() (*common.RollupVariables, *common.AuctionVariables,
1270 *common.WDelayerVariables, error) {
1271 var rollup common.RollupVariables
1272 var auction common.AuctionVariables
1273 var wDelayer common.WDelayerVariables
1274 if err := meddler.QueryRow(hdb.db, &rollup,
1275 "SELECT * FROM rollup_vars ORDER BY eth_block_num DESC LIMIT 1;"); err != nil {
1276 return nil, nil, nil, tracerr.Wrap(err)
1277 }
1278 if err := meddler.QueryRow(hdb.db, &auction,
1279 "SELECT * FROM auction_vars ORDER BY eth_block_num DESC LIMIT 1;"); err != nil {
1280 return nil, nil, nil, tracerr.Wrap(err)
1281 }
1282 if err := meddler.QueryRow(hdb.db, &wDelayer,
1283 "SELECT * FROM wdelayer_vars ORDER BY eth_block_num DESC LIMIT 1;"); err != nil {
1284 return nil, nil, nil, tracerr.Wrap(err)
1285 }
1286 return &rollup, &auction, &wDelayer, nil
1287}
1288
1289func (hdb *HistoryDB) setRollupVars(d meddler.DB, rollup *common.RollupVariables) error {
1290 return tracerr.Wrap(meddler.Insert(d, "rollup_vars", rollup))
1291}
1292
1293func (hdb *HistoryDB) setAuctionVars(d meddler.DB, auction *common.AuctionVariables) error {
1294 return tracerr.Wrap(meddler.Insert(d, "auction_vars", auction))
1295}
1296
1297func (hdb *HistoryDB) setWDelayerVars(d meddler.DB, wDelayer *common.WDelayerVariables) error {
1298 return tracerr.Wrap(meddler.Insert(d, "wdelayer_vars", wDelayer))
1299}
1300
1301func (hdb *HistoryDB) addBucketUpdates(d meddler.DB, bucketUpdates []common.BucketUpdate) error {
1302 if len(bucketUpdates) == 0 {
1303 return nil
1304 }
1305 return tracerr.Wrap(db.BulkInsert(
1306 d,
1307 `INSERT INTO bucket_update (
1308 eth_block_num,
1309 num_bucket,
1310 block_stamp,
1311 withdrawals
1312 ) VALUES %s;`,
1313 bucketUpdates[:],
1314 ))
1315}
1316
1317// GetAllBucketUpdates retrieves all the bucket updates
1318func (hdb *HistoryDB) GetAllBucketUpdates() ([]common.BucketUpdate, error) {
1319 var bucketUpdates []*common.BucketUpdate
1320 err := meddler.QueryAll(
1321 hdb.db, &bucketUpdates,
1322 "SELECT * FROM bucket_update;",
1323 )
1324 return db.SlicePtrsToSlice(bucketUpdates).([]common.BucketUpdate), tracerr.Wrap(err)
1325}
1326
1327func (hdb *HistoryDB) addTokenExchanges(d meddler.DB, tokenExchanges []common.TokenExchange) error {
1328 if len(tokenExchanges) == 0 {
1329 return nil
1330 }
1331 return tracerr.Wrap(db.BulkInsert(
1332 d,
1333 `INSERT INTO token_exchange (
1334 eth_block_num,
1335 eth_addr,
1336 value_usd
1337 ) VALUES %s;`,
1338 tokenExchanges[:],
1339 ))
1340}
1341
1342// GetAllTokenExchanges retrieves all the token exchanges
1343func (hdb *HistoryDB) GetAllTokenExchanges() ([]common.TokenExchange, error) {
1344 var tokenExchanges []*common.TokenExchange
1345 err := meddler.QueryAll(
1346 hdb.db, &tokenExchanges,
1347 "SELECT * FROM token_exchange;",
1348 )
1349 return db.SlicePtrsToSlice(tokenExchanges).([]common.TokenExchange), tracerr.Wrap(err)
1350}
1351
1352func (hdb *HistoryDB) addEscapeHatchWithdrawals(d meddler.DB,
1353 escapeHatchWithdrawals []common.WDelayerEscapeHatchWithdrawal) error {
1354 if len(escapeHatchWithdrawals) == 0 {
1355 return nil
1356 }
1357 return tracerr.Wrap(db.BulkInsert(
1358 d,
1359 `INSERT INTO escape_hatch_withdrawal (
1360 eth_block_num,
1361 who_addr,
1362 to_addr,
1363 token_addr,
1364 amount
1365 ) VALUES %s;`,
1366 escapeHatchWithdrawals[:],
1367 ))
1368}
1369
1370// GetAllEscapeHatchWithdrawals retrieves all the escape hatch withdrawals
1371func (hdb *HistoryDB) GetAllEscapeHatchWithdrawals() ([]common.WDelayerEscapeHatchWithdrawal, error) {
1372 var escapeHatchWithdrawals []*common.WDelayerEscapeHatchWithdrawal
1373 err := meddler.QueryAll(
1374 hdb.db, &escapeHatchWithdrawals,
1375 "SELECT * FROM escape_hatch_withdrawal;",
1376 )
1377 return db.SlicePtrsToSlice(escapeHatchWithdrawals).([]common.WDelayerEscapeHatchWithdrawal),
1378 tracerr.Wrap(err)
1379}
1380
1381// SetInitialSCVars sets the initial state of rollup, auction, wdelayer smart
1382// contract variables. This initial state is stored linked to block 0, which
1383// always exist in the DB and is used to store initialization data that always
1384// exist in the smart contracts.
1385func (hdb *HistoryDB) SetInitialSCVars(rollup *common.RollupVariables,
1386 auction *common.AuctionVariables, wDelayer *common.WDelayerVariables) error {
1387 txn, err := hdb.db.Beginx()
1388 if err != nil {
1389 return tracerr.Wrap(err)
1390 }
1391 defer func() {
1392 if err != nil {
1393 db.Rollback(txn)
1394 }
1395 }()
1396 // Force EthBlockNum to be 0 because it's the block used to link data
1397 // that belongs to the creation of the smart contracts
1398 rollup.EthBlockNum = 0
1399 auction.EthBlockNum = 0
1400 wDelayer.EthBlockNum = 0
1401 auction.DefaultSlotSetBidSlotNum = 0
1402 if err := hdb.setRollupVars(txn, rollup); err != nil {
1403 return tracerr.Wrap(err)
1404 }
1405 if err := hdb.setAuctionVars(txn, auction); err != nil {
1406 return tracerr.Wrap(err)
1407 }
1408 if err := hdb.setWDelayerVars(txn, wDelayer); err != nil {
1409 return tracerr.Wrap(err)
1410 }
1411
1412 return tracerr.Wrap(txn.Commit())
1413}
1414
1415// setL1UserTxEffectiveAmounts sets the EffectiveAmount and EffectiveDepositAmount
1416// of the given l1UserTxs (with an UPDATE)
1417func (hdb *HistoryDB) setL1UserTxEffectiveAmounts(d sqlx.Ext, txs []common.L1Tx) error {
1418 if len(txs) == 0 {
1419 return nil
1420 }
1421 // Effective amounts are stored as success flags in the DB, with true value by default
1422 // to reduce the amount of updates. Therefore, only amounts that became uneffective should be
1423 // updated to become false
1424 type txUpdate struct {
1425 ID common.TxID `db:"id"`
1426 AmountSuccess bool `db:"amount_success"`
1427 DepositAmountSuccess bool `db:"deposit_amount_success"`
1428 }
1429 txUpdates := []txUpdate{}
1430 equal := func(a *big.Int, b *big.Int) bool {
1431 return a.Cmp(b) == 0
1432 }
1433 for i := range txs {
1434 amountSuccess := equal(txs[i].Amount, txs[i].EffectiveAmount)
1435 depositAmountSuccess := equal(txs[i].DepositAmount, txs[i].EffectiveDepositAmount)
1436 if !amountSuccess || !depositAmountSuccess {
1437 txUpdates = append(txUpdates, txUpdate{
1438 ID: txs[i].TxID,
1439 AmountSuccess: amountSuccess,
1440 DepositAmountSuccess: depositAmountSuccess,
1441 })
1442 }
1443 }
1444 const query string = `
1445 UPDATE tx SET
1446 amount_success = tx_update.amount_success,
1447 deposit_amount_success = tx_update.deposit_amount_success
1448 FROM (VALUES
1449 (NULL::::BYTEA, NULL::::BOOL, NULL::::BOOL),
1450 (:id, :amount_success, :deposit_amount_success)
1451 ) as tx_update (id, amount_success, deposit_amount_success)
1452 WHERE tx.id = tx_update.id;
1453 `
1454 if len(txUpdates) > 0 {
1455 if _, err := sqlx.NamedExec(d, query, txUpdates); err != nil {
1456 return tracerr.Wrap(err)
1457 }
1458 }
1459 return nil
1460}
1461
1462// AddBlockSCData stores all the information of a block retrieved by the
1463// Synchronizer. Blocks should be inserted in order, leaving no gaps because
1464// the pagination system of the API/DB depends on this. Within blocks, all
1465// items should also be in the correct order (Accounts, Tokens, Txs, etc.)
1466func (hdb *HistoryDB) AddBlockSCData(blockData *common.BlockData) (err error) {
1467 txn, err := hdb.db.Beginx()
1468 if err != nil {
1469 return tracerr.Wrap(err)
1470 }
1471 defer func() {
1472 if err != nil {
1473 db.Rollback(txn)
1474 }
1475 }()
1476
1477 // Add block
1478 if err := hdb.addBlock(txn, &blockData.Block); err != nil {
1479 return tracerr.Wrap(err)
1480 }
1481
1482 // Add Coordinators
1483 if err := hdb.addCoordinators(txn, blockData.Auction.Coordinators); err != nil {
1484 return tracerr.Wrap(err)
1485 }
1486
1487 // Add Bids
1488 if err := hdb.addBids(txn, blockData.Auction.Bids); err != nil {
1489 return tracerr.Wrap(err)
1490 }
1491
1492 // Add Tokens
1493 if err := hdb.addTokens(txn, blockData.Rollup.AddedTokens); err != nil {
1494 return tracerr.Wrap(err)
1495 }
1496
1497 // Prepare user L1 txs to be added.
1498 // They must be added before the batch that will forge them (which can be in the same block)
1499 // and after the account that will be sent to (also can be in the same block).
1500 // Note: insert order is not relevant since item_id will be updated by a DB trigger when
1501 // the batch that forges those txs is inserted
1502 userL1s := make(map[common.BatchNum][]common.L1Tx)
1503 for i := range blockData.Rollup.L1UserTxs {
1504 batchThatForgesIsInTheBlock := false
1505 for _, batch := range blockData.Rollup.Batches {
1506 if batch.Batch.ForgeL1TxsNum != nil &&
1507 *batch.Batch.ForgeL1TxsNum == *blockData.Rollup.L1UserTxs[i].ToForgeL1TxsNum {
1508 // Tx is forged in this block. It's guaranteed that:
1509 // * the first batch of the block won't forge user L1 txs that have been added in this block
1510 // * batch nums are sequential therefore it's safe to add the tx at batch.BatchNum -1
1511 batchThatForgesIsInTheBlock = true
1512 addAtBatchNum := batch.Batch.BatchNum - 1
1513 userL1s[addAtBatchNum] = append(userL1s[addAtBatchNum], blockData.Rollup.L1UserTxs[i])
1514 break
1515 }
1516 }
1517 if !batchThatForgesIsInTheBlock {
1518 // User artificial batchNum 0 to add txs that are not forge in this block
1519 // after all the accounts of the block have been added
1520 userL1s[0] = append(userL1s[0], blockData.Rollup.L1UserTxs[i])
1521 }
1522 }
1523
1524 // Add Batches
1525 for i := range blockData.Rollup.Batches {
1526 batch := &blockData.Rollup.Batches[i]
1527
1528 // Add Batch: this will trigger an update on the DB
1529 // that will set the batch num of forged L1 txs in this batch
1530 if err = hdb.addBatch(txn, &batch.Batch); err != nil {
1531 return tracerr.Wrap(err)
1532 }
1533
1534 // Set the EffectiveAmount and EffectiveDepositAmount of all the
1535 // L1UserTxs that have been forged in this batch
1536 if err = hdb.setL1UserTxEffectiveAmounts(txn, batch.L1UserTxs); err != nil {
1537 return tracerr.Wrap(err)
1538 }
1539
1540 // Add accounts
1541 if err := hdb.addAccounts(txn, batch.CreatedAccounts); err != nil {
1542 return tracerr.Wrap(err)
1543 }
1544
1545 // Add forged l1 coordinator Txs
1546 if err := hdb.addL1Txs(txn, batch.L1CoordinatorTxs); err != nil {
1547 return tracerr.Wrap(err)
1548 }
1549
1550 // Add l2 Txs
1551 if err := hdb.addL2Txs(txn, batch.L2Txs); err != nil {
1552 return tracerr.Wrap(err)
1553 }
1554
1555 // Add user L1 txs that will be forged in next batch
1556 if userlL1s, ok := userL1s[batch.Batch.BatchNum]; ok {
1557 if err := hdb.addL1Txs(txn, userlL1s); err != nil {
1558 return tracerr.Wrap(err)
1559 }
1560 }
1561
1562 // Add exit tree
1563 if err := hdb.addExitTree(txn, batch.ExitTree); err != nil {
1564 return tracerr.Wrap(err)
1565 }
1566 }
1567 // Add user L1 txs that won't be forged in this block
1568 if userL1sNotForgedInThisBlock, ok := userL1s[0]; ok {
1569 if err := hdb.addL1Txs(txn, userL1sNotForgedInThisBlock); err != nil {
1570 return tracerr.Wrap(err)
1571 }
1572 }
1573
1574 // Set SC Vars if there was an update
1575 if blockData.Rollup.Vars != nil {
1576 if err := hdb.setRollupVars(txn, blockData.Rollup.Vars); err != nil {
1577 return tracerr.Wrap(err)
1578 }
1579 }
1580 if blockData.Auction.Vars != nil {
1581 if err := hdb.setAuctionVars(txn, blockData.Auction.Vars); err != nil {
1582 return tracerr.Wrap(err)
1583 }
1584 }
1585 if blockData.WDelayer.Vars != nil {
1586 if err := hdb.setWDelayerVars(txn, blockData.WDelayer.Vars); err != nil {
1587 return tracerr.Wrap(err)
1588 }
1589 }
1590
1591 // Update withdrawals in exit tree table
1592 if err := hdb.updateExitTree(txn, blockData.Block.Num,
1593 blockData.Rollup.Withdrawals, blockData.WDelayer.Withdrawals); err != nil {
1594 return tracerr.Wrap(err)
1595 }
1596
1597 // Add Escape Hatch Withdrawals
1598 if err := hdb.addEscapeHatchWithdrawals(txn,
1599 blockData.WDelayer.EscapeHatchWithdrawals); err != nil {
1600 return tracerr.Wrap(err)
1601 }
1602
1603 // Add Buckets withdrawals updates
1604 if err := hdb.addBucketUpdates(txn, blockData.Rollup.UpdateBucketWithdraw); err != nil {
1605 return tracerr.Wrap(err)
1606 }
1607
1608 // Add Token exchange updates
1609 if err := hdb.addTokenExchanges(txn, blockData.Rollup.TokenExchanges); err != nil {
1610 return tracerr.Wrap(err)
1611 }
1612
1613 return tracerr.Wrap(txn.Commit())
1614}
1615
1616// GetCoordinatorAPI returns a coordinator by its bidderAddr
1617func (hdb *HistoryDB) GetCoordinatorAPI(bidderAddr ethCommon.Address) (*CoordinatorAPI, error) {
1618 coordinator := &CoordinatorAPI{}
1619 err := meddler.QueryRow(hdb.db, coordinator, "SELECT * FROM coordinator WHERE bidder_addr = $1;", bidderAddr)
1620 return coordinator, tracerr.Wrap(err)
1621}
1622
1623// GetCoordinatorsAPI returns a list of coordinators from the DB and pagination info
1624func (hdb *HistoryDB) GetCoordinatorsAPI(fromItem, limit *uint, order string) ([]CoordinatorAPI, uint64, error) {
1625 var query string
1626 var args []interface{}
1627 queryStr := `SELECT coordinator.*,
1628 COUNT(*) OVER() AS total_items
1629 FROM coordinator `
1630 // Apply filters
1631 if fromItem != nil {
1632 queryStr += "WHERE "
1633 if order == OrderAsc {
1634 queryStr += "coordinator.item_id >= ? "
1635 } else {
1636 queryStr += "coordinator.item_id <= ? "
1637 }
1638 args = append(args, fromItem)
1639 }
1640 // pagination
1641 queryStr += "ORDER BY coordinator.item_id "
1642 if order == OrderAsc {
1643 queryStr += " ASC "
1644 } else {
1645 queryStr += " DESC "
1646 }
1647 queryStr += fmt.Sprintf("LIMIT %d;", *limit)
1648 query = hdb.db.Rebind(queryStr)
1649
1650 coordinators := []*CoordinatorAPI{}
1651 if err := meddler.QueryAll(hdb.db, &coordinators, query, args...); err != nil {
1652 return nil, 0, tracerr.Wrap(err)
1653 }
1654 if len(coordinators) == 0 {
1655 return nil, 0, tracerr.Wrap(sql.ErrNoRows)
1656 }
1657 return db.SlicePtrsToSlice(coordinators).([]CoordinatorAPI),
1658 coordinators[0].TotalItems - uint64(len(coordinators)), nil
1659}
1660
1661// AddAuctionVars insert auction vars into the DB
1662func (hdb *HistoryDB) AddAuctionVars(auctionVars *common.AuctionVariables) error {
1663 return tracerr.Wrap(meddler.Insert(hdb.db, "auction_vars", auctionVars))
1664}
1665
1666// GetAuctionVars returns auction variables
1667func (hdb *HistoryDB) GetAuctionVars() (*common.AuctionVariables, error) {
1668 auctionVars := &common.AuctionVariables{}
1669 err := meddler.QueryRow(
1670 hdb.db, auctionVars, `SELECT * FROM auction_vars;`,
1671 )
1672 return auctionVars, tracerr.Wrap(err)
1673}
1674
1675// GetAccountAPI returns an account by its index
1676func (hdb *HistoryDB) GetAccountAPI(idx common.Idx) (*AccountAPI, error) {
1677 account := &AccountAPI{}
1678 err := meddler.QueryRow(hdb.db, account, `SELECT account.item_id, hez_idx(account.idx,
1679 token.symbol) as idx, account.batch_num, account.bjj, account.eth_addr,
1680 token.token_id, token.item_id AS token_item_id, token.eth_block_num AS token_block,
1681 token.eth_addr as token_eth_addr, token.name, token.symbol, token.decimals, token.usd, token.usd_update
1682 FROM account INNER JOIN token ON account.token_id = token.token_id WHERE idx = $1;`, idx)
1683
1684 if err != nil {
1685 return nil, tracerr.Wrap(err)
1686 }
1687
1688 return account, nil
1689}
1690
1691// GetAccountsAPI returns a list of accounts from the DB and pagination info
1692func (hdb *HistoryDB) GetAccountsAPI(
1693 tokenIDs []common.TokenID, ethAddr *ethCommon.Address,
1694 bjj *babyjub.PublicKey, fromItem, limit *uint, order string,
1695) ([]AccountAPI, uint64, error) {
1696 if ethAddr != nil && bjj != nil {
1697 return nil, 0, tracerr.Wrap(errors.New("ethAddr and bjj are incompatible"))
1698 }
1699 var query string
1700 var args []interface{}
1701 queryStr := `SELECT account.item_id, hez_idx(account.idx, token.symbol) as idx, account.batch_num,
1702 account.bjj, account.eth_addr, token.token_id, token.item_id AS token_item_id, token.eth_block_num AS token_block,
1703 token.eth_addr as token_eth_addr, token.name, token.symbol, token.decimals, token.usd, token.usd_update,
1704 COUNT(*) OVER() AS total_items
1705 FROM account INNER JOIN token ON account.token_id = token.token_id `
1706 // Apply filters
1707 nextIsAnd := false
1708 // ethAddr filter
1709 if ethAddr != nil {
1710 queryStr += "WHERE account.eth_addr = ? "
1711 nextIsAnd = true
1712 args = append(args, ethAddr)
1713 } else if bjj != nil { // bjj filter
1714 queryStr += "WHERE account.bjj = ? "
1715 nextIsAnd = true
1716 args = append(args, bjj)
1717 }
1718 // tokenID filter
1719 if len(tokenIDs) > 0 {
1720 if nextIsAnd {
1721 queryStr += "AND "
1722 } else {
1723 queryStr += "WHERE "
1724 }
1725 queryStr += "account.token_id IN (?) "
1726 args = append(args, tokenIDs)
1727 nextIsAnd = true
1728 }
1729 if fromItem != nil {
1730 if nextIsAnd {
1731 queryStr += "AND "
1732 } else {
1733 queryStr += "WHERE "
1734 }
1735 if order == OrderAsc {
1736 queryStr += "account.item_id >= ? "
1737 } else {
1738 queryStr += "account.item_id <= ? "
1739 }
1740 args = append(args, fromItem)
1741 }
1742 // pagination
1743 queryStr += "ORDER BY account.item_id "
1744 if order == OrderAsc {
1745 queryStr += " ASC "
1746 } else {
1747 queryStr += " DESC "
1748 }
1749 queryStr += fmt.Sprintf("LIMIT %d;", *limit)
1750 query, argsQ, err := sqlx.In(queryStr, args...)
1751 if err != nil {
1752 return nil, 0, tracerr.Wrap(err)
1753 }
1754 query = hdb.db.Rebind(query)
1755
1756 accounts := []*AccountAPI{}
1757 if err := meddler.QueryAll(hdb.db, &accounts, query, argsQ...); err != nil {
1758 return nil, 0, tracerr.Wrap(err)
1759 }
1760 if len(accounts) == 0 {
1761 return nil, 0, tracerr.Wrap(sql.ErrNoRows)
1762 }
1763
1764 return db.SlicePtrsToSlice(accounts).([]AccountAPI),
1765 accounts[0].TotalItems - uint64(len(accounts)), nil
1766}
1767
1768// GetMetrics returns metrics
1769func (hdb *HistoryDB) GetMetrics(lastBatchNum common.BatchNum) (*Metrics, error) {
1770 metricsTotals := &MetricsTotals{}
1771 metrics := &Metrics{}
1772 err := meddler.QueryRow(
1773 hdb.db, metricsTotals, `SELECT COUNT(tx.*) as total_txs,
1774 COALESCE (MIN(tx.batch_num), 0) as batch_num
1775 FROM tx INNER JOIN block ON tx.eth_block_num = block.eth_block_num
1776 WHERE block.timestamp >= NOW() - INTERVAL '24 HOURS';`)
1777 if err != nil {
1778 return nil, tracerr.Wrap(err)
1779 }
1780
1781 metrics.TransactionsPerSecond = float64(metricsTotals.TotalTransactions / (24 * 60 * 60))
1782 if (lastBatchNum - metricsTotals.FirstBatchNum) > 0 {
1783 metrics.TransactionsPerBatch = float64(int64(metricsTotals.TotalTransactions) /
1784 int64(lastBatchNum-metricsTotals.FirstBatchNum))
1785 } else {
1786 metrics.TransactionsPerBatch = float64(0)
1787 }
1788
1789 err = meddler.QueryRow(
1790 hdb.db, metricsTotals, `SELECT COUNT(*) AS total_batches,
1791 COALESCE (SUM(total_fees_usd), 0) AS total_fees FROM batch
1792 WHERE batch_num > $1;`, metricsTotals.FirstBatchNum)
1793 if err != nil {
1794 return nil, tracerr.Wrap(err)
1795 }
1796 if metricsTotals.TotalBatches > 0 {
1797 metrics.BatchFrequency = float64((24 * 60 * 60) / metricsTotals.TotalBatches)
1798 } else {
1799 metrics.BatchFrequency = 0
1800 }
1801 if metricsTotals.TotalTransactions > 0 {
1802 metrics.AvgTransactionFee = metricsTotals.TotalFeesUSD / float64(metricsTotals.TotalTransactions)
1803 } else {
1804 metrics.AvgTransactionFee = 0
1805 }
1806 err = meddler.QueryRow(
1807 hdb.db, metrics,
1808 `SELECT COUNT(*) AS total_bjjs, COUNT(DISTINCT(bjj)) AS total_accounts FROM account;`)
1809 if err != nil {
1810 return nil, tracerr.Wrap(err)
1811 }
1812
1813 return metrics, nil
1814}
1815
1816// GetAvgTxFee returns average transaction fee of the last 1h
1817func (hdb *HistoryDB) GetAvgTxFee() (float64, error) {
1818 metricsTotals := &MetricsTotals{}
1819 err := meddler.QueryRow(
1820 hdb.db, metricsTotals, `SELECT COUNT(tx.*) as total_txs,
1821 COALESCE (MIN(tx.batch_num), 0) as batch_num
1822 FROM tx INNER JOIN block ON tx.eth_block_num = block.eth_block_num
1823 WHERE block.timestamp >= NOW() - INTERVAL '1 HOURS';`)
1824 if err != nil {
1825 return 0, tracerr.Wrap(err)
1826 }
1827 err = meddler.QueryRow(
1828 hdb.db, metricsTotals, `SELECT COUNT(*) AS total_batches,
1829 COALESCE (SUM(total_fees_usd), 0) AS total_fees FROM batch
1830 WHERE batch_num > $1;`, metricsTotals.FirstBatchNum)
1831 if err != nil {
1832 return 0, tracerr.Wrap(err)
1833 }
1834
1835 var avgTransactionFee float64
1836 if metricsTotals.TotalTransactions > 0 {
1837 avgTransactionFee = metricsTotals.TotalFeesUSD / float64(metricsTotals.TotalTransactions)
1838 } else {
1839 avgTransactionFee = 0
1840 }
1841
1842 return avgTransactionFee, nil
1843}