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