mirror of
https://github.com/arnaucube/hermez-node.git
synced 2026-02-07 11:26:44 +01:00
Compare commits
1 Commits
feature/ap
...
fix/packr-
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
628c582ea7 |
13
.github/workflows/release.yml
vendored
13
.github/workflows/release.yml
vendored
@@ -9,18 +9,19 @@ jobs:
|
||||
goreleaser:
|
||||
runs-on: ubuntu-latest
|
||||
steps:
|
||||
-
|
||||
name: Checkout
|
||||
- name: Checkout
|
||||
uses: actions/checkout@v2
|
||||
with:
|
||||
fetch-depth: 0
|
||||
-
|
||||
name: Set up Go
|
||||
- name: Set up Go
|
||||
uses: actions/setup-go@v2
|
||||
with:
|
||||
go-version: 1.16
|
||||
-
|
||||
name: Run GoReleaser
|
||||
- name: Get packr
|
||||
run: go get -u github.com/gobuffalo/packr
|
||||
- name: Prepare
|
||||
run: git reset --hard
|
||||
- name: Run GoReleaser
|
||||
uses: goreleaser/goreleaser-action@v2
|
||||
with:
|
||||
version: latest
|
||||
|
||||
3
.gitignore
vendored
3
.gitignore
vendored
@@ -1,2 +1 @@
|
||||
bin/
|
||||
dist/
|
||||
bin/
|
||||
@@ -1,7 +1,6 @@
|
||||
before:
|
||||
hooks:
|
||||
- go mod download
|
||||
- make migration-pack
|
||||
|
||||
builds:
|
||||
- main: ./cli/node/main.go
|
||||
@@ -13,14 +12,6 @@ builds:
|
||||
goarch:
|
||||
- amd64
|
||||
|
||||
archives:
|
||||
- replacements:
|
||||
darwin: Darwin
|
||||
linux: Linux
|
||||
windows: Windows
|
||||
386: i386
|
||||
amd64: x86_64
|
||||
|
||||
checksum:
|
||||
name_template: 'checksums.txt'
|
||||
|
||||
|
||||
@@ -161,8 +161,6 @@ var SetBlockchain = `
|
||||
> block
|
||||
> batch
|
||||
> block
|
||||
ForceTransfer(0) D-B: 77777700000000000
|
||||
> block
|
||||
`
|
||||
|
||||
type testCommon struct {
|
||||
@@ -364,12 +362,6 @@ func TestMain(m *testing.M) {
|
||||
commonL1Txs = append(commonL1Txs, batch.L1CoordinatorTxs...)
|
||||
}
|
||||
}
|
||||
// Add unforged L1 tx
|
||||
unforgedTx := blocksData[len(blocksData)-1].Rollup.L1UserTxs[0]
|
||||
if unforgedTx.BatchNum != nil {
|
||||
panic("Unforged tx batch num should be nil")
|
||||
}
|
||||
commonL1Txs = append(commonL1Txs, unforgedTx)
|
||||
|
||||
// Generate Coordinators and add them to HistoryDB
|
||||
const nCoords = 10
|
||||
|
||||
@@ -109,7 +109,7 @@ func (a *API) getFullBatch(c *gin.Context) {
|
||||
// Fetch txs forged in the batch from historyDB
|
||||
maxTxsPerBatch := uint(2048) //nolint:gomnd
|
||||
txs, _, err := a.h.GetTxsAPI(
|
||||
nil, nil, nil, nil, batchNum, nil, nil, nil, &maxTxsPerBatch, historydb.OrderAsc,
|
||||
nil, nil, nil, nil, batchNum, nil, nil, &maxTxsPerBatch, historydb.OrderAsc,
|
||||
)
|
||||
if err != nil && tracerr.Unwrap(err) != sql.ErrNoRows {
|
||||
retSQLErr(err, c)
|
||||
|
||||
@@ -529,15 +529,6 @@ paths:
|
||||
type: integer
|
||||
minimum: 1
|
||||
maximum: 2049
|
||||
- name: includePendingL1s
|
||||
in: query
|
||||
required: false
|
||||
description: |
|
||||
If set to true L1 transactions that have been added to the smart contract queue but haven't been forged yet are returned.
|
||||
Warning: the correctness of the order is not guaranteed when using this filter, as the unforged transactions may change their position
|
||||
once they are forged.
|
||||
schema:
|
||||
type: boolean
|
||||
responses:
|
||||
'200':
|
||||
description: Successful operation.
|
||||
|
||||
@@ -26,14 +26,6 @@ func (a *API) getHistoryTxs(c *gin.Context) {
|
||||
retBadReq(err, c)
|
||||
return
|
||||
}
|
||||
// IncludePendingL1s
|
||||
includePendingL1s := new(bool)
|
||||
*includePendingL1s = false
|
||||
includePendingL1s, err = parseQueryBool("includePendingL1s", includePendingL1s, c)
|
||||
if err != nil {
|
||||
retBadReq(err, c)
|
||||
return
|
||||
}
|
||||
// Pagination
|
||||
fromItem, order, limit, err := parsePagination(c)
|
||||
if err != nil {
|
||||
@@ -43,7 +35,7 @@ func (a *API) getHistoryTxs(c *gin.Context) {
|
||||
|
||||
// Fetch txs from historyDB
|
||||
txs, pendingItems, err := a.h.GetTxsAPI(
|
||||
addr, bjj, tokenID, idx, batchNum, txType, includePendingL1s, fromItem, limit, order,
|
||||
addr, bjj, tokenID, idx, batchNum, txType, fromItem, limit, order,
|
||||
)
|
||||
if err != nil {
|
||||
retSQLErr(err, c)
|
||||
|
||||
@@ -71,7 +71,7 @@ func (t txsSort) Less(i, j int) bool {
|
||||
}
|
||||
// i is forged
|
||||
if jsf.BatchNum == nil {
|
||||
return true // j is not forged
|
||||
return false // j is not forged
|
||||
}
|
||||
// Both are forged
|
||||
if *isf.BatchNum == *jsf.BatchNum {
|
||||
@@ -111,7 +111,7 @@ func genTestTxs(
|
||||
) []testTx {
|
||||
txs := []testTx{}
|
||||
// common.L1Tx ==> testTx
|
||||
for i, l1 := range l1s {
|
||||
for _, l1 := range l1s {
|
||||
token := getTokenByID(l1.TokenID, tokens)
|
||||
// l1.FromEthAddr and l1.FromBJJ can't be nil
|
||||
fromEthAddr := string(apitypes.NewHezEthAddr(l1.FromEthAddr))
|
||||
@@ -137,26 +137,15 @@ func genTestTxs(
|
||||
},
|
||||
Token: token,
|
||||
}
|
||||
|
||||
// set BatchNum for user txs
|
||||
if tx.L1Info.ToForgeL1TxsNum != nil {
|
||||
// WARNING: this works just because the way "common" txs are generated using til
|
||||
// any change on the test set could break this
|
||||
// WARNING: this is an asumption, and the test input data can brake it easily
|
||||
bn := common.BatchNum(*tx.L1Info.ToForgeL1TxsNum + 2)
|
||||
tx.BatchNum = &bn
|
||||
}
|
||||
// If FromIdx is not nil
|
||||
idxStr := idxToHez(l1.EffectiveFromIdx, token.Symbol)
|
||||
tx.FromIdx = &idxStr
|
||||
if i == len(l1s)-1 {
|
||||
// Last tx of the L1 set is supposed to be unforged as per the til set.
|
||||
// Unforged txs have some special propperties
|
||||
tx.L1Info.DepositAmountSuccess = false
|
||||
tx.L1Info.AmountSuccess = false
|
||||
tx.BatchNum = nil
|
||||
idxStrUnforged := idxToHez(l1.FromIdx, token.Symbol)
|
||||
tx.FromIdx = &idxStrUnforged
|
||||
}
|
||||
// If tx has a normal ToIdx (>255), set FromEthAddr and FromBJJ
|
||||
if l1.ToIdx >= common.UserThreshold {
|
||||
// find account
|
||||
@@ -272,26 +261,12 @@ func TestGetHistoryTxs(t *testing.T) {
|
||||
fetchedTxs = append(fetchedTxs, tmp.(testTx))
|
||||
}
|
||||
}
|
||||
// Get all (no filters, excluding unforged txs)
|
||||
// Get all (no filters)
|
||||
limit := 20
|
||||
path := fmt.Sprintf("%s?limit=%d", endpoint, limit)
|
||||
err := doGoodReqPaginated(path, historydb.OrderAsc, &testTxsResponse{}, appendIter)
|
||||
assert.NoError(t, err)
|
||||
forgedTxs := []testTx{}
|
||||
for i := 0; i < len(tc.txs); i++ {
|
||||
if tc.txs[i].BatchNum != nil {
|
||||
forgedTxs = append(forgedTxs, tc.txs[i])
|
||||
}
|
||||
}
|
||||
assertTxs(t, forgedTxs, fetchedTxs)
|
||||
|
||||
// Get all, including unforged txs
|
||||
fetchedTxs = []testTx{}
|
||||
path = fmt.Sprintf("%s?limit=%d&includePendingL1s=true", endpoint, limit)
|
||||
err = doGoodReqPaginated(path, historydb.OrderAsc, &testTxsResponse{}, appendIter)
|
||||
assert.NoError(t, err)
|
||||
assertTxs(t, tc.txs, fetchedTxs)
|
||||
|
||||
// Get by ethAddr
|
||||
account := tc.accounts[2]
|
||||
fetchedTxs = []testTx{}
|
||||
@@ -310,7 +285,7 @@ func TestGetHistoryTxs(t *testing.T) {
|
||||
(tx.FromEthAddr != nil && *tx.FromEthAddr == string(account.EthAddr)) ||
|
||||
(tx.ToEthAddr != nil && *tx.ToEthAddr == string(account.EthAddr)) ||
|
||||
(tx.FromBJJ != nil && *tx.FromBJJ == string(account.PublicKey)) ||
|
||||
(tx.ToBJJ != nil && *tx.ToBJJ == string(account.PublicKey)) && tx.BatchNum != nil {
|
||||
(tx.ToBJJ != nil && *tx.ToBJJ == string(account.PublicKey)) {
|
||||
accountTxs = append(accountTxs, tx)
|
||||
}
|
||||
}
|
||||
@@ -337,7 +312,7 @@ func TestGetHistoryTxs(t *testing.T) {
|
||||
assert.NoError(t, err)
|
||||
tokenIDTxs := []testTx{}
|
||||
for i := 0; i < len(tc.txs); i++ {
|
||||
if tc.txs[i].BatchNum != nil && tc.txs[i].Token.TokenID == tokenID {
|
||||
if tc.txs[i].Token.TokenID == tokenID {
|
||||
tokenIDTxs = append(tokenIDTxs, tc.txs[i])
|
||||
}
|
||||
}
|
||||
@@ -356,9 +331,6 @@ func TestGetHistoryTxs(t *testing.T) {
|
||||
assert.NoError(t, err)
|
||||
idxTxs := []testTx{}
|
||||
for i := 0; i < len(tc.txs); i++ {
|
||||
if tc.txs[i].BatchNum == nil {
|
||||
continue
|
||||
}
|
||||
var fromIdx *common.Idx
|
||||
if tc.txs[i].FromIdx != nil {
|
||||
fromIdx, err = stringToIdx(*tc.txs[i].FromIdx, "")
|
||||
@@ -416,7 +388,7 @@ func TestGetHistoryTxs(t *testing.T) {
|
||||
assert.NoError(t, err)
|
||||
txTypeTxs := []testTx{}
|
||||
for i := 0; i < len(tc.txs); i++ {
|
||||
if tc.txs[i].Type == txType && tc.txs[i].BatchNum != nil {
|
||||
if tc.txs[i].Type == txType {
|
||||
txTypeTxs = append(txTypeTxs, tc.txs[i])
|
||||
}
|
||||
}
|
||||
@@ -448,9 +420,7 @@ func TestGetHistoryTxs(t *testing.T) {
|
||||
assert.NoError(t, err)
|
||||
flipedTxs := []testTx{}
|
||||
for i := 0; i < len(tc.txs); i++ {
|
||||
if tc.txs[len(tc.txs)-1-i].BatchNum != nil {
|
||||
flipedTxs = append(flipedTxs, tc.txs[len(tc.txs)-1-i])
|
||||
}
|
||||
flipedTxs = append(flipedTxs, tc.txs[len(tc.txs)-1-i])
|
||||
}
|
||||
assertTxs(t, flipedTxs, fetchedTxs)
|
||||
// Empty array
|
||||
|
||||
@@ -457,7 +457,6 @@ func (hdb *HistoryDB) GetTxAPI(txID common.TxID) (*TxAPI, error) {
|
||||
func (hdb *HistoryDB) GetTxsAPI(
|
||||
ethAddr *ethCommon.Address, bjj *babyjub.PublicKeyComp,
|
||||
tokenID *common.TokenID, idx *common.Idx, batchNum *uint, txType *common.TxType,
|
||||
includePendingL1s *bool,
|
||||
fromItem, limit *uint, order string,
|
||||
) ([]TxAPI, uint64, error) {
|
||||
// Warning: amount_success and deposit_amount_success have true as default for
|
||||
@@ -555,16 +554,12 @@ func (hdb *HistoryDB) GetTxsAPI(
|
||||
args = append(args, fromItem)
|
||||
nextIsAnd = true
|
||||
}
|
||||
|
||||
// Include pending L1 txs? (deafault false)
|
||||
if includePendingL1s == nil || (includePendingL1s != nil && !*includePendingL1s) {
|
||||
if nextIsAnd {
|
||||
queryStr += "AND "
|
||||
} else {
|
||||
queryStr += "WHERE "
|
||||
}
|
||||
queryStr += "tx.batch_num IS NOT NULL "
|
||||
if nextIsAnd {
|
||||
queryStr += "AND "
|
||||
} else {
|
||||
queryStr += "WHERE "
|
||||
}
|
||||
queryStr += "tx.batch_num IS NOT NULL "
|
||||
|
||||
// pagination
|
||||
queryStr += "ORDER BY tx.item_id "
|
||||
|
||||
Reference in New Issue
Block a user