cerc-io/ipld-eth-server
18
0
Fork 1
Code Issues 10 Pull Requests 1 Actions Packages Projects Releases 37 Wiki Activity

increase timeout on price feeds integration tests

Browse Source
This commit is contained in:
David Terry 2018-09-28 14:19:40 +02:00
parent 02853014b2
commit f56c882b9d
1 changed files with 9 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
pkg/transformers/price_feeds/integration_test.go
View File

@ -2,6 +2,9 @@ package price_feeds_test
import ( import (
"context" "context"
"math/big"
"time"
"github.com/ethereum/go-ethereum/common/hexutil" "github.com/ethereum/go-ethereum/common/hexutil"
"github.com/ethereum/go-ethereum/ethclient" "github.com/ethereum/go-ethereum/ethclient"
"github.com/ethereum/go-ethereum/rpc" "github.com/ethereum/go-ethereum/rpc"
@ -16,8 +19,6 @@ import (
"github.com/vulcanize/vulcanizedb/pkg/geth/node" "github.com/vulcanize/vulcanizedb/pkg/geth/node"
"github.com/vulcanize/vulcanizedb/pkg/transformers/price_feeds" "github.com/vulcanize/vulcanizedb/pkg/transformers/price_feeds"
"github.com/vulcanize/vulcanizedb/test_config" "github.com/vulcanize/vulcanizedb/test_config"
"math/big"
"time"
) )
var _ = Describe("Price feeds transformer", func() { var _ = Describe("Price feeds transformer", func() {
@ -52,7 +53,8 @@ var _ = Describe("Price feeds transformer", func() {
err := transformer.Execute() err := transformer.Execute()
time.AfterFunc(3*time.Second, func() { time.AfterFunc(5*time.Second, func() {
defer GinkgoRecover()
Expect(err).NotTo(HaveOccurred()) Expect(err).NotTo(HaveOccurred())
var model price_feeds.PriceFeedModel var model price_feeds.PriceFeedModel
err = db.Get(&model, `SELECT block_number, medianizer_address, usd_value, tx_idx, raw_log FROM maker.price_feeds WHERE block_number = $1`, config.StartingBlockNumber) err = db.Get(&model, `SELECT block_number, medianizer_address, usd_value, tx_idx, raw_log FROM maker.price_feeds WHERE block_number = $1`, config.StartingBlockNumber)
@ -72,7 +74,8 @@ var _ = Describe("Price feeds transformer", func() {
err := transformer.Execute() err := transformer.Execute()
time.AfterFunc(3*time.Second, func() { time.AfterFunc(5*time.Second, func() {
defer GinkgoRecover()
Expect(err).NotTo(HaveOccurred()) Expect(err).NotTo(HaveOccurred())
var model price_feeds.PriceFeedModel var model price_feeds.PriceFeedModel
err = db.Get(&model, `SELECT block_number, medianizer_address, usd_value, tx_idx, raw_log FROM maker.price_feeds WHERE block_number = $1`, config.StartingBlockNumber) err = db.Get(&model, `SELECT block_number, medianizer_address, usd_value, tx_idx, raw_log FROM maker.price_feeds WHERE block_number = $1`, config.StartingBlockNumber)
@ -92,7 +95,8 @@ var _ = Describe("Price feeds transformer", func() {
err := transformer.Execute() err := transformer.Execute()
time.AfterFunc(3*time.Second, func() { time.AfterFunc(5*time.Second, func() {
defer GinkgoRecover()
Expect(err).NotTo(HaveOccurred()) Expect(err).NotTo(HaveOccurred())
var model price_feeds.PriceFeedModel var model price_feeds.PriceFeedModel
err = db.Get(&model, `SELECT block_number, medianizer_address, usd_value, tx_idx, raw_log FROM maker.price_feeds WHERE block_number = $1`, config.StartingBlockNumber) err = db.Get(&model, `SELECT block_number, medianizer_address, usd_value, tx_idx, raw_log FROM maker.price_feeds WHERE block_number = $1`, config.StartingBlockNumber)