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

update from PR feedback

Browse Source
This commit is contained in:
Taka Goto 2018-08-31 10:37:02 -05:00
parent adc7c47244
commit 415ec3d97c
5 changed files with 65 additions and 49 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
README.md
View File

@ -28,8 +28,7 @@ Vulcanize DB is a set of tools that make it easier for developers to write appli
* See below for configuring additional environments
## Create a migration file (up and down)
1. install migrate library: https://github.com/golang-migrate/migrate
1. `migrate create -ext sql -seq -dir db/migrations/ -digits 10 create_bite_table`
1. ./script/create_migrate create_bite_table
## Configuration
- To use a local Ethereum node, copy `environments/public.toml.example` to

2
pkg/transformers/bite/converter_test.go
View File

@ -17,8 +17,8 @@
package bite_test
import (
"math/big"
"encoding/json"
"math/big"
"github.com/ethereum/go-ethereum/core/types"
"github.com/vulcanize/vulcanizedb/pkg/transformers/bite"

104
pkg/transformers/bite/integration_test.go
View File

@ -17,53 +17,67 @@
package bite_test
import (
"github.com/ethereum/go-ethereum/accounts/abi/bind"
"github.com/ethereum/go-ethereum/common"
"github.com/ethereum/go-ethereum/ethclient"
. "github.com/onsi/ginkgo"
. "github.com/onsi/gomega"
"github.com/ethereum/go-ethereum/rpc"
"github.com/vulcanize/vulcanizedb/pkg/geth"
"github.com/vulcanize/vulcanizedb/pkg/geth/client"
rpc2 "github.com/vulcanize/vulcanizedb/pkg/geth/converters/rpc"
"github.com/vulcanize/vulcanizedb/pkg/geth/node"
"github.com/vulcanize/vulcanizedb/pkg/transformers/bite"
"github.com/vulcanize/vulcanizedb/pkg/transformers/shared"
"github.com/vulcanize/vulcanizedb/pkg/transformers/test_data"
"github.com/vulcanize/vulcanizedb/test_config"
)
var _ = Describe("Integration tests", func() {
//It("Fetches bite event logs from a local test chain", func() {
// ipcPath := test_config.TestClient.IPCPath
//
// rawRpcClient, err := rpc.Dial(ipcPath)
// Expect(err).NotTo(HaveOccurred())
//
// rpcClient := client.NewRpcClient(rawRpcClient, ipcPath)
// ethClient := ethclient.NewClient(rawRpcClient)
// blockChainClient := client.NewEthClient(ethClient)
// realNode := node.MakeNode(rpcClient)
// transactionConverter := rpc2.NewRpcTransactionConverter(ethClient)
// realBlockChain := geth.NewBlockChain(blockChainClient, realNode, transactionConverter)
// realFetcher := shared.NewFetcher(realBlockChain)
// topic0 := common.HexToHash(bite.BiteSignature)
// topics := [][]common.Hash{{topic0}}
//
// result, err := realFetcher.FetchLogs(test_data.TemporaryBiteAddress, topics, int64(26))
// Expect(err).NotTo(HaveOccurred())
//
// Expect(len(result) > 0).To(BeTrue())
// Expect(result[0].Address).To(Equal(common.HexToAddress(test_data.TemporaryBiteAddress)))
// Expect(result[0].TxHash).To(Equal(test_data.EthBiteLog.TxHash))
// Expect(result[0].BlockNumber).To(Equal(test_data.EthBiteLog.BlockNumber))
// Expect(result[0].Topics).To(Equal(test_data.EthBiteLog.Topics))
// Expect(result[0].Index).To(Equal(test_data.EthBiteLog.Index))
//})
//
//It("unpacks an event log", func() {
// address := common.HexToAddress(test_data.TemporaryBiteAddress)
// abi, err := geth.ParseAbi(bite.BiteABI)
// Expect(err).NotTo(HaveOccurred())
//
// contract := bind.NewBoundContract(address, abi, nil, nil, nil)
// entity := &bite.BiteEntity{}
//
// var eventLog = test_data.EthBiteLog
//
// err = contract.UnpackLog(entity, "Bite", eventLog)
// Expect(err).NotTo(HaveOccurred())
//
// expectedEntity := test_data.BiteEntity
// Expect(entity.Art).To(Equal(expectedEntity.Art))
// Expect(entity.Ilk).To(Equal(expectedEntity.Ilk))
// Expect(entity.Ink).To(Equal(expectedEntity.Ink))
//})
XIt("Fetches bite event logs from a local test chain", func() {
ipcPath := test_config.TestClient.IPCPath
rawRpcClient, err := rpc.Dial(ipcPath)
Expect(err).NotTo(HaveOccurred())
rpcClient := client.NewRpcClient(rawRpcClient, ipcPath)
ethClient := ethclient.NewClient(rawRpcClient)
blockChainClient := client.NewEthClient(ethClient)
realNode := node.MakeNode(rpcClient)
transactionConverter := rpc2.NewRpcTransactionConverter(ethClient)
realBlockChain := geth.NewBlockChain(blockChainClient, realNode, transactionConverter)
realFetcher := shared.NewFetcher(realBlockChain)
topic0 := common.HexToHash(bite.BiteSignature)
topics := [][]common.Hash{{topic0}}
result, err := realFetcher.FetchLogs(test_data.TemporaryBiteAddress, topics, int64(26))
Expect(err).NotTo(HaveOccurred())
Expect(len(result) > 0).To(BeTrue())
Expect(result[0].Address).To(Equal(common.HexToAddress(test_data.TemporaryBiteAddress)))
Expect(result[0].TxHash).To(Equal(test_data.EthBiteLog.TxHash))
Expect(result[0].BlockNumber).To(Equal(test_data.EthBiteLog.BlockNumber))
Expect(result[0].Topics).To(Equal(test_data.EthBiteLog.Topics))
Expect(result[0].Index).To(Equal(test_data.EthBiteLog.Index))
})
It("unpacks an event log", func() {
address := common.HexToAddress(test_data.TemporaryBiteAddress)
abi, err := geth.ParseAbi(bite.BiteABI)
Expect(err).NotTo(HaveOccurred())
contract := bind.NewBoundContract(address, abi, nil, nil, nil)
entity := &bite.BiteEntity{}
var eventLog = test_data.EthBiteLog
err = contract.UnpackLog(entity, "Bite", eventLog)
Expect(err).NotTo(HaveOccurred())
expectedEntity := test_data.BiteEntity
Expect(entity.Art).To(Equal(expectedEntity.Art))
Expect(entity.Ilk).To(Equal(expectedEntity.Ilk))
Expect(entity.Ink).To(Equal(expectedEntity.Ink))
})
})

3
pkg/transformers/transformers.go
View File

@ -15,6 +15,7 @@
package transformers
import (
"github.com/vulcanize/vulcanizedb/pkg/transformers/bite"
"github.com/vulcanize/vulcanizedb/pkg/transformers/flip_kick"
"github.com/vulcanize/vulcanizedb/pkg/transformers/frob"
"github.com/vulcanize/vulcanizedb/pkg/transformers/price_feeds"
@ -31,8 +32,10 @@ func TransformerInitializers() []shared.TransformerInitializer {
priceFeedTransformerInitializer := price_feeds.PriceFeedTransformerInitializer{Config: priceFeedConfig}
tendConfig := tend.TendConfig
tendTransformerInitializer := tend.TendTransformerInitializer{Config: tendConfig}
biteTransformerInitializer := bite.BiteTransformerInitializer{Config: bite.BiteConfig}
return []shared.TransformerInitializer{
biteTransformerInitializer.NewBiteTransformer,
flipKickTransformerInitializer.NewFlipKickTransformer,
frobTransformerInitializer.NewFrobTransformer,
priceFeedTransformerInitializer.NewPriceFeedTransformer,