forked from cerc-io/ipld-eth-server
83 lines
2.5 KiB
Go
83 lines
2.5 KiB
Go
package transactions_test
|
|
|
|
import (
|
|
"github.com/ethereum/go-ethereum/core/types"
|
|
. "github.com/onsi/ginkgo"
|
|
. "github.com/onsi/gomega"
|
|
"github.com/vulcanize/vulcanizedb/libraries/shared/transactions"
|
|
"github.com/vulcanize/vulcanizedb/pkg/core"
|
|
"github.com/vulcanize/vulcanizedb/pkg/fakes"
|
|
"github.com/vulcanize/vulcanizedb/test_config"
|
|
)
|
|
|
|
var _ = Describe("Transaction syncer", func() {
|
|
var (
|
|
blockChain *fakes.MockBlockChain
|
|
syncer transactions.TransactionsSyncer
|
|
)
|
|
|
|
BeforeEach(func() {
|
|
db := test_config.NewTestDB(test_config.NewTestNode())
|
|
test_config.CleanTestDB(db)
|
|
blockChain = fakes.NewMockBlockChain()
|
|
syncer = transactions.NewTransactionsSyncer(db, blockChain)
|
|
})
|
|
|
|
It("fetches transactions for logs", func() {
|
|
err := syncer.SyncTransactions(0, []types.Log{{TxHash: fakes.FakeHash}})
|
|
|
|
Expect(err).NotTo(HaveOccurred())
|
|
Expect(blockChain.GetTransactionsCalled).To(BeTrue())
|
|
})
|
|
|
|
It("does not fetch transactions if no logs", func() {
|
|
err := syncer.SyncTransactions(0, []types.Log{})
|
|
|
|
Expect(err).NotTo(HaveOccurred())
|
|
Expect(blockChain.GetTransactionsCalled).To(BeFalse())
|
|
})
|
|
|
|
It("only fetches transactions with unique hashes", func() {
|
|
err := syncer.SyncTransactions(0, []types.Log{{
|
|
TxHash: fakes.FakeHash,
|
|
}, {
|
|
TxHash: fakes.FakeHash,
|
|
}})
|
|
|
|
Expect(err).NotTo(HaveOccurred())
|
|
Expect(len(blockChain.GetTransactionsPassedHashes)).To(Equal(1))
|
|
})
|
|
|
|
It("returns error if fetching transactions fails", func() {
|
|
blockChain.GetTransactionsError = fakes.FakeError
|
|
|
|
err := syncer.SyncTransactions(0, []types.Log{{TxHash: fakes.FakeHash}})
|
|
|
|
Expect(err).To(HaveOccurred())
|
|
Expect(err).To(MatchError(fakes.FakeError))
|
|
})
|
|
|
|
It("passes transactions to repository for persistence", func() {
|
|
blockChain.Transactions = []core.TransactionModel{{}}
|
|
mockHeaderRepository := fakes.NewMockHeaderRepository()
|
|
syncer.Repository = mockHeaderRepository
|
|
|
|
err := syncer.SyncTransactions(0, []types.Log{{TxHash: fakes.FakeHash}})
|
|
|
|
Expect(err).NotTo(HaveOccurred())
|
|
Expect(mockHeaderRepository.CreateTransactionsCalled).To(BeTrue())
|
|
})
|
|
|
|
It("returns error if persisting transactions fails", func() {
|
|
blockChain.Transactions = []core.TransactionModel{{}}
|
|
mockHeaderRepository := fakes.NewMockHeaderRepository()
|
|
mockHeaderRepository.CreateTransactionsError = fakes.FakeError
|
|
syncer.Repository = mockHeaderRepository
|
|
|
|
err := syncer.SyncTransactions(0, []types.Log{{TxHash: fakes.FakeHash}})
|
|
|
|
Expect(err).To(HaveOccurred())
|
|
Expect(err).To(MatchError(fakes.FakeError))
|
|
})
|
|
})
|